#!/usr/bin/env bash
#
# File: .claude/hooks/tts-queue.sh
#
# TTS Queue Manager for Party Mode
# Queues TTS requests and plays them sequentially in the background
# This allows Claude to continue generating responses while audio plays in order

set -euo pipefail

# Security: Use secure temp directory with restrictive permissions
# Check if XDG_RUNTIME_DIR is available (more secure than /tmp)
if [[ -n "${XDG_RUNTIME_DIR:-}" ]] && [[ -d "$XDG_RUNTIME_DIR" ]]; then
  QUEUE_DIR="$XDG_RUNTIME_DIR/agentvibes-tts-queue"
else
  # Fallback to user-specific temp directory
  QUEUE_DIR="/tmp/agentvibes-tts-queue-$(id -u)"
fi

QUEUE_LOCK="$QUEUE_DIR/queue.lock"
WORKER_PID_FILE="$QUEUE_DIR/worker.pid"

# Get script directory
SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"

# Initialize queue directory with restrictive permissions
if [[ ! -d "$QUEUE_DIR" ]]; then
  mkdir -p "$QUEUE_DIR"
  chmod 700 "$QUEUE_DIR"  # Only owner can read/write/execute
fi

# @function add_to_queue
# @intent Add a TTS request to the queue for sequential playback
# @param $1 dialogue text
# @param $2 voice name (optional)
# @param $3 agent name (optional, for background music in party mode)
# @param $4 agent profile path (optional, PID-scoped temp JSON with reverb/personality/music overrides)
add_to_queue() {
  local text="$1"
  local voice="${2:-}"
  local agent="${3:-default}"
  local profile_path="${4:-}"

  # Create unique queue item with timestamp
  local timestamp=$(date +%s%N)
  local queue_file="$QUEUE_DIR/$timestamp.queue"

  # Write request to queue file using direct storage
  # Text is stored in a separate .txt file (handles newlines and special chars safely)
  # Voice and agent are simple identifiers with no special chars
  printf '%s' "$text" > "${queue_file%.queue}.txt"
  cat > "$queue_file" <<EOF
TEXT_FILE=${queue_file%.queue}.txt
VOICE=$voice
AGENT=$agent
PROFILE_PATH=$profile_path
EOF

  # Start queue worker if not already running
  start_worker_if_needed
}

# @function start_worker_if_needed
# @intent Start the queue worker process if it's not already running
start_worker_if_needed() {
  # Security: Use file locking to prevent race condition
  # Open file descriptor 200 for locking
  exec 200>"$QUEUE_LOCK"

  # Acquire exclusive lock (flock -x) with timeout
  if ! flock -x -w 5 200; then
    echo "Warning: Could not acquire queue lock" >&2
    return 1
  fi

  # Check if worker is already running (within lock)
  if [[ -f "$WORKER_PID_FILE" ]]; then
    local pid=$(cat "$WORKER_PID_FILE")
    if kill -0 "$pid" 2>/dev/null; then
      # Worker is running, release lock and return
      flock -u 200
      exec 200>&-
      return 0
    fi
  fi

  # Start worker in background
  "$SCRIPT_DIR/tts-queue-worker.sh" &
  local worker_pid=$!
  echo $worker_pid > "$WORKER_PID_FILE"

  # Release lock
  flock -u 200
  exec 200>&-
}

# @function clear_queue
# @intent Clear all pending TTS requests (emergency stop)
clear_queue() {
  rm -f "$QUEUE_DIR"/*.queue
  echo "✅ Queue cleared"
}

# @function show_queue
# @intent Display current queue status
show_queue() {
  local count=$(ls -1 "$QUEUE_DIR"/*.queue 2>/dev/null | wc -l)
  echo "📊 Queue status: $count items pending"

  if [[ -f "$WORKER_PID_FILE" ]]; then
    local pid=$(cat "$WORKER_PID_FILE")
    if kill -0 "$pid" 2>/dev/null; then
      echo "✅ Worker process running (PID: $pid)"
    else
      echo "❌ Worker process not running"
    fi
  else
    echo "❌ Worker process not running"
  fi
}

# @function play_wav
# @intent Queue a pre-generated WAV file for sequential playback
# @param $1 path to WAV file
play_wav() {
  local wav_file="$1"
  [[ -z "$wav_file" ]] && return 1
  [[ ! -f "$wav_file" ]] && return 1

  local timestamp=$(date +%s%N)
  local queue_file="$QUEUE_DIR/$timestamp.queue"

  # Write a playback-only queue item (no synthesis needed)
  cat > "$queue_file" <<EOF
PLAY_WAV=$wav_file
EOF

  start_worker_if_needed
}

# Main command dispatcher
case "${1:-help}" in
  add)
    add_to_queue "${2:-}" "${3:-}" "${4:-default}" "${5:-}"
    ;;
  play)
    play_wav "${2:-}"
    ;;
  clear)
    clear_queue
    ;;
  status)
    show_queue
    ;;
  *)
    echo "Usage: tts-queue.sh {add|play|clear|status}"
    echo ""
    echo "Commands:"
    echo "  add <text> [voice] [agent]  Add TTS request to queue"
    echo "  play <wav_file>             Queue a pre-generated WAV for playback"
    echo "  clear                       Clear all pending requests"
    echo "  status                      Show queue status"
    exit 1
    ;;
esac