From bf33e2c821d2220f04e3f8fcdf1ce499c62e6ab6 Mon Sep 17 00:00:00 2001
From: Jesper Saastamoinen <jespersaastamoinen@gmail.com>
Date: Fri, 13 Dec 2024 18:54:15 +0100
Subject: [PATCH] Formatted and refactored SocketServer

---
 src/com/jsaasta/froj/stdlib/socket/ClientHandler.java | 2 +-
 src/com/jsaasta/froj/stdlib/socket/SocketServer.java  | 7 ++++++-
 2 files changed, 7 insertions(+), 2 deletions(-)

diff --git a/src/com/jsaasta/froj/stdlib/socket/ClientHandler.java b/src/com/jsaasta/froj/stdlib/socket/ClientHandler.java
index 6ebeb28..82e0979 100644
--- a/src/com/jsaasta/froj/stdlib/socket/ClientHandler.java
+++ b/src/com/jsaasta/froj/stdlib/socket/ClientHandler.java
@@ -17,7 +17,7 @@ class ClientHandler implements Runnable {
 
             byte[] buffer = new byte[1024];
             int bytesRead = in.read(buffer);
-            if(bytesRead == -1){
+            if (bytesRead == -1) {
                 System.out.println("Client closed the Connection");
             }
 
diff --git a/src/com/jsaasta/froj/stdlib/socket/SocketServer.java b/src/com/jsaasta/froj/stdlib/socket/SocketServer.java
index 79e5a24..edcba8b 100644
--- a/src/com/jsaasta/froj/stdlib/socket/SocketServer.java
+++ b/src/com/jsaasta/froj/stdlib/socket/SocketServer.java
@@ -14,6 +14,7 @@ import java.util.concurrent.LinkedBlockingQueue;
 public class SocketServer implements FrojCallable {
     protected static BlockingQueue<String> messageQueue = new LinkedBlockingQueue<>();
     private static ServerSocket serverSocket;
+
     private final String EXIT_CODE = "EXIT";
 
     @Override
@@ -23,8 +24,12 @@ public class SocketServer implements FrojCallable {
 
     @Override
     public Object call(Interpreter interpreter, List<Object> arguments) {
+        return startSocketServer(arguments.get(0));
+    }
+
+    private Object startSocketServer(Object port) {
         try {
-            Double param = (Double) arguments.get(0);
+            Double param = (Double) port;
             final int PORT = param.intValue();
 
             serverSocket = new ServerSocket(PORT);