import { inngest } from "@/lib/inngest/client";
import { sendEmail } from "@/lib/email/send";

export const welcomeSequence = inngest.createFunction(
  { name: "Welcome Email Sequence" },
  { event: "user/signup.completed" },
  async ({ event, step }) => {
    const { email, name } = event.data;

    // Send welcome email immediately
    await step.run("send-welcome-email", async () => {
      await sendEmail({
        to: email,
        template: "welcome",
        data: { name }
      });
    });

    // Send getting started tips after 1 day
    await step.sleep("wait-day-1", "24h");
    await step.run("send-getting-started", async () => {
      await sendEmail({
        to: email,
        template: "getting-started",
        data: { name }
      });
    });

    // Send feature highlights after 3 days
    await step.sleep("wait-day-3", "72h");
    await step.run("send-features", async () => {
      await sendEmail({
        to: email,
        template: "feature-highlights",
        data: { name }
      });
    });

    // Send upgrade offer after 7 days
    await step.sleep("wait-day-7", "168h");
    await step.run("send-upgrade-offer", async () => {
      await sendEmail({
        to: email,
        template: "upgrade-offer",
        data: { name }
      });
    });
  }
);

import { welcomeSequence } from "./welcome-sequence";

export const functions = [
  welcomeSequence,
  // ... other functions
];

import { inngest } from "@/lib/inngest/client";

// After user signup
await inngest.send({
  name: "user/signup.completed",
  data: {
    email: user.email,
    name: user.name,
  },
});

export const onboardingSequence = inngest.createFunction(
  { name: "Onboarding Sequence" },
  { event: "user/onboarding.started" },
  async ({ event, step }) => {
    const { email, name } = event.data;

    // Day 1: Welcome
    await step.run("day-1", async () => {
      await sendEmail({ to: email, template: "onboarding-1", data: { name } });
    });

    // Day 2: Core Features
    await step.sleep("wait-24h", "24h");
    await step.run("day-2", async () => {
      await sendEmail({ to: email, template: "onboarding-2", data: { name } });
    });

    // Day 4: Success Stories
    await step.sleep("wait-48h", "48h");
    await step.run("day-4", async () => {
      await sendEmail({ to: email, template: "onboarding-3", data: { name } });
    });
  }
);

export const trialExpirySequence = inngest.createFunction(
  { name: "Trial Expiry Sequence" },
  { event: "subscription/trial.started" },
  async ({ event, step }) => {
    const { email, name, trialEnds } = event.data;

    // 3 days before expiry
    await step.sleepUntil("3-days-before", new Date(trialEnds - 3 * 24 * 60 * 60 * 1000));
    await step.run("send-3-day-reminder", async () => {
      await sendEmail({ to: email, template: "trial-ending-soon", data: { name, daysLeft: 3 } });
    });

    // Last day reminder
    await step.sleepUntil("last-day", new Date(trialEnds - 24 * 60 * 60 * 1000));
    await step.run("send-last-day", async () => {
      await sendEmail({ to: email, template: "trial-last-day", data: { name } });
    });
  }
);