import { createRavenflowApp } from "ravenflow";

const app = createRavenflowApp(
  {
    defaultQueue: "default",
    queues: ["default"],
    jobs: {
      sendEmail: {
        type: "job",
        queueName: "default",
        handler: async (job, params: { to: string; subject: string }) => {
          console.log(`Sending email to ${params.to}`);
          return { sent: true };
        },
      },
    },
  },
  {
    host: "localhost",
    port: 6379,
  }
);

// Enqueue job
await app.jobs.sendEmail.send({
  to: "user@example.com",
  subject: "Hello",
});

// Start worker
app.startWorker("default");