Update agentos_core.py

agentos_core.py

@@ -18,38 +18,22 @@ class AgentCore:
         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_items = self.context.query_context(self.agent_id, "favorite")
-
-            if recall_items and not prompt.lower().startswith("my "):
-                cleaned = []
-                seen = set()
-                for item in recall_items:
-                    text = (
-                        item.replace("Agent", "")
-                        .replace("processed:", "")
-                        .replace(self.agent_id, "")
-                        .replace(".", "")
-                        .strip()
-                    )
-                    # Avoid duplicates
-                    if text and text not in seen:
-                        seen.add(text)
-                        cleaned.append(text)
-
-                recall_text = " and ".join(cleaned)
-                response = f"You told me {recall_text}."
-            else:
-                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
+    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
+
+    # 🔹 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
 
         except Exception as e:
             self.telemetry.log("run_failed", "error", {"error": str(e)})