The Framework

// Define type-safe events with effects
const { event, router } = ev()

const taskEvents = router({
  created: event({
    schema: z.object({ name: z.string() }),
    effect: async (input) =>
      prisma.task.create({ data: input }),
    selectId: ({ output }) => output.id,
  }),
})

// Publish with composable adapters
const client = createEventClient(events, {
  adapters: [createEventStoreAdapter({ storage })],
  createContext: (fn) => prisma.$transaction((tx) => fn({ tx })),
})