Monitor Carrier Authority

import requests
import time
from datetime import datetime

API_KEY = "YOUR_API_KEY"
BASE = "https://api.carrierok.com"

def get_monitored_carriers():
    """Fetch the carriers that changed since we last acknowledged them."""
    resp = requests.get(
        f"{BASE}/v2/monitoring/list",
        headers={"Authorization": f"Bearer {API_KEY}"},
    )
    resp.raise_for_status()
    data = resp.json()
    return list(data["items"].keys())

def lookup_carrier(dot_number: str):
    """Fetch a fresh profile for a single carrier."""
    resp = requests.get(
        f"{BASE}/v2/profile",
        params={"dot_number": dot_number},
        headers={"Authorization": f"Bearer {API_KEY}"},
    )
    if resp.status_code == 429:
        time.sleep(2)
        return lookup_carrier(dot_number)
    resp.raise_for_status()
    items = resp.json()["items"]
    return items[0] if items else None

def check_carrier(carrier: dict) -> list[dict]:
    """Run compliance rules against a carrier profile.
    Returns a list of alerts (empty = all clear).
    """
    alerts = []
    dot = carrier["dot_number"]
    name = carrier["legal_name"]

    # 1. Authority status
    if carrier["authority_common"] != "Active":
        alerts.append({
            "severity": "critical",
            "rule": "authority_revoked",
            "message": f"{name} (DOT {dot}): common authority "
                       f"is {carrier['authority_common']}",
        })

    # 2. Insurance coverage
    bipd_on_file = int(carrier.get("insurance_bipd_on_file", 0))
    bipd_required = int(carrier.get("insurance_bipd_required", 0))
    if bipd_required > 0 and bipd_on_file < bipd_required:
        alerts.append({
            "severity": "critical",
            "rule": "insurance_lapse",
            "message": f"{name} (DOT {dot}): BIPD on file "
                       f"(${bipd_on_file:,}) < required (${bipd_required:,})",
        })

    # 3. ISS score spike
    iss = int(carrier.get("iss_value", 0))
    if iss >= 75:
        alerts.append({
            "severity": "high",
            "rule": "iss_high",
            "message": f"{name} (DOT {dot}): ISS score is {iss} "
                       f"(high risk threshold: 75)",
        })

    # 4. Vehicle OOS rate above national average
    veh_oos = float(carrier.get("inspections_vehicle_out_of_service_pct", 0))
    natl_avg = float(carrier.get("natl_avg_oos_vehicle", 0.22))
    if veh_oos > natl_avg * 1.5:
        alerts.append({
            "severity": "medium",
            "rule": "oos_elevated",
            "message": f"{name} (DOT {dot}): vehicle OOS rate "
                       f"{veh_oos:.1%} vs national avg {natl_avg:.1%}",
        })

    # 5. New entrant (< 18 months / 540 days)
    dot_age = int(carrier.get("dot_age", 9999))
    if dot_age < 540:
        alerts.append({
            "severity": "info",
            "rule": "new_entrant",
            "message": f"{name} (DOT {dot}): new entrant — "
                       f"registered {dot_age} days ago",
        })

    return alerts

def run_daily_check():
    """Main monitoring loop."""
    print(f"[{datetime.now():%Y-%m-%d %H:%M}] Starting daily check")

    profile_ids = get_monitored_carriers()
    print(f"  Monitoring {len(profile_ids)} carriers")

    all_alerts = []

    for pid in profile_ids:
        dot = pid.split("-")[0]
        carrier = lookup_carrier(dot)
        if not carrier:
            all_alerts.append({
                "severity": "warning",
                "rule": "not_found",
                "message": f"DOT {dot}: carrier not found",
            })
            continue

        alerts = check_carrier(carrier)
        all_alerts.extend(alerts)

    # Summary
    critical = [a for a in all_alerts if a["severity"] == "critical"]
    print(f"  Finished: {len(all_alerts)} alerts "
          f"({len(critical)} critical)")

    if all_alerts:
        send_alerts(all_alerts)

    return all_alerts

def send_alerts(alerts: list[dict]):
    """Send alerts via your preferred channel."""
    # Replace with your webhook, email, or Slack integration
    for alert in alerts:
        level = alert["severity"].upper()
        print(f"  [{level}] {alert['message']}")

if __name__ == "__main__":
    run_daily_check()