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

Marking relays with failure as not connected

Browse Source
This commit is contained in:
Vitor Pamplona
2023-01-19 17:54:07 -05:00
parent dd35e01f8a
commit 625bbaf35c
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
app/src/main/java/com/vitorpamplona/amethyst/service/relays/Relay.kt
View File

@@ -30,6 +30,7 @@ class Relay(
} }
fun requestAndWatch() { fun requestAndWatch() {
println("Connecting with ${url}")
val request = Request.Builder().url(url).build() val request = Request.Builder().url(url).build()
val listener = object : WebSocketListener() { val listener = object : WebSocketListener() {
@@ -87,6 +88,9 @@ class Relay(
} }
override fun onFailure(webSocket: WebSocket, t: Throwable, response: Response?) { override fun onFailure(webSocket: WebSocket, t: Throwable, response: Response?) {
// Failures disconnect the relay.
socket = null
//println("Relay onFailure ${url}, ${response?.message}")
t.printStackTrace() t.printStackTrace()
listeners.forEach { listeners.forEach {
it.onError(this@Relay, "", Error("WebSocket Failure. Response: ${response}. Exception: ${t.message}", t)) it.onError(this@Relay, "", Error("WebSocket Failure. Response: ${response}. Exception: ${t.message}", t))
@@ -99,6 +103,7 @@ class Relay(
fun disconnect() { fun disconnect() {
//httpClient.dispatcher.executorService.shutdown() //httpClient.dispatcher.executorService.shutdown()
socket?.close(1000, "Normal close") socket?.close(1000, "Normal close")
socket = null
} }
fun sendFilter(requestId: String) { fun sendFilter(requestId: String) {