tmp(): preparation for battle starting

3 files changed, 26 insertions, 4 deletions

diff --git a/api/src/main/java/akkamon/api/MessagingEngine.java b/api/src/main/java/akkamon/api/MessagingEngine.java
index e3caa79..191ac1a 100644
--- a/api/src/main/java/akkamon/api/MessagingEngine.java
+++ b/api/src/main/java/akkamon/api/MessagingEngine.java
@@ -4,6 +4,7 @@ import akka.actor.typed.ActorRef;
 import akka.actor.typed.ActorSystem;
 import akkamon.api.models.Event;
 import akkamon.api.models.HeartBeatEvent;
+import akkamon.api.models.TrainerRegistrationReplyEvent;
 import akkamon.domain.AkkamonMessageEngine;
 import akkamon.domain.AkkamonNexus;
 import akkamon.domain.AkkamonSession;
@@ -77,7 +78,12 @@ public class MessagingEngine implements AkkamonMessageEngine {
             );
             System.out.println(sceneIdToAkkamonSessions.keySet());
         }
-        //heartBeat();
+
+        System.out.println("Sending trainerId: " + session.getTrainerId());
+        // TODO what if registration goes wrong ...
+        session.send(
+                gson.toJson(new TrainerRegistrationReplyEvent(session.getTrainerId()))
+        );
     }
 
     @Override
@@ -138,7 +144,7 @@ public class MessagingEngine implements AkkamonMessageEngine {
                         )
                 );
                 break;
-            case TRAINER_REGISTRATION:
+            case TRAINER_REGISTRATION_REQUEST:
                 String trainerId = String.valueOf(sceneIdToAkkamonSessions.get(sceneId) == null ? 1 : sceneIdToAkkamonSessions.get(sceneId).size() + 1);
                 system.tell(new AkkamonNexus.RequestTrainerRegistration(
                         trainerId,
diff --git a/api/src/main/java/akkamon/api/models/EventType.java b/api/src/main/java/akkamon/api/models/EventType.java
index cb10cee..67bb28d 100644
--- a/api/src/main/java/akkamon/api/models/EventType.java
+++ b/api/src/main/java/akkamon/api/models/EventType.java
@@ -3,8 +3,11 @@ package akkamon.api.models;
 import com.google.gson.annotations.SerializedName;
 
 public enum EventType {
-    @SerializedName("PlayerRegistrationEvent")
-    TRAINER_REGISTRATION,
+    @SerializedName("TrainerRegistrationRequestEvent")
+    TRAINER_REGISTRATION_REQUEST,
+
+    @SerializedName("TrainerRegistrationReplyEvent")
+    TRAINER_REGISTRATION_REPLY,
 
     @SerializedName("HeartBeat")
     HEART_BEAT,
diff --git a/api/src/main/java/akkamon/api/models/TrainerRegistrationReplyEvent.java b/api/src/main/java/akkamon/api/models/TrainerRegistrationReplyEvent.java
new file mode 100644
index 0000000..107b722
--- /dev/null
+++ b/api/src/main/java/akkamon/api/models/TrainerRegistrationReplyEvent.java
@@ -0,0 +1,13 @@
+package akkamon.api.models;
+
+import akkamon.domain.AkkamonNexus;
+
+import java.util.Map;
+
+public class TrainerRegistrationReplyEvent extends Event {
+    public TrainerRegistrationReplyEvent(String sessionTrainerId) {
+        this.type = EventType.TRAINER_REGISTRATION_REPLY;
+
+        this.trainerId = sessionTrainerId;
+    }
+}