From 7443dec65c18438df45cc315597cc26ea6f84347 Mon Sep 17 00:00:00 2001 From: Kgothatso Ngako Date: Mon, 20 Apr 2026 01:21:48 +0200 Subject: [PATCH] Only look for synchronization request from when the app is opened --- .../compose/database/dao/SynchronizeNostrEventRequestDao.kt | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/composeApp/src/commonMain/kotlin/ac/aux/compose/database/dao/SynchronizeNostrEventRequestDao.kt b/composeApp/src/commonMain/kotlin/ac/aux/compose/database/dao/SynchronizeNostrEventRequestDao.kt index a2ac0b50..70bb1cc7 100644 --- a/composeApp/src/commonMain/kotlin/ac/aux/compose/database/dao/SynchronizeNostrEventRequestDao.kt +++ b/composeApp/src/commonMain/kotlin/ac/aux/compose/database/dao/SynchronizeNostrEventRequestDao.kt @@ -6,11 +6,13 @@ import androidx.room.Insert import androidx.room.Query import androidx.room.Upsert import kotlinx.coroutines.flow.Flow +import kotlin.time.Clock +import kotlin.time.Instant @Dao interface SynchronizeNostrEventRequestDao { - @Query("SELECT * FROM SynchronizeNostrEventRequest WHERE status = :status") - fun observeSynchronizeNostrEventRequestsByStatus(status: String): Flow + @Query("SELECT * FROM SynchronizeNostrEventRequest WHERE status = :status AND createdAt > :createdAt") + fun observeSynchronizeNostrEventRequestsByStatus(status: String, createdAt: Instant = Clock.System.now()): Flow @Query("SELECT COUNT(*) FROM SynchronizeNostrEventRequest WHERE purpose = :purpose AND status IN (:status)") fun observeSynchronizeNostrEventRequestByPurposeAndStatusCount(purpose: String, status: List): Flow