Relay management fix

KoalaSat · Nov 2, 2024 · cdba8b8 · cdba8b8
1 parent 7a75eaf
commit cdba8b8
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/app/src/main/java/com/koalasat/pokey/database/ApplicationDao.kt b/app/src/main/java/com/koalasat/pokey/database/ApplicationDao.kt
@@ -22,6 +22,9 @@ interface ApplicationDao {
     @Insert(onConflict = OnConflictStrategy.REPLACE)
     fun insertRelay(notificationEntity: RelayEntity): Long?
 
+    @Query("SELECT * FROM relay where kind = :kind")
+    fun getRelaysByKind(kind: Int): List<RelayEntity>
+
     @Query("DELETE FROM relay where kind = :kind")
     fun deleteRelaysByKind(kind: Int): Int
 

diff --git a/app/src/main/java/com/koalasat/pokey/service/NotificationsService.kt b/app/src/main/java/com/koalasat/pokey/service/NotificationsService.kt
@@ -127,6 +127,7 @@ class NotificationsService : Service() {
                     scope.launch(Dispatchers.IO) {
                         stopSubscription()
                         delay(1000)
+                        connectRelays()
                         startSubscription()
                     }
                 }
@@ -149,6 +150,7 @@ class NotificationsService : Service() {
                     if (Connectivity.updateNetworkCapabilities(networkCapabilities)) {
                         stopSubscription()
                         delay(1000)
+                        connectRelays()
                         startSubscription()
                     }
                 }
@@ -261,6 +263,7 @@ class NotificationsService : Service() {
 
     private fun stopSubscription() {
         Client.unsubscribe(clientListener)
+        RelayPool.unloadRelays()
     }
 
     private fun keepAlive() {
@@ -313,9 +316,8 @@ class NotificationsService : Service() {
             val lastCreatedRelayAt = dao.getLatestRelaysByKind(event.kind)
 
             if (lastCreatedRelayAt == null || lastCreatedRelayAt < event.createdAt) {
-                stopSubscription()
+                RelayPool.unloadRelays()
                 dao.deleteRelaysByKind(event.kind)
-
                 event.tags
                     .filter { it.size > 1 && (it[0] == "relay" || it[0] == "r") }
                     .forEach {
@@ -329,6 +331,7 @@ class NotificationsService : Service() {
                         dao.insertRelay(entity)
                     }
 
+                connectRelays()
                 startSubscription()
             }
         }