summaryrefslogtreecommitdiff
path: root/api/src/main/java
diff options
context:
space:
mode:
authorMike Vink <mike1994vink@gmail.com>2021-07-20 22:05:13 +0200
committerMike Vink <mike1994vink@gmail.com>2021-07-20 22:05:13 +0200
commitf4dc48cd8359d5b8da35f678ae6630c5c4427769 (patch)
tree075acbc259735c096751d9ece5044b8114c1fddb /api/src/main/java
parentb5ec13318a8b6a5f825eb726d6465873495a49ab (diff)
refactor(client): typed message improvement!
Diffstat (limited to 'api/src/main/java')
-rw-r--r--api/src/main/java/akkamon/api/MessagingEngine.java14
-rw-r--r--api/src/main/java/akkamon/api/models/Event.java6
-rw-r--r--api/src/main/java/akkamon/api/models/EventType.java5
3 files changed, 21 insertions, 4 deletions
diff --git a/api/src/main/java/akkamon/api/MessagingEngine.java b/api/src/main/java/akkamon/api/MessagingEngine.java
index 4919b32..e888d8b 100644
--- a/api/src/main/java/akkamon/api/MessagingEngine.java
+++ b/api/src/main/java/akkamon/api/MessagingEngine.java
@@ -11,6 +11,7 @@ import com.google.gson.Gson;
import java.util.HashMap;
import java.util.Map;
+import java.util.UUID;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
@@ -59,10 +60,19 @@ public class MessagingEngine implements AkkamonMessageEngine {
void incoming(AkkamonSession session, String message) {
Event event = gson.fromJson(message, Event.class);
+ String trainerId = String.valueOf(trainerIdToAkkamonSessions.size());
+ String sceneId = "akkamonStartScene";
+
switch (event.type) {
+ case START_MOVING:
+ system.tell(new AkkamonNexus.RequestStartMoving(
+ UUID.randomUUID().getMostSignificantBits() & Long.MAX_VALUE,
+ "0",
+ event.sceneId,
+ event.direction
+ ));
+ break;
case TRAINER_REGISTRATION:
- String trainerId = String.valueOf(trainerIdToAkkamonSessions.size());
- String sceneId = "AkkamonStartScene";
system.tell(new AkkamonNexus.RequestTrainerRegistration(
trainerId,
diff --git a/api/src/main/java/akkamon/api/models/Event.java b/api/src/main/java/akkamon/api/models/Event.java
index 8517b06..351d39f 100644
--- a/api/src/main/java/akkamon/api/models/Event.java
+++ b/api/src/main/java/akkamon/api/models/Event.java
@@ -1,6 +1,10 @@
package akkamon.api.models;
+import akkamon.domain.Direction;
+
public class Event {
public EventType type;
-
+ public String trainerId;
+ public Direction direction;
+ public String sceneId;
}
diff --git a/api/src/main/java/akkamon/api/models/EventType.java b/api/src/main/java/akkamon/api/models/EventType.java
index 1ca2ef2..ad537a5 100644
--- a/api/src/main/java/akkamon/api/models/EventType.java
+++ b/api/src/main/java/akkamon/api/models/EventType.java
@@ -7,5 +7,8 @@ public enum EventType {
TRAINER_REGISTRATION,
@SerializedName("HeartBeat")
- HEART_BEAT
+ HEART_BEAT,
+
+ @SerializedName("StartMoving")
+ START_MOVING
}