File size: 1,721 Bytes
79e375f
b49e0e0
 
79e375f
ca9ee83
30c0316
 
 
79e375f
b49e0e0
79e375f
 
 
 
 
ae6122c
 
b7575e1
79e375f
9e3c2a9
79e375f
 
 
 
 
 
 
 
 
 
 
 
 
 
 
b49e0e0
79e375f
 
 
 
 
 
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
import uuid
from memory import MemoryManager
from telemetry import Telemetry
from context_manager import ContextManager
from summarizer import MemorySummarizer

class AgentCore:
    def __init__(self, model="gpt-4o-mini"):
        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})

        # 🔹 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

        # 🔹 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