From 8e3b49333cfada7c8ab0d96b78e32fea23165ac5 Mon Sep 17 00:00:00 2001 From: duncte123 Date: Thu, 8 Feb 2024 09:05:21 +0100 Subject: [PATCH] Attempt to fix session not found errors when node reconnects --- .../arbjerg/lavalink/internal/LavalinkSocket.kt | 14 +++++++------- .../src/main/java/me/duncte123/testbot/Main.java | 2 +- 2 files changed, 8 insertions(+), 8 deletions(-) diff --git a/src/main/kotlin/dev/arbjerg/lavalink/internal/LavalinkSocket.kt b/src/main/kotlin/dev/arbjerg/lavalink/internal/LavalinkSocket.kt index d12a0c5..3836367 100644 --- a/src/main/kotlin/dev/arbjerg/lavalink/internal/LavalinkSocket.kt +++ b/src/main/kotlin/dev/arbjerg/lavalink/internal/LavalinkSocket.kt @@ -41,13 +41,6 @@ class LavalinkSocket(private val node: LavalinkNode) : WebSocketListener(), Clos node.available = true open = true reconnectsAttempted = 0 - - node.playerCache.values.forEach { player -> - // Re-create the player on the node. - player.stateToBuilder() - .setNoReplace(false) - .subscribe() - } } override fun onMessage(webSocket: WebSocket, text: String) { @@ -60,6 +53,13 @@ class LavalinkSocket(private val node: LavalinkNode) : WebSocketListener(), Clos val sessionId = (event as Message.ReadyEvent).sessionId node.sessionId = sessionId logger.info("${node.name} is ready with session id $sessionId") + + node.playerCache.values.forEach { player -> + // Re-create the player on the node. + player.stateToBuilder() + .setNoReplace(false) + .subscribe() + } } Message.Op.Stats -> { diff --git a/testbot/src/main/java/me/duncte123/testbot/Main.java b/testbot/src/main/java/me/duncte123/testbot/Main.java index 32536a1..6b49c54 100644 --- a/testbot/src/main/java/me/duncte123/testbot/Main.java +++ b/testbot/src/main/java/me/duncte123/testbot/Main.java @@ -43,7 +43,7 @@ private static void registerLavalinkNodes(LavalinkClient client) { URI.create("ws://localhost:2333"), "youshallnotpass", RegionGroup.EUROPE - ),*/ + )*/ client.addNode( "Pi-local",