Initial project commit

Author: sleipnir

.gitignore

@@ -1,4 +1,5 @@
 target/
+.idea/
 pom.xml.tag
 pom.xml.releaseBackup
 pom.xml.versionsBackup

pom.xml

@@ -0,0 +1,19 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+  <groupId>io.eigr.spawn</groupId>
+  <artifactId>spawn-java-std-sdk</artifactId>
+  <packaging>jar</packaging>
+  <version>0.5.0</version>
+  <name>spawn-java-std-sdk</name>
+  <url>http://maven.apache.org</url>
+
+  <dependencies>
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <version>3.8.1</version>
+      <scope>test</scope>
+    </dependency>
+  </dependencies>
+</project>

src/main/java/io/eigr/spawn/Actor.java

@@ -0,0 +1,6 @@
+package io.eigr.spawn;
+
+public interface Actor {
+
+    ActorConfig getConfig();
+}

src/main/java/io/eigr/spawn/ActorConfig.java

@@ -0,0 +1,4 @@
+package io.eigr.spawn;
+
+public class ActorConfig {
+}

src/main/java/io/eigr/spawn/ActorConfigBuilder.java

@@ -0,0 +1,4 @@
+package io.eigr.spawn;
+
+public final class ActorConfigBuilder {
+}

src/main/java/io/eigr/spawn/Spawn.java

@@ -0,0 +1,113 @@
+package io.eigr.spawn;
+
+import com.sun.net.httpserver.HttpServer;
+import io.eigr.spawn.internal.handlers.ActorServiceHandler;
+
+import java.io.IOException;
+import java.net.InetSocketAddress;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.List;
+import java.util.concurrent.Executors;
+
+/**
+ * Spawn SDK Entrypoint
+ */
+public final class Spawn {
+
+    private String host;
+    private int port;
+    private String proxyHost;
+    private int proxyPort;
+
+    private String system;
+
+    private List<Actor> actors;
+
+    public int getPort() {
+        return port;
+    }
+
+    public String getProxyHost() {
+        return proxyHost;
+    }
+
+    public int getProxyPort() {
+        return proxyPort;
+    }
+    public String getSystem() {
+        return system;
+    }
+
+    public List<Actor> getActors() {
+        return actors;
+    }
+
+    public void start() throws IOException {
+        startServer();
+        registerActorSystem();
+    }
+    private void startServer() throws IOException {
+        HttpServer httpServer = HttpServer.create(new InetSocketAddress(this.port), 0);
+        httpServer.createContext("/api/v1/actors", new ActorServiceHandler(this.system, this.actors));
+        httpServer.setExecutor(Executors.newVirtualThreadPerTaskExecutor());
+
+        httpServer.start();
+    }
+
+    private void registerActorSystem(){
+        // TODO register actors on proxy
+    }
+
+    private Spawn(SpawnSystem builder) {
+        this.port = builder.port;
+        this.proxyHost = builder.proxyHost;
+        this.proxyPort = builder.proxyPort;
+        this.system = builder.system;
+        this.actors = builder.actors;
+    }
+
+    private static final class SpawnSystem {
+        private int port = 8091;
+        private String proxyHost = "127.0.0.1";
+        private int proxyPort = 9001;
+
+        private String system = "spawn-system";
+        private List<Actor> actors = new ArrayList<>();
+
+        public SpawnSystem port(int port) {
+            this.port = port;
+            return this;
+        }
+
+        public SpawnSystem proxyHost(String host) {
+            this.proxyHost = host;
+            return this;
+        }
+
+        public SpawnSystem proxyPort(int port) {
+            this.proxyPort = port;
+            return this;
+        }
+
+        public SpawnSystem of(String system) {
+            this.system = system;
+            return this;
+        }
+
+        public SpawnSystem registerActor(Actor actor) {
+            this.actors.add(actor);
+            return this;
+        }
+
+        public SpawnSystem registerAllActors(Collection<Actor> actors) {
+            this.actors.addAll(actors);
+            return this;
+        }
+
+        public Spawn build() {
+            return new Spawn(this);
+        }
+
+    }
+}

src/main/java/io/eigr/spawn/internal/handlers/ActorServiceHandler.java

@@ -0,0 +1,25 @@
+package io.eigr.spawn.internal.handlers;
+
+import com.sun.net.httpserver.HttpExchange;
+import com.sun.net.httpserver.HttpHandler;
+import io.eigr.spawn.Actor;
+
+import java.io.IOException;
+import java.util.List;
+
+public final class ActorServiceHandler implements HttpHandler {
+
+    private String system;
+
+    private List<Actor> actors;
+
+    public ActorServiceHandler(String system, List<Actor> actors) {
+        this.system = system;
+        this.actors = actors;
+    }
+
+    @Override
+    public void handle(HttpExchange exchange) throws IOException {
+
+    }
+}

src/test/java/io/eigr/spawn/SpawnTest.java

@@ -0,0 +1,34 @@
+package io.eigr.spawn;
+
+import junit.framework.Test;
+import junit.framework.TestCase;
+import junit.framework.TestSuite;
+
+/**
+ * Unit test for simple App.
+ */
+public class SpawnTest
+        extends TestCase {
+    /**
+     * Create the test case
+     *
+     * @param testName name of the test case
+     */
+    public SpawnTest(String testName) {
+        super(testName);
+    }
+
+    /**
+     * @return the suite of tests being tested
+     */
+    public static Test suite() {
+        return new TestSuite(SpawnTest.class);
+    }
+
+    /**
+     * Rigourous Test :-)
+     */
+    public void testApp() {
+        assertTrue(true);
+    }
+}