Win-back and sunset

// src/buckets/dormant-30d.ts
import { days, defineBucket } from "@hogsend/engine";
import { Events } from "../journeys/constants/index.js";

export const dormant30d = defineBucket({
  meta: {
    id: "dormant-30d",
    name: "Dormant 30 days",
    enabled: true,
    timeBased: true,
    criteria: (b) =>
      b.all(
        // The floor: active once, ever — keeps never-active signups out.
        b.event(Events.APP_ACTIVE).exists(),
        // The decay: nothing in the last 30 days.
        b.event(Events.APP_ACTIVE).within(days(30)).notExists(),
      ),
  },
});

// src/journeys/winback-and-sunset.ts
import { days, hours, minutes } from "@hogsend/engine";
import { defineJourney, sendEmail } from "@hogsend/engine";
// Leaf-module import — reading a typed ref through the barrel closes an ESM cycle.
import { dormant30d } from "../buckets/dormant-30d.js";
import { Events, Templates } from "./constants/index.js";

// The documented programmatic preference write: the Admin API upsert.
// {id} accepts the contact's externalId — which is what user.id carries.
async function sunsetContact(userId: string): Promise<void> {
  const res = await fetch(
    `${process.env.API_PUBLIC_URL}/v1/admin/contacts/${userId}/preferences`,
    {
      method: "PUT",
      headers: {
        Authorization: `Bearer ${process.env.ADMIN_API_KEY}`,
        "Content-Type": "application/json",
      },
      body: JSON.stringify({ unsubscribedAll: true }),
    },
  );
  if (!res.ok) {
    // Throwing marks the run "failed" in Studio; a swallowed error here
    // leaves a dead address mailable.
    throw new Error(`Sunset preference write failed: ${res.status}`);
  }
}

export const winbackAndSunset = defineJourney({
  meta: {
    id: "winback-and-sunset",
    name: "Retention — win-back and sunset",
    enabled: true,
    trigger: { event: dormant30d.entered },
    entryLimit: "once_per_period",
    entryPeriod: days(180),
    suppress: hours(24),
    // Returning leaves the bucket, which exits the run — even mid-sleep.
    // The awaited answer event (repermission.answered) is deliberately NOT here.
    exitOn: [{ event: dormant30d.left }],
  },

  run: async (user, ctx) => {
    // Touch 1 — the win-back attempt.
    await sendEmail({
      to: user.email,
      userId: user.id,
      journeyStateId: user.stateId,
      template: Templates.RETENTION_WINBACK, // "retention/winback"
      subject: "What's changed since you've been away",
      journeyName: user.journeyName,
    });

    // A return during this week fires dormant30d.left and ends the run here.
    await ctx.sleep({ duration: days(7), label: "post-winback" });
    if (!(await ctx.guard.isSubscribed())) return;

    // Touch 2 — still silent: ask the question directly.
    await sendEmail({
      to: user.email,
      userId: user.id,
      journeyStateId: user.stateId,
      template: Templates.RETENTION_REPERMISSION, // "retention/re-permission"
      subject: "Should we keep emailing you?",
      journeyName: user.journeyName,
    });

    // Answers are provisional clicks confirmed ~30s later; lookback covers
    // the send→wait gap.
    const answer = await ctx.waitForEvent({
      event: Events.REPERMISSION_ANSWERED,
      timeout: days(10),
      label: "await-repermission",
      lookback: minutes(30),
    });

    if (!answer.timedOut && answer.properties?.answer === "stay") {
      return; // explicit opt-in renewed — keep them, send nothing more
    }

    // "leave", any other answer, or ten days of silence: for a sunset
    // policy, no answer IS the answer.
    await sunsetContact(user.id);
    await ctx.checkpoint("sunset-applied");
  },
});

// src/emails/retention-re-permission.tsx (the answer row)
import { EmailAction, HOSTED_ANSWER_HREF } from "@hogsend/email";
import { Events } from "../journeys/constants/index.js";

<Section className="my-6 text-center">
  <EmailAction
    event={Events.REPERMISSION_ANSWERED}
    properties={{ answer: "stay" }}
    href={HOSTED_ANSWER_HREF}
    className="mx-1 inline-block rounded-lg border px-5 py-2"
  >
    Keep me on the list
  </EmailAction>
  <EmailAction
    event={Events.REPERMISSION_ANSWERED}
    properties={{ answer: "leave" }}
    href={HOSTED_ANSWER_HREF}
    className="mx-1 inline-block rounded-lg border px-5 py-2"
  >
    Remove me
  </EmailAction>
</Section>

// src/journeys/constants/index.ts
export const Events = {
  APP_ACTIVE: "app.active",
  REPERMISSION_ANSWERED: "repermission.answered",
} as const;

export const Templates = {
  RETENTION_WINBACK: "retention/winback",
  RETENTION_REPERMISSION: "retention/re-permission",
} as const;