content: package de.danoeh.antennapod.ui.statistics.subscriptions;
  
  import android.content.Context;
  import android.content.SharedPreferences;
  import android.os.Bundle;
  import android.util.Log;
  import android.view.LayoutInflater;
  import android.view.Menu;
  import android.view.MenuItem;
  import android.view.View;
  import android.view.ViewGroup;
  import android.widget.ProgressBar;
  import androidx.annotation.NonNull;
  import androidx.annotation.Nullable;
  import androidx.fragment.app.Fragment;
  import androidx.recyclerview.widget.LinearLayoutManager;
  import androidx.recyclerview.widget.RecyclerView;
  import de.danoeh.antennapod.event.StatisticsEvent;
  import de.danoeh.antennapod.storage.database.DBReader;
  import de.danoeh.antennapod.ui.statistics.R;
  import de.danoeh.antennapod.ui.statistics.StatisticsFragment;
  import io.reactivex.rxjava3.core.Observable;
  import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers;
  import io.reactivex.rxjava3.disposables.Disposable;
  import io.reactivex.rxjava3.schedulers.Schedulers;
  import org.greenrobot.eventbus.EventBus;
  import org.greenrobot.eventbus.Subscribe;
  import org.greenrobot.eventbus.ThreadMode;
  
  import java.util.Collections;
  
  /**
   * Displays the 'playback statistics' screen
   */
  public class SubscriptionStatisticsFragment extends Fragment {
      private static final String TAG = SubscriptionStatisticsFragment.class.getSimpleName();
  
      private Disposable disposable;
      private RecyclerView feedStatisticsList;
      private ProgressBar progressBar;
      private PlaybackStatisticsListAdapter listAdapter;
      private DBReader.StatisticsResult statisticsResult;
  
      @Override
      public void onCreate(Bundle savedInstanceState) {
          super.onCreate(savedInstanceState);
          setHasOptionsMenu(true);
      }
  
      @Nullable
      @Override
      public View onCreateView(@NonNull LayoutInflater inflater, @Nullable ViewGroup container,
                               @Nullable Bundle savedInstanceState) {
          View root = inflater.inflate(R.layout.statistics_fragment, container, false);
          feedStatisticsList = root.findViewById(R.id.statistics_list);
          progressBar = root.findViewById(R.id.progressBar);
          listAdapter = new PlaybackStatisticsListAdapter(this);
          feedStatisticsList.setLayoutManager(new LinearLayoutManager(getContext()));
          feedStatisticsList.setAdapter(listAdapter);
          EventBus.getDefault().register(this);
          return root;
      }
  
      @Override
      public void onStart() {
          super.onStart();
          refreshStatistics();
      }
  
      @Override
      public void onDestroyView() {
          super.onDestroyView();
          EventBus.getDefault().unregister(this);
          if (disposable != null) {
              disposable.dispose();
          }
      }
  
      @Subscribe(threadMode = ThreadMode.MAIN)
      public void statisticsEvent(StatisticsEvent event) {
          refreshStatistics();
      }
  
      @Override
      public void onPrepareOptionsMenu(@NonNull Menu menu) {
          super.onPrepareOptionsMenu(menu);
          menu.findItem(R.id.statistics_reset).setVisible(true);
          menu.findItem(R.id.statistics_filter).setVisible(true);
      }
  
      @Override
      public boolean onOptionsItemSelected(MenuItem item) {
          if (item.getItemId() == R.id.statistics_filter) {
              if (statisticsResult != null) {
                  new StatisticsFilterDialog(getContext(), statisticsResult.oldestDate).show();
              }
              return true;
          }
          return super.onOptionsItemSelected(item);
      }
  
      private void refreshStatistics() {
          progressBar.setVisibility(View.VISIBLE);
          feedStatisticsList.setVisibility(View.GONE);
          loadStatistics();
      }
  
      private void loadStatistics() {
          if (disposable != null) {
              disposable.dispose();
          }
          SharedPreferences prefs = getContext().getSharedPreferences(StatisticsFragment.PREF_NAME, Context.MODE_PRIVATE);
          boolean includeMarkedAsPlayed = prefs.getBoolean(StatisticsFragment.PREF_INCLUDE_MARKED_PLAYED, false);
          long timeFilterFrom = prefs.getLong(StatisticsFragment.PREF_FILTER_FROM, 0);
          long timeFilterTo = prefs.getLong(StatisticsFragment.PREF_FILTER_TO, Long.MAX_VALUE);
          disposable = Observable.fromCallable(
                  () -> {
                      DBReader.StatisticsResult statisticsData = DBReader.getStatistics(
                              includeMarkedAsPlayed, timeFilterFrom, timeFilterTo);
                      Collections.sort(statisticsData.feedTime, (item1, item2) ->
                              Long.compare(item2.timePlayed, item1.timePlayed));
                      return statisticsData;
                  })
                  .subscribeOn(Schedulers.io())
                  .observeOn(AndroidSchedulers.mainThread())
                  .subscribe(result -> {
                      statisticsResult = result;
                      // When "from" is "today", set it to today
                      listAdapter.setTimeFilter(includeMarkedAsPlayed, Math.max(
                                  Math.min(timeFilterFrom, System.currentTimeMillis()), result.oldestDate),
                              Math.min(timeFilterTo, System.currentTimeMillis()));
                      listAdapter.update(result.feedTime);
                      progressBar.setVisibility(View.GONE);
                      feedStatisticsList.setVisibility(View.VISIBLE);
                  }, error -> Log.e(TAG, Log.getStackTraceString(error)));
      }
  }
  