From 019ea5fcefa16c2746fb2c7d6fa4a29d18b8d53b Mon Sep 17 00:00:00 2001
From: Mike Vink <mike1994vink@gmail.com>
Date: Tue, 27 Jul 2021 17:00:00 +0200
Subject: tmp(): preparation for battle starting

---
 domain/src/main/java/akkamon/domain/AkkamonNexus.java   | 16 ++++++++--------
 domain/src/main/java/akkamon/domain/HeartBeatQuery.java |  3 +--
 domain/src/main/java/akkamon/domain/Trainer.java        |  6 +++---
 3 files changed, 12 insertions(+), 13 deletions(-)

(limited to 'domain/src/main/java')

diff --git a/domain/src/main/java/akkamon/domain/AkkamonNexus.java b/domain/src/main/java/akkamon/domain/AkkamonNexus.java
index d467df7..4958e21 100644
--- a/domain/src/main/java/akkamon/domain/AkkamonNexus.java
+++ b/domain/src/main/java/akkamon/domain/AkkamonNexus.java
@@ -245,13 +245,13 @@ public class AkkamonNexus extends AbstractBehavior<AkkamonNexus.Command> {
         // Turn on for logging
 
 
-        StringBuilder positions = new StringBuilder();
-        positions.append("\n" + response.sceneId.toUpperCase(Locale.ROOT) + "\n");
-        for (Map.Entry<String, MovementQueueReading> entry : response.trainerMovementQueues.entrySet()) {
-            positions.append(entry.getKey() + ": " +entry.getValue());
-            positions.append("\n");
-        }
-        getContext().getLog().info(String.valueOf(positions));
+        // StringBuilder positions = new StringBuilder();
+        // positions.append("\n" + response.sceneId.toUpperCase(Locale.ROOT) + "\n");
+        // for (Map.Entry<String, MovementQueueReading> entry : response.trainerMovementQueues.entrySet()) {
+        //     positions.append(entry.getKey() + ": " +entry.getValue());
+        //     positions.append("\n");
+        // }
+        // getContext().getLog().info(String.valueOf(positions));
 
         messageEngine.broadCastHeartBeatToScene(response.sceneId, response.trainerMovementQueues);
 
@@ -305,8 +305,8 @@ public class AkkamonNexus extends AbstractBehavior<AkkamonNexus.Command> {
     private AkkamonNexus onTrainerRegistered(TrainerRegistered reply) {
         // TODO test when registration fails?
         getContext().getLog().info("Adding {} to scene {} Live AkkamonSessions in Messaging Engine", reply.trainerId, reply.sceneId);
-        messageEngine.registerTrainerSessionToScene(reply.sceneId, reply.session);
         reply.session.setTrainerId(reply.trainerId);
+        messageEngine.registerTrainerSessionToScene(reply.sceneId, reply.session);
         return this;
     }
 
diff --git a/domain/src/main/java/akkamon/domain/HeartBeatQuery.java b/domain/src/main/java/akkamon/domain/HeartBeatQuery.java
index 5e88ff5..aa201c3 100644
--- a/domain/src/main/java/akkamon/domain/HeartBeatQuery.java
+++ b/domain/src/main/java/akkamon/domain/HeartBeatQuery.java
@@ -86,8 +86,7 @@ public class HeartBeatQuery extends AbstractBehavior<HeartBeatQuery.Command> {
                     new Trainer.ReadMovementQueue(
                             0L,
                             respondTrainerPositionAdapter
-                    )
-                    );
+                    ));
         }
         stillWaiting = new HashSet<>(trainerIdToActor.keySet());
     }
diff --git a/domain/src/main/java/akkamon/domain/Trainer.java b/domain/src/main/java/akkamon/domain/Trainer.java
index 710f844..caad860 100644
--- a/domain/src/main/java/akkamon/domain/Trainer.java
+++ b/domain/src/main/java/akkamon/domain/Trainer.java
@@ -101,7 +101,7 @@ public class Trainer extends AbstractBehavior<Trainer.Command> {
     }
 
     private Trainer onNewTilePos(AkkamonNexus.RequestNewTilePos newTilePosRequest) {
-        getContext().getLog().info("Trainer {} has new {}.", trainerId, newTilePosRequest.tilePos);
+        // getContext().getLog().info("Trainer {} has new {}.", trainerId, newTilePosRequest.tilePos);
         if (isMoving()) {
             this.movementQueue.add(this.movementDirection);
         }
@@ -109,13 +109,13 @@ public class Trainer extends AbstractBehavior<Trainer.Command> {
     }
 
     private Trainer onStopMoving(AkkamonNexus.RequestStopMoving stopMovingRequest) {
-        getContext().getLog().info("Trainer {} stops to move {}.", trainerId, stopMovingRequest.direction);
+        // getContext().getLog().info("Trainer {} stops to move {}.", trainerId, stopMovingRequest.direction);
         this.movementDirection = Direction.NONE;
         return this;
     }
 
     private Trainer onStartMoving(AkkamonNexus.RequestStartMoving startMovingRequest) {
-        getContext().getLog().info("Trainer {} starts to move {}.", trainerId, startMovingRequest.direction);
+        // getContext().getLog().info("Trainer {} starts to move {}.", trainerId, startMovingRequest.direction);
         this.movementDirection = startMovingRequest.direction;
         return this;
     }
-- 
cgit v1.2.3