Notifies relay failures after marking them as closed.

vitorpamplona · Aug 2, 2024 · fd06193 · fd06193
1 parent b02fa43
commit fd06193
Showing 1 changed file with 10 additions and 10 deletions.
diff --git a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/Relay.kt b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/Relay.kt
@@ -233,20 +233,20 @@ class Relay(
             // checks if this is an actual failure. Closing the socket generates an onFailure as well.
             if (!(socket == null && (t.message == "Socket is closed" || t.message == "Socket closed"))) {
                 RelayStats.newError(url, response?.message ?: t.message)
-
-                Log.w("Relay", "Relay onFailure $url, ${response?.message} $response ${t.message} $socket")
-                t.printStackTrace()
-                listeners.forEach {
-                    it.onError(
-                        this@Relay,
-                        "",
-                        Error("WebSocket Failure. Response: $response. Exception: ${t.message}", t),
-                    )
-                }
             }
 
             // Failures disconnect the relay.
             markConnectionAsClosed()
+
+            Log.w("Relay", "Relay onFailure $url, ${response?.message} $response ${t.message} $socket")
+            t.printStackTrace()
+            listeners.forEach {
+                it.onError(
+                    this@Relay,
+                    "",
+                    Error("WebSocket Failure. Response: $response. Exception: ${t.message}", t),
+                )
+            }
         }
     }