Skip to content

Commit 8e3b493

Browse files
committed
Attempt to fix session not found errors when node reconnects
1 parent e78c5bc commit 8e3b493

File tree

2 files changed

+8
-8
lines changed

2 files changed

+8
-8
lines changed

src/main/kotlin/dev/arbjerg/lavalink/internal/LavalinkSocket.kt

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -41,13 +41,6 @@ class LavalinkSocket(private val node: LavalinkNode) : WebSocketListener(), Clos
4141
node.available = true
4242
open = true
4343
reconnectsAttempted = 0
44-
45-
node.playerCache.values.forEach { player ->
46-
// Re-create the player on the node.
47-
player.stateToBuilder()
48-
.setNoReplace(false)
49-
.subscribe()
50-
}
5144
}
5245

5346
override fun onMessage(webSocket: WebSocket, text: String) {
@@ -60,6 +53,13 @@ class LavalinkSocket(private val node: LavalinkNode) : WebSocketListener(), Clos
6053
val sessionId = (event as Message.ReadyEvent).sessionId
6154
node.sessionId = sessionId
6255
logger.info("${node.name} is ready with session id $sessionId")
56+
57+
node.playerCache.values.forEach { player ->
58+
// Re-create the player on the node.
59+
player.stateToBuilder()
60+
.setNoReplace(false)
61+
.subscribe()
62+
}
6363
}
6464

6565
Message.Op.Stats -> {

testbot/src/main/java/me/duncte123/testbot/Main.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ private static void registerLavalinkNodes(LavalinkClient client) {
4343
URI.create("ws://localhost:2333"),
4444
"youshallnotpass",
4545
RegionGroup.EUROPE
46-
),*/
46+
)*/
4747

4848
client.addNode(
4949
"Pi-local",

0 commit comments

Comments
 (0)