From 625bbaf35caacde2645375f299db60d89930286b Mon Sep 17 00:00:00 2001
From: Vitor Pamplona <vitor@vitorpamplona.com>
Date: Thu, 19 Jan 2023 17:54:07 -0500
Subject: [PATCH] Marking relays with failure as not connected

---
 .../java/com/vitorpamplona/amethyst/service/relays/Relay.kt  | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/app/src/main/java/com/vitorpamplona/amethyst/service/relays/Relay.kt b/app/src/main/java/com/vitorpamplona/amethyst/service/relays/Relay.kt
index 93684bd58..d93b45391 100644
--- a/app/src/main/java/com/vitorpamplona/amethyst/service/relays/Relay.kt
+++ b/app/src/main/java/com/vitorpamplona/amethyst/service/relays/Relay.kt
@@ -30,6 +30,7 @@ class Relay(
     }
 
     fun requestAndWatch() {
+        println("Connecting with ${url}")
         val request = Request.Builder().url(url).build()
         val listener = object : WebSocketListener() {
 
@@ -87,6 +88,9 @@ class Relay(
             }
 
             override fun onFailure(webSocket: WebSocket, t: Throwable, response: Response?) {
+                // Failures disconnect the relay. 
+                socket = null
+                //println("Relay onFailure ${url}, ${response?.message}")
                 t.printStackTrace()
                 listeners.forEach {
                     it.onError(this@Relay, "", Error("WebSocket Failure. Response: ${response}. Exception: ${t.message}", t))
@@ -99,6 +103,7 @@ class Relay(
     fun disconnect() {
         //httpClient.dispatcher.executorService.shutdown()
         socket?.close(1000, "Normal close")
+        socket = null
     }
 
     fun sendFilter(requestId: String) {