Integrating from a TMS, ERP or WMS

import { randomUUID } from "node:crypto";

const BASE = "https://<your-host>/api/v1/partners/addons/route-optimization";
const headers = { "api-key": process.env.ROUTE4GREEN_API_KEY! };

// Shaped like the Pilot data template: one row per site, one row per
// vehicle, one row per order leg (direction "pickup" or "drop").
type Site = { site_code: string; address: string; lat: number; lon: number };
type Vehicle = {
  external_id: string;
  depot_code: string;
  capacity_kg: number;
  // Parsed once from the sheet's single shift_availability value.
  shiftFrom: string;
  shiftTo: string;
};
type OrderLeg = {
  external_id: string;
  direction: "pickup" | "drop";
  site_code: string;
  weight_kg: number;
  package_count: number;
  ready_time: string;
  due_time: string;
};

function buildJobBody(sites: Site[], vehicles: Vehicle[], orderLegs: OrderLeg[]) {
  const siteByCode = new Map(sites.map((site) => [site.site_code, site]));

  const jobVehicles = vehicles.map((vehicle) => {
    const depot = siteByCode.get(vehicle.depot_code)!;
    return {
      external_vehicle_id: vehicle.external_id,
      resource_id: 1, // assigned by your integration, not in the workbook
      from_address: depot.address,
      from_lat: depot.lat,
      from_lon: depot.lon,
      from_working_time: vehicle.shiftFrom,
      to_working_time: vehicle.shiftTo,
      handling_unit_ids: [1], // assigned by your integration, not in the workbook
      // No workbook column for physical dimensions: keep a one-time fleet
      // reference alongside the vehicle list rather than pulling these per job.
      height_of_vehicle: 180,
      length_of_vehicle: 420,
      width_of_vehicle: 190,
      vehicle_tonnage: vehicle.capacity_kg,
    };
  });

  // Pair each order's pickup and drop rows into one job order item.
  const legsByExternalId = new Map<string, OrderLeg[]>();
  for (const leg of orderLegs) {
    legsByExternalId.set(leg.external_id, [...(legsByExternalId.get(leg.external_id) ?? []), leg]);
  }

  const jobOrders = [...legsByExternalId.entries()].map(([externalId, legs]) => {
    const pickup = legs.find((leg) => leg.direction === "pickup")!;
    const drop = legs.find((leg) => leg.direction === "drop")!;
    const pickupSite = siteByCode.get(pickup.site_code)!;
    const dropSite = siteByCode.get(drop.site_code)!;

    return {
      external_order_id: externalId,
      // No workbook column: set once per integration, not per row.
      transport_mode: "lastmile" as const,
      handling_unit_id: 1, // assigned by your integration, not in the workbook
      service_id: 1, // assigned by your integration, not in the workbook
      pickup_address: pickupSite.address,
      pickup_lat: pickupSite.lat,
      pickup_lon: pickupSite.lon,
      pickup_date_time: pickup.ready_time,
      pickup_date_time_to: pickup.due_time,
      drop_address: dropSite.address,
      drop_lat: dropSite.lat,
      drop_lon: dropSite.lon,
      drop_date_time: drop.ready_time,
      drop_date_time_to: drop.due_time,
      // No workbook column for per-package dimensions: the template only
      // carries a total weight, so length/width/height need their own source.
      rlength: 40,
      rwidth: 30,
      rheight: 30,
      rweight: pickup.weight_kg,
      count_of_parcels: pickup.package_count,
    };
  });

  return {
    external_reference: `cutoff-${new Date().toISOString().slice(0, 10)}`,
    optimization_options: {
      delivery_mode: "1",
      kind_of_plan: "1",
      tour_mode: "1;0;0;0;0;0",
    },
    vehicles: jobVehicles,
    orders: jobOrders,
  };
}

// Submit once per cut-off, with a fresh Idempotency-Key for this submit.
async function submitFromWorkbook(sites: Site[], vehicles: Vehicle[], orderLegs: OrderLeg[]) {
  const body = buildJobBody(sites, vehicles, orderLegs);
  const idempotencyKey = randomUUID();

  const response = await fetch(`${BASE}/jobs`, {
    method: "POST",
    headers: { ...headers, "Idempotency-Key": idempotencyKey, "content-type": "application/json" },
    body: JSON.stringify(body),
  });
  const envelope = await response.json();
  if (!envelope.success) throw new Error(String(envelope.error_code));

  return envelope.data.id as string;
}