import assert from "node:assert/strict";
import { test } from "node:test";
import { pickForForward, resetAbrpState, toTlm } from "../src/lib/abrp.ts";
import { ValidationError, validateTelemetryBatch } from "../src/lib/validate.ts";

const INSTALLATION = "6f1a2b3c-4d5e-4f60-8a9b-0c1d2e3f4a5b";
const NOW_S = 1_790_000_000;

test("accepts a sample in ABRP's field names and keeps only what was sent", () => {
  const batch = validateTelemetryBatch({
    installationId: INSTALLATION,
    samples: [{ utc: NOW_S, soc: 81, power: -12.5, speed: 0, lat: 52.1, lon: 7.6, is_charging: 1, is_dcfc: false }],
  });
  assert.deepEqual(batch.samples[0], {
    utc: NOW_S, soc: 81, power: -12.5, speed: 0, lat: 52.1, lon: 7.6, is_charging: true, is_dcfc: false,
  });
  // An unread signal stays absent: a missing SOC must never become 0.
  assert.equal("est_battery_range" in batch.samples[0], false);
});

test("drops unknown fields instead of rejecting the batch", () => {
  const batch = validateTelemetryBatch({ installationId: INSTALLATION, samples: [{ utc: NOW_S, future_field: 3 }] });
  assert.deepEqual(batch.samples[0], { utc: NOW_S });
});

test("rejects bad timestamps, out-of-range values, bad flags and half positions", () => {
  const send = (sample: object) => validateTelemetryBatch({ installationId: INSTALLATION, samples: [sample] });
  assert.throws(() => send({ utc: NOW_S * 1000 }), ValidationError); // milliseconds, not seconds
  assert.throws(() => send({ utc: 1.5 }), ValidationError);
  assert.throws(() => send({ utc: NOW_S, soc: 101 }), ValidationError);
  assert.throws(() => send({ utc: NOW_S, speed: "fast" }), ValidationError);
  assert.throws(() => send({ utc: NOW_S, is_parked: 2 }), ValidationError);
  assert.throws(() => send({ utc: NOW_S, lat: 52.1 }), ValidationError);
});

test("rejects empty and oversized batches and bad installation ids", () => {
  assert.throws(() => validateTelemetryBatch({ installationId: INSTALLATION, samples: [] }), ValidationError);
  const many = Array.from({ length: 501 }, (_, i) => ({ utc: NOW_S + i }));
  assert.throws(() => validateTelemetryBatch({ installationId: INSTALLATION, samples: many }), ValidationError);
  assert.throws(() => validateTelemetryBatch({ installationId: "nope", samples: [{ utc: NOW_S }] }), ValidationError);
});

test("ABRP gets flags as 0/1", () => {
  assert.deepEqual(toTlm({ utc: NOW_S, soc: 50, is_charging: true, is_parked: false }), {
    utc: NOW_S, soc: 50, is_charging: 1, is_parked: 0,
  });
});

test("forwards only the newest fresh sample, at most once per interval", () => {
  resetAbrpState();
  const nowMs = NOW_S * 1000;
  const picked = pickForForward([{ utc: NOW_S - 10 }, { utc: NOW_S - 2 }, { utc: NOW_S - 5 }], nowMs);
  assert.equal(picked?.utc, NOW_S - 2);
  // A sample from ten minutes ago describes a car that has moved on.
  assert.equal(pickForForward([{ utc: NOW_S - 600 }], nowMs), null);
});