Update agentos_core.py

agentos_core.py

@@ -1,40 +1,43 @@
-import os
+import uuid
 from memory import MemoryManager
-from context_graph import ContextGraph
 from telemetry import Telemetry
-from identity_core import create_agent_identity
+from context_manager import ContextManager
 from summarizer import MemorySummarizer
 
 class AgentCore:
     def __init__(self, model="gpt-4o-mini"):
-        self.agent_id = create_agent_identity()
-        self.telemetry = Telemetry(self.agent_id)
-        self.memory = MemoryManager(self.agent_id)
-        self.context = ContextGraph()
-        self.summarizer = MemorySummarizer("semantic_memory.json")if "summarize" in prompt.lower() or "what do you know" in prompt.lower():
-    return self.summarizer.summarize()
+        self.agent_id = str(uuid.uuid4())
         self.model = model
-    
+        print(f"[Identity] Created digital DNA for agent {self.agent_id}")
+        self.memory = MemoryManager("semantic_memory.json")
+        self.telemetry = Telemetry(self.agent_id)
+        self.context = ContextManager()
+        self.summarizer = MemorySummarizer("semantic_memory.json")
         print(f"[INIT] Agent {self.agent_id} initialized with model {self.model}")
 
     def run(self, prompt):
-    self.telemetry.log("run_start", "in_progress", {"prompt": prompt})
-
-    # 🔹 Summarization Trigger
-    if "summarize" in prompt.lower() or "what do you know" in prompt.lower() or "who am i" in prompt.lower():
-        summary = self.summarizer.summarize()
-        self.telemetry.log("run_complete", "success", {"response": summary})
-        print(f"[RUN] {summary}")
-        return summary
+        self.telemetry.log("run_start", "in_progress", {"prompt": prompt})
 
-    # 🔹 Normal processing flow
-    response = f"Agent {self.agent_id} processed: {prompt}"
-    self.memory.save({"prompt": prompt, "response": response})
-    self.context.link_context(self.agent_id, prompt, response)
-    self.telemetry.log("run_complete", "success", {"response": response})
-    print(f"[RUN] {response}")
-    return response
+        # 🔹 Reflection / Summarization Trigger
+        summary_triggers = [
+            "summarize",
+            "what do you know",
+            "who am i",
+            "remember about me",
+            "list everything",
+            "recall memory",
+            "summarize my data"
+        ]
+        if any(trigger in prompt.lower() for trigger in summary_triggers):
+            summary = self.summarizer.summarize()
+            self.telemetry.log("run_complete", "success", {"response": summary})
+            print(f"[RUN] {summary}")
+            return summary
 
-        except Exception as e:
-            self.telemetry.log("run_failed", "error", {"error": str(e)})
-            raise e
+        # 🔹 Normal conversation & memory flow
+        response = f"Agent {self.agent_id} processed: {prompt}"
+        self.memory.save({"prompt": prompt, "response": response})
+        self.context.link_context(self.agent_id, prompt, response)
+        self.telemetry.log("run_complete", "success", {"response": response})
+        print(f"[RUN] {response}")
+        return response