System Touch

Author: mearvk

scripts/shutdown.sh

@@ -1,28 +1,16 @@
 #!/usr/bin/env bash
-# shutdown.sh — gracefully stop the WebExpress server and all related connections
+# shutdown.sh — kill processes on server ports silently (printing handled by ShutdownHooks via CommonRails)
 
 PORTS=(49152 49155 5512 6682)
 
-echo "[shutdown] Closing server ports: ${PORTS[*]}"
-
 for PORT in "${PORTS[@]}"; do
-    # collect every PID listening on this port
     PIDS=$(lsof -ti TCP:"$PORT" 2>/dev/null)
-    if [ -n "$PIDS" ]; then
-        echo "[shutdown] Sending SIGTERM to PIDs on port $PORT: $PIDS"
-        kill -TERM $PIDS 2>/dev/null
-    fi
+    [ -n "$PIDS" ] && kill -TERM $PIDS 2>/dev/null
 done
 
-# allow a brief grace period for clean shutdown
 sleep 2
 
 for PORT in "${PORTS[@]}"; do
     PIDS=$(lsof -ti TCP:"$PORT" 2>/dev/null)
-    if [ -n "$PIDS" ]; then
-        echo "[shutdown] Sending SIGKILL to remaining PIDs on port $PORT: $PIDS"
-        kill -KILL $PIDS 2>/dev/null
-    fi
+    [ -n "$PIDS" ] && kill -KILL $PIDS 2>/dev/null
 done
-
-echo "[shutdown] Done."

source/exceptions/ExceptionPersistenceService.java

@@ -1,5 +1,6 @@
 package exceptions;
 
+import java.io.File;
 import java.io.FileWriter;
 import java.io.IOException;
 import java.time.Instant;
@@ -21,6 +22,12 @@ public ExceptionPersistenceService(final String FILEPATH)
      */
     public void persist(final ExceptionRecord RECORD)
     {
+        try
+        {
+            new File(FILEPATH).getParentFile().mkdirs();
+        }
+        catch (Exception ignored) {}
+
         try (FileWriter writer = new FileWriter(FILEPATH, true))
         {
 

source/exceptions/PersistenceListener.java

@@ -1,5 +1,6 @@
 package exceptions;
 
+import java.io.File;
 import java.io.FileWriter;
 import java.io.IOException;
 import java.time.Instant;
@@ -29,6 +30,12 @@ public void onException(final ExceptionRecord RECORD)
 
     private void writeRecordToFile(final ExceptionRecord RECORD)
     {
+        try
+        {
+            new File(FILEPATH).getParentFile().mkdirs();
+        }
+        catch (Exception ignored) {}
+
         try (FileWriter writer = new FileWriter(FILEPATH, true))
         {
             writer.write("[EXCEPTION] " + Instant.now() + System.lineSeparator() + "Type: " + RECORD.EXCEPTION().getClass().getName() + System.lineSeparator() + "Message: " + RECORD.EXCEPTION().getMessage() + System.lineSeparator() + "Origin: " + RECORD.ORIGIN() + System.lineSeparator() + "StackTrace: " + RECORD.STACKTRACE() + System.lineSeparator() + "------------------------------------------------------------" + System.lineSeparator());

source/shutdown/ShutdownHooks.java

@@ -0,0 +1,65 @@
+package shutdown;
+
+import commons.CommonRails;
+
+import java.io.File;
+import java.net.Socket;
+
+/**
+ * Centralises all JVM shutdown hook registration and shutdown printing via CommonRails.
+ * The bash script performs the actual OS-level kills silently; all console output goes
+ * through CommonRails.printShutdownSignal / printSystemComponent.
+ */
+public class ShutdownHooks
+{
+    public static final int[] PORTS = { 49152, 49155, 5512, 6682 };
+
+    public static void register()
+    {
+        Runtime.getRuntime().addShutdownHook(new Thread(ShutdownHooks::run, "ShutdownHook"));
+    }
+
+    private static void run()
+    {
+        ShutdownHooks owner = new ShutdownHooks();
+
+        CommonRails.printSystemComponent(owner, owner.hashCode(), "[shutdown] Closing server ports: 49152 49155 5512 6682");
+
+        for (int port : PORTS)
+            CommonRails.printShutdownSignal(owner, port, "SIGTERM");
+
+        // run script silently — it performs the actual kills
+        try
+        {
+            String script = new File("scripts/shutdown.sh").getAbsolutePath();
+            Process proc = new ProcessBuilder("bash", script)
+                    .redirectOutput(ProcessBuilder.Redirect.DISCARD)
+                    .redirectError(ProcessBuilder.Redirect.DISCARD)
+                    .start();
+
+            // grace period mirrors the script's sleep 2
+            Thread.sleep(2000);
+
+            // report any ports that needed SIGKILL
+            for (int port : PORTS)
+            {
+                if (portStillOpen(port))
+                    CommonRails.printShutdownSignal(owner, port, "SIGKILL");
+            }
+
+            proc.waitFor();
+        }
+        catch (Exception e)
+        {
+            CommonRails.EXCEPTION_SINK.accept(e);
+        }
+
+        CommonRails.printSystemComponent(owner, owner.hashCode(), "[shutdown] Done.");
+    }
+
+    private static boolean portStillOpen(final int PORT)
+    {
+        try (Socket s = new Socket("localhost", PORT)) { return true; }
+        catch (Exception e) { return false; }
+    }
+}