diff --git a/app/src/main/java/com/vitorpamplona/amethyst/service/relays/Client.kt b/app/src/main/java/com/vitorpamplona/amethyst/service/relays/Client.kt index 3b4267df0..4fef51755 100644 --- a/app/src/main/java/com/vitorpamplona/amethyst/service/relays/Client.kt +++ b/app/src/main/java/com/vitorpamplona/amethyst/service/relays/Client.kt @@ -165,7 +165,7 @@ object Client : RelayPool.Listener { checkNotInMainThread() relayList.forEach { relayUrl -> - RelayPool.getOrCreateRelay(relayUrl, setOf(FeedType.PRIVATE_DMS), { }) { + RelayPool.getOrCreateRelay(relayUrl, emptySet(), { }) { it.sendOverride(signedEvent) } } diff --git a/app/src/main/java/com/vitorpamplona/amethyst/service/relays/RelayPool.kt b/app/src/main/java/com/vitorpamplona/amethyst/service/relays/RelayPool.kt index 59d4638f1..4f07771d0 100644 --- a/app/src/main/java/com/vitorpamplona/amethyst/service/relays/RelayPool.kt +++ b/app/src/main/java/com/vitorpamplona/amethyst/service/relays/RelayPool.kt @@ -91,6 +91,7 @@ object RelayPool : Relay.Listener { feedTypes: Set?, onConnected: (Relay) -> Unit, onDone: (() -> Unit)?, + timeout: Long = 60000, ) { val relay = Relay(url, true, true, feedTypes ?: emptySet()) addRelay(relay) @@ -103,7 +104,7 @@ object RelayPool : Relay.Listener { onConnected(relay) GlobalScope.launch(Dispatchers.IO) { - delay(60000) // waits for a reply + delay(timeout) // waits for a reply relay.disconnect() removeRelay(relay)