"""Einmaliger Backfill: Laedt die 30 neuesten Artikel einer Lage und generiert
   latest_developments als kompletten Rebuild (previous_developments=None).

   Verwendung: python3 scripts/backfill_latest_developments.py <incident_id> [limit]
"""
import asyncio
import sqlite3
import sys
sys.path.insert(0, "src")

from agents.analyzer import AnalyzerAgent


async def backfill(incident_id: int, limit: int = 30):
    c = sqlite3.connect("data/osint.db")
    c.row_factory = sqlite3.Row

    inc = c.execute("SELECT * FROM incidents WHERE id=?", (incident_id,)).fetchone()
    if not inc:
        print(f"Incident #{incident_id} nicht gefunden.")
        return
    title = inc["title"]
    description = inc["description"] or ""

    rows = c.execute(
        """SELECT id, source, source_url, language, published_at,
                  headline, headline_de, content_original, content_de
           FROM articles WHERE incident_id=?
           ORDER BY datetime(published_at) DESC LIMIT ?""",
        (incident_id, limit),
    ).fetchall()

    # Bias-Anreicherung analog zum Orchestrator (optional, Tabelle evtl. nicht vorhanden)
    bias_by_name: dict[str, str] = {}
    bias_by_domain: dict[str, str] = {}
    try:
        bias_rows = c.execute("SELECT name, domain, bias FROM source_bias").fetchall()
        bias_by_name = {r["name"].lower(): r["bias"] for r in bias_rows if r["name"]}
        bias_by_domain = {r["domain"].lower(): r["bias"] for r in bias_rows if r["domain"]}
    except sqlite3.OperationalError:
        pass

    articles = []
    for r in rows:
        a = dict(r)
        src = (a.get("source") or "").lower()
        url = (a.get("source_url") or "").lower()
        bias = bias_by_name.get(src)
        if not bias:
            for dom, b in bias_by_domain.items():
                if dom and dom in url:
                    bias = b
                    break
        if bias:
            a["source_bias"] = bias
        articles.append(a)

    print(f"Backfill fuer #{incident_id} {title!r}")
    print(f"Artikel als Input: {len(articles)} (neueste first)")
    for a in articles[:5]:
        print(f"  ID {a['id']} | {a.get('published_at', '?')} | {a.get('source', '?')}")

    analyzer = AnalyzerAgent()
    dev_text, usage = await analyzer.generate_latest_developments(
        title=title,
        description=description,
        new_articles=articles,
        previous_developments=None,
    )

    print()
    print("=== Neue latest_developments ===")
    print(dev_text or "(leer)")

    if dev_text:
        c.execute("UPDATE incidents SET latest_developments=? WHERE id=?", (dev_text, incident_id))
        c.commit()
        print(f"\nDB aktualisiert: Incident #{incident_id}")


if __name__ == "__main__":
    if len(sys.argv) < 2:
        print("Usage: backfill_latest_developments.py <incident_id> [limit]")
        sys.exit(1)
    iid = int(sys.argv[1])
    lim = int(sys.argv[2]) if len(sys.argv) > 2 else 30
    asyncio.run(backfill(iid, lim))