Added basic integration tests

Author: sleipnir

Makefile

@@ -0,0 +1,21 @@
+# Variables
+VERSION := 1.0-SNAPSHOT
+PACKAGE := target/spawn-java-demo-${VERSION}-shaded.jar
+
+clean:
+	mvn clean
+
+build: clean
+	mvn compile
+
+install:
+	mvn install
+
+test: run-dependencies
+	mvn test
+
+run-dependencies:
+	docker-compose up -d && docker-compose logs -f
+
+stop-dependencies:
+	docker-compose down

docker-compose.yaml

@@ -0,0 +1,43 @@
+version: "3.8"
+services:
+  mariadb:
+    image: mariadb
+    environment:
+      MYSQL_ROOT_PASSWORD: admin
+      MYSQL_DATABASE: eigr-functions-db
+      MYSQL_USER: admin
+      MYSQL_PASSWORD: admin
+    volumes:
+      - mariadb:/var/lib/mysql
+    ports:
+      - "3307:3306"
+  nats:
+    image: nats:0.8.0
+    entrypoint: "/gnatsd -DV"
+    ports:
+      - "8222:8222"
+      - "4222:4222"
+  spawn-proxy:
+    build:
+      context: https://github.com/eigr/spawn.git#main
+      dockerfile: ./Dockerfile-proxy
+    restart: always
+    network_mode: "host"
+    environment:
+      SPAWN_USE_INTERNAL_NATS: "true"
+      SPAWN_PUBSUB_ADAPTER: nats
+      SPAWN_STATESTORE_KEY: 3Jnb0hZiHIzHTOih7t2cTEPEpY98Tu1wvQkPfq/XwqE=
+      PROXY_APP_NAME: spawn
+      PROXY_CLUSTER_STRATEGY: gossip
+      PROXY_DATABASE_PORT: 3307
+      PROXY_DATABASE_TYPE: mariadb
+      PROXY_HTTP_PORT: 9003
+      USER_FUNCTION_PORT: 8091
+    depends_on:
+      - mariadb
+      - nats
+networks:
+  mysql-compose-network:
+    driver: bridge
+volumes:
+  mariadb:

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

@@ -85,7 +85,7 @@ public void start() throws Exception {
     }
 
     private void startServer() throws IOException {
-        HttpServer httpServer = HttpServer.create(new InetSocketAddress("127.0.0.1", this.port), 0);
+        HttpServer httpServer = HttpServer.create(new InetSocketAddress(this.host, this.port), 0);
         httpServer.createContext(HTTP_ACTORS_ACTIONS_URI, new ActorServiceHandler(this, this.entities));
         if (this.optionalExecutor.isPresent()) {
             httpServer.setExecutor(this.optionalExecutor.get());
@@ -228,7 +228,7 @@ public static final class SpawnSystem {
         private int proxyPort = 9001;
         private String system = "spawn-system";
 
-        private Optional<Executor> optionalExecutor;
+        private Optional<Executor> optionalExecutor = Optional.empty();
 
         public SpawnSystem create(String system) {
             this.system = system;
@@ -256,7 +256,7 @@ public SpawnSystem withProxyPort(int port) {
         }
 
         public SpawnSystem withHttpHandlerExecutor(Executor executor) {
-            this.optionalExecutor = Optional.ofNullable(executor);
+            this.optionalExecutor = Optional.of(executor);
             return this;
         }
 

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

@@ -1,12 +1,45 @@
 package io.eigr.spawn;
 
+import io.eigr.spawn.api.Spawn;
+import io.eigr.spawn.api.actors.ActorRef;
+import io.eigr.spawn.java.test.domain.Actor;
+import io.eigr.spawn.test.actors.JoeActor;
+import org.junit.Before;
 import org.junit.Test;
 
-import static org.junit.Assert.assertTrue;
+import java.util.Optional;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
 
 public class SpawnTest {
+
+    private Spawn spawnSystem;
+
+    @Before
+    public void before() throws Exception {
+        spawnSystem = new Spawn.SpawnSystem()
+                .create("spawn-system")
+                .withPort(8091)
+                .withProxyPort(9003)
+                .addActor(JoeActor.class)
+                .build();
+
+        spawnSystem.start();
+    }
+
     @Test
     public void testApp() throws Exception {
-        assertTrue(true);
+        ActorRef joeActor = spawnSystem.createActorRef("spawn-system", "test_joe");
+
+        Actor.Request msg = Actor.Request.newBuilder()
+                .setLanguage("erlang")
+                .build();
+
+        Actor.Reply reply =
+                (Actor.Reply) joeActor.invoke("setLanguage", msg, Actor.Reply.class, Optional.empty());
+
+        assertNotNull(reply);
+        assertEquals("Hello From Java", reply.getResponse());
     }
 }