SpectraFlux is an ultra-lean WebAssembly chassis for asynchronous workloads.

import { Context, Database } from "@spectraflux/sdk";

export async function handleCheckout(ctx: Context, cmd: CheckoutCommand) {
  // STEP 1: Idempotent External Side-Effect (Memoized in host Kevy storage)
  // On broker redelivery after crash, returns in < 50µs WITHOUT re-charging!
  const charge = await ctx.step("stripe_charge", async () => {
    return await stripe.charges.create({
      amount: cmd.amountCents,
      currency: "usd",
      source: cmd.paymentToken,
      idempotency_key: `checkout_${cmd.orderId}`
    });
  });

  // STEP 2: ACID Relational Commit (Pooled PostgreSQL)
  // Causally dependent on Step 1 output (charge.id).
  // RAII Guard: If the worker panics or times out, pending SQL rolls back instantly.
  const tx = await Database.beginTx();
  await tx.execute(
    "INSERT INTO orders (id, user_id, charge_id, total, status) VALUES ($1, $2, $3, $4, $5)",
    [cmd.orderId, cmd.userId, charge.id, cmd.amountCents, "PAID"]
  );
  await tx.commit();

  // STEP 3: Out-of-Band Downstream Event Dispatch
  await ctx.publish("orders.confirmed", { orderId: cmd.orderId, chargeId: charge.id });
}