Update agentos_core.py

agentos_core.py

@@ -18,26 +18,32 @@ class AgentCore:
         self.telemetry.log("run_start", "in_progress", {"prompt": prompt})
 
         try:
-            # 1️⃣ Search for all stored 'favorite' context
             recall_items = self.context.query_context(self.agent_id, "favorite")
 
-            # 2️⃣ Decide response type
             if recall_items and not prompt.lower().startswith("my "):
-                # Clean and humanize recall
                 cleaned = []
+                seen = set()
                 for item in recall_items:
-                    text = item.replace("Agent", "").replace("processed:", "").strip()
-                    cleaned.append(text)
+                    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}"
 
-            # 3️⃣ Save new info to memory + link to graph
             self.memory.save({"prompt": prompt, "response": response})
             self.context.link_context(self.agent_id, prompt, response)
 
-            # 4️⃣ Log complete
             self.telemetry.log("run_complete", "success", {"response": response})
             print(f"[RUN] {response}")
             return response