feat: Add Reboot action to server

Author: CubitsDev

src/main/java/dev/tomr/hcloud/listener/ServerChangeListener.java

@@ -39,6 +39,9 @@ public void propertyChange(PropertyChangeEvent evt) {
                 logger.info("Server power on has been called. Instructing Hetzner to power up the server");
                 HetznerCloud.getInstance().getServiceManager().getServerService().powerOnServer(server);
             }
+            case "reboot" -> {
+                logger.info("Server reboot has been called. Instructing Hetzner to reboot the server");
+            }
             default -> {
                 logger.info("Server changed: {}", evt.getPropertyName());
                 logger.info("Server: {} -> {}", evt.getOldValue(), evt.getNewValue());

src/main/java/dev/tomr/hcloud/resources/server/Server.java

@@ -107,7 +107,8 @@ public void delete() {
     }
 
     /**
-     * Sends a Shutdown signal to the server, which will instruct the OS to shut it down. Note that if you <b>must</b>> ensure the server is completely offline, you should also call .powerOff() to ensure the 'plug is pulled'
+     * Sends a Shutdown request to the server by sending an ACPI request, which will instruct the OS to shut it down. Note that if you <b>must</b>> ensure the server is completely offline, you should also call .powerOff() to ensure the 'plug is pulled'.
+     * The server OS must support ACPI
      */
     public void shutdown() {
         propertyChangeSupport.firePropertyChange("shutdown", null, null);
@@ -121,12 +122,18 @@ public void powerOff() {
     }
 
     /**
-     * Starts the Server by turning it's power on
+     * Starts the Server by turning its power on
      */
     public void powerOn() {
         propertyChangeSupport.firePropertyChange("poweron", null, null);
     }
 
+    /**
+     * Sends a reboot request to the server by sending an ACPI request. The server OS must support ACPI
+     */
+    public void reboot() {
+        propertyChangeSupport.firePropertyChange("reboot", null, null);
+    }
 
     // These are the current setters that will send an API request (PUT /servers) when actions begin to be added, they will also likely be triggered by setters
 

src/main/java/dev/tomr/hcloud/service/action/Action.java

@@ -3,7 +3,8 @@
 public enum Action {
     SHUTDOWN("shutdown"),
     POWEROFF("poweroff"),
-    POWERON("poweron");
+    POWERON("poweron"),
+    REBOOT("reboot");
 
     public final String path;
 

src/main/java/dev/tomr/hcloud/service/server/ServerService.java

@@ -139,6 +139,10 @@ public void powerOnServer(Server server) {
         sendServerAction(server, POWERON);
     }
 
+    public void rebootServer(Server server) {
+        sendServerAction(server, REBOOT);
+    }
+
     private void sendServerAction(Server server, dev.tomr.hcloud.service.action.Action givenAction) {
         List<String> hostAndKey = HetznerCloud.getInstance().getHttpDetails();
         String httpUrl = String.format("%sservers/%d/actions/%s", hostAndKey.get(0), server.getId(), givenAction.path);

src/test/java/dev/tomr/hcloud/resources/server/ServerTest.java

@@ -193,7 +193,6 @@ void callingSetNameSendsAnEventToTheServerChangeListener() {
             assertNull(captor.getValue().getOldValue());
             assertEquals("test", captor.getValue().getNewValue());
         }
-
     }
 
     @Test
@@ -219,7 +218,6 @@ void callingDeleteSendsAnEventToTheServerChangeListener() {
             verify(serverChangeListener, times(1)).propertyChange(captor.capture());
             assertEquals("delete", captor.getValue().getPropertyName());
         }
-
     }
 
     @Test
@@ -245,7 +243,6 @@ void callingShutdownSendsAnEventToTheServerChangeListener() {
             verify(serverChangeListener, times(1)).propertyChange(captor.capture());
             assertEquals("shutdown", captor.getValue().getPropertyName());
         }
-
     }
 
     @Test
@@ -271,7 +268,6 @@ void callingPoweroffSendsAnEventToTheServerChangeListener() {
             verify(serverChangeListener, times(1)).propertyChange(captor.capture());
             assertEquals("poweroff", captor.getValue().getPropertyName());
         }
-
     }
 
     @Test
@@ -297,6 +293,30 @@ void callingPowerOnSendsAnEventToTheServerChangeListener() {
             verify(serverChangeListener, times(1)).propertyChange(captor.capture());
             assertEquals("poweron", captor.getValue().getPropertyName());
         }
+    }
+    @Test
+    @DisplayName("calling reboot sends an event to the ServerChangeListener")
+    void callingRebootSendsAnEventToTheServerChangeListener() {
+        try (MockedStatic<HetznerCloud> hetznerCloud = mockStatic(HetznerCloud.class)) {
+            HetznerCloud hetznerCloudMock = mock(HetznerCloud.class);
+            ServerChangeListener scl = new ServerChangeListener();
+            ServerChangeListener serverChangeListener = spy(scl);
+            ListenerManager listenerManager = mock(ListenerManager.class);
+            ServiceManager serviceManager = mock(ServiceManager.class);
+            ServerService serverService = mock(ServerService.class);
+            ArgumentCaptor<PropertyChangeEvent> captor = ArgumentCaptor.forClass(PropertyChangeEvent.class);
+
+            hetznerCloud.when(HetznerCloud::getInstance).thenReturn(hetznerCloudMock);
+            when(hetznerCloudMock.getListenerManager()).thenReturn(listenerManager);
+            when(hetznerCloudMock.getServiceManager()).thenReturn(serviceManager);
+            when(listenerManager.getServerChangeListener()).thenReturn(serverChangeListener);
+            when(serviceManager.getServerService()).thenReturn(serverService);
 
+            Server server = new Server();
+            server.reboot();
+            verify(serverChangeListener, times(1)).propertyChange(captor.capture());
+            assertEquals("reboot", captor.getValue().getPropertyName());
+        }
     }
+
 }

src/test/java/dev/tomr/hcloud/service/action/ActionEnumTest.java

@@ -18,4 +18,16 @@ void shutdown() {
     void poweroff() {
         assertEquals("poweroff", Action.POWEROFF.path);
     }
+
+    @Test
+    @DisplayName("POWERON enum returns 'poweron' for the path")
+    void poweron() {
+        assertEquals("poweron", Action.POWERON.path);
+    }
+
+    @Test
+    @DisplayName("REBOOT enum returns 'reboot' for the path")
+    void reboot() {
+        assertEquals("reboot", Action.REBOOT.path);
+    }
 }

src/test/java/dev/tomr/hcloud/service/server/ServerServiceTest.java

@@ -821,4 +821,36 @@ void powerOnServerCallsHetznerAndTracksTheAction() throws IOException, Interrupt
             verify(actionService, times(1)).waitForActionToComplete(any(Action.class));
         }
     }
+
+    @Test
+    @DisplayName("Reboot Server calls Hetzner and tracks the action")
+    void RebootServerCallsHetznerAndTracksTheAction() throws IOException, InterruptedException, IllegalAccessException {
+        HetznerCloud hetznerCloud = mock(HetznerCloud.class);
+        HetznerCloudHttpClient hetznerCloudHttpClient = mock(HetznerCloudHttpClient.class);
+        ListenerManager listenerManager = mock(ListenerManager.class);
+        ServiceManager serviceManager = mock(ServiceManager.class);
+        ActionService actionService = mock(ActionService.class);
+
+        try (MockedStatic<HetznerCloud> hetznerCloudMockedStatic = mockStatic(HetznerCloud.class);
+             MockedStatic<HetznerCloudHttpClient> hetznerCloudHttpClientMockedStatic = mockStatic(HetznerCloudHttpClient.class)) {
+
+            Action action = new Action();
+            action.setFinished(Date.from(Instant.now()).toString());
+
+            hetznerCloudHttpClientMockedStatic.when(HetznerCloudHttpClient::getInstance).thenReturn(hetznerCloudHttpClient);
+            hetznerCloudMockedStatic.when(HetznerCloud::getInstance).thenReturn(hetznerCloud);
+            when(hetznerCloud.getListenerManager()).thenReturn(listenerManager);
+            when(hetznerCloud.getHttpDetails()).thenReturn(List.of("http://host/", "key1234"));
+            when(serviceManager.getActionService()).thenReturn(actionService);
+            when(actionService.waitForActionToComplete(any(Action.class))).thenReturn(CompletableFuture.completedFuture(action));
+
+            when(hetznerCloudHttpClient.sendHttpRequest(any(), anyString(), any(RequestVerb.class), anyString(), anyString())).thenReturn(new ActionWrapper(action));
+
+            ServerService serverService = new ServerService(serviceManager);
+            serverService.rebootServer(new Server());
+
+            verify(hetznerCloudHttpClient, times(1)).sendHttpRequest(any(), anyString(), eq(RequestVerb.POST), eq("key1234"), eq(""));
+            verify(actionService, times(1)).waitForActionToComplete(any(Action.class));
+        }
+    }
 }