From 4a354cd7a4edb203dd5e66355dbed0e62994e09b Mon Sep 17 00:00:00 2001
From: Mike Vink <mike1994vink@gmail.com>
Date: Thu, 29 Jul 2021 03:34:50 +0200
Subject: feat(): handshaker part1

---
 api/src/main/java/akkamon/api/MessagingEngine.java | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

(limited to 'api/src')

diff --git a/api/src/main/java/akkamon/api/MessagingEngine.java b/api/src/main/java/akkamon/api/MessagingEngine.java
index f1c4a78..c315a0b 100644
--- a/api/src/main/java/akkamon/api/MessagingEngine.java
+++ b/api/src/main/java/akkamon/api/MessagingEngine.java
@@ -6,6 +6,7 @@ import akkamon.api.models.*;
 import akkamon.domain.AkkamonMessageEngine;
 import akkamon.domain.AkkamonNexus;
 import akkamon.domain.AkkamonSession;
+import akkamon.domain.InteractionHandshaker;
 import com.google.gson.Gson;
 
 import java.util.*;
@@ -16,7 +17,7 @@ public class MessagingEngine implements AkkamonMessageEngine {
 
     private Map<String, Set<AkkamonSession>> sceneIdToAkkamonSessions = new HashMap<>();
     private Map<String, AkkamonSession> trainerIdToAkkamonSessions = new HashMap<>();
-    private Set<String> pendingInteractioRequestNameSet = new HashSet<>();
+    private Map<String, ActorRef<InteractionHandshaker.Command>> pendingInteractioRequestToHandshaker = new HashMap<>();
     private Gson gson = new Gson();
 
     private ActorRef<AkkamonNexus.Command> system;
@@ -65,9 +66,10 @@ public class MessagingEngine implements AkkamonMessageEngine {
     }
 
     @Override
-    public void broadCastInteractionRequestToSessionWithTrainerIds(List<String> trainerIds, String type, String trainerId, String requestName) {
+    public void broadCastInteractionRequestToSessionWithTrainerIds(List<String> trainerIds, String type, String trainerId, String requestName, ActorRef<InteractionHandshaker.Command> handshaker) {
         System.out.println("Sending interaction request " + requestName);
-        this.pendingInteractioRequestNameSet.add(requestName);
+        this.pendingInteractioRequestToHandshaker.put(requestName, handshaker);
+        trainerIds.add(trainerId);
         for (String id : trainerIds) {
             AkkamonSession session = trainerIdToAkkamonSessions.get(id);
             if (session != null) {
-- 
cgit v1.2.3