"""Live satellite-camera tracker. Re-propagates imaging-satellite positions to 'now' every

INTERVAL seconds (locally, from cached orbital elements - no network spam), upserts the latest

position into live_entities, and appends to entity_positions so each satellite has a moving

ground track. Prunes position history beyond RETAIN_MINUTES.

"""

from __future__ import annotations

import signal

import time

from datetime import datetime, timedelta, timezone

from sqlalchemy import delete, select

from sqlalchemy.dialects.postgresql import insert as pg_insert

from app.db.session import SessionLocal

from app.models import EntityPosition, LiveEntity

from app.services.realsources import imaging_satellites

INTERVAL = 30

RETAIN_MINUTES = 180

_running = True

def _stop(*_):

    global _running

    _running = False

def main():

    signal.signal(signal.SIGTERM, _stop)

    signal.signal(signal.SIGINT, _stop)

    db = SessionLocal()

    print(f"satellite tracker started (every {INTERVAL}s)", flush=True)

    while _running:

        try:

            sats = imaging_satellites()

            now = datetime.now(timezone.utc)

            for s in sats:

                stmt = pg_insert(LiveEntity).values(

                    kind="satellite_camera", source=s["source"], identifier=s["identifier"],

                    label=s["label"], lat=s["lat"], lon=s["lon"], altitude_m=s["altitude_m"],

                    origin_country=None, attributes=s["attributes"], observed_at=now)

                stmt = stmt.on_conflict_do_update(

                    index_elements=["source", "identifier"],

                    set_={"lat": s["lat"], "lon": s["lon"], "altitude_m": s["altitude_m"],

                          "observed_at": now})

                db.execute(stmt)

            if sats:

                db.execute(EntityPosition.__table__.insert(),

                           [{"identifier": s["identifier"], "kind": "satellite_camera",

                             "lat": s["lat"], "lon": s["lon"], "altitude_m": s["altitude_m"],

                             "observed_at": now} for s in sats])

            db.execute(delete(EntityPosition).where(

                EntityPosition.observed_at < now - timedelta(minutes=RETAIN_MINUTES)))

            db.commit()

            print(f"propagated {len(sats)} satellite cameras @ {now.strftime('%H:%M:%S')}", flush=True)

        except Exception as e:

            print(f"sat tracker error: {e}", flush=True)

            db.rollback()

        for _ in range(INTERVAL):

            if not _running:

                break

            time.sleep(1)

    db.close()

if __name__ == "__main__":

    main()