From 5a62e31c86ac55256d7915606b11d25cf830e12f Mon Sep 17 00:00:00 2001
From: Benoit Marty <benoit@matrix.org>
Date: Fri, 27 Jan 2023 16:44:35 +0100
Subject: [PATCH] Ensure sync thread is started when recovering from crash.

---
 .../session/EnsureSessionSyncingUseCase.kt    | 38 +++++++++++++++++++
 .../features/home/HomeActivityViewModel.kt    |  4 ++
 2 files changed, 42 insertions(+)
 create mode 100644 vector/src/main/java/im/vector/app/core/session/EnsureSessionSyncingUseCase.kt

diff --git a/vector/src/main/java/im/vector/app/core/session/EnsureSessionSyncingUseCase.kt b/vector/src/main/java/im/vector/app/core/session/EnsureSessionSyncingUseCase.kt
new file mode 100644
index 0000000000..c53795d18d
--- /dev/null
+++ b/vector/src/main/java/im/vector/app/core/session/EnsureSessionSyncingUseCase.kt
@@ -0,0 +1,38 @@
+/*
+ * Copyright (c) 2022 New Vector Ltd
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package im.vector.app.core.session
+
+import android.content.Context
+import dagger.hilt.android.qualifiers.ApplicationContext
+import im.vector.app.core.di.ActiveSessionHolder
+import im.vector.app.core.extensions.startSyncing
+import org.matrix.android.sdk.api.session.sync.SyncState
+import timber.log.Timber
+import javax.inject.Inject
+
+class EnsureSessionSyncingUseCase @Inject constructor(
+        @ApplicationContext private val context: Context,
+        private val activeSessionHolder: ActiveSessionHolder,
+) {
+    fun execute() {
+        val session = activeSessionHolder.getSafeActiveSession() ?: return
+        if (session.syncService().getSyncState() == SyncState.Idle) {
+            Timber.w("EnsureSessionSyncingUseCase: start syncing")
+            session.startSyncing(context)
+        }
+    }
+}
diff --git a/vector/src/main/java/im/vector/app/features/home/HomeActivityViewModel.kt b/vector/src/main/java/im/vector/app/features/home/HomeActivityViewModel.kt
index 8f16121a30..f961cc5da6 100644
--- a/vector/src/main/java/im/vector/app/features/home/HomeActivityViewModel.kt
+++ b/vector/src/main/java/im/vector/app/features/home/HomeActivityViewModel.kt
@@ -30,6 +30,7 @@ import im.vector.app.core.pushers.EnsureFcmTokenIsRetrievedUseCase
 import im.vector.app.core.pushers.PushersManager
 import im.vector.app.core.pushers.RegisterUnifiedPushUseCase
 import im.vector.app.core.pushers.UnregisterUnifiedPushUseCase
+import im.vector.app.core.session.EnsureSessionSyncingUseCase
 import im.vector.app.features.analytics.AnalyticsConfig
 import im.vector.app.features.analytics.AnalyticsTracker
 import im.vector.app.features.analytics.extensions.toAnalyticsType
@@ -95,6 +96,7 @@ class HomeActivityViewModel @AssistedInject constructor(
         private val registerUnifiedPushUseCase: RegisterUnifiedPushUseCase,
         private val unregisterUnifiedPushUseCase: UnregisterUnifiedPushUseCase,
         private val ensureFcmTokenIsRetrievedUseCase: EnsureFcmTokenIsRetrievedUseCase,
+        private val ensureSessionSyncingUseCase: EnsureSessionSyncingUseCase,
 ) : VectorViewModel<HomeActivityViewState, HomeActivityViewActions, HomeActivityViewEvents>(initialState) {
 
     @AssistedFactory
@@ -118,6 +120,8 @@ class HomeActivityViewModel @AssistedInject constructor(
     private fun initialize() {
         if (isInitialized) return
         isInitialized = true
+        // Ensure Session is syncing
+        ensureSessionSyncingUseCase.execute()
         registerUnifiedPushIfNeeded()
         cleanupFiles()
         observeInitialSync()