Onboarding that reacts to product events

import { days } from "@hogsend/core";
import { defineJourney, sendEmail } from "@hogsend/engine";

export const onboarding = defineJourney({
  meta: {
    id: "onboarding",
    name: "Onboarding",
    enabled: true,
    trigger: { event: "user.signed_up" },
    entryLimit: "once",
    exitOn: [{ event: "user.deleted" }],
  },

  run: async (user, ctx) => {
    await sendEmail({
      to: user.email,
      userId: user.id,
      journeyStateId: user.stateId,
      template: "activation-quickstart",
      subject: "Welcome — here's the shortest path to a first win",
      journeyName: user.journeyName,
    });

    // Park the journey — durably — until THIS user creates a project,
    // or 3 days pass. Survives deploys, restarts, and crashes.
    const { timedOut } = await ctx.waitForEvent({
      event: "project.created",
      timeout: days(3),
    });

    await sendEmail({
      to: user.email,
      userId: user.id,
      journeyStateId: user.stateId,
      template: timedOut ? "activation-nudge" : "activation-feature-highlight",
      subject: timedOut
        ? "Stuck? Here's the 2-minute version"
        : "Nice — here's what to try next",
      journeyName: user.journeyName,
    });

    await ctx.sleep({ duration: days(4), label: "pre-community" });

    // Re-check after the long wait — unsubscribes don't exit a journey.
    if (await ctx.guard.isSubscribed()) {
      await sendEmail({
        to: user.email,
        userId: user.id,
        journeyStateId: user.stateId,
        template: "activation-community",
        subject: "Join the community",
        journeyName: user.journeyName,
      });
    }
  },
});