diff --git a/agent-office/app/agents/stock.py b/agent-office/app/agents/stock.py index c59bd4a..87934d8 100644 --- a/agent-office/app/agents/stock.py +++ b/agent-office/app/agents/stock.py @@ -37,6 +37,16 @@ class StockAgent(BaseAgent): }, ) + # 아내 chat 추가 전송 (설정된 경우) — 제목 + 본문만 간결하게 + from ..config import TELEGRAM_WIFE_CHAT_ID + if TELEGRAM_WIFE_CHAT_ID: + from ..telegram.messaging import send_raw + wife_text = f"📈 아침 시장 브리핑\n\n{result['summary']}" + wife_result = await send_raw(wife_text, chat_id=TELEGRAM_WIFE_CHAT_ID) + if not wife_result.get("ok"): + desc = wife_result.get("description") or "unknown" + add_log(self.agent_id, f"Wife telegram send failed: {desc}", "warning", task_id) + update_task_status(task_id, "succeeded", { "summary": result["summary"], "article_count": result.get("article_count", 0), diff --git a/agent-office/app/config.py b/agent-office/app/config.py index d113807..ddede7a 100644 --- a/agent-office/app/config.py +++ b/agent-office/app/config.py @@ -10,6 +10,7 @@ REALESTATE_LAB_URL = os.getenv("REALESTATE_LAB_URL", "http://localhost:18800") TELEGRAM_BOT_TOKEN = os.getenv("TELEGRAM_BOT_TOKEN", "") TELEGRAM_CHAT_ID = os.getenv("TELEGRAM_CHAT_ID", "") TELEGRAM_WEBHOOK_URL = os.getenv("TELEGRAM_WEBHOOK_URL", "") +TELEGRAM_WIFE_CHAT_ID = os.getenv("TELEGRAM_WIFE_CHAT_ID", "") # Database DB_PATH = os.getenv("AGENT_OFFICE_DB_PATH", "/app/data/agent_office.db") diff --git a/agent-office/app/telegram/messaging.py b/agent-office/app/telegram/messaging.py index 75dfb4d..49a3ee6 100644 --- a/agent-office/app/telegram/messaging.py +++ b/agent-office/app/telegram/messaging.py @@ -8,12 +8,12 @@ from .client import _enabled, api_call from .formatter import MessageKind, format_agent_message -async def send_raw(text: str, reply_markup: Optional[dict] = None) -> dict: - """가장 저수준. 원문 텍스트 그대로 전송.""" +async def send_raw(text: str, reply_markup: Optional[dict] = None, chat_id: Optional[str] = None) -> dict: + """가장 저수준. 원문 텍스트 그대로 전송. chat_id 생략 시 기본 TELEGRAM_CHAT_ID로.""" if not _enabled(): return {"ok": False, "message_id": None} payload = { - "chat_id": TELEGRAM_CHAT_ID, + "chat_id": chat_id or TELEGRAM_CHAT_ID, "text": text, "parse_mode": "HTML", }