Handle reconnect even on abnormal closure

freyacodes · freyacodes · commit bb8c7c4fd850 · 2025-02-18T15:15:34.000+01:00
diff --git a/src/main/kotlin/dev/arbjerg/lavalink/internal/LavalinkSocket.kt b/src/main/kotlin/dev/arbjerg/lavalink/internal/LavalinkSocket.kt
@@ -150,9 +150,6 @@ class LavalinkSocket(private val node: LavalinkNode) : WebSocketListener(), Clos
         if (mayReconnect) {
             logger.info("${node.name} disconnected, reconnecting in ${reconnectInterval / 1000} seconds")
         }
-
-        node.available = false
-        open = false
     }
 
     override fun onFailure(webSocket: WebSocket, t: Throwable, response: Response?) {
@@ -200,6 +197,7 @@ class LavalinkSocket(private val node: LavalinkNode) : WebSocketListener(), Clos
 
     override fun onClosing(webSocket: WebSocket, code: Int, reason: String) {
         node.available = false
+        open = false
         node.lavalink.onNodeDisconnected(node)
 
         if (code == 1000) {

Original file line number	Diff line number	Diff line change
`@@ -150,9 +150,6 @@ class LavalinkSocket(private val node: LavalinkNode) : WebSocketListener(), Clos`
`150`	`150`	`if (mayReconnect) {`
`151`	`151`	`logger.info("${node.name} disconnected, reconnecting in ${reconnectInterval / 1000} seconds")`
`152`	`152`	`}`
`153`		`-`
`154`		`- node.available = false`
`155`		`- open = false`
`156`	`153`	`}`
`157`	`154`
`158`	`155`	`override fun onFailure(webSocket: WebSocket, t: Throwable, response: Response?) {`
`@@ -200,6 +197,7 @@ class LavalinkSocket(private val node: LavalinkNode) : WebSocketListener(), Clos`
`200`	`197`
`201`	`198`	`override fun onClosing(webSocket: WebSocket, code: Int, reason: String) {`
`202`	`199`	`node.available = false`
	`200`	`+ open = false`
`203`	`201`	`node.lavalink.onNodeDisconnected(node)`
`204`	`202`
`205`	`203`	`if (code == 1000) {`