Kurumsal sistemler için
modern mühendislik
ekosistemi.

// OrderCreatedEvent → Outbox-driven, transactionally idempotent
async function handleOrderCreated(evt: OrderCreatedEvent) {
  await db.tx(async (t) => {
    const seen = await t.processedEvents.findUnique({
      where: { id: evt.idempotencyKey },
    });
    if (seen) return; // replay → no-op

    await t.processedEvents.create({
      data: { id: evt.idempotencyKey, topic: "order.created" },
    });

    await t.orders.update({
      where: { id: evt.orderId },
      data: { status: "CREATED", placedAt: evt.occurredAt },
    });

    await t.outbox.create({
      data: { topic: "stock.reserve", payload: evt },
    });
  });
}