Add Endpoint to extend automatic server shutdown timer

Author: JulianVennen

CHANGELOG.md

@@ -1,2 +1,2 @@
-## Build System
-- Migrate to new Maven Central publishing system.
+## New Features
+- Add Endpoint to extend automatic server shutdown timer

src/main/java/com/exaroton/api/request/server/ExtendServerStopTimeRequest.java

@@ -0,0 +1,46 @@
+package com.exaroton.api.request.server;
+
+import com.exaroton.api.APIResponse;
+import com.exaroton.api.ExarotonClient;
+import com.google.gson.Gson;
+import com.google.gson.reflect.TypeToken;
+import org.jetbrains.annotations.NotNull;
+
+import java.net.http.HttpRequest;
+import java.util.HashMap;
+
+public class ExtendServerStopTimeRequest extends ServerRequest<Void> {
+    private final int time;
+
+    public ExtendServerStopTimeRequest(
+            @NotNull ExarotonClient client,
+            @NotNull Gson gson,
+            @NotNull String serverId,
+            int time
+    ) {
+        super(client, gson, serverId);
+        this.time = time;
+    }
+
+    @Override
+    protected String getEndpoint() {
+        return "servers/{id}/extend-time";
+    }
+
+    @Override
+    protected String getMethod() {
+        return "POST";
+    }
+
+    @Override
+    protected TypeToken<APIResponse<Void>> getType() {
+        return new TypeToken<APIResponse<Void>>() {};
+    }
+
+    @Override
+    protected HttpRequest.BodyPublisher getBodyPublisher(Gson gson, HttpRequest.Builder builder) {
+        HashMap<String, Integer> body = new HashMap<>();
+        body.put("time", this.time);
+        return this.jsonBodyPublisher(gson, builder, body);
+    }
+}

src/main/java/com/exaroton/api/server/Server.java

@@ -427,6 +427,16 @@ public CompletableFuture<Void> executeCommand(@NotNull String command) throws IO
         return client.request(new ExecuteCommandRequest(this.client, this.gson, this.id, command));
     }
 
+    /**
+     * Extend the server stop time by the given amount of minutes. This only works if the server is currently stopping.
+     * @param time time in minutes to extend the stop time by
+     * @return completable future that completes once the request has been sent
+     * @throws IOException connection errors
+     */
+    public CompletableFuture<Void> extendStopTime(int time) throws IOException {
+        return client.request(new ExtendServerStopTimeRequest(this.client, this.gson, this.id, time));
+    }
+
     /**
      * Get a list of available player lists
      *

src/test/java/WebSocketTest.java

@@ -47,6 +47,7 @@ void testStartServer() throws IOException, ExecutionException, InterruptedExcept
         assertEquals(server.getPort().get(), server.getSocketAddress().get().getPort());
         assertEquals(server.getHost().get(), server.getSocketAddress().get().getHostString());
 
+        testExtendStopTime();
         testHeapSubscriber();
         testStatsSubscriber();
         testTickSubscriber();
@@ -57,6 +58,10 @@ void testStartServer() throws IOException, ExecutionException, InterruptedExcept
         assertTrue(server.getWebSocket().isEmpty(), "Expected websocket to be closed");
     }
 
+    void testExtendStopTime() throws IOException {
+        server.extendStopTime(5).join();
+    }
+
     void testHeapSubscriber() throws ExecutionException, InterruptedException, TimeoutException {
         CompletableFuture<HeapUsage> heapFuture = new CompletableFuture<>();
         HeapSubscriber heapSubscriber = heapFuture::complete;