diff --git a/app/src/main/java/com/nextcloud/talk/controllers/AccountVerificationController.java b/app/src/main/java/com/nextcloud/talk/controllers/AccountVerificationController.java
deleted file mode 100644
index 59d9d9f4a..000000000
--- a/app/src/main/java/com/nextcloud/talk/controllers/AccountVerificationController.java
+++ /dev/null
@@ -1,546 +0,0 @@
-/*
- * Nextcloud Talk application
- *
- * @author Mario Danic
- * Copyright (C) 2017 Mario Danic (mario@lovelyhq.com)
- *
- * This program is free software: you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation, either version 3 of the License, or
- * at your option) any later version.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License
- * along with this program. If not, see .
- */
-
-package com.nextcloud.talk.controllers;
-
-import android.annotation.SuppressLint;
-import android.content.pm.ActivityInfo;
-import android.os.Bundle;
-import android.os.Handler;
-import android.text.TextUtils;
-import android.view.LayoutInflater;
-import android.view.View;
-import android.view.ViewGroup;
-import android.widget.TextView;
-
-import com.bluelinelabs.conductor.RouterTransaction;
-import com.bluelinelabs.conductor.changehandler.HorizontalChangeHandler;
-import com.nextcloud.talk.R;
-import com.nextcloud.talk.api.NcApi;
-import com.nextcloud.talk.application.NextcloudTalkApplication;
-import com.nextcloud.talk.controllers.base.BaseController;
-import com.nextcloud.talk.events.EventStatus;
-import com.nextcloud.talk.jobs.CapabilitiesWorker;
-import com.nextcloud.talk.jobs.PushRegistrationWorker;
-import com.nextcloud.talk.jobs.SignalingSettingsWorker;
-import com.nextcloud.talk.models.database.UserEntity;
-import com.nextcloud.talk.models.json.capabilities.CapabilitiesOverall;
-import com.nextcloud.talk.models.json.generic.Status;
-import com.nextcloud.talk.models.json.userprofile.UserProfileOverall;
-import com.nextcloud.talk.utils.ApiUtils;
-import com.nextcloud.talk.utils.ClosedInterfaceImpl;
-import com.nextcloud.talk.utils.bundle.BundleKeys;
-import com.nextcloud.talk.utils.database.user.UserUtils;
-import com.nextcloud.talk.utils.preferences.AppPreferences;
-import com.nextcloud.talk.utils.singletons.ApplicationWideMessageHolder;
-
-import org.greenrobot.eventbus.EventBus;
-import org.greenrobot.eventbus.Subscribe;
-import org.greenrobot.eventbus.ThreadMode;
-
-import java.net.CookieManager;
-import java.util.ArrayList;
-import java.util.List;
-
-import javax.inject.Inject;
-
-import androidx.annotation.NonNull;
-import androidx.work.Data;
-import androidx.work.OneTimeWorkRequest;
-import androidx.work.WorkManager;
-import autodagger.AutoInjector;
-import butterknife.BindView;
-import io.reactivex.CompletableObserver;
-import io.reactivex.Observer;
-import io.reactivex.android.schedulers.AndroidSchedulers;
-import io.reactivex.disposables.Disposable;
-import io.reactivex.schedulers.Schedulers;
-
-
-@AutoInjector(NextcloudTalkApplication.class)
-public class AccountVerificationController extends BaseController {
-
- public static final String TAG = "AccountVerificationController";
-
- @Inject
- NcApi ncApi;
-
- @Inject
- UserUtils userUtils;
-
- @Inject
- CookieManager cookieManager;
-
- @Inject
- AppPreferences appPreferences;
-
- @Inject
- EventBus eventBus;
-
- @BindView(R.id.progress_text)
- TextView progressText;
-
- private long internalAccountId = -1;
-
- private List disposables = new ArrayList<>();
-
- private String baseUrl;
- private String username;
- private String token;
- private boolean isAccountImport;
- private String originalProtocol;
-
- public AccountVerificationController(Bundle args) {
- super(args);
- if (args != null) {
- baseUrl = args.getString(BundleKeys.INSTANCE.getKEY_BASE_URL());
- username = args.getString(BundleKeys.INSTANCE.getKEY_USERNAME());
- token = args.getString(BundleKeys.INSTANCE.getKEY_TOKEN());
- if (args.containsKey(BundleKeys.INSTANCE.getKEY_IS_ACCOUNT_IMPORT())) {
- isAccountImport = true;
- }
- if (args.containsKey(BundleKeys.INSTANCE.getKEY_ORIGINAL_PROTOCOL())) {
- originalProtocol = args.getString(BundleKeys.INSTANCE.getKEY_ORIGINAL_PROTOCOL());
- }
- }
- }
-
- @Override
- protected void onAttach(@NonNull View view) {
- super.onAttach(view);
- eventBus.register(this);
- }
-
- @Override
- protected void onDetach(@NonNull View view) {
- super.onDetach(view);
- eventBus.unregister(this);
- }
-
- @Override
- protected View inflateView(@NonNull LayoutInflater inflater, @NonNull ViewGroup container) {
- return inflater.inflate(R.layout.controller_account_verification, container, false);
- }
-
- @Override
- protected void onViewBound(@NonNull View view) {
- super.onViewBound(view);
- NextcloudTalkApplication.Companion.getSharedApplication().getComponentApplication().inject(this);
-
- if (getActivity() != null) {
- getActivity().setRequestedOrientation(ActivityInfo.SCREEN_ORIENTATION_PORTRAIT);
- }
-
- if (getActionBar() != null) {
- getActionBar().hide();
- }
-
- if (isAccountImport && !baseUrl.startsWith("http://") && !baseUrl.startsWith("https://") || (!TextUtils
- .isEmpty(originalProtocol) && !baseUrl.startsWith(originalProtocol))) {
- determineBaseUrlProtocol(true);
- } else {
- checkEverything();
- }
- }
-
- private void checkEverything() {
- String credentials = ApiUtils.getCredentials(username, token);
- cookieManager.getCookieStore().removeAll();
-
- findServerTalkApp(credentials);
- }
-
- private void determineBaseUrlProtocol(boolean checkForcedHttps) {
- cookieManager.getCookieStore().removeAll();
-
- String queryUrl;
-
- baseUrl = baseUrl.replace("http://", "").replace("https://", "");
-
- if (checkForcedHttps) {
- queryUrl = "https://" + baseUrl + ApiUtils.getUrlPostfixForStatus();
- } else {
- queryUrl = "http://" + baseUrl + ApiUtils.getUrlPostfixForStatus();
- }
-
- ncApi.getServerStatus(queryUrl)
- .subscribeOn(Schedulers.io())
- .observeOn(AndroidSchedulers.mainThread())
- .subscribe(new Observer() {
- @Override
- public void onSubscribe(Disposable d) {
- disposables.add(d);
- }
-
- @Override
- public void onNext(Status status) {
- if (checkForcedHttps) {
- baseUrl = "https://" + baseUrl;
- } else {
- baseUrl = "http://" + baseUrl;
- }
-
- if (isAccountImport) {
- getRouter().replaceTopController(RouterTransaction.with(new WebViewLoginController(baseUrl,
- false, username, ""))
- .pushChangeHandler(new HorizontalChangeHandler())
- .popChangeHandler(new HorizontalChangeHandler()));
- } else {
- checkEverything();
- }
- }
-
- @Override
- public void onError(Throwable e) {
- if (checkForcedHttps) {
- determineBaseUrlProtocol(false);
- } else {
- abortVerification();
- }
- }
-
- @Override
- public void onComplete() {
-
- }
- });
- }
-
- private void findServerTalkApp(String credentials) {
- ncApi.getCapabilities(credentials, ApiUtils.getUrlForCapabilities(baseUrl))
- .subscribeOn(Schedulers.io())
- .subscribe(new Observer() {
- @Override
- public void onSubscribe(Disposable d) {
- disposables.add(d);
- }
-
- @Override
- public void onNext(CapabilitiesOverall capabilitiesOverall) {
- boolean hasTalk =
- capabilitiesOverall.getOcs().getData().getCapabilities() != null
- && capabilitiesOverall.getOcs().getData().getCapabilities().getSpreedCapability() != null
- && capabilitiesOverall.getOcs().getData().getCapabilities().getSpreedCapability().getFeatures() != null
- && !capabilitiesOverall.getOcs().getData().getCapabilities().getSpreedCapability().getFeatures().isEmpty();
-
- if (hasTalk) {
- fetchProfile(credentials);
- } else {
- if (getActivity() != null && getResources() != null) {
- getActivity().runOnUiThread(() -> progressText.setText(
- String.format(
- getResources().getString(R.string.nc_nextcloud_talk_app_not_installed),
- getResources().getString(R.string.nc_app_product_name))));
- }
-
- ApplicationWideMessageHolder.getInstance().setMessageType(
- ApplicationWideMessageHolder.MessageType.SERVER_WITHOUT_TALK);
-
- abortVerification();
- }
- }
-
- @Override
- public void onError(Throwable e) {
- if (getActivity() != null && getResources() != null) {
- getActivity().runOnUiThread(() -> progressText.setText(
- String.format(
- getResources().getString(R.string.nc_nextcloud_talk_app_not_installed),
- getResources().getString(R.string.nc_app_product_name))));
- }
-
- ApplicationWideMessageHolder.getInstance().setMessageType(
- ApplicationWideMessageHolder.MessageType.SERVER_WITHOUT_TALK);
-
- abortVerification();
- }
-
- @Override
- public void onComplete() {
-
- }
- });
- }
-
- private void storeProfile(String displayName, String userId) {
- userUtils.createOrUpdateUser(username, token,
- baseUrl, displayName, null, Boolean.TRUE,
- userId, null, null,
- appPreferences.getTemporaryClientCertAlias(), null)
- .subscribeOn(Schedulers.io())
- .subscribe(new Observer() {
- @Override
- public void onSubscribe(Disposable d) {
- disposables.add(d);
- }
-
- @SuppressLint("SetTextI18n")
- @Override
- public void onNext(UserEntity userEntity) {
- internalAccountId = userEntity.getId();
-
- if (new ClosedInterfaceImpl().isGooglePlayServicesAvailable()) {
- registerForPush();
- } else {
- getActivity().runOnUiThread(() -> progressText.setText(progressText.getText().toString() + "\n" +
- getResources().getString(R.string.nc_push_disabled)));
- fetchAndStoreCapabilities();
- }
- }
-
- @SuppressLint("SetTextI18n")
- @Override
- public void onError(Throwable e) {
- progressText.setText(progressText.getText().toString() +
- "\n" +
- getResources().getString(
- R.string.nc_display_name_not_stored));
- abortVerification();
-
- }
-
- @Override
- public void onComplete() {
-
- }
- });
- }
-
- private void fetchProfile(String credentials) {
- ncApi.getUserProfile(credentials,
- ApiUtils.getUrlForUserProfile(baseUrl))
- .subscribeOn(Schedulers.io())
- .subscribe(new Observer() {
- @Override
- public void onSubscribe(Disposable d) {
- disposables.add(d);
- }
-
- @SuppressLint("SetTextI18n")
- @Override
- public void onNext(UserProfileOverall userProfileOverall) {
- String displayName = null;
- if (!TextUtils.isEmpty(userProfileOverall.getOcs().getData()
- .getDisplayName())) {
- displayName = userProfileOverall.getOcs().getData()
- .getDisplayName();
- } else if (!TextUtils.isEmpty(userProfileOverall.getOcs().getData()
- .getDisplayNameAlt())) {
- displayName = userProfileOverall.getOcs().getData()
- .getDisplayNameAlt();
- }
-
- if (!TextUtils.isEmpty(displayName)) {
- storeProfile(displayName, userProfileOverall.getOcs().getData().getUserId());
- } else {
- if (getActivity() != null) {
- getActivity().runOnUiThread(() -> progressText.setText(progressText.getText().toString() + "\n" +
- getResources().getString(R.string.nc_display_name_not_fetched)));
- }
- abortVerification();
- }
- }
-
- @SuppressLint("SetTextI18n")
- @Override
- public void onError(Throwable e) {
- if (getActivity() != null) {
- getActivity().runOnUiThread(() -> progressText.setText(progressText.getText().toString() + "\n" +
- getResources().getString(R.string.nc_display_name_not_fetched)));
- }
- abortVerification();
-
- }
-
- @Override
- public void onComplete() {
-
- }
- });
- }
-
- private void registerForPush() {
- Data data =
- new Data.Builder().putString(PushRegistrationWorker.ORIGIN, "AccountVerificationController#registerForPush").build();
-
- OneTimeWorkRequest pushRegistrationWork = new OneTimeWorkRequest.Builder(PushRegistrationWorker.class)
- .setInputData(data)
- .build();
- WorkManager.getInstance().enqueue(pushRegistrationWork);
- }
-
- @SuppressLint("SetTextI18n")
- @Subscribe(threadMode = ThreadMode.BACKGROUND)
- public void onMessageEvent(EventStatus eventStatus) {
- if (eventStatus.getEventType().equals(EventStatus.EventType.PUSH_REGISTRATION)) {
- if (internalAccountId == eventStatus.getUserId() && !eventStatus.isAllGood() && getActivity() != null) {
- getActivity().runOnUiThread(() -> progressText.setText(progressText.getText().toString() + "\n" +
- getResources().getString(R.string.nc_push_disabled)));
- }
- fetchAndStoreCapabilities();
- } else if (eventStatus.getEventType().equals(EventStatus.EventType.CAPABILITIES_FETCH)) {
- if (internalAccountId == eventStatus.getUserId() && !eventStatus.isAllGood()) {
- if (getActivity() != null) {
- getActivity().runOnUiThread(() -> progressText.setText(progressText.getText().toString() + "\n" +
- getResources().getString(R.string.nc_capabilities_failed)));
- }
- abortVerification();
- } else if (internalAccountId == eventStatus.getUserId() && eventStatus.isAllGood()) {
- fetchAndStoreExternalSignalingSettings();
- }
- } else if (eventStatus.getEventType().equals(EventStatus.EventType.SIGNALING_SETTINGS)) {
- if (internalAccountId == eventStatus.getUserId() && !eventStatus.isAllGood()) {
- if (getActivity() != null) {
- getActivity().runOnUiThread(() -> progressText.setText(progressText.getText().toString() + "\n" +
- getResources().getString(R.string.nc_external_server_failed)));
- }
- }
-
- proceedWithLogin();
- }
-
- }
-
- private void fetchAndStoreCapabilities() {
- Data userData = new Data.Builder()
- .putLong(BundleKeys.INSTANCE.getKEY_INTERNAL_USER_ID(), internalAccountId)
- .build();
-
- OneTimeWorkRequest pushNotificationWork = new OneTimeWorkRequest.Builder(CapabilitiesWorker.class)
- .setInputData(userData)
- .build();
- WorkManager.getInstance().enqueue(pushNotificationWork);
- }
-
- private void fetchAndStoreExternalSignalingSettings() {
- Data userData = new Data.Builder()
- .putLong(BundleKeys.INSTANCE.getKEY_INTERNAL_USER_ID(), internalAccountId)
- .build();
-
- OneTimeWorkRequest signalingSettings = new OneTimeWorkRequest.Builder(SignalingSettingsWorker.class)
- .setInputData(userData)
- .build();
- WorkManager.getInstance().enqueue(signalingSettings);
- }
-
- private void proceedWithLogin() {
- cookieManager.getCookieStore().removeAll();
- userUtils.disableAllUsersWithoutId(internalAccountId);
-
- if (getActivity() != null) {
- getActivity().runOnUiThread(() -> {
- if (userUtils.getUsers().size() == 1) {
- getRouter().setRoot(RouterTransaction.with(new
- ConversationsListController(new Bundle()))
- .pushChangeHandler(new HorizontalChangeHandler())
- .popChangeHandler(new HorizontalChangeHandler()));
- } else {
- if (isAccountImport) {
- ApplicationWideMessageHolder.getInstance().setMessageType(
- ApplicationWideMessageHolder.MessageType.ACCOUNT_WAS_IMPORTED);
- }
- getRouter().popToRoot();
- }
- });
- }
- }
-
-
- private void dispose() {
- for (int i = 0; i < disposables.size(); i++) {
- if (!disposables.get(i).isDisposed()) {
- disposables.get(i).dispose();
- }
- }
- }
-
- @Override
- protected void onDestroyView(@NonNull View view) {
- super.onDestroyView(view);
- if (getActivity() != null) {
- getActivity().setRequestedOrientation(ActivityInfo.SCREEN_ORIENTATION_FULL_SENSOR);
- }
- }
-
- @Override
- public void onDestroy() {
- dispose();
- super.onDestroy();
- }
-
- private void abortVerification() {
-
- if (!isAccountImport) {
- if (internalAccountId != -1) {
- userUtils.deleteUserWithId(internalAccountId).subscribe(new CompletableObserver() {
- @Override
- public void onSubscribe(Disposable d) {
-
- }
-
- @Override
- public void onComplete() {
- if (getActivity() != null) {
- getActivity().runOnUiThread(() -> {
- new Handler().postDelayed(() -> getRouter().popToRoot(), 7500);
- });
- }
- }
-
- @Override
- public void onError(Throwable e) {
-
- }
- });
- } else {
- if (getActivity() != null) {
- getActivity().runOnUiThread(() -> {
- new Handler().postDelayed(() -> getRouter().popToRoot(), 7500);
- });
- }
- }
- } else {
- ApplicationWideMessageHolder.getInstance().setMessageType(
- ApplicationWideMessageHolder.MessageType.FAILED_TO_IMPORT_ACCOUNT);
- if (getActivity() != null) {
- getActivity().runOnUiThread(() -> new Handler().postDelayed(() -> {
- if (getRouter().hasRootController()) {
- if (getActivity() != null) {
- getRouter().popToRoot();
- }
-
-
- } else {
- if (userUtils.anyUserExists()) {
- getRouter().setRoot(RouterTransaction.with(new ConversationsListController(new Bundle()))
- .pushChangeHandler(new HorizontalChangeHandler())
- .popChangeHandler(new HorizontalChangeHandler()));
- } else {
- getRouter().setRoot(RouterTransaction.with(new ServerSelectionController())
- .pushChangeHandler(new HorizontalChangeHandler())
- .popChangeHandler(new HorizontalChangeHandler()));
- }
- }
- }, 7500));
- }
- }
- }
-
-}
diff --git a/app/src/main/java/com/nextcloud/talk/controllers/AccountVerificationController.kt b/app/src/main/java/com/nextcloud/talk/controllers/AccountVerificationController.kt
new file mode 100644
index 000000000..9ed3324c2
--- /dev/null
+++ b/app/src/main/java/com/nextcloud/talk/controllers/AccountVerificationController.kt
@@ -0,0 +1,513 @@
+/*
+ * Nextcloud Talk application
+ *
+ * @author Mario Danic
+ * Copyright (C) 2017 Mario Danic (mario@lovelyhq.com)
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see .
+ */
+package com.nextcloud.talk.controllers
+
+import android.annotation.SuppressLint
+import android.content.pm.ActivityInfo
+import android.os.Bundle
+import android.os.Handler
+import android.text.TextUtils
+import android.view.View
+import androidx.work.Data
+import androidx.work.OneTimeWorkRequest
+import androidx.work.WorkManager
+import autodagger.AutoInjector
+import com.bluelinelabs.conductor.RouterTransaction
+import com.bluelinelabs.conductor.changehandler.HorizontalChangeHandler
+import com.nextcloud.talk.R
+import com.nextcloud.talk.api.NcApi
+import com.nextcloud.talk.application.NextcloudTalkApplication
+import com.nextcloud.talk.application.NextcloudTalkApplication.Companion.sharedApplication
+import com.nextcloud.talk.controllers.base.NewBaseController
+import com.nextcloud.talk.controllers.util.viewBinding
+import com.nextcloud.talk.databinding.ControllerAccountVerificationBinding
+import com.nextcloud.talk.events.EventStatus
+import com.nextcloud.talk.jobs.CapabilitiesWorker
+import com.nextcloud.talk.jobs.PushRegistrationWorker
+import com.nextcloud.talk.jobs.SignalingSettingsWorker
+import com.nextcloud.talk.models.database.UserEntity
+import com.nextcloud.talk.models.json.capabilities.CapabilitiesOverall
+import com.nextcloud.talk.models.json.generic.Status
+import com.nextcloud.talk.models.json.userprofile.UserProfileOverall
+import com.nextcloud.talk.utils.ApiUtils
+import com.nextcloud.talk.utils.ClosedInterfaceImpl
+import com.nextcloud.talk.utils.bundle.BundleKeys.KEY_BASE_URL
+import com.nextcloud.talk.utils.bundle.BundleKeys.KEY_INTERNAL_USER_ID
+import com.nextcloud.talk.utils.bundle.BundleKeys.KEY_IS_ACCOUNT_IMPORT
+import com.nextcloud.talk.utils.bundle.BundleKeys.KEY_ORIGINAL_PROTOCOL
+import com.nextcloud.talk.utils.bundle.BundleKeys.KEY_TOKEN
+import com.nextcloud.talk.utils.bundle.BundleKeys.KEY_USERNAME
+import com.nextcloud.talk.utils.database.user.UserUtils
+import com.nextcloud.talk.utils.singletons.ApplicationWideMessageHolder
+import io.reactivex.CompletableObserver
+import io.reactivex.Observer
+import io.reactivex.android.schedulers.AndroidSchedulers
+import io.reactivex.disposables.Disposable
+import io.reactivex.schedulers.Schedulers
+import org.greenrobot.eventbus.EventBus
+import org.greenrobot.eventbus.Subscribe
+import org.greenrobot.eventbus.ThreadMode
+import java.net.CookieManager
+import java.util.ArrayList
+import javax.inject.Inject
+
+@AutoInjector(NextcloudTalkApplication::class)
+class AccountVerificationController(args: Bundle? = null) :
+ NewBaseController(
+ R.layout.controller_account_verification,
+ args
+ ) {
+ private val binding: ControllerAccountVerificationBinding by viewBinding(ControllerAccountVerificationBinding::bind)
+
+ @Inject
+ lateinit var ncApi: NcApi
+
+ @Inject
+ lateinit var userUtils: UserUtils
+
+ @Inject
+ lateinit var cookieManager: CookieManager
+
+ @Inject
+ lateinit var eventBus: EventBus
+
+ private var internalAccountId: Long = -1
+ private val disposables: MutableList = ArrayList()
+ private var baseUrl: String? = null
+ private var username: String? = null
+ private var token: String? = null
+ private var isAccountImport = false
+ private var originalProtocol: String? = null
+
+ override fun onAttach(view: View) {
+ super.onAttach(view)
+ eventBus.register(this)
+ }
+
+ override fun onDetach(view: View) {
+ super.onDetach(view)
+ eventBus.unregister(this)
+ }
+
+ override fun onViewBound(view: View) {
+ super.onViewBound(view)
+ activity?.requestedOrientation = ActivityInfo.SCREEN_ORIENTATION_PORTRAIT
+
+ actionBar?.hide()
+
+ if (isAccountImport &&
+ !baseUrl!!.startsWith("http://") &&
+ !baseUrl!!.startsWith("https://") ||
+ !TextUtils.isEmpty(originalProtocol!!) &&
+ !baseUrl!!.startsWith(originalProtocol!!)
+ ) {
+ determineBaseUrlProtocol(true)
+ } else {
+ checkEverything()
+ }
+ }
+
+ private fun checkEverything() {
+ val credentials = ApiUtils.getCredentials(username, token)
+ cookieManager.cookieStore.removeAll()
+ findServerTalkApp(credentials)
+ }
+
+ private fun determineBaseUrlProtocol(checkForcedHttps: Boolean) {
+ cookieManager.cookieStore.removeAll()
+ baseUrl = baseUrl!!.replace("http://", "").replace("https://", "")
+ val queryUrl: String = if (checkForcedHttps) {
+ "https://" + baseUrl + ApiUtils.getUrlPostfixForStatus()
+ } else {
+ "http://" + baseUrl + ApiUtils.getUrlPostfixForStatus()
+ }
+ ncApi.getServerStatus(queryUrl)
+ .subscribeOn(Schedulers.io())
+ .observeOn(AndroidSchedulers.mainThread())
+ .subscribe(object : Observer {
+ override fun onSubscribe(d: Disposable) {
+ disposables.add(d)
+ }
+
+ override fun onNext(status: Status) {
+ baseUrl = if (checkForcedHttps) {
+ "https://$baseUrl"
+ } else {
+ "http://$baseUrl"
+ }
+ if (isAccountImport) {
+ router.replaceTopController(
+ RouterTransaction.with(
+ WebViewLoginController(
+ baseUrl,
+ false, username, ""
+ )
+ )
+ .pushChangeHandler(HorizontalChangeHandler())
+ .popChangeHandler(HorizontalChangeHandler())
+ )
+ } else {
+ checkEverything()
+ }
+ }
+
+ override fun onError(e: Throwable) {
+ if (checkForcedHttps) {
+ determineBaseUrlProtocol(false)
+ } else {
+ abortVerification()
+ }
+ }
+
+ override fun onComplete() {}
+ })
+ }
+
+ private fun findServerTalkApp(credentials: String) {
+ ncApi.getCapabilities(credentials, ApiUtils.getUrlForCapabilities(baseUrl))
+ .subscribeOn(Schedulers.io())
+ .subscribe(object : Observer {
+ override fun onSubscribe(d: Disposable) {
+ disposables.add(d)
+ }
+
+ override fun onNext(capabilitiesOverall: CapabilitiesOverall) {
+ val hasTalk =
+ capabilitiesOverall.ocs!!.data!!.capabilities != null &&
+ capabilitiesOverall.ocs!!.data!!.capabilities!!.spreedCapability != null &&
+ capabilitiesOverall.ocs!!.data!!.capabilities!!.spreedCapability!!.features != null &&
+ !capabilitiesOverall.ocs!!.data!!.capabilities!!.spreedCapability!!.features!!.isEmpty()
+ if (hasTalk) {
+ fetchProfile(credentials)
+ } else {
+ if (activity != null && resources != null) {
+ activity!!.runOnUiThread {
+ binding.progressText.setText(
+ String.format(
+ resources!!.getString(R.string.nc_nextcloud_talk_app_not_installed),
+ resources!!.getString(R.string.nc_app_product_name)
+ )
+ )
+ }
+ }
+ ApplicationWideMessageHolder.getInstance().setMessageType(
+ ApplicationWideMessageHolder.MessageType.SERVER_WITHOUT_TALK
+ )
+ abortVerification()
+ }
+ }
+
+ override fun onError(e: Throwable) {
+ if (activity != null && resources != null) {
+ activity!!.runOnUiThread {
+ binding.progressText.setText(
+ String.format(
+ resources!!.getString(R.string.nc_nextcloud_talk_app_not_installed),
+ resources!!.getString(R.string.nc_app_product_name)
+ )
+ )
+ }
+ }
+ ApplicationWideMessageHolder.getInstance().setMessageType(
+ ApplicationWideMessageHolder.MessageType.SERVER_WITHOUT_TALK
+ )
+ abortVerification()
+ }
+
+ override fun onComplete() {}
+ })
+ }
+
+ private fun storeProfile(displayName: String?, userId: String) {
+ userUtils.createOrUpdateUser(
+ username, token,
+ baseUrl, displayName, null, java.lang.Boolean.TRUE,
+ userId, null, null,
+ appPreferences!!.temporaryClientCertAlias, null
+ )
+ .subscribeOn(Schedulers.io())
+ .subscribe(object : Observer {
+ override fun onSubscribe(d: Disposable) {
+ disposables.add(d)
+ }
+
+ @SuppressLint("SetTextI18n")
+ override fun onNext(userEntity: UserEntity) {
+ internalAccountId = userEntity.id
+ if (ClosedInterfaceImpl().isGooglePlayServicesAvailable) {
+ registerForPush()
+ } else {
+ activity!!.runOnUiThread {
+ binding.progressText.text = """
+ ${binding.progressText.text}
+ ${resources!!.getString(R.string.nc_push_disabled)}
+ """.trimIndent()
+ }
+ fetchAndStoreCapabilities()
+ }
+ }
+
+ @SuppressLint("SetTextI18n")
+ override fun onError(e: Throwable) {
+ binding.progressText.text = """
+ ${binding.progressText.text}
+ """.trimIndent() +
+ resources!!.getString(
+ R.string.nc_display_name_not_stored
+ )
+ abortVerification()
+ }
+
+ override fun onComplete() {}
+ })
+ }
+
+ private fun fetchProfile(credentials: String) {
+ ncApi.getUserProfile(
+ credentials,
+ ApiUtils.getUrlForUserProfile(baseUrl)
+ )
+ .subscribeOn(Schedulers.io())
+ .subscribe(object : Observer {
+ override fun onSubscribe(d: Disposable) {
+ disposables.add(d)
+ }
+
+ @SuppressLint("SetTextI18n")
+ override fun onNext(userProfileOverall: UserProfileOverall) {
+ var displayName: String? = null
+ if (!TextUtils.isEmpty(userProfileOverall.ocs.data.displayName)) {
+ displayName = userProfileOverall.ocs.data.displayName
+ } else if (!TextUtils.isEmpty(userProfileOverall.ocs.data.displayNameAlt)) {
+ displayName = userProfileOverall.ocs.data.displayNameAlt
+ }
+ if (!TextUtils.isEmpty(displayName)) {
+ storeProfile(displayName, userProfileOverall.ocs.data.userId)
+ } else {
+ if (activity != null) {
+ activity!!.runOnUiThread {
+ binding.progressText.text = """
+ ${binding.progressText.text}
+ ${resources!!.getString(R.string.nc_display_name_not_fetched)}
+ """.trimIndent()
+ }
+ }
+ abortVerification()
+ }
+ }
+
+ @SuppressLint("SetTextI18n")
+ override fun onError(e: Throwable) {
+ if (activity != null) {
+ activity!!.runOnUiThread {
+ binding.progressText.text = """
+ ${binding.progressText.text}
+ ${resources!!.getString(R.string.nc_display_name_not_fetched)}
+ """.trimIndent()
+ }
+ }
+ abortVerification()
+ }
+
+ override fun onComplete() {}
+ })
+ }
+
+ private fun registerForPush() {
+ val data =
+ Data.Builder()
+ .putString(PushRegistrationWorker.ORIGIN, "AccountVerificationController#registerForPush")
+ .build()
+ val pushRegistrationWork =
+ OneTimeWorkRequest.Builder(PushRegistrationWorker::class.java)
+ .setInputData(data)
+ .build()
+ WorkManager.getInstance().enqueue(pushRegistrationWork)
+ }
+
+ @SuppressLint("SetTextI18n")
+ @Subscribe(threadMode = ThreadMode.BACKGROUND)
+ fun onMessageEvent(eventStatus: EventStatus) {
+ if (eventStatus.eventType == EventStatus.EventType.PUSH_REGISTRATION) {
+ if (internalAccountId == eventStatus.userId && !eventStatus.isAllGood && activity != null) {
+ activity!!.runOnUiThread {
+ binding.progressText!!.text = """
+ ${binding.progressText!!.text}
+ ${resources!!.getString(R.string.nc_push_disabled)}
+ """.trimIndent()
+ }
+ }
+ fetchAndStoreCapabilities()
+ } else if (eventStatus.eventType == EventStatus.EventType.CAPABILITIES_FETCH) {
+ if (internalAccountId == eventStatus.userId && !eventStatus.isAllGood) {
+ if (activity != null) {
+ activity!!.runOnUiThread {
+ binding.progressText!!.text = """
+ ${binding.progressText!!.text}
+ ${resources!!.getString(R.string.nc_capabilities_failed)}
+ """.trimIndent()
+ }
+ }
+ abortVerification()
+ } else if (internalAccountId == eventStatus.userId && eventStatus.isAllGood) {
+ fetchAndStoreExternalSignalingSettings()
+ }
+ } else if (eventStatus.eventType == EventStatus.EventType.SIGNALING_SETTINGS) {
+ if (internalAccountId == eventStatus.userId && !eventStatus.isAllGood) {
+ if (activity != null) {
+ activity!!.runOnUiThread {
+ binding.progressText!!.text = """
+ ${binding.progressText!!.text}
+ ${resources!!.getString(R.string.nc_external_server_failed)}
+ """.trimIndent()
+ }
+ }
+ }
+ proceedWithLogin()
+ }
+ }
+
+ private fun fetchAndStoreCapabilities() {
+ val userData =
+ Data.Builder()
+ .putLong(KEY_INTERNAL_USER_ID, internalAccountId)
+ .build()
+ val pushNotificationWork =
+ OneTimeWorkRequest.Builder(CapabilitiesWorker::class.java)
+ .setInputData(userData)
+ .build()
+ WorkManager.getInstance().enqueue(pushNotificationWork)
+ }
+
+ private fun fetchAndStoreExternalSignalingSettings() {
+ val userData =
+ Data.Builder()
+ .putLong(KEY_INTERNAL_USER_ID, internalAccountId)
+ .build()
+ val signalingSettings =
+ OneTimeWorkRequest.Builder(SignalingSettingsWorker::class.java)
+ .setInputData(userData)
+ .build()
+ WorkManager.getInstance().enqueue(signalingSettings)
+ }
+
+ private fun proceedWithLogin() {
+ cookieManager.cookieStore.removeAll()
+ userUtils.disableAllUsersWithoutId(internalAccountId)
+ if (activity != null) {
+ activity!!.runOnUiThread {
+ if (userUtils.users.size == 1) {
+ router.setRoot(
+ RouterTransaction.with(ConversationsListController(Bundle()))
+ .pushChangeHandler(HorizontalChangeHandler())
+ .popChangeHandler(HorizontalChangeHandler())
+ )
+ } else {
+ if (isAccountImport) {
+ ApplicationWideMessageHolder.getInstance().messageType =
+ ApplicationWideMessageHolder.MessageType.ACCOUNT_WAS_IMPORTED
+ }
+ router.popToRoot()
+ }
+ }
+ }
+ }
+
+ private fun dispose() {
+ for (i in disposables.indices) {
+ if (!disposables[i].isDisposed) {
+ disposables[i].dispose()
+ }
+ }
+ }
+
+ override fun onDestroyView(view: View) {
+ super.onDestroyView(view)
+ activity?.requestedOrientation = ActivityInfo.SCREEN_ORIENTATION_FULL_SENSOR
+ }
+
+ public override fun onDestroy() {
+ dispose()
+ super.onDestroy()
+ }
+
+ private fun abortVerification() {
+ if (!isAccountImport) {
+ if (internalAccountId != -1L) {
+ userUtils.deleteUserWithId(internalAccountId).subscribe(object : CompletableObserver {
+ override fun onSubscribe(d: Disposable) {}
+ override fun onComplete() {
+ activity?.runOnUiThread { Handler().postDelayed({ router.popToRoot() }, 7500) }
+ }
+
+ override fun onError(e: Throwable) {}
+ })
+ } else {
+ activity?.runOnUiThread { Handler().postDelayed({ router.popToRoot() }, 7500) }
+ }
+ } else {
+ ApplicationWideMessageHolder.getInstance().setMessageType(
+ ApplicationWideMessageHolder.MessageType.FAILED_TO_IMPORT_ACCOUNT
+ )
+ activity?.runOnUiThread {
+ Handler().postDelayed({
+ if (router.hasRootController()) {
+ if (activity != null) {
+ router.popToRoot()
+ }
+ } else {
+ if (userUtils.anyUserExists()) {
+ router.setRoot(
+ RouterTransaction.with(ConversationsListController(Bundle()))
+ .pushChangeHandler(HorizontalChangeHandler())
+ .popChangeHandler(HorizontalChangeHandler())
+ )
+ } else {
+ router.setRoot(
+ RouterTransaction.with(ServerSelectionController())
+ .pushChangeHandler(HorizontalChangeHandler())
+ .popChangeHandler(HorizontalChangeHandler())
+ )
+ }
+ }
+ }, 7500)
+ }
+ }
+ }
+
+ companion object {
+ const val TAG = "AccountVerificationController"
+ }
+
+ init {
+ sharedApplication!!.componentApplication.inject(this)
+ if (args != null) {
+ baseUrl = args.getString(KEY_BASE_URL)
+ username = args.getString(KEY_USERNAME)
+ token = args.getString(KEY_TOKEN)
+ if (args.containsKey(KEY_IS_ACCOUNT_IMPORT)) {
+ isAccountImport = true
+ }
+ if (args.containsKey(KEY_ORIGINAL_PROTOCOL)) {
+ originalProtocol = args.getString(KEY_ORIGINAL_PROTOCOL)
+ }
+ }
+ }
+}
\ No newline at end of file