22 tests. one command.
against the real worker.

import { describe, it, expect } from 'vitest';
import { postJSON } from './helpers/api-client';
import { getFulfillmentLanes, getQRLabels } from './helpers/assertions';

describe('er_fulfillment · lane logic', () => {
  it('in-zone + small order: pickup + paid drop · default pickup_belleville · fee $15', async () => {
    const r = await postJSON('/api/v1/er-fulfillment', {
      cf_postal: 'K8N 4Z2',
      cf_cart_total: 249,
      cf_is_tire_package: false,
    });

    const lanes = getFulfillmentLanes(r);
    expect(lanes).toEqual(['pickup_belleville', 'pickup_kingston', 'drop_paid']);
    expect(r.set_field_value?.cf_fulfillment_default).toBe('pickup_belleville');
    expect(r.set_field_value?.cf_delivery_fee).toBe(15);
    expect(r.set_field_value?.cf_in_zone).toBe(true);
    expect(r.set_field_value?.cf_branch_origin).toBe('belleville');
    expect(r.set_field_value?.cf_cart_total_with_fee).toBe(264);

    const labels = getQRLabels(r);
    expect(labels).toContain('Drop off · $15');
  });

  it('tire+rim package: free drop default regardless of cart total', async () => {
    const r = await postJSON('/api/v1/er-fulfillment', {
      cf_postal: 'K7L 2R3',
      cf_cart_total: 1489,
      cf_is_tire_package: true,
    });

    const lanes = getFulfillmentLanes(r);
    expect(lanes).toContain('drop_free');
    expect(lanes).not.toContain('drop_paid');
    expect(r.set_field_value?.cf_fulfillment_default).toBe('drop_free');
    expect(r.set_field_value?.cf_delivery_fee).toBe(0);
    expect(r.set_field_value?.cf_branch_origin).toBe('kingston');
  });
});

async function waitForDevServer(timeoutMs = 10_000, intervalMs = 500): Promise<void> {
  const startedAt = Date.now();
  let lastError = '';

  while (Date.now() - startedAt < timeoutMs) {
    try {
      const r = await fetch(HEALTH_URL);
      if (r.ok) return;
      lastError = `HTTP ${r.status}`;
    } catch (e: any) {
      lastError = e.message ?? String(e);
    }
    await sleep(intervalMs);
  }

  throw new Error(
    `\n\n[setup] ✗ wrangler dev not reachable at ${HEALTH_URL}\n\n` +
    `Last error: ${lastError}\n\n` +
    `Start it in another terminal:\n` +
    `   cd worker && npm run dev\n\n` +
    `Then re-run the tests:\n` +
    `   npm test\n`
  );
}

import { execSync } from 'node:child_process';

const BUCKET = '613parts-catalog';

/**
 * Read an R2 object as parsed JSON. Throws if the key doesn't exist.
 */
export function getR2JSON<T = unknown>(key: string): T {
  const text = execSync(
    `npx wrangler r2 object get ${BUCKET}/${key} --pipe --local 2>/dev/null`,
    { encoding: 'utf-8' }
  );
  return JSON.parse(text) as T;
}

/**
 * Check whether an R2 object exists.
 */
export function r2KeyExists(key: string): boolean {
  try {
    execSync(
      `npx wrangler r2 object get ${BUCKET}/${key} --pipe --local 2>/dev/null`,
      { encoding: 'utf-8', stdio: 'pipe' }
    );
    return true;
  } catch { return false; }
}