From e3a2000e29153e1897140ae5aa88ad9d9085bc21 Mon Sep 17 00:00:00 2001
From: Maxime NATUREL <46314705+mnaturel@users.noreply.github.com>
Date: Wed, 18 Jan 2023 15:03:51 +0100
Subject: [PATCH] Calling syncPolls of SDK service

---
 .../session/room/poll/DefaultPollHistoryService.kt    | 11 ++++-------
 .../roomprofile/polls/list/data/RoomPollDataSource.kt |  6 +-----
 2 files changed, 5 insertions(+), 12 deletions(-)

diff --git a/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/room/poll/DefaultPollHistoryService.kt b/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/room/poll/DefaultPollHistoryService.kt
index c4ba89f4a6..e01d91d1be 100644
--- a/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/room/poll/DefaultPollHistoryService.kt
+++ b/matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/session/room/poll/DefaultPollHistoryService.kt
@@ -20,11 +20,11 @@ import androidx.lifecycle.LiveData
 import dagger.assisted.Assisted
 import dagger.assisted.AssistedFactory
 import dagger.assisted.AssistedInject
+import kotlinx.coroutines.delay
 import org.matrix.android.sdk.api.session.room.model.PollResponseAggregatedSummary
 import org.matrix.android.sdk.api.session.room.poll.LoadedPollsStatus
 import org.matrix.android.sdk.api.session.room.poll.PollHistoryService
 import org.matrix.android.sdk.internal.util.time.Clock
-import timber.log.Timber
 
 private const val LOADING_PERIOD_IN_DAYS = 30
 private const val EVENTS_PAGE_SIZE = 250
@@ -42,10 +42,6 @@ internal class DefaultPollHistoryService @AssistedInject constructor(
         fun create(roomId: String): DefaultPollHistoryService
     }
 
-    init {
-        Timber.d("init with roomId: $roomId")
-    }
-
     override val loadingPeriodInDays: Int
         get() = LOADING_PERIOD_IN_DAYS
 
@@ -68,10 +64,11 @@ internal class DefaultPollHistoryService @AssistedInject constructor(
     }
 
     override suspend fun syncPolls() {
-        TODO("Not yet implemented")
+        // TODO unmock
+        delay(1000)
     }
 
     override fun getPolls(): LiveData<List<PollResponseAggregatedSummary>> {
-        TODO("Not yet implemented")
+        TODO("listen database and update query depending on latest PollHistoryStatusEntity.oldestTimestampReachedMs")
     }
 }
diff --git a/vector/src/main/java/im/vector/app/features/roomprofile/polls/list/data/RoomPollDataSource.kt b/vector/src/main/java/im/vector/app/features/roomprofile/polls/list/data/RoomPollDataSource.kt
index f22f494f49..ee3b477685 100644
--- a/vector/src/main/java/im/vector/app/features/roomprofile/polls/list/data/RoomPollDataSource.kt
+++ b/vector/src/main/java/im/vector/app/features/roomprofile/polls/list/data/RoomPollDataSource.kt
@@ -18,7 +18,6 @@ package im.vector.app.features.roomprofile.polls.list.data
 
 import im.vector.app.core.di.ActiveSessionHolder
 import im.vector.app.features.roomprofile.polls.list.ui.PollSummary
-import kotlinx.coroutines.delay
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.MutableSharedFlow
 import kotlinx.coroutines.flow.asSharedFlow
@@ -60,9 +59,6 @@ class RoomPollDataSource @Inject constructor(
     }
 
     suspend fun syncPolls(roomId: String) {
-        Timber.d("roomId=$roomId")
-        // TODO unmock using SDK service
-        // fake sync
-        delay(1000)
+        getPollHistoryService(roomId).syncPolls()
     }
 }