--- /dev/null
+package com.moiseum.wolnelektury.view.main;
+
+import android.net.Uri;
+import android.util.Log;
+
+import com.moiseum.wolnelektury.R;
+import com.moiseum.wolnelektury.base.WLApplication;
+import com.moiseum.wolnelektury.base.mvp.Presenter;
+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.OAuthTokenModel;
+import com.moiseum.wolnelektury.connection.models.UserModel;
+import com.moiseum.wolnelektury.connection.services.BooksService;
+import com.moiseum.wolnelektury.connection.services.UserService;
+import com.moiseum.wolnelektury.events.LoggedInEvent;
+import com.moiseum.wolnelektury.utils.SharedPreferencesUtils;
+import com.moiseum.wolnelektury.view.main.events.PremiumStatusEvent;
+
+import org.greenrobot.eventbus.EventBus;
+
+import java.util.List;
+
+import retrofit2.Call;
+
+/**
+ * Created by Piotr Ostrowski on 12.06.2018.
+ */
+class MainPresenter extends Presenter<MainView> {
+
+ private static final String TAG = MainPresenter.class.getSimpleName();
+ private static final String OAUTH_CALLBACK_VALUE = "wolnelekturyapp://oauth.callback/?oauth_token=";
+ private static final String PAYPAL_SUCCESS_CALLBACK_VALUE = "wolnelekturyapp://paypal_return";
+ private static final String PAYPAL_ERROR_CALLBACK_VALUE = "wolnelekturyapp://paypal_error";
+
+ private RestClient client = WLApplication.getInstance().getRestClient();
+ private SharedPreferencesUtils preferences = WLApplication.getInstance().getPreferences();
+ private Call currentCall;
+ private Call checkCall;
+
+ MainPresenter(MainView view) {
+ super(view);
+ getView().setLoggedIn(preferences.isUserLoggedIn());
+ getView().setLoggedUsername(preferences.getUsername());
+ }
+
+ @Override
+ public void onResume() {
+ super.onResume();
+ if (preferences.isUserLoggedIn()) {
+ checkPremiumStatus();
+ }
+ }
+
+ @Override
+ public void onDestroy() {
+ super.onDestroy();
+ if (currentCall != null) {
+ currentCall.cancel();
+ }
+ if (checkCall != null) {
+ checkCall.cancel();
+ }
+ }
+
+ void onLoginClicked() {
+ getView().setProgressDialogVisibility(true);
+ currentCall = client.call(new RestClientCallback<OAuthTokenModel, UserService>() {
+
+ @Override
+ public void onSuccess(OAuthTokenModel data) {
+ preferences.setTemporaryLoginToken(data.getToken());
+ String authUrl = String.format(RestClient.WEB_OAUTH_AUTHORIZATION_URL, data.getToken());
+ getView().setProgressDialogVisibility(false);
+ getView().showCustomTabsAuthentication(Uri.parse(authUrl));
+ }
+
+ @Override
+ public void onFailure(Exception e) {
+ Log.e(TAG, "Failed to obtain request token.", e);
+ getView().setProgressDialogVisibility(false);
+ getView().showToastMessage(R.string.login_request_token_failed);
+ }
+
+ @Override
+ public void onCancel() {
+ getView().setProgressDialogVisibility(false);
+ }
+
+ @Override
+ public Call<OAuthTokenModel> execute(UserService service) {
+ return service.requestToken();
+ }
+ }, UserService.class);
+ }
+
+ void onLogoutClicked() {
+ client.clearOAuthTokens();
+ preferences.clearUserData();
+ getView().relaunch(R.string.logout_successful);
+ }
+
+ void onBecomeAFriendClick() {
+ if (preferences.isUserLoggedIn()) {
+ getView().showPremiumForm();
+ } else {
+ getView().showLoginFirst();
+ }
+ }
+
+ void onBrowserCallback(String intentData) {
+ if (PAYPAL_SUCCESS_CALLBACK_VALUE.equals(intentData)) {
+ preferences.setPremium(true);
+ EventBus.getDefault().post(new PremiumStatusEvent(true));
+ getView().showToastMessage(R.string.premium_purchase_succeeded);
+ } else if (PAYPAL_ERROR_CALLBACK_VALUE.equals(intentData)) {
+ getView().showToastMessage(R.string.premium_purchase_failed);
+ } else {
+ onAuthorizationIntent(intentData);
+ }
+ }
+
+ void checkForPremiumBook() {
+ fetchHeader();
+ }
+
+ private void onAuthorizationIntent(String intentData) {
+ String correctDataString = OAUTH_CALLBACK_VALUE + preferences.getTemporaryLoginToken();
+ if (intentData.compareTo(correctDataString) != 0) {
+ getView().showToastMessage(R.string.login_auth_callback_malformed);
+ return;
+ }
+
+ getView().setProgressDialogVisibility(true);
+ currentCall = client.call(new RestClientCallback<OAuthTokenModel, UserService>() {
+
+ @Override
+ public void onSuccess(OAuthTokenModel data) {
+ preferences.storeAccessToken(data);
+ fetchUser();
+ }
+
+ @Override
+ public void onFailure(Exception e) {
+ Log.e(TAG, "Failed to obtain access token.", e);
+ getView().setProgressDialogVisibility(false);
+ getView().showToastMessage(R.string.login_access_token_failed);
+ }
+
+ @Override
+ public void onCancel() {
+ getView().setProgressDialogVisibility(false);
+ }
+
+ @Override
+ public Call<OAuthTokenModel> execute(UserService service) {
+ return service.accessToken();
+ }
+ }, UserService.class);
+ }
+
+ private void fetchUser() {
+ getView().setProgressDialogVisibility(true);
+
+ /*
+ * We are marking user as logged in cause we already have credentials at this point.
+ * If this request fails we can perform it later on and ignore those errors for now.
+ */
+ currentCall = client.call(new RestClientCallback<UserModel, UserService>() {
+ @Override
+ public void onSuccess(UserModel userModel) {
+ preferences.setUsername(userModel.getUsername());
+ preferences.setPremium(userModel.isPremium());
+ EventBus.getDefault().post(new LoggedInEvent());
+ getView().setProgressDialogVisibility(false);
+ getView().setLoggedIn(true);
+ getView().setLoggedUsername(userModel.getUsername());
+ }
+
+ @Override
+ public void onFailure(Exception e) {
+ EventBus.getDefault().post(new LoggedInEvent());
+ getView().setProgressDialogVisibility(false);
+ getView().setLoggedIn(true);
+ }
+
+ @Override
+ public void onCancel() {
+ EventBus.getDefault().post(new LoggedInEvent());
+ getView().setProgressDialogVisibility(false);
+ getView().setLoggedIn(true);
+ }
+
+ @Override
+ public Call<UserModel> execute(UserService service) {
+ return service.getUser();
+ }
+ }, UserService.class);
+ }
+
+ private void fetchHeader() {
+ getView().setProgressDialogVisibility(true);
+ currentCall = client.call(new RestClientCallback<List<BookDetailsModel>, BooksService>() {
+ @Override
+ public void onSuccess(List<BookDetailsModel> data) {
+ getView().setProgressDialogVisibility(false);
+ if (data.size() > 0) {
+ getView().showPremiumBook(data.get(0).getSlug());
+ } else {
+ getView().showNoPremiumBookAvailable(preferences.isUserLoggedIn());
+ }
+ }
+
+ @Override
+ public void onFailure(Exception e) {
+ getView().showToastMessage(R.string.fetching_premium_failed);
+ }
+
+ @Override
+ public void onCancel() {
+ // nop.
+ }
+
+ @Override
+ public Call<List<BookDetailsModel>> execute(BooksService service) {
+ return service.getPreview();
+ }
+ }, BooksService.class);
+ }
+
+ private void checkPremiumStatus() {
+ checkCall = client.call(new RestClientCallback<UserModel, UserService>() {
+ @Override
+ public void onSuccess(UserModel userModel) {
+ boolean currentPremiumStatus = preferences.isUserPremium();
+ preferences.setUsername(userModel.getUsername());
+ preferences.setPremium(userModel.isPremium());
+ if (currentPremiumStatus && !userModel.isPremium()) {
+ getView().relaunch(R.string.subscription_lost);
+ }
+ }
+
+ @Override
+ public void onFailure(Exception e) {
+ // nop
+ }
+
+ @Override
+ public void onCancel() {
+ // nop
+ }
+
+ @Override
+ public Call<UserModel> execute(UserService service) {
+ return service.getUser();
+ }
+ }, UserService.class);
+ }
+}
fnp / wl-app.git / blobdiff