Vehicle Health Dashboard

import os, requests

API_BASE   = "https://api.telemax.com.au"
COMPANY_ID = 85
VEHICLE_IDS = [1000, 1001, 1002]   # replace with your fleet

# — fetch helpers (get_token() assumed from authentication module) —

def build_health_record(vehicle_id: int, token: str) -> dict:
    pos     = get_position(vehicle_id, token)
    battery = {b["vehicleId"]: b for b in get_all_battery_health(COMPANY_ID, token)}
    dtcs    = get_dtc_codes(vehicle_id, token)

    batt_entry = battery.get(vehicle_id, {})
    top_pred   = next(
        (p for p in sorted(
            batt_entry.get("predictionResults", []),
            key=lambda p: p.get("predictionForDay", 0)
        )),
        None,
    )

    return {
        "name":       pos.get("DeviceName", str(vehicle_id)),
        "voltage_v":  pos.get("Voltage"),
        "ignition":   pos.get("Ignition"),
        "speed_kmh":  pos.get("Speed"),
        "odometer_km": pos.get("Odometer"),
        "last_seen":  pos.get("UtcTime"),
        "battery_pred": top_pred["BatteryPredictionValue"] if top_pred else "N/A",
        "dtc_codes":  dtcs,
    }

token = get_token()
print(f"{'Vehicle':<25} {'V':>5} {'Ign':<5} {'Battery':>8} {'DTCs'}")
print("-" * 60)
for vid in VEHICLE_IDS:
    h = build_health_record(vid, token)
    dtc_str = ", ".join(h["dtc_codes"]) or "none"
    ign_str = "ON" if h["ignition"] else "off"
    print(
        f"{h['name']:<25} {h['voltage_v']:>5.1f} {ign_str:<5} "
        f"{h['battery_pred']:>8}  {dtc_str}"
    )

const API_BASE = "https://api.telemax.com.au";
const COMPANY_ID = 85;
const VEHICLE_IDS = [1000, 1001, 1002];

// getToken() assumed available from your auth module

async function getPosition(vehicleId, token) {
  const res = await fetch(`${API_BASE}/api/GetLastPositionData?id=${vehicleId}`, {
    method: "POST",
    headers: { Authorization: `Bearer ${token}` },
  });
  return res.json();
}

async function getAllBatteryHealth(companyId, token) {
  const items = [];
  let page = 1;
  while (true) {
    const res = await fetch(
      `${API_BASE}/api/GetCompanyVehiclesBatteryHealth?compId=${companyId}&page=${page}&pageSize=50`,
      { method: "POST", headers: { Authorization: `Bearer ${token}` } },
    );
    const data = await res.json();
    items.push(...(data.items ?? []));
    if (page >= (data.numberOfPages ?? 1)) break;
    page++;
  }
  return Object.fromEntries(items.map(b => [b.vehicleId, b]));
}

async function getDtcCodes(vehicleId, token) {
  const res = await fetch(`${API_BASE}/api/devices/${vehicleId}/dtc-codes`, {
    headers: { Authorization: `Bearer ${token}` },
  });
  const raw = await res.json();  // array-of-arrays
  const codes = [...new Set(raw.flat().map(d => d.code).filter(Boolean))];
  return codes;
}

async function buildDashboard() {
  const token = await getToken();
  const batteryMap = await getAllBatteryHealth(COMPANY_ID, token);

  const records = await Promise.all(
    VEHICLE_IDS.map(async (vid) => {
      const [pos, dtcs] = await Promise.all([
        getPosition(vid, token),
        getDtcCodes(vid, token),
      ]);
      const batt = batteryMap[vid];
      const topPred = batt?.predictionResults?.sort(
        (a, b) => a.predictionForDay - b.predictionForDay
      )[0];
      return {
        name:        pos.DeviceName ?? String(vid),
        voltageV:    pos.Voltage,
        ignition:    pos.Ignition,
        batteryPred: topPred?.BatteryPredictionValue ?? "N/A",
        dtcCodes:    dtcs,
        lastSeen:    pos.UtcTime,
      };
    }),
  );

  console.table(records.map(r => ({
    Vehicle:    r.name,
    "V":        r.voltageV?.toFixed(1),
    Ignition:   r.ignition ? "ON" : "off",
    Battery:    r.batteryPred,
    DTCs:       r.dtcCodes.join(", ") || "none",
    "Last seen": r.lastSeen,
  })));
}

buildDashboard();