Cross-journey funnels

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

export const onboardingCheckin = defineJourney({
  meta: {
    id: "onboarding-checkin",
    name: "Onboarding — check-in router",
    enabled: true,
    trigger: { event: Events.USER_SIGNED_UP },
    entryLimit: "once",
    suppress: hours(12),
  },

  run: async (user, ctx) => {
    // A week with the product before asking.
    await ctx.sleep({ duration: days(5), label: "pre-checkin" });
    if (!(await ctx.guard.isSubscribed())) return;

    await sendEmail({
      to: user.email,
      userId: user.id,
      journeyStateId: user.stateId,
      template: Templates.ONBOARDING_CHECKIN, // "onboarding/checkin"
      subject: "One tap: how is setup going?",
      journeyName: user.journeyName,
    });

    const checkin = await ctx.waitForEvent({
      event: Events.CHECKIN_ANSWERED,
      timeout: days(5),
      label: "await-checkin",
      lookback: minutes(30), // covers the send → wait-established gap
    });

    await ctx.checkpoint("checkin-resolved");
    if (!(await ctx.guard.isSubscribed())) return;

    const answer = checkin.timedOut ? undefined : checkin.properties?.answer;

    if (answer === "yes") {
      // Activated — route to the referral ask.
      await ctx.trigger({
        event: Events.REFERRAL_ELIGIBLE,
        userId: user.id,
        properties: { reason: "activated", source: "onboarding-checkin" },
      });
      return;
    }

    // Silence can still mean activated — they got moving without answering.
    if (answer === undefined) {
      const { found: activated } = await ctx.history.hasEvent({
        userId: user.id,
        event: Events.KEY_FEATURE_USED,
        within: days(6), // the 5-day wait plus slop
      });
      if (activated) {
        await ctx.trigger({
          event: Events.REFERRAL_ELIGIBLE,
          userId: user.id,
          properties: { reason: "activated-silent", source: "onboarding-checkin" },
        });
        return;
      }
    }

    // "no", or silent and stalled — the help-offer path. Never re-pitch
    // someone who already completed that flow (eligibility events can
    // arrive from more than one router).
    const { completed: alreadyPitched } = await ctx.history.journey({
      userId: user.id,
      journeyId: "setup-offer",
    });
    if (alreadyPitched) return;

    await ctx.trigger({
      event: Events.SETUP_ELIGIBLE,
      userId: user.id,
      properties: {
        reason: answer === "no" ? "needs-help" : "silent",
        source: "onboarding-checkin",
      },
    });
  },
});

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

export const setupOffer = defineJourney({
  meta: {
    id: "setup-offer",
    name: "Onboarding — setup offer",
    enabled: true, // this branch has its own kill switch
    trigger: { event: Events.SETUP_ELIGIBLE },
    entryLimit: "once", // a duplicate eligibility fire is harmless
    suppress: hours(12),
    // Booking at any point withdraws the pitch, even mid-sleep.
    exitOn: [{ event: Events.SETUP_BOOKED }],
  },

  run: async (user, ctx) => {
    // Day-1 breather: an offer landing seconds after the "no" click reads
    // automated, not responsive.
    await ctx.sleep({ duration: days(1), label: "pre-offer" });
    if (!(await ctx.guard.isSubscribed())) return;

    await sendEmail({
      to: user.email,
      userId: user.id,
      journeyStateId: user.stateId,
      template: Templates.SETUP_OFFER, // "onboarding/setup-offer"
      subject: "If setup is the blocker, we'll do it with you",
      journeyName: user.journeyName,
      props: { reason: String(user.properties.reason ?? "") },
    });
  },
});

// src/journeys/constants/index.ts
export const Events = {
  USER_SIGNED_UP: "user.signed_up",
  KEY_FEATURE_USED: "feature.used",
  CHECKIN_ANSWERED: "checkin.answered",
  SETUP_ELIGIBLE: "setup.eligible",
  REFERRAL_ELIGIBLE: "referral.eligible",
  SETUP_BOOKED: "setup.booked",
} as const;

export const Templates = {
  ONBOARDING_CHECKIN: "onboarding/checkin",
  SETUP_OFFER: "onboarding/setup-offer",
  REFERRAL_ASK: "onboarding/referral-ask",
} as const;

// src/journeys/index.ts
import type { DefinedJourney } from "@hogsend/engine";
import { onboardingCheckin } from "./onboarding-checkin.js";
import { referralAsk } from "./referral-ask.js";
import { setupOffer } from "./setup-offer.js";

export const journeys: DefinedJourney[] = [
  onboardingCheckin,
  setupOffer,
  referralAsk,
];