adding server status listener

Author: madhephaestus

src/main/java/eu/mihosoft/vrl/v3d/CSGServer.java

@@ -15,6 +15,7 @@
 import java.security.SecureRandom;
 import java.security.cert.Certificate;
 import java.security.cert.X509Certificate;
+import java.util.ArrayList;
 import java.util.Date;
 import java.time.Instant;
 import java.time.temporal.ChronoUnit;
@@ -38,6 +39,7 @@ public class CSGServer {
 	private static final String KEYSTORE_NAME = "CSGSelfSign";
 	private String[] lines = null;
 	private SSLServerSocket serverSocket2;
+	private ArrayList<ICSGServerEvent> listeners = new ArrayList<>();
 
 	public CSGServer(int port, File APIKEYS) throws IOException {
 		this.port = port;
@@ -54,7 +56,27 @@ public CSGServer(int port, File APIKEYS) throws IOException {
 			System.err.println("NO API KEYFILE Provided: "+APIKEYS.getAbsolutePath());
 		}
 	}
-
+	public void addListener(ICSGServerEvent e) {
+		if(listeners.contains(e))
+			return;
+		listeners.add(e);
+	}
+	public void removeListener(ICSGServerEvent e) {
+		if(!listeners.contains(e))
+			return;
+		listeners.remove(e);
+	}
+	
+	private void fireStart() {
+		for(ICSGServerEvent e:listeners) {
+			try {
+				e.starting();
+			}catch(Throwable t) {
+				t.printStackTrace();
+			}
+		}
+	}
+	
 	public static void ensureKeystoreExists(String keystorePath, String keystorePassword, String alias,
 			String commonName) {
 		File keystoreFile = new File(keystorePath);
@@ -181,8 +203,9 @@ public void start() throws Exception {
 
 		while (isRunning()) {
 			try {
+				fireStart();
 				SSLSocket clientSocket = (SSLSocket) serverSocket2.accept();
-				threadPool.execute(new CSGServerHandler(clientSocket,lines));
+				threadPool.execute(new CSGServerHandler(clientSocket,lines,listeners));
 			} catch (IOException e) {
 				if (isRunning()) {
 					System.err.println("Error accepting client connection: " + e.getMessage());

src/main/java/eu/mihosoft/vrl/v3d/CSGServerHandler.java

@@ -16,9 +16,14 @@ class CSGServerHandler implements Runnable {
 
 	private String[] APIKEY = null;
 
-	public CSGServerHandler(SSLSocket socket, String[] lines) {
+	private ArrayList<ICSGServerEvent> listeners;
+
+	private ServerActionState state;
+
+	public CSGServerHandler(SSLSocket socket, String[] lines,ArrayList<ICSGServerEvent> listeners ) {
 		this.clientSocket = socket;
 		APIKEY = lines;
+		this.listeners = listeners;
 	}
 
 	@Override
@@ -31,6 +36,13 @@ public void run() {
 
 			// Read the CSG request
 			CSGRequest request = (CSGRequest) ois.readObject();
+			for(ICSGServerEvent e:listeners) {
+				try {
+					e.gotRequest(request.getOperation(),this);
+				}catch(Throwable t) {
+					t.printStackTrace();
+				}
+			}
 			// System.out.println("Received request: " + request.getOperation());
 			boolean APIPass = true;
 			String apiKey2 = request.getAPIKey();
@@ -64,7 +76,7 @@ public void run() {
 			// Send back the response
 			oos.writeObject(response);
 			oos.flush();
-
+			state = response.getState();
 			// System.out.println("Sent response: " + response);
 
 		} catch (IOException | ClassNotFoundException e) {
@@ -83,6 +95,13 @@ private void close() {
 		} catch (IOException e) {
 			System.err.println("Error closing client socket: " + e.getMessage());
 		}
+		for(ICSGServerEvent e:listeners) {
+			try {
+				e.finishedOp(state,this);
+			}catch(Throwable t) {
+				t.printStackTrace();
+			}
+		}
 	}
 
 	private CSGResponse processCSGRequest(CSGRequest request) {

src/main/java/eu/mihosoft/vrl/v3d/ICSGServerEvent.java

@@ -0,0 +1,10 @@
+package eu.mihosoft.vrl.v3d;
+
+public interface ICSGServerEvent {
+	public void starting();
+
+	public void finishedOp(ServerActionState state,CSGServerHandler source);
+
+	public void gotRequest(CSGRemoteOperation operation,CSGServerHandler source);
+	
+}