Integration Test Plan

mkdir stateset-restart-tests
cd stateset-restart-tests
npm init -y
npm install --save-dev @stateset/embedded@1.35.1

import test from 'node:test';
import assert from 'node:assert/strict';
import { spawnSync } from 'node:child_process';
import { mkdtempSync, rmSync } from 'node:fs';
import { tmpdir } from 'node:os';
import { join } from 'node:path';

// Both workers run this same code, with their action and input supplied over stdin.
const worker = `
import { readFileSync } from 'node:fs';
import { Commerce } from '@stateset/embedded';
const request = JSON.parse(readFileSync(0, 'utf8'));
const commerce = new Commerce(request.database);
let input = request.input;
if (request.action === 'create') {
  const customer = await commerce.customers.create({
    email: 'ada@example.com', firstName: 'Ada', lastName: 'Lovelace',
  });
  const order = await commerce.orders.createExact({
    customerId: customer.id,
    currency: 'USD',
    items: [{ sku: 'MUG-001', name: 'Ceramic mug', quantity: 2, unitPrice: '12.50' }],
  });
  input = {
    customerId: customer.id,
    orderId: order.id,
    amount: order.totalAmountExact,
    currency: 'USD',
    paymentMethod: 'card',
    idempotencyKey: 'restart-payment-001',
  };
}
const payment = await commerce.payments.createExact(input);
console.log(JSON.stringify({
  input,
  paymentId: payment.id,
  amount: payment.amountExact,
  status: payment.status,
  paymentCount: await commerce.payments.count(),
  orderCount: await commerce.orders.count(),
}));
`;

test('payment replay survives a process restart without another record', () => {
  const directory = mkdtempSync(join(tmpdir(), 'stateset-restart-'));
  const database = join(directory, 'commerce.db');
  function runWorker(action, input) {
    const result = spawnSync(process.execPath, ['--input-type=module', '--eval', worker], {
      input: JSON.stringify({ action, database, input }),
      encoding: 'utf8',
      timeout: 30000,
    });
    assert.ifError(result.error);
    assert.equal(result.status, 0, result.stderr || 'Worker did not exit successfully');
    return JSON.parse(result.stdout);
  }
  try {
    const created = runWorker('create');
    assert.ok(created.paymentId);
    assert.equal(created.amount, '25.00');
    assert.equal(created.status, 'pending');
    assert.equal(created.paymentCount, 1);
    assert.equal(created.orderCount, 1);

    const replayed = runWorker('replay', created.input);
    assert.equal(replayed.paymentId, created.paymentId);
    assert.equal(replayed.amount, '25.00');
    assert.equal(replayed.status, 'pending');
    assert.equal(replayed.paymentCount, 1);
    assert.equal(replayed.orderCount, 1);
  } finally {
    // The workers have exited; delete only the temporary directory this test created.
    rmSync(directory, { recursive: true, force: true, maxRetries: 3 });
  }
});

node --test restart.test.mjs