Halit Soydan

// form → doğrula → kaydet → arayüzü tazele
'use server';

export async function createOrder(form: FormData) {
  const data = orderSchema.parse(
    Object.fromEntries(form),
  );

  const order = await db.tx(async (tx) => {
    const stock = await tx.lockStock(data.items);
    if (!stock.ok) throw new Conflict('stok yetersiz');
    return tx.orders.insert(data);
  });

  await queue.publish('order.created', order.id);
  revalidatePath('/siparisler');
  return { ok: true, order };
}