From 22800bdabb2b91c2600233c38ae2de0e59a9712a Mon Sep 17 00:00:00 2001
From: Kgothatso Ngako <kgothatso@machankura.com>
Date: Wed, 3 Jun 2026 01:37:15 +0200
Subject: [PATCH] Broadcast nostr DM

---
 .../compose/database/dao/NostrDao.kt          |  3 +-
 .../compose/database/dao/NostrNip17Dao.kt     | 49 +++++++++++++++----
 2 files changed, 41 insertions(+), 11 deletions(-)

diff --git a/composeApp/src/commonMain/kotlin/ac/cord/auxiliary/compose/database/dao/NostrDao.kt b/composeApp/src/commonMain/kotlin/ac/cord/auxiliary/compose/database/dao/NostrDao.kt
index e53e1959..39c433e4 100644
--- a/composeApp/src/commonMain/kotlin/ac/cord/auxiliary/compose/database/dao/NostrDao.kt
+++ b/composeApp/src/commonMain/kotlin/ac/cord/auxiliary/compose/database/dao/NostrDao.kt
@@ -24,6 +24,7 @@ import com.vitorpamplona.quartz.nip01Core.metadata.MetadataEvent
 import com.vitorpamplona.quartz.nip01Core.tags.events.taggedEvents
 import com.vitorpamplona.quartz.nip01Core.tags.people.taggedUsers
 import com.vitorpamplona.quartz.nip02FollowList.ContactListEvent
+import com.vitorpamplona.quartz.nip17Dm.settings.ChatMessageRelayListEvent
 import com.vitorpamplona.quartz.nip59Giftwrap.wraps.GiftWrapEvent
 import kotlin.time.Clock
 import kotlin.time.Instant
@@ -37,8 +38,8 @@ abstract class NostrDao(
     val profileEventKinds = arrayOf(
         MetadataEvent.KIND,
         ContactListEvent.KIND,
+        ChatMessageRelayListEvent.KIND,
 //        AdvertisedRelayListEvent.KIND,
-//        ChatMessageRelayListEvent.KIND,
 //        SearchRelayListEvent.KIND,
 //        IndexerRelayListEvent.KIND,
 //        ChannelListEvent.KIND,
diff --git a/composeApp/src/commonMain/kotlin/ac/cord/auxiliary/compose/database/dao/NostrNip17Dao.kt b/composeApp/src/commonMain/kotlin/ac/cord/auxiliary/compose/database/dao/NostrNip17Dao.kt
index 2b19b07c..c7819bcd 100644
--- a/composeApp/src/commonMain/kotlin/ac/cord/auxiliary/compose/database/dao/NostrNip17Dao.kt
+++ b/composeApp/src/commonMain/kotlin/ac/cord/auxiliary/compose/database/dao/NostrNip17Dao.kt
@@ -1,6 +1,7 @@
 package ac.cord.auxiliary.compose.database.dao
 
 import ac.cord.auxiliary.compose.database.AuxDatabase
+import ac.cord.auxiliary.compose.database.GENESIS_AT
 import ac.cord.auxiliary.compose.database.model.BroadcastNostrEventRequest
 import ac.cord.auxiliary.compose.database.model.ChatRoom
 import ac.cord.auxiliary.compose.database.model.GiftWrapMessage
@@ -17,6 +18,7 @@ import com.vitorpamplona.quartz.nip01Core.tags.people.PTag
 import com.vitorpamplona.quartz.nip17Dm.settings.ChatMessageRelayListEvent
 import com.vitorpamplona.quartz.nip59Giftwrap.seals.SealedRumorEvent
 import com.vitorpamplona.quartz.nip59Giftwrap.wraps.GiftWrapEvent
+import kotlin.math.log
 import kotlin.time.Instant
 
 
@@ -94,16 +96,43 @@ abstract class NostrNip17Dao(
         database.nostrEventDao().insert(nostrEvent)
 
         // TODO: Get ChatMessageRelayListEvent.KIND for receiverPublicKey.pubkey
-//        receiverPublicKey.relayHint?.url?.let { url ->
-//            database.broadcastNostrEventRequestDao().insert(
-//                listOf(
-//                    BroadcastNostrEventRequest(
-//                        nostrEventId = nostrEvent.id,
-//                        relayURL = url
-//                    )
-//                )
-//            )
-//        }
+        val chatMessageRelayListEvents = database.nostrEventDao().getAuthoredNostrEvents(
+            kinds = arrayOf(ChatMessageRelayListEvent.KIND),
+            authors = arrayOf(
+                receiverPublicKey.pubKey
+            ),
+            since = GENESIS_AT,
+            limit = 5
+        )
+        logger.d("Found messageRelayLists: $chatMessageRelayListEvents")
+
+        chatMessageRelayListEvents.firstOrNull()?.let { chatMessageRelayListNostrEvent ->
+            val chatMessageRelayListEvent = ChatMessageRelayListEvent(
+                id = chatMessageRelayListNostrEvent.id,
+                pubKey = chatMessageRelayListNostrEvent.pubKey,
+                tags = chatMessageRelayListNostrEvent.tags,
+                content = chatMessageRelayListNostrEvent.content,
+                sig = chatMessageRelayListNostrEvent.sig,
+                createdAt = chatMessageRelayListNostrEvent.createdAt.epochSeconds,
+            )
+
+            logger.d("Broadcast to ${chatMessageRelayListEvent.relays()}")
+
+            // TODO: Only broadcasting to the first 3 relays...
+            chatMessageRelayListEvent.relays().take(3).forEach { relayUrl ->
+                logger.d("Submit BroadcastNostrEventRequest to $relayUrl")
+                database.broadcastNostrEventRequestDao().insert(
+                    listOf(
+                        BroadcastNostrEventRequest(
+                            nostrEventId = nostrEvent.id,
+                            relayURL = relayUrl.url
+                        )
+                    )
+                )
+            }
+        }
+
+
 
 
         database.giftWrapMessageDao().upsert(