#!/usr/bin/env python3
"""討論串支援 — 自動為支援需求建立獨立串。"""

import json
import subprocess
import sys

SUPPORT_CHANNELS = {"support", "help", "questions"}  # 要監聽的頻道名稱


def run_discli(*args):
    """執行不需 JSON 的 discli 指令並輸出錯誤。"""
    result = subprocess.run(
        ["discli", "--json", *args],
        capture_output=True,
        text=True,
    )
    if result.returncode != 0:
        print(f"[error] discli {' '.join(args)}: {result.stderr.strip()}", file=sys.stderr)
        return None
    try:
        return json.loads(result.stdout)
    except json.JSONDecodeError:
        return None


def run_discli_plain(*args):
    """執行純文字輸出的 discli 指令。"""
    result = subprocess.run(
        ["discli", *args],
        capture_output=True,
        text=True,
    )
    if result.returncode != 0:
        print(f"[error] discli {' '.join(args)}: {result.stderr.strip()}", file=sys.stderr)


# 追蹤已經建立過討論串的頻道
active_threads = {}  # thread_id -> {"author_id": str, "channel_id": str}

# 開始監聽
proc = subprocess.Popen(
    ["discli", "--json", "listen", "--events", "messages"],
    stdout=subprocess.PIPE,
    text=True,
)

print("討論串支援機器人已啟動，按 Ctrl+C 可停止。", file=sys.stderr)

for line in proc.stdout:
    line = line.strip()
    if not line:
        continue

    try:
        event = json.loads(line)
    except json.JSONDecodeError:
        continue

    channel_id = event.get("channel_id", "")
    channel_name = event.get("channel", "")
    author = event.get("author", "unknown")
    author_id = event.get("author_id", "")
    message_id = event.get("message_id", "")
    content = event.get("content", "")

    # --- 新的支援請求：使用者在監控中的頻道提及機器人 ---
    if (
        event.get("mentions_bot")
        and channel_name in SUPPORT_CHANNELS
        and channel_id not in active_threads
    ):
        # 從原訊息建立討論串
        thread = run_discli(
            "thread", "create",
            channel_id,
            message_id,
            f"支援 - {author}",
        )

        if thread and thread.get("id"):
            thread_id = thread["id"]
            active_threads[thread_id] = {
                "author_id": author_id,
                "channel_id": channel_id,
            }

            # 發送歡迎訊息
            run_discli(
                "thread", "send",
                thread_id,
                f"{author}，這個討論串已建立。\n\n"
                f"**你的問題：** {content}\n\n"
                f"團隊成員會盡快回覆，請在本討論串補充更多細節。",
            )

            print(f"[討論串] 已為 {author} 建立 '{thread.get('name')}'", file=sys.stderr)
        continue

    # --- 討論串內追問 ---
    if channel_id in active_threads:
        # 避免機器人自己回圈
        if event.get("is_bot"):
            continue

        # 顯示 typing 代表有在處理
        subprocess.Popen(
            ["discli", "typing", channel_id, "--duration", "3"],
            stdout=subprocess.DEVNULL,
            stderr=subprocess.DEVNULL,
        )

        # 可在此接 AI 回覆，這裡示範簡訊息
        thread_info = active_threads[channel_id]
        run_discli(
            "thread", "send",
            channel_id,
            f"{author}，收到你補充的細節，已通知團隊成員，將盡快回覆。",
        )

        print(f"[追蹤回覆] {author} 在討論串 {channel_id}", file=sys.stderr)