Vehicle Health Dashboard

def battery_by_imei(rows):
    """Battery rows keyed by IMEI. vehicleId here is the internal ID, so it cannot be matched to deviceId."""
    by_imei = {}
    for row in rows:
        if row.get("imei"):
            by_imei.setdefault(row["imei"], []).append(row)
    return by_imei


def build_health_record(vehicle_id, battery_map):
    pos = get_position(vehicle_id)
    codes = get_engine_codes(vehicle_id)
    record = {"vehicle": vehicle_id, "name": None, "voltage_v": None, "ignition": None, "last_record": None,
              "band": None, "score": None, "days_to_replace": None, "battery_note": None,
              "engine_codes": [c["code"] for c in codes]}
    if pos is None:
        record["battery_note"] = "no last position, so no IMEI to match battery data"
        return record
    record.update(name=pos.get("deviceName"), voltage_v=pos.get("voltage"), ignition=pos.get("ignition"),
                  last_record=pos.get("utcTime"))
    imei = pos.get("imei")
    matches = battery_map.get(imei, []) if imei else []
    if not imei:
        record["battery_note"] = "vehicle has no IMEI; battery data cannot be matched"
    elif len(matches) > 1:
        record["battery_note"] = f"IMEI {imei} is shared by {len(matches)} battery rows; not matched"
    elif matches:
        batt = matches[0]
        if batt.get("vehicleName") != pos.get("deviceName"):
            record["battery_note"] = "battery row name differs from the vehicle name; check the match"
        record.update(band=batt.get("band"), score=batt.get("score"), days_to_replace=batt.get("daysToReplace"))
    return record

def main():
    battery_map = battery_by_imei(get_all_battery_health())
    print(f"{'Vehicle':<32} {'V':>5} {'Ign':<4} {'Band':<10} {'Engine codes'}")
    for vid in VEHICLE_IDS:                      # one vehicle at a time
        h = build_health_record(vid, battery_map)
        volts = f"{h['voltage_v']:.1f}" if h["voltage_v"] is not None else "-"
        ign = "-" if h["ignition"] is None else ("ON" if h["ignition"] else "off")
        print(f"{(h['name'] or str(vid)):<32} {volts:>5} {ign:<4} {(h['band'] or 'N/A'):<10} "
              f"{', '.join(h['engine_codes']) or 'none'}{'  (' + h['battery_note'] + ')' if h['battery_note'] else ''}")


if __name__ == "__main__":
    main()

// Save as diagnostics.mjs and run with Node 18+ (an ES module: it uses top-level await).
const API_BASE = process.env.TELEMAX_API_BASE ?? "https://api.telemax.com.au";
const API_KEY = process.env.TELEMAX_API_KEY;
// Public vehicle IDs (deviceId) — the IDs every /v2/api/vehicles/{id} route takes.
const VEHICLE_IDS = (process.env.TELEMAX_VEHICLE_IDS ?? "1000,1001,1002").split(",").map(Number);

let token = null, tokenExpiresAt = 0;

async function getToken() {
  if (token && Date.now() < tokenExpiresAt - 300_000) return token;
  const res = await fetch(`${API_BASE}/v2/api/authentication/token/api-key`, {
    method: "POST",
    headers: { "Content-Type": "application/x-www-form-urlencoded" },
    body: new URLSearchParams({ apiKey: API_KEY }),
  });
  if (!res.ok) throw new Error(`Token request failed: HTTP ${res.status}`);
  const body = await res.json();
  token = body.access_token;
  tokenExpiresAt = Date.now() + body.expires_in * 1000;
  return token;
}

// One GET. Waits out a short 429; stops when an hourly or daily budget is exhausted.
async function request(path, params = {}) {
  for (;;) {
    const res = await fetch(`${API_BASE}${path}?${new URLSearchParams(params)}`,
                            { headers: { Authorization: `Bearer ${await getToken()}` } });
    if (res.status === 429) {
      const wait = Number(res.headers.get("Retry-After") ?? 1);
      if (wait >= 3600) throw new Error(`Rate-limit budget exhausted (Retry-After: ${wait} s); try again later`);
      await new Promise((r) => setTimeout(r, wait * 1000));
      continue;
    }
    if (!res.ok) throw new Error(`HTTP ${res.status} for ${path}`);
    return res;
  }
}

// Latest record for one vehicle, or null for an empty 200 body (no stored position, or no completed ignition period yet).
async function getPosition(vehicleId) {
  const text = await (await request(`/v2/api/vehicles/${vehicleId}/last-position`)).text();
  return text ? JSON.parse(text) : null;
}

// Battery health pages with pageNumber (not page). vehicleId here is the internal ID, so key rows by IMEI.
async function getBatteryByImei() {
  const byImei = new Map();
  for (let pageNumber = 1, pageSize = 25; ; pageNumber++) {
    const data = await (await request("/v2/api/battery-health", { pageNumber, pageSize })).json();
    const batch = data.items ?? [];
    for (const row of batch) if (row.imei) byImei.set(row.imei, [...(byImei.get(row.imei) ?? []), row]);
    if (!batch.length || pageNumber * pageSize >= (data.totalCount ?? 0)) return byImei;
  }
}

// Codes first reported in the vehicle's latest engine-fault record. items is null when there is none.
async function getEngineCodes(vehicleId) {
  const codes = [];
  for (let page = 1; ; page++) {
    const data = await (await request(`/v2/api/vehicles/${vehicleId}/engine-codes`, { page, pageSize: 50 })).json();
    codes.push(...(data.items ?? []));
    if (page >= (data.numberOfPages || 1)) return codes;
  }
}

async function buildDashboard() {
  const batteryByImei = await getBatteryByImei();
  const rows = [];
  for (const vid of VEHICLE_IDS) {                       // one vehicle at a time
    const pos = await getPosition(vid);
    const codes = await getEngineCodes(vid);
    const matches = pos?.imei ? batteryByImei.get(pos.imei) ?? [] : [];
    let note = "";
    if (!pos) note = "no last position, so no IMEI to match battery data";
    else if (!pos.imei) note = "vehicle has no IMEI; battery data cannot be matched";
    else if (matches.length > 1) note = `IMEI ${pos.imei} is shared by ${matches.length} battery rows; not matched`;
    const batt = matches.length === 1 ? matches[0] : null;
    if (batt && batt.vehicleName !== pos.deviceName) note = "battery row name differs from the vehicle name; check the match";
    rows.push({
      Vehicle: pos?.deviceName ?? String(vid),
      V: pos?.voltage != null ? pos.voltage.toFixed(1) : "-",
      Ignition: pos == null ? "-" : pos.ignition ? "ON" : "off",
      Band: batt?.band ?? "N/A",
      "Engine codes": codes.map((c) => c.code).join(", ") || "none",
      Note: note,
    });
  }
  console.table(rows);
}

await buildDashboard();