Event Plugin

import { Jobbig } from "@jobbig/core";
import { EventPlugin } from "@jobbig/core/plugins";
import { z } from "zod";

const jobbig = Jobbig({ store, jobs: [] })
  .use(EventPlugin({
    events: [{
      type: "user.created",
      schema: z.object({ id: z.string() })
    }, {
      type: "user.updated", 
      schema: z.object({ id: z.string(), email: z.email() })
    }]
  }));

// Define additional events
jobbig
  .event({
    type: "user.deleted",
    schema: z.object({ id: z.string() }),
  })
  // Register handlers for events
  .on({
    types: ["user.created", "user.updated"],
    handler: async ({ ctx }) => {
      if (ctx.id === "user.created") {
        console.log("User created:", ctx.data.id);
      } else if (ctx.id === "user.updated") {
        console.log("User updated:", ctx.data.id, ctx.data.email);
      }
    },
  })
  .on({
    types: ["user.deleted"],
    handler: async ({ ctx }) => {
      console.log("User deleted:", ctx.data.id);
    },
  });

await jobbig.publish({ type: "user.created", payload: { id: "123" } });