From 0c7019204cae26c4057e5836a19a3c88b45ac0ef Mon Sep 17 00:00:00 2001 From: Kgothatso Ngako Date: Mon, 4 May 2026 22:47:03 +0200 Subject: [PATCH] Don't broadcast what we have already broadcasted --- .../ui/view/model/NavigationViewModel.kt | 46 +++++++++---------- 1 file changed, 23 insertions(+), 23 deletions(-) diff --git a/composeApp/src/commonMain/kotlin/ac/cord/auxiliary/compose/ui/view/model/NavigationViewModel.kt b/composeApp/src/commonMain/kotlin/ac/cord/auxiliary/compose/ui/view/model/NavigationViewModel.kt index 2b84d060..4e50faeb 100644 --- a/composeApp/src/commonMain/kotlin/ac/cord/auxiliary/compose/ui/view/model/NavigationViewModel.kt +++ b/composeApp/src/commonMain/kotlin/ac/cord/auxiliary/compose/ui/view/model/NavigationViewModel.kt @@ -398,29 +398,29 @@ class NavigationViewModel( localBroadcastNostrEventRequest.broadcastNostrEventRequest ) -// if (localBroadcastNostrEventRequest.nostrEvent.broadcastedAt == null) { -// scope.launch(Dispatchers.IO) { -// relaysSocketManager.publishEvent( -// localBroadcastNostrEventRequest.nostrEvent -// ).timeout(PUBLISH_TIMEOUT.milliseconds).catch { -// // Timeout... -// }.collect { nostrPublishResult -> -// if (nostrPublishResult.error != null) { -// logger.e("Error publishing note: $nostrPublishResult") -// nostrRepository.broadcastProcessed( -// localBroadcastNostrEventRequest.broadcastNostrEventRequest, -// "failed" -// ) -// } else { -// logger.d("Nostr Publish Result: $nostrPublishResult") -// nostrRepository.broadcastProcessed( -// localBroadcastNostrEventRequest.broadcastNostrEventRequest, -// "published" -// ) -// } -// } -// } -// } + if (localBroadcastNostrEventRequest.nostrEvent.broadcastedAt == null) { + scope.launch(Dispatchers.IO) { + relaysSocketManager.publishEvent( + localBroadcastNostrEventRequest.nostrEvent + ).timeout(PUBLISH_TIMEOUT.milliseconds).catch { + // Timeout... + }.collect { nostrPublishResult -> + if (nostrPublishResult.error != null) { + logger.e("Error publishing note: $nostrPublishResult") + nostrRepository.broadcastProcessed( + localBroadcastNostrEventRequest.broadcastNostrEventRequest, + "failed" + ) + } else { + logger.d("Nostr Publish Result: $nostrPublishResult") + nostrRepository.broadcastProcessed( + localBroadcastNostrEventRequest.broadcastNostrEventRequest, + "published" + ) + } + } + } + } scope.launch(Dispatchers.IO) { // Broadcast to the intended relay...