add convo id for logs

README.md

@@ -195,3 +195,7 @@ This should start a basic webserver that would allow us to view the game state a
 
 3. Pass in to `engine.py` with `--environment` flag.
 
+
+
+TODO:
+refactor add_agents bc of jumping

src/agents.py

@@ -264,6 +264,7 @@ def summarize_conversation(self, timestamp):
             print_and_log(interaction, f"{self.matrix.id}:events:{self.name}")
 
         self.addMemory("conversation", interaction, timestamp, random.randint(4, 6))
+        self.matrix.add_to_logs({"step_type":"agent_set","convo":"complete","from":self.id,"to":self.last_conversation.other_agent.id,"convo_id":self.last_conversation.mid})
         self.last_conversation = None
 
     def talk(self, opts={}):
@@ -345,9 +346,10 @@ def talk(self, opts={}):
         self.last_conversation.messages.append(interaction)
         other_agent.last_conversation.messages.append(interaction)
         if self.matrix:
-            self.matrix.add_to_logs({"agent_id":self.id,"to_id":other_agent.id,"step_type":"talk","content": msg})
+            self.matrix.add_to_logs({"agent_id":self.id,"to_id":other_agent.id,"step_type":"talk","content": msg,"convo_id":self.last_conversation.mid})
         return msg
 
+    # TO DELETE
     def talk_many(self, perceived_agents, timestamp):
         relevant_memories = self.getMemories(f"{[a.name for a in perceived_agents]}", timestamp)
         relevant_memories_string = "\n".join(f"Memory {i + 1}:\n{memory}" for i, memory in enumerate(relevant_memories)) if relevant_memories else ""

src/conversation.py

@@ -1,7 +1,9 @@
+import uuid
 class Conversation:
     def __init__(self, agent, other_agent, messages=None):
         self.agent = agent
         self.other_agent = other_agent
+        self.mid = str(uuid.uuid4())
         self.messages = messages
 
         if self.messages is None:

src/matrix.py

@@ -62,7 +62,7 @@ def __init__(self, config={}):
         self.allow_movement = ALLOW_MOVEMENT
         self.model = MODEL
         self.replay = None
-        self.add_to_logs({"step_type":"world_init","data":config})
+        self.add_to_logs({"step_type":"matrix_init","data":config})
         self.agent_locks = { agent: threading.Lock() for agent in self.agents }
         self.environment = Environment({ "filename": self.environment_file })
         if self.scenario_file is not None: