"""Complete servers.domain_ltd depuis qualys_assets.fqdn.

Pour chaque serveur sans domain_ltd renseigne, extrait le domaine
(tout ce qui suit le 1er point) depuis le FQDN Qualys.

Ex: fqdn='vposapapp1.sanef.groupe' -> domain_ltd='sanef.groupe'

Usage:
    python tools/import_domain_ltd_from_qualys.py [--dry-run] [--overwrite]
"""
import os
import argparse
from sqlalchemy import create_engine, text

DATABASE_URL = os.getenv("DATABASE_URL_DEMO") or os.getenv("DATABASE_URL") \
    or "postgresql://patchcenter:PatchCenter2026!@localhost:5432/patchcenter_demo"


def main():
    parser = argparse.ArgumentParser()
    parser.add_argument("--dry-run", action="store_true")
    parser.add_argument("--overwrite", action="store_true",
                        help="Remplace domain_ltd existant (sinon ne remplit que les vides)")
    args = parser.parse_args()

    engine = create_engine(DATABASE_URL)
    print(f"[INFO] DB: {DATABASE_URL.split('@')[-1]}")
    conn = engine.connect().execution_options(isolation_level="AUTOCOMMIT")

    where_clause = "" if args.overwrite else "AND (s.domain_ltd IS NULL OR s.domain_ltd = '')"

    rows = conn.execute(text(f"""
        SELECT s.id as sid, s.hostname, s.domain_ltd, qa.fqdn
        FROM servers s
        JOIN qualys_assets qa ON (qa.server_id = s.id
                                  OR LOWER(qa.hostname) = LOWER(s.hostname))
        WHERE qa.fqdn IS NOT NULL
          AND qa.fqdn != ''
          AND qa.fqdn LIKE '%.%'
          {where_clause}
    """)).fetchall()
    print(f"[INFO] {len(rows)} candidats")

    updated = skipped = unchanged = 0
    for r in rows:
        # Extract domain = tout apres le 1er point du FQDN
        parts = r.fqdn.split(".", 1)
        if len(parts) != 2 or not parts[1]:
            skipped += 1
            continue
        new_domain = parts[1].strip().lower()[:50]
        if not new_domain:
            skipped += 1
            continue
        if r.domain_ltd == new_domain:
            unchanged += 1
            continue
        if args.dry_run:
            print(f"  DRY: {r.hostname:25s}  {r.domain_ltd or '(vide)':20s} -> {new_domain}")
        else:
            conn.execute(text("UPDATE servers SET domain_ltd=:d WHERE id=:sid"),
                         {"d": new_domain, "sid": r.sid})
        updated += 1

    conn.close()
    print(f"\n[DONE] Maj: {updated} | Inchanges: {unchanged} | Skip: {skipped}")


if __name__ == "__main__":
    main()