#!/usr/bin/env python3
"""Thread-Based Support — auto-create threads for support requests."""

import json
import subprocess
import sys

SUPPORT_CHANNELS = {"support", "help", "questions"}  # Channel names to watch

def run_discli(*args):
    """Run a discli command with JSON output and return parsed result."""
    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):
    """Run a discli command without JSON output."""
    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)

# Track active threads so we can handle follow-ups
active_threads = {}  # thread_id -> {"author_id": str, "channel_id": str}

# Start listening
proc = subprocess.Popen(
    ["discli", "--json", "listen", "--events", "messages"],
    stdout=subprocess.PIPE,
    text=True,
)

print("Thread support bot running. Ctrl+C to stop.", 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", "")

    # --- New support request: bot mentioned in a watched channel ---
    if (
        event.get("mentions_bot")
        and channel_name in SUPPORT_CHANNELS
        and channel_id not in active_threads
    ):
        # Create a thread from the user's message
        thread = run_discli(
            "thread", "create",
            channel_id,
            message_id,
            f"Support - {author}",
        )

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

            # Send welcome message in the thread
            run_discli(
                "thread", "send",
                thread_id,
                f"Hi {author}! I've created this thread for your request.\n\n"
                f"**Your question:** {content}\n\n"
                f"A team member will respond here shortly. "
                f"Please share any additional details in this thread.",
            )

            print(f"[thread] Created '{thread.get('name')}' for {author}", file=sys.stderr)
        continue

    # --- Follow-up in an active thread ---
    if channel_id in active_threads:
        # Skip bot messages to avoid loops
        if event.get("is_bot"):
            continue

        # Show typing while processing
        subprocess.Popen(
            ["discli", "typing", channel_id, "--duration", "3"],
            stdout=subprocess.DEVNULL,
            stderr=subprocess.DEVNULL,
        )

        # Simple acknowledgment (replace with AI in production)
        thread_info = active_threads[channel_id]
        run_discli(
            "thread", "send",
            channel_id,
            f"Thanks for the additional details, {author}. "
            f"A team member has been notified and will respond soon.",
        )

        print(f"[follow-up] {author} in thread {channel_id}", file=sys.stderr)