From 7d75217dbee3d8ee750221057643363ab070beed Mon Sep 17 00:00:00 2001
From: Tobias Eidelpes <tobias@eidelpes.info>
Date: Sun, 8 Nov 2020 15:44:57 +0100
Subject: [PATCH] Implement basic mailbox server

---
 .../java/dslab/mailbox/MailboxServer.java     | 38 +++++++++++++++++--
 1 file changed, 35 insertions(+), 3 deletions(-)

diff --git a/src/main/java/dslab/mailbox/MailboxServer.java b/src/main/java/dslab/mailbox/MailboxServer.java
index f422eda..85db7e3 100644
--- a/src/main/java/dslab/mailbox/MailboxServer.java
+++ b/src/main/java/dslab/mailbox/MailboxServer.java
@@ -1,12 +1,22 @@
 package dslab.mailbox;
 
+import java.io.IOException;
 import java.io.InputStream;
 import java.io.PrintStream;
+import java.net.ServerSocket;
+import java.util.logging.Logger;
 
+import at.ac.tuwien.dsg.orvell.Shell;
+import at.ac.tuwien.dsg.orvell.StopShellException;
+import at.ac.tuwien.dsg.orvell.annotation.Command;
 import dslab.ComponentFactory;
 import dslab.util.Config;
 
 public class MailboxServer implements IMailboxServer, Runnable {
+    private static final Logger logger = Logger.getLogger(MailboxServer.class.getName());
+    private ServerSocket serverSocket;
+    private final Shell shell;
+    private final Integer serverPort;
 
     /**
      * Creates a new server instance.
@@ -17,17 +27,39 @@ public class MailboxServer implements IMailboxServer, Runnable {
      * @param out the output stream to write console output to
      */
     public MailboxServer(String componentId, Config config, InputStream in, PrintStream out) {
-        // TODO
+        // TODO initialize email and user storage (concurrent hashmap?)
+        this.shell = new Shell(in, out);
+        this.shell.register(this);
+        this.shell.setPrompt("Mailboxserver> ");
+        this.serverPort = config.getInt("tcp.port");
     }
 
     @Override
     public void run() {
-        // TODO
+        logger.info("Creating serverSocket for " + this.toString());
+        try {
+            this.serverSocket = new ServerSocket(serverPort);
+        } catch (IOException e) {
+            logger.severe("Error creating serverSocket " + serverSocket.toString());
+            e.printStackTrace();
+            shutdown();
+        }
+        // TODO spawn listener for transfer servers
+        // TODO spawn listener for user clients
+        this.shell.run();
     }
 
+    @Command
     @Override
     public void shutdown() {
-        // TODO
+        try {
+            if (serverSocket != null)
+                serverSocket.close();
+        } catch (IOException e) {
+            logger.severe("Error closing serverSocket " + serverSocket.toString());
+            e.printStackTrace();
+        }
+        throw new StopShellException();
     }
 
     public static void main(String[] args) throws Exception {