Update agentos_core.py

agentos_core.py

@@ -19,8 +19,54 @@ class AgentCore:
         print(f"[INIT] Agent {self.agent_id} initialized with model {self.model}")
 
     def run(self, prompt):
-       ==== Application Startup at 2025-10-20 07:10:44 =====
+   import os
+from telemetry import Telemetry
+from memory_core import MemoryManager
+from context_graph import ContextGraph
+from identity_core import create_agent_identity
+
+
+class AgentCore:
+    def __init__(self, model="gpt-4o-mini"):
+        self.agent_id = create_agent_identity()
+        self.telemetry = Telemetry(agent_id=self.agent_id)
+        self.model = model
+        self.memory = MemoryManager(self.agent_id)
+        self.context = ContextGraph()
+
+        self.telemetry.log("init", "success", {"agent_id": self.agent_id})
+        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})
+        try:
+            recall_hits = self.context.query_context(self.agent_id, prompt)
+            response = None
+
+            if recall_hits and recall_hits != ["No matching context found."]:
+                for hit in recall_hits:
+                    if " is " in hit:
+                        parts = hit.split(" is ", 1)
+                        subject = parts[0].replace("My ", "Your ").strip()
+                        fact = parts[1].strip().rstrip(".")
+                        if subject.lower() in prompt.lower():
+                            response = f"{subject} is {fact}."
+                            break
+
+            if not response:
+                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
 
+        except Exception as e:
+            self.telemetry.log("run_failed", "error", {"error": str(e)})
+            print(f"[ERROR] {e}")
+            return f"Error: {e}"
 [Identity] Created digital DNA for agent 4a65fb77-5b14-4caa-9883-806a67eff093
 [Telemetry] init - success | {'agent_id': '4a65fb77-5b14-4caa-9883-806a67eff093'}
 [INIT] Agent 4a65fb77-5b14-4caa-9883-806a67eff093 initialized with model gpt-4o-mini