highperfocused/amethyst
1
0
Fork 0
mirror of https://github.com/vitorpamplona/amethyst.git synced 2025-09-27 20:26:33 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fixes wrong EOSE updates.

Browse Source
This commit is contained in:
Vitor Pamplona
2023-08-31 13:21:08 -04:00
parent 1af3bb7dfc
commit 0ccd41f5e8
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
app/src/main/java/com/vitorpamplona/amethyst/service/NostrDataSource.kt
View File

@@ -49,7 +49,7 @@ abstract class NostrDataSource(val debugName: String) {
// Log.e("ERROR", "Relay ${relay.url}: ${error.message}") // Log.e("ERROR", "Relay ${relay.url}: ${error.message}")
} }
override fun onRelayStateChange(type: Relay.Type, relay: Relay, channel: String?) { override fun onRelayStateChange(type: Relay.Type, relay: Relay, subscriptionId: String?) {
// Log.d("RELAY", "Relay ${relay.url} ${when (type) { // Log.d("RELAY", "Relay ${relay.url} ${when (type) {
// Relay.Type.CONNECT -> "connected." // Relay.Type.CONNECT -> "connected."
// Relay.Type.DISCONNECT -> "disconnected." // Relay.Type.DISCONNECT -> "disconnected."
@@ -57,9 +57,9 @@ abstract class NostrDataSource(val debugName: String) {
// Relay.Type.EOSE -> "sent all events it had stored." // Relay.Type.EOSE -> "sent all events it had stored."
// }}") // }}")
if (type == Relay.Type.EOSE && channel != null) { if (type == Relay.Type.EOSE && subscriptionId != null && subscriptionId in subscriptions.keys) {
// updates a per subscripton since date // updates a per subscripton since date
subscriptions[channel]?.updateEOSE(TimeUtils.now(), relay.url) subscriptions[subscriptionId]?.updateEOSE(TimeUtils.now(), relay.url)
} }
} }