--- /dev/null
+package com.moiseum.wolnelektury.view.library;
+
+import android.os.Bundle;
+
+import com.moiseum.wolnelektury.base.DataObserver;
+import com.moiseum.wolnelektury.base.WLApplication;
+import com.moiseum.wolnelektury.base.mvp.FragmentPresenter;
+import com.moiseum.wolnelektury.connection.RestClient;
+import com.moiseum.wolnelektury.connection.RestClientCallback;
+import com.moiseum.wolnelektury.connection.models.BookDetailsModel;
+import com.moiseum.wolnelektury.connection.models.BookModel;
+import com.moiseum.wolnelektury.connection.models.ReadingStateModel;
+import com.moiseum.wolnelektury.connection.services.BooksService;
+import com.moiseum.wolnelektury.events.LoggedInEvent;
+import com.moiseum.wolnelektury.storage.BookStorage;
+import com.moiseum.wolnelektury.utils.SharedPreferencesUtils;
+import com.moiseum.wolnelektury.view.book.BookType;
+import com.moiseum.wolnelektury.view.book.list.NewestBooksDataProvider;
+import com.moiseum.wolnelektury.view.book.list.ReadingStateDataProvider;
+import com.moiseum.wolnelektury.view.book.list.RecommendedBooksDataProvider;
+import com.moiseum.wolnelektury.view.main.MainActivity;
+import com.moiseum.wolnelektury.view.main.NavigationElement;
+import com.moiseum.wolnelektury.view.main.events.PremiumStatusEvent;
+
+import org.greenrobot.eventbus.EventBus;
+import org.greenrobot.eventbus.Subscribe;
+import org.greenrobot.eventbus.ThreadMode;
+
+import java.util.List;
+
+import retrofit2.Call;
+
+/**
+ * @author golonkos
+ */
+class LibraryPresenter extends FragmentPresenter<LibraryView> {
+
+ private static final String TAG = LibraryPresenter.class.getSimpleName();
+ private final NewestBooksDataProvider newestBooksDataProvider;
+ private final RecommendedBooksDataProvider recommendedBooksDataProvider;
+ private final ReadingStateDataProvider nowReadingBooksDataProvider;
+ private BookDetailsModel premiereBook;
+ private Call currentCall;
+ private RestClient client = WLApplication.getInstance().getRestClient();
+
+ private SharedPreferencesUtils preferences = WLApplication.getInstance().getPreferences();
+
+ LibraryPresenter(LibraryView view) {
+ super(view);
+ newestBooksDataProvider = new NewestBooksDataProvider();
+ newestBooksDataProvider.setDataObserver(new NewestDataObserver());
+
+ recommendedBooksDataProvider = new RecommendedBooksDataProvider();
+ recommendedBooksDataProvider.setDataObserver(new RecommendedDataObserver());
+
+ nowReadingBooksDataProvider = new ReadingStateDataProvider(ReadingStateModel.ReadingState.STATE_READING);
+ nowReadingBooksDataProvider.setDataObserver(new NowReadingDataObserver());
+ }
+
+ @Override
+ public void onCreate(Bundle savedInstanceState) {
+ super.onCreate(savedInstanceState);
+ EventBus.getDefault().register(this);
+ }
+
+ @Override
+ public void onViewCreated(Bundle savedInstanceState) {
+ super.onViewCreated(savedInstanceState);
+ newestBooksDataProvider.load(null);
+ recommendedBooksDataProvider.load(null);
+ if (preferences.isUserLoggedIn()) {
+ getView().setNowReadingVisibility(true);
+ nowReadingBooksDataProvider.load(null);
+ }
+ fetchHeader();
+ }
+
+ @Override
+ public void onResume() {
+ super.onResume();
+ getView().showBecomeAFriendHeader(preferences.isUserPremium());
+ }
+
+ @Override
+ public void onDestroy() {
+ super.onDestroy();
+ newestBooksDataProvider.cancel();
+ recommendedBooksDataProvider.cancel();
+ nowReadingBooksDataProvider.cancel();
+ if (currentCall != null) {
+ currentCall.cancel();
+ }
+ EventBus.getDefault().unregister(this);
+ }
+
+ void onNowReadingSeeAllClicked() {
+ EventBus.getDefault().post(new MainActivity.ChangeNavigationEvent(NavigationElement.NOW_READING));
+ }
+
+ void onBookClicked(BookModel book) {
+ getView().openBookDetailsView(book.getSlug(), BookType.TYPE_DEFAULT);
+ }
+
+ void reloadNewest() {
+ newestBooksDataProvider.load(null);
+ }
+
+ void reloadRecommended() {
+ recommendedBooksDataProvider.load(null);
+ }
+
+ void reloadNowReading() {
+ nowReadingBooksDataProvider.load(null);
+ }
+
+ @SuppressWarnings("unused")
+ @Subscribe(threadMode = ThreadMode.MAIN)
+ public void onBookAdded(BookStorage.BookAddedEvent event) {
+ if (preferences.isUserLoggedIn()) {
+ nowReadingBooksDataProvider.load(null);
+ }
+ }
+
+ @SuppressWarnings("unused")
+ @Subscribe(threadMode = ThreadMode.MAIN)
+ public void onBookDeleted(BookStorage.BookDeletedEvent event) {
+ if (preferences.isUserLoggedIn()) {
+ nowReadingBooksDataProvider.load(null);
+ }
+ }
+
+ @SuppressWarnings("unused")
+ @Subscribe(threadMode = ThreadMode.MAIN)
+ public void onPremiumChanged(PremiumStatusEvent event) {
+ getView().showBecomeAFriendHeader(event.isPremium());
+ }
+
+ @SuppressWarnings("unused")
+ @Subscribe(threadMode = ThreadMode.MAIN)
+ public void onLoggedIn(LoggedInEvent event) {
+ getView().showBecomeAFriendHeader(preferences.isUserPremium());
+ getView().setNowReadingVisibility(true);
+ nowReadingBooksDataProvider.load(null);
+ }
+
+ void onPremiereHeaderClicked() {
+ if (premiereBook != null) {
+ getView().openBookDetailsView(premiereBook.getSlug(), BookType.TYPE_PREMIUM);
+ }
+ }
+
+ void fetchHeader() {
+ getView().setProgressContainerVisible(true);
+ getView().setHeaderProgressVisible(true);
+ currentCall = client.call(new RestClientCallback<List<BookDetailsModel>, BooksService>() {
+ @Override
+ public void onSuccess(List<BookDetailsModel> data) {
+ getView().setHeaderProgressVisible(false);
+ if (data.size() > 0) {
+ premiereBook = data.get(0);
+ getView().initHeader(premiereBook);
+ getView().setProgressContainerVisible(false);
+ } else {
+ getView().showHeaderEmpty(preferences.isUserLoggedIn());
+ }
+ }
+
+ @Override
+ public void onFailure(Exception e) {
+ getView().showHeaderError();
+ }
+
+ @Override
+ public void onCancel() {
+ // nop.
+ }
+
+ @Override
+ public Call<List<BookDetailsModel>> execute(BooksService service) {
+ return service.getPreview();
+ }
+ }, BooksService.class);
+ }
+
+
+ private class NewestDataObserver implements DataObserver<List<BookModel>> {
+
+ @Override
+ public void onLoadStarted() {
+ getView().setNewestProgressVisible(true);
+ }
+
+ @Override
+ public void onLoadSuccess(List<BookModel> data) {
+ getView().setNewestProgressVisible(false);
+ getView().setNewest(data);
+ }
+
+ @Override
+ public void onLoadFailed(Exception e) {
+ getView().setNewestProgressVisible(false);
+ getView().showNewestError(e);
+ }
+ }
+
+ private class RecommendedDataObserver implements DataObserver<List<BookModel>> {
+
+ @Override
+ public void onLoadStarted() {
+ getView().setRecommendedProgressVisible(true);
+ }
+
+ @Override
+ public void onLoadSuccess(List<BookModel> data) {
+ getView().setRecommendedProgressVisible(false);
+ getView().setRecommended(data);
+ }
+
+ @Override
+ public void onLoadFailed(Exception e) {
+ getView().setRecommendedProgressVisible(false);
+ getView().showRecommendedError(e);
+ }
+ }
+
+ private class NowReadingDataObserver implements DataObserver<List<BookModel>> {
+
+ @Override
+ public void onLoadStarted() {
+ getView().setNowReadingProgressVisible(true);
+ }
+
+ @Override
+ public void onLoadSuccess(List<BookModel> data) {
+ getView().setNowReadingProgressVisible(false);
+ getView().setNowReading(data);
+ }
+
+ @Override
+ public void onLoadFailed(Exception e) {
+ getView().setNowReadingProgressVisible(false);
+ getView().showNowReadingError(e);
+ }
+ }
+}
fnp / wl-app.git / blobdiff