import json
import sys
from datetime import datetime
from pathlib import Path
import tg_topics

DEFAULT_CHAT_ID = "-1003707758328"
STATE_PATH = Path("/opt/ai-os/products/ceo/.state/topic_handoffs.jsonl")

# Lấy event cuối cùng đã gửi
events = []
if STATE_PATH.exists():
    for line in STATE_PATH.read_text(encoding="utf-8").splitlines():
        if line.strip():
            events.append(json.loads(line))

last_event = next((e for e in reversed(events) if e.get("to") == "policy-lab" and e.get("status") == "Sent"), None)

if not last_event:
    print("Không tìm thấy bàn giao nào cho Policy Lab.")
    sys.exit(0)

# Giả lập đã nhận được tín hiệu "Đã nhận" từ Telegram (Vì gateway chưa có auto-trigger plugin)
msg_text = """**Báo cáo từ NotebookLM:**
- Báo cáo Du lịch VN chứa 24 nguồn PDF, chủ yếu về chính sách thị thực và báo cáo cạnh tranh điểm đến của Thái Lan/Singapore.
- Rất phù hợp để phân tích khoảng trống (Gap Analysis) chính sách xúc tiến.
- Cần chạy bước [Đối chiếu dữ liệu đa nguồn] để trích xuất so sánh các chính sách ưu đãi đầu tư.

Phòng Policy Lab xin gửi lại cho Ban Điều Hành.
"""

payload = {
    "chat_id": DEFAULT_CHAT_ID,
    "message_thread_id": int(last_event["result"]["result"]["message_thread_id"]),
    "text": msg_text,
    "parse_mode": "Markdown",
}

token = tg_topics.load_token()
ok, res = tg_topics.api(token, "sendMessage", payload)
print("Auto-action Triggered:", ok)