Add enableResuming() and disableResuming() methods

Author: freyacodes

src/main/kotlin/dev/arbjerg/lavalink/client/LavalinkNode.kt

@@ -25,6 +25,7 @@ import reactor.core.publisher.Sinks.Many
 import reactor.kotlin.core.publisher.toMono
 import java.io.Closeable
 import java.io.IOException
+import java.time.Duration
 import java.util.concurrent.ConcurrentHashMap
 import java.util.concurrent.TimeUnit
 import java.util.function.Consumer
@@ -234,6 +235,22 @@ class LavalinkNode(
         return rest.getNodeInfo()
     }
 
+    /**
+     * Enables resuming. This causes Lavalink to continue playing for a certain duration of time, during which
+     *  we can reconnect without losing our session data. */
+    fun enableResuming(timeout: Duration): Mono<Session> {
+        return rest.patchSession(Session(resuming = true, timeout.seconds))
+    }
+
+    /**
+     * Disables resuming, causing Lavalink to immediately drop all players upon this client disconnecting from it.
+     *
+     * This is the default behavior, reversing calls to [enableResuming].
+     */
+    fun disableResuming(): Mono<Session> {
+        return rest.patchSession(Session(resuming = false, timeoutSeconds = 0))
+    }
+
     /**
      * Send a custom request to the lavalink node. Any host and port you set will be replaced with the node host automatically.
      * The scheme must match your node's scheme, however.

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

@@ -69,6 +69,13 @@ class LavalinkRestClient(val node: LavalinkNode) {
         }.toMono()
     }
 
+    fun patchSession(session: Session): Mono<Session> {
+        return newRequest {
+            path("/v4/sessions/${node.sessionId}")
+            patch(json.encodeToString(session).toRequestBody("application/json".toMediaType()))
+        }.toMono()
+    }
+
     /**
      * Make a request to the lavalink node. This is internal to keep it looking nice in kotlin. Java compatibility is in the node class.
      */