Added some simple tests

Author: sleipnir

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

@@ -0,0 +1,20 @@
+package io.eigr.spawn;
+
+import io.eigr.spawn.api.actors.annotations.NamedActor;
+import io.eigr.spawn.internal.Entity;
+import io.eigr.spawn.test.actors.JoeActor;
+import org.junit.Test;
+
+import static org.junit.Assert.assertEquals;
+
+public class EntityTest {
+
+    @Test
+    public void testEntityBuilder() {
+        NamedActor annotation = JoeActor.class.getAnnotation(NamedActor.class);
+        final Entity entity = Entity.fromAnnotationToEntity(JoeActor.class, annotation, null, null);
+        assertEquals(1, entity.getActions().values().size());
+        assertEquals(0, entity.getTimerActions().values().size());
+        assertEquals("test.channel", entity.getChannel());
+    }
+}

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

@@ -1,32 +1,12 @@
 package io.eigr.spawn;
 
-import io.eigr.spawn.api.Spawn;
-import io.eigr.spawn.api.actors.ActorRef;
-import junit.framework.Test;
-import junit.framework.TestCase;
-import junit.framework.TestSuite;
+import org.junit.Test;
 
-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);
-    }
+import static org.junit.Assert.assertTrue;
 
+public class SpawnTest {
+    @Test
     public void testApp() throws Exception {
-        Spawn spawn = new Spawn.SpawnSystem().build();
-        ActorRef actor = spawn.createActorRef("spawn-system", "joe");
         assertTrue(true);
     }
 }

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

@@ -0,0 +1,50 @@
+package io.eigr.spawn;
+
+import io.eigr.functions.protocol.Protocol;
+import io.eigr.spawn.api.actors.ActorRef;
+import io.eigr.spawn.api.actors.workflows.Broadcast;
+import io.eigr.spawn.api.actors.workflows.Forward;
+import io.eigr.spawn.api.actors.workflows.Pipe;
+import io.eigr.spawn.api.actors.workflows.SideEffect;
+import io.eigr.spawn.java.test.domain.Actor;
+import org.junit.Test;
+
+import static org.junit.Assert.*;
+
+public class WorkflowTest {
+
+    @Test
+    public void testBroadcastBuilder() {
+        Broadcast broadcast = Broadcast.to("test.channel", "hi", Actor.Request.getDefaultInstance());
+        final Protocol.Broadcast protocolBroadcast = broadcast.build();
+        assertEquals("hi", protocolBroadcast.getActionName());
+        assertEquals("test.channel", protocolBroadcast.getChannelGroup());
+        assertNotNull(protocolBroadcast.getValue());
+    }
+
+    @Test
+    public void testForwardBuilder() throws Exception {
+        Forward forward = Forward.to(ActorRef.of(null, "spawn-system", "joe"), "hi");
+        final Protocol.Forward protocolForward = forward.build();
+        assertEquals("hi", protocolForward.getActionName());
+        assertEquals("joe", protocolForward.getActor());
+    }
+
+    @Test
+    public void testPipeBuilder() throws Exception {
+        Pipe pipe = Pipe.to(ActorRef.of(null, "spawn-system", "joe"), "hi");
+        final Protocol.Pipe protocolPipe = pipe.build();
+        assertEquals("hi", protocolPipe.getActionName());
+        assertEquals("joe", protocolPipe.getActor());
+    }
+
+    @Test
+    public void testSideEffectBuilder() throws Exception {
+        SideEffect effect = SideEffect.to(ActorRef.of(null, "spawn-system", "joe"), "hi", Actor.Request.getDefaultInstance());
+        final Protocol.SideEffect protocolSideEffect = effect.build();
+        Protocol.InvocationRequest request = protocolSideEffect.getRequest();
+        assertNotNull(request);
+        assertEquals("hi", request.getActionName());
+        assertEquals("joe", request.getActor().getId().getName());
+    }
+}

src/test/java/io/eigr/spawn/test/actors/JoeActor.java

@@ -0,0 +1,29 @@
+package io.eigr.spawn.test.actors;
+
+import io.eigr.spawn.api.Value;
+import io.eigr.spawn.api.actors.ActorContext;
+import io.eigr.spawn.api.actors.annotations.Action;
+import io.eigr.spawn.api.actors.annotations.NamedActor;
+import io.eigr.spawn.java.test.domain.Actor;
+
+@NamedActor(name = "test_joe", stateful = true, stateType = Actor.State.class, channel = "test.channel")
+public class JoeActor {
+    @Action(inputType = Actor.Request.class)
+    public Value setLanguage(Actor.Request msg, ActorContext<Actor.State> context) {
+        if (context.getState().isPresent()) {
+        }
+
+        return Value.at()
+                .response(Actor.Reply.newBuilder()
+                        .setResponse("Hello From Java")
+                        .build())
+                .state(updateState("java"))
+                .reply();
+    }
+
+    private Actor.State updateState(String language) {
+        return Actor.State.newBuilder()
+                .addLanguages(language)
+                .build();
+    }
+}

src/test/proto/eigr/functions/java/sdk/test/actor.proto

@@ -0,0 +1,15 @@
+syntax = "proto3";
+package domain;
+option java_package = "io.eigr.spawn.java.test.domain";
+
+message State {
+  repeated string languages = 1;
+}
+
+message Request {
+  string language = 1;
+}
+
+message Reply {
+  string response = 1;
+}