"""The /api/report endpoint the Unity SDK posts to.

Multipart form:
  report      application/json  (title, severity, buildVersion, game/scene, device fields, metadata)
  logs        text/plain        (optional)
  screenshot  image/jpeg        (optional)

The game is either sent explicitly (SetGame) or derived here from the active scene path — see
_game_from_scene below.
Header:
  X-Api-Key   the project's write-only key

Design: this is the only unauthenticated-ish write path in the app, so it is defensive —
key hash lookup, per-key rate limit, size caps, and it never trusts client filenames.
"""
import json
import os
import struct
import time

from flask import Blueprint, current_app, jsonify, request

from . import db

bp = Blueprint("ingest", __name__)

UPLOAD_ROOT = os.environ.get("BR_UPLOAD_DIR", "/data/uploads")
MAX_LOG_BYTES = 512 * 1024          # 200 lines should be ~30KB; half a MB is generous
MAX_SHOT_BYTES = 2 * 1024 * 1024    # jpeg q60 of a 1440p frame stays well under this
MAX_THUMB_BYTES = 256 * 1024        # ~400px q55 preview the grid loads instead of the full frame
MAX_CLIP_BYTES = 12 * 1024 * 1024   # packed flipbook frames (last ~20s at 6fps ≈ 1-3MB, capped generously)
MAX_CLIP_FRAMES = 900


def _unpack_clip(data: bytes):
    """Split the SDK's packed clip blob — [u32 count][u32 len]×count][frame bytes…] (little-endian) —
    back into individual JPEG frames. Returns [] on anything malformed (never raises to the caller)."""
    try:
        if len(data) < 4:
            return []
        (count,) = struct.unpack_from("<I", data, 0)
        if not 0 < count <= MAX_CLIP_FRAMES:
            return []
        off = 4
        lengths = []
        for _ in range(count):
            if off + 4 > len(data):
                return []
            (ln,) = struct.unpack_from("<I", data, off)
            off += 4
            lengths.append(ln)
        frames = []
        for ln in lengths:
            if not 0 < ln <= 1_000_000 or off + ln > len(data):
                break
            chunk = data[off:off + ln]
            off += ln
            if chunk[:3] == b"\xff\xd8\xff":   # only keep real JPEGs — we serve these to browsers
                frames.append(chunk)
        return frames
    except Exception:
        return []

# Naive in-process rate limit: {key_hash: [timestamps]}. Fine for a single-instance MVP;
# revisit if Wasmer ever runs multiple replicas.
_recent: dict[str, list[float]] = {}
RATE_LIMIT = 30          # reports
RATE_WINDOW = 60.0       # per minute per key

# Retention runs off the ingest path — there's no scheduler here, and this is exactly when new bytes
# arrive, so growth and cleanup stay coupled. Throttled so it's at most an hourly cost on one report.
_last_purge = 0.0
PURGE_EVERY = 3600.0


# ── scene → game ────────────────────────────────────────────────────────────
# The SDK ships the active scene's asset path, e.g. "Assets/_Games/CRICKET/Scene/Ground.unity".
# Every game lives under "_Games/<Folder>/", so we take the folder right after that marker as the
# game key — more robust than a substring match (plain "Car".contains would also fire on "Carrom").
# Unknown folders pass through as-is, so a new game shows up in the dashboard with no code change here;
# only add a row below when the folder name isn't the label you want to see.
_GAME_MARKER = "_Games/"

# Checked BEFORE folder derivation — for scenes whose "_Games/<folder>" would mislabel them. The app's
# global lobby ("Home") physically lives under the 8Ball pool folder but isn't an 8-ball screen, so match
# its distinctive path and tag it "Lobby" instead. (Substring match; keep fragments specific.)
_SCENE_OVERRIDES = [
    ("MultiplayerSystem/Scenes/Home", "Lobby"),
]

_GAME_NAMES = {
    "CRICKET":          "Cricket",
    "8Ball pool":       "8 Ball Pool",
    "Carrom":           "Carrom",
    "Ludo":             "Ludo",
    "Snokker":          "Snooker",
    "Snake aur Ladder": "Snake & Ladder",
    "12 Beads":         "12 Beads",
    "Highway Racer":    "Highway Racer",
    "1.Horse Riding":   "Horse Racing",
    "Car":              "Car Racing",
}


def _game_from_scene(scene: str) -> str:
    """Folder right after '_Games/' → its display name. Shared scenes (Login, Loading, Connection)
    aren't under _Games and map to '' (no game)."""
    for frag, label in _SCENE_OVERRIDES:
        if frag in scene:
            return label
    i = scene.find(_GAME_MARKER)
    if i == -1:
        return ""
    folder = scene[i + len(_GAME_MARKER):].split("/", 1)[0].strip()
    if not folder:
        return ""
    return _GAME_NAMES.get(folder, folder)[:80]


def _rate_limited(key_hash: str) -> bool:
    cutoff = time.time() - RATE_WINDOW
    stamps = [t for t in _recent.get(key_hash, []) if t > cutoff]
    if len(stamps) >= RATE_LIMIT:
        _recent[key_hash] = stamps
        return True
    stamps.append(time.time())
    _recent[key_hash] = stamps
    return False


@bp.post("/api/report")
def report():
    api_key = request.headers.get("X-Api-Key", "")
    if not api_key.startswith("br_"):
        return jsonify(error="missing or malformed X-Api-Key"), 401

    key_hash = db.hash_api_key(api_key)
    with db.connect() as conn:
        project = conn.execute(
            "SELECT id FROM projects WHERE api_key_hash = ?", (key_hash,)
        ).fetchone()
    if project is None:
        return jsonify(error="unknown api key"), 401
    if _rate_limited(key_hash):
        return jsonify(error="rate limited"), 429

    raw = request.form.get("report")
    if not raw:
        return jsonify(error="missing report part"), 400
    try:
        body = json.loads(raw)
    except json.JSONDecodeError:
        return jsonify(error="report part is not valid JSON"), 400

    title = str(body.get("title") or "").strip()[:200]
    if not title:
        return jsonify(error="title required"), 400
    build_version = str(body.get("buildVersion") or "unknown")[:50]
    # Prefer an explicit game (SetGame) if the SDK sent one; otherwise derive it from the active scene.
    game = str(body.get("game") or "")[:80] or _game_from_scene(str(body.get("scene") or ""))
    session = str(body.get("session") or "")[:80]
    severity = body.get("severity")
    if severity not in ("low", "normal", "high", "crash"):
        severity = "normal"

    logs = request.files.get("logs")
    shot = request.files.get("screenshot")
    thumb = request.files.get("thumbnail")
    clip = request.files.get("clip")

    issue_id = db.new_id()
    issue_dir = os.path.join(UPLOAD_ROOT, project["id"], issue_id)
    has_logs = has_shot = has_clip = 0
    os.makedirs(issue_dir, exist_ok=True)

    if logs is not None:
        data = logs.read(MAX_LOG_BYTES + 1)
        if len(data) <= MAX_LOG_BYTES:
            with open(os.path.join(issue_dir, "logs.txt"), "wb") as f:
                f.write(data)
            has_logs = 1
    if shot is not None:
        data = shot.read(MAX_SHOT_BYTES + 1)
        # JPEG magic check — we serve these back to browsers, so never store an unvalidated blob as an image.
        if len(data) <= MAX_SHOT_BYTES and data[:3] == b"\xff\xd8\xff":
            with open(os.path.join(issue_dir, "screenshot.jpg"), "wb") as f:
                f.write(data)
            has_shot = 1
    if thumb is not None:
        data = thumb.read(MAX_THUMB_BYTES + 1)
        if len(data) <= MAX_THUMB_BYTES and data[:3] == b"\xff\xd8\xff":
            with open(os.path.join(issue_dir, "thumb.jpg"), "wb") as f:
                f.write(data)
    if clip is not None:
        data = clip.read(MAX_CLIP_BYTES + 1)
        if len(data) <= MAX_CLIP_BYTES:
            frames = _unpack_clip(data)
            if frames:
                clip_dir = os.path.join(issue_dir, "clip")
                os.makedirs(clip_dir, exist_ok=True)
                for i, frame in enumerate(frames):
                    with open(os.path.join(clip_dir, f"{i:03d}.jpg"), "wb") as f:
                        f.write(frame)
                has_clip = 1
                # Capture rate lives next to the frames (no DB column needed) so the player runs at real speed.
                try:
                    fps = int(body.get("clipFps") or 0)
                except (TypeError, ValueError):
                    fps = 0
                with open(os.path.join(clip_dir, "fps"), "w") as f:
                    f.write(str(fps if 0 < fps <= 60 else 6))

    ts = db.now()
    metadata = body.get("metadata")
    metadata_json = json.dumps(metadata)[:8192] if isinstance(metadata, dict) else "{}"
    platform = str(body.get("platform") or "")[:40]

    with db.connect() as conn:
        conn.execute(
            """INSERT INTO issues (id, project_id, title, description, severity, status,
                   build_version, game, session, platform, device_model, os_version, screen_resolution,
                   memory_mb, metadata, has_screenshot, has_logs, has_clip, created_at, updated_at)
               VALUES (?,?,?,?,?,'open',?,?,?,?,?,?,?,?,?,?,?,?,?,?)""",
            (
                issue_id, project["id"], title,
                str(body.get("description") or "")[:2000],
                severity, build_version, game, session, platform,
                str(body.get("deviceModel") or "")[:80],
                str(body.get("osVersion") or "")[:80],
                str(body.get("screenResolution") or "")[:20],
                int(body.get("memoryMB") or 0),
                metadata_json, has_shot, has_logs, has_clip, ts, ts,
            ),
        )
        # Build registry: first report from an unseen version creates the row (MySQL upsert).
        conn.execute(
            """INSERT INTO builds (id, project_id, version, platform, first_seen_at, report_count)
               VALUES (?,?,?,?,?,1)
               ON DUPLICATE KEY UPDATE report_count = report_count + 1""",
            (db.new_id(), project["id"], build_version, platform, ts),
        )

    current_app.logger.info("report %s accepted (build %s)", issue_id, build_version)

    global _last_purge
    if time.time() - _last_purge > PURGE_EVERY:
        _last_purge = time.time()          # set first: a failing purge must not retry on every report
        try:
            from . import retention        # imported late — retention imports this module
            current_app.logger.info("retention: %s", retention.purge())
        except Exception as e:             # noqa: BLE001 — never fail a report over housekeeping
            current_app.logger.warning("retention purge failed: %s", e)

    return jsonify(id=issue_id), 201