Bespoke software,
built to last.

import { db, log, metrics } from "@apollo/platform"
import { z } from "zod"

// Typed at the boundary. Anything that gets past this is well-shaped.

const CreateOrder = z.object({
  customerId: z.string().uuid(),
  items: z.array(z.object({
    sku: z.string(),
    quantity: z.number().int().positive(),
  })).min(1),
  shippingAddressId: z.string().uuid(),
});

export async function createOrder(
  input: unknown,
  ctx: RequestContext,
) {
  const parsed = CreateOrder.safeParse(input);
  if (!parsed.success) {
    log.warn({
      event: "order.create.invalid",
      errors: parsed.error.issues,
      ctx,
    });
    throw new ValidationError(parsed.error);
  }

  const { customerId, items, shippingAddressId } = parsed.data;

  // One transaction. Either the order and its line items both land, or neither does.
  const order = await db.transaction(async (tx) => {
    const created = await tx.order.create({
      customerId,
      shippingAddressId,
      status: "pending",
    });
    await tx.orderItem.bulkInsert(
      items.map((item) => ({ orderId: created.id, ...item })),
    );
   return created;
  });

  log.info({event: "order.create.success", orderId: order.id, customerId, ctx,});
  metrics.increment("orders.created", { customerId });

  return order;
}