Activation milestones

// src/journeys/activation-milestones.ts
import { days, hours, minutes } from "@hogsend/engine";
import { defineJourney, sendEmail } from "@hogsend/engine";
import { Events, Templates } from "./constants/index.js";

const STEPS = [
  {
    id: "project",
    event: Events.PROJECT_CREATED,
    template: Templates.ONBOARDING_STEP_PROJECT, // "onboarding/step-project"
    subject: "First step: create a project",
  },
  {
    id: "data",
    event: Events.DATA_CONNECTED,
    template: Templates.ONBOARDING_STEP_DATA, // "onboarding/step-data"
    subject: "Your project is empty — connect a data source",
  },
  {
    id: "team",
    event: Events.TEAM_INVITED,
    template: Templates.ONBOARDING_STEP_TEAM, // "onboarding/step-team"
    subject: "Working alone? Invite your team",
  },
] as const;

export const activationMilestones = defineJourney({
  meta: {
    id: "activation-milestones",
    name: "Onboarding — activation milestones",
    enabled: true,
    trigger: {
      event: Events.USER_SIGNED_UP,
      // invited teammates aren't responsible for workspace setup
      where: (b) => b.prop("role").eq("owner"),
    },
    entryLimit: "once",
    suppress: hours(24),
    exitOn: [
      { event: Events.ONBOARDING_COMPLETED },
      { event: Events.USER_DELETED },
    ],
  },

  run: async (user, ctx) => {
    for (const step of STEPS) {
      // Done out of order, or before the run got here? Skip ahead —
      // waitForEvent is forward-looking and would miss a past event.
      const done = await ctx.history.hasEvent({
        userId: user.id,
        event: step.event,
      });
      if (done.found) continue;

      // Visible as currentNodeId in journey state: exactly which step.
      await ctx.checkpoint(`milestone:${step.id}`);

      const reached = await ctx.waitForEvent({
        event: step.event,
        timeout: days(2),
        label: `await-${step.id}`,
      });
      if (!reached.timedOut) continue; // on to the next milestone

      // Stalled on THIS step — nudge it specifically, nothing else.
      if (!(await ctx.guard.isSubscribed())) return;
      await sendEmail({
        to: user.email,
        userId: user.id,
        journeyStateId: user.stateId,
        template: step.template,
        subject: step.subject,
        journeyName: user.journeyName,
      });

      // The lookback covers a click that lands while this wait spins up.
      const nudged = await ctx.waitForEvent({
        event: step.event,
        timeout: days(3),
        label: `await-${step.id}-nudged`,
        lookback: minutes(30),
      });
      if (nudged.timedOut) return; // still stalled — stop, don't pile on
    }
    // All milestones reached — the run completes. exitOn already covers
    // the case where onboarding.completed landed mid-wait.
  },
});

// your app server — when the last milestone lands
await hs.events.send({
  name: "onboarding.completed",
  userId: user.id,
  idempotencyKey: `onboarding-completed-${user.id}`,
});

// src/journeys/constants/index.ts
export const Events = {
  USER_SIGNED_UP: "user.signed_up",
  USER_DELETED: "user.deleted",
  PROJECT_CREATED: "project.created",
  DATA_CONNECTED: "data.connected",
  TEAM_INVITED: "team.invited",
  ONBOARDING_COMPLETED: "onboarding.completed",
} as const;

export const Templates = {
  ONBOARDING_STEP_PROJECT: "onboarding/step-project",
  ONBOARDING_STEP_DATA: "onboarding/step-data",
  ONBOARDING_STEP_TEAM: "onboarding/step-team",
} as const;