Create agents/base_agent.py
Browse files- agents/base_agent.py +41 -0
agents/base_agent.py
ADDED
@@ -0,0 +1,41 @@
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
1 |
+
# agents/base_agent.py
|
2 |
+
|
3 |
+
from typing import Dict
|
4 |
+
|
5 |
+
class ACPMessage:
|
6 |
+
def __init__(self, sender: str, receiver: str, performative: str, content: str):
|
7 |
+
self.sender = sender
|
8 |
+
self.receiver = receiver
|
9 |
+
self.performative = performative # "inform", "request", etc.
|
10 |
+
self.content = content
|
11 |
+
|
12 |
+
def to_dict(self) -> Dict:
|
13 |
+
return {
|
14 |
+
"sender": self.sender,
|
15 |
+
"receiver": self.receiver,
|
16 |
+
"performative": self.performative,
|
17 |
+
"content": self.content
|
18 |
+
}
|
19 |
+
|
20 |
+
def __str__(self):
|
21 |
+
return f"[{self.performative.upper()}] {self.sender} → {self.receiver}: {self.content}"
|
22 |
+
|
23 |
+
|
24 |
+
class BaseAgent:
|
25 |
+
def __init__(self, name: str, role: str):
|
26 |
+
self.name = name
|
27 |
+
self.role = role
|
28 |
+
|
29 |
+
def receive_message(self, message: ACPMessage) -> ACPMessage:
|
30 |
+
"""
|
31 |
+
Override this method to define agent-specific reply logic.
|
32 |
+
"""
|
33 |
+
raise NotImplementedError("You must override receive_message() in your agent.")
|
34 |
+
|
35 |
+
def create_message(self, receiver: str, performative: str, content: str) -> ACPMessage:
|
36 |
+
return ACPMessage(
|
37 |
+
sender=self.name,
|
38 |
+
receiver=receiver,
|
39 |
+
performative=performative,
|
40 |
+
content=content
|
41 |
+
)
|