#!/usr/bin/env python3
"""Synchronisiert data/regions/de_regions.json in die Tabelle license_plate_regions.

Nutzung:  python scripts/import_regions.py
Die JSON bleibt die fuehrende Quelle; die DB-Tabelle dient der Admin-Pflege/Abfrage.
"""
import json
import sys
from pathlib import Path

sys.path.insert(0, str(Path(__file__).resolve().parent.parent))

from app.config import settings  # noqa: E402
from app.database.base import SessionLocal, Base, engine  # noqa: E402
from app.database.models import LicensePlateRegion  # noqa: E402


def main() -> None:
    Base.metadata.create_all(bind=engine)
    path = settings.path(settings.regions_de_file)
    data = json.loads(Path(path).read_text(encoding="utf-8"))
    regions = data.get("regions", {})

    db = SessionLocal()
    inserted = updated = 0
    try:
        for code, info in regions.items():
            row = (db.query(LicensePlateRegion)
                   .filter_by(country_code="DE", code=code).first())
            if row:
                row.name = info.get("name")
                row.state = info.get("state")
                row.active = True
                updated += 1
            else:
                db.add(LicensePlateRegion(
                    country_code="DE", code=code,
                    name=info.get("name"), state=info.get("state"), active=True,
                ))
                inserted += 1
        db.commit()
    finally:
        db.close()
    print(f"Regionen importiert: {inserted} neu, {updated} aktualisiert "
          f"(gesamt {len(regions)}).")


if __name__ == "__main__":
    main()