From 08ad66a7326e6d487b9ab951ae487735308e9fde Mon Sep 17 00:00:00 2001 From: daniel Date: Thu, 7 May 2026 19:22:40 -0500 Subject: [PATCH] Log Telegram API response message_id to find duplicate source --- src/lambdas/agent-runner/handler.py | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/src/lambdas/agent-runner/handler.py b/src/lambdas/agent-runner/handler.py index 390a95b..6768278 100644 --- a/src/lambdas/agent-runner/handler.py +++ b/src/lambdas/agent-runner/handler.py @@ -81,7 +81,15 @@ def send_telegram_direct(chat_id: str, token: str, text: str) -> None: url = f'https://api.telegram.org/bot{token}/sendMessage' data = json.dumps({'chat_id': chat_id, 'text': text}).encode() req = urllib.request.Request(url, data=data, headers={'Content-Type': 'application/json'}) - urllib.request.urlopen(req, timeout=10) + try: + resp = urllib.request.urlopen(req, timeout=10) + resp_body = resp.read() + import re + msg_id = re.search(r'"message_id":(\d+)', resp_body.decode('utf-8', errors='replace')) + print(f'[agent-runner] Telegram sendMessage -> msg_id={msg_id.group(1) if msg_id else "?"} hash={h}') + except Exception as e: + print(f'[agent-runner] Telegram sendMessage FAILED: {type(e).__name__}: {e} hash={h}') + raise def get_or_create_session(actor_id: str) -> str: