#!/usr/bin/env bash
set -euo pipefail

if [ -z "${BASE_URL:-}" ]; then
  if curl --silent --fail http://127.0.0.1:8085/api/health >/dev/null 2>&1; then
    BASE_URL="http://127.0.0.1:8085"
  elif curl --silent --fail http://host.containers.internal:8085/api/health >/dev/null 2>&1; then
    BASE_URL="http://host.containers.internal:8085"
  else
    echo "ERROR: could not determine BASE_URL. Tried 127.0.0.1 and host.containers.internal." >&2
    exit 1
  fi
fi

if [ -z "${TEST_MEDIA_ROOT:-}" ]; then
  for candidate in \
    "/Volumes/8TB/Shared_Folders/TV_Shows" \
    "/Volumes/8TB_RAID1/Shared_Folders/Library/TV_Shows"
  do
    if [ -d "$candidate" ] && [ -w "$candidate" ]; then
      TEST_MEDIA_ROOT="$candidate"
      break
    fi
  done
fi

if [ -z "${TEST_MEDIA_ROOT:-}" ]; then
  echo "ERROR: no writable allowed media root found. Set TEST_MEDIA_ROOT." >&2
  exit 1
fi

TEST_DIR="${TEST_MEDIA_ROOT}/_rename_mvp_phase7_$(date +%s)_$$"
mkdir -p "${TEST_DIR}"

TMP_DIR="$(mktemp -d)"
trap 'rm -rf "$TMP_DIR"' EXIT

clear_session() {
  local sid="$1"
  curl --fail --silent --show-error -X DELETE \
    "${BASE_URL}/api/session/selected-episodes?session_id=${sid}" \
    >/dev/null
  curl --fail --silent --show-error -X DELETE \
    "${BASE_URL}/api/session/selected-files?session_id=${sid}" \
    >/dev/null
}

add_payloads() {
  local sid="$1"
  local file1="$2"
  local file2="$3"

  cat > "${TMP_DIR}/episodes_${sid}.json" <<'JSON'
{
  "items": [
    {
      "id": 1,
      "series": "Elsbeth",
      "year": "2024",
      "season_number": 1,
      "episode_number": 1,
      "title": "Pilot"
    },
    {
      "id": 2,
      "series": "Elsbeth",
      "year": "2024",
      "season_number": 1,
      "episode_number": 2,
      "title": "Second Episode"
    }
  ]
}
JSON

  cat > "${TMP_DIR}/files_${sid}.json" <<JSON
{
  "items": [
    {
      "path": "${file1}",
      "name": "$(basename "${file1}")"
    },
    {
      "path": "${file2}",
      "name": "$(basename "${file2}")"
    }
  ]
}
JSON

  curl --fail --silent --show-error \
    -X POST "${BASE_URL}/api/session/selected-episodes?session_id=${sid}" \
    -H "Content-Type: application/json" \
    --data @"${TMP_DIR}/episodes_${sid}.json" \
    >/dev/null

  curl --fail --silent --show-error \
    -X POST "${BASE_URL}/api/session/selected-files?session_id=${sid}" \
    -H "Content-Type: application/json" \
    --data @"${TMP_DIR}/files_${sid}.json" \
    >/dev/null
}

echo "== Feature test 1: successful rename run is logged with duration =="
SESSION_OK="rename-log-ok-$(date +%s)-$$"
SRC1="${TEST_DIR}/ok_src1.mkv"
SRC2="${TEST_DIR}/ok_src2.mp4"
printf "a" > "${SRC1}"
printf "b" > "${SRC2}"

clear_session "${SESSION_OK}"
add_payloads "${SESSION_OK}" "${SRC1}" "${SRC2}"

curl --fail --silent --show-error \
  -X POST "${BASE_URL}/api/session/rename-execute?session_id=${SESSION_OK}&confirm=true" \
  -o "${TMP_DIR}/rename_ok.json"

curl --fail --silent --show-error \
  "${BASE_URL}/api/session/rename-log?session_id=${SESSION_OK}" \
  -o "${TMP_DIR}/log_ok.json"

cat "${TMP_DIR}/log_ok.json"

python3 - "${TMP_DIR}/log_ok.json" > "${TMP_DIR}/run_id_ok.txt" <<'PY'
import json
import sys
from pathlib import Path

data = json.loads(Path(sys.argv[1]).read_text(encoding="utf-8"))
items = data.get("items", [])
assert len(items) >= 1, "expected at least one logged run"
run = items[0]
assert run.get("executed") is True, "expected executed=true"
assert run.get("preflight_ok") is True, "expected preflight_ok=true"
assert isinstance(run.get("duration_ms"), int), "duration_ms must be int"
assert run["duration_ms"] >= 0, "duration_ms must be >= 0"
assert run.get("items_count") == 2, "expected 2 item logs"
print(run["run_id"])
PY

RUN_ID_OK="$(cat "${TMP_DIR}/run_id_ok.txt")"

echo
echo "== Feature test 2: preflight-failed run is also logged =="
SESSION_FAIL="rename-log-fail-$(date +%s)-$$"
SRC3="${TEST_DIR}/fail_src1.mkv"
SRC4="${TEST_DIR}/fail_src2.mp4"
printf "c" > "${SRC3}"
printf "d" > "${SRC4}"

# Force destination conflict for first mapping.
CONFLICT1="${TEST_DIR}/Elsbeth (2024) - S01E01 - Pilot.mkv"
printf "existing" > "${CONFLICT1}"

clear_session "${SESSION_FAIL}"
add_payloads "${SESSION_FAIL}" "${SRC3}" "${SRC4}"

curl --fail --silent --show-error \
  -X POST "${BASE_URL}/api/session/rename-execute?session_id=${SESSION_FAIL}&confirm=true" \
  -o "${TMP_DIR}/rename_fail.json"

curl --fail --silent --show-error \
  "${BASE_URL}/api/session/rename-log?session_id=${SESSION_FAIL}" \
  -o "${TMP_DIR}/log_fail.json"

cat "${TMP_DIR}/log_fail.json"

python3 - "${TMP_DIR}/log_fail.json" > "${TMP_DIR}/run_id_fail.txt" <<'PY'
import json
import sys
from pathlib import Path

data = json.loads(Path(sys.argv[1]).read_text(encoding="utf-8"))
items = data.get("items", [])
assert len(items) >= 1, "expected at least one logged run"
run = items[0]
assert run.get("executed") is False, "expected executed=false"
assert run.get("preflight_ok") is False, "expected preflight_ok=false"
assert isinstance(run.get("duration_ms"), int), "duration_ms must be int"
assert run["duration_ms"] >= 0, "duration_ms must be >= 0"
print(run["run_id"])
PY

RUN_ID_FAIL="$(cat "${TMP_DIR}/run_id_fail.txt")"

echo
echo "== Feature test 3: run detail endpoint returns item statuses and errors =="
curl --fail --silent --show-error \
  "${BASE_URL}/api/session/rename-log/${RUN_ID_FAIL}" \
  -o "${TMP_DIR}/run_detail_fail.json"

cat "${TMP_DIR}/run_detail_fail.json"

python3 - "${TMP_DIR}/run_detail_fail.json" <<'PY'
import json
import sys
from pathlib import Path

data = json.loads(Path(sys.argv[1]).read_text(encoding="utf-8"))
assert data.get("executed") is False, "detail should show executed=false"
assert data.get("preflight_ok") is False, "detail should show preflight_ok=false"
assert isinstance(data.get("duration_ms"), int), "detail duration_ms must be int"
items = data.get("items", [])
assert len(items) == 2, "expected 2 item details"
assert any("destination file already exists" in " ".join(i.get("errors", [])) for i in items), \
    "expected destination conflict error in item details"
print("rename-log detail validation passed")
PY

echo
echo "All rename log feature tests passed."