Post-purchase series

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

export const postPurchaseSeries = defineJourney({
  meta: {
    id: "post-purchase-series",
    name: "E-commerce — post-purchase series",
    enabled: true,
    trigger: { event: Events.ORDER_COMPLETED },
    entryLimit: "once_per_period",
    entryPeriod: days(14),
    suppress: hours(12),
    // a return cancels the arc — no "getting the most from your product"
    // email to someone boxing it back up
    exitOn: [{ event: Events.ORDER_REFUNDED }],
  },

  run: async (user, ctx) => {
    const orderId = String(user.properties.order_id ?? "");
    const productName = String(user.properties.product_name ?? "your order");

    // Day 0 — the receipt is the arc's first touch.
    await sendEmail({
      to: user.email,
      userId: user.id,
      journeyStateId: user.stateId,
      template: Templates.ECOMMERCE_RECEIPT, // "ecommerce/receipt"
      subject: `Order confirmed — ${productName}`,
      journeyName: user.journeyName,
      props: { orderId, productName },
    });

    // Wait for the carrier to report delivery. Ten days is the proxy
    // window when no signal ever arrives.
    const delivery = await ctx.waitForEvent({
      event: Events.DELIVERY_CONFIRMED,
      timeout: days(10),
      label: "await-delivery",
    });

    if (delivery.timedOut) {
      // No carrier feed, or a lost webhook. Assume delivered so the rest
      // of the purchase stream — the review ask included — keys off one
      // event name; `source` records the provenance.
      await ctx.trigger({
        event: Events.DELIVERY_CONFIRMED,
        userId: user.id,
        properties: {
          order_id: orderId,
          product_name: productName,
          source: "assumed",
        },
      });
    }

    if (!(await ctx.guard.isSubscribed())) return;

    // The product is in their hands — help them get value from it.
    await sendEmail({
      to: user.email,
      userId: user.id,
      journeyStateId: user.stateId,
      template: Templates.ECOMMERCE_PRODUCT_ONBOARDING, // "ecommerce/product-onboarding"
      subject: `Getting the most from ${productName}`,
      journeyName: user.journeyName,
      props: { orderId, productName },
    });
  },
});

// your order pipeline
await hs.events.send({
  name: "order.completed",
  email: customer.email,
  userId: customer.id,
  eventProperties: {
    order_id: order.id,
    product_name: order.items[0].name,
    revenue: order.total,
  },
  idempotencyKey: `order-completed-${order.id}`,
});

// your carrier/3PL webhook handler
await hs.events.send({
  name: "delivery.confirmed",
  userId: order.customerId,
  eventProperties: {
    order_id: order.id,
    product_name: order.items[0].name,
    source: "carrier",
  },
  idempotencyKey: `delivery-${order.id}`,
});

// src/journeys/constants/index.ts
export const Events = {
  ORDER_COMPLETED: "order.completed",
  ORDER_REFUNDED: "order.refunded",
  DELIVERY_CONFIRMED: "delivery.confirmed",
} as const;

export const Templates = {
  ECOMMERCE_RECEIPT: "ecommerce/receipt",
  ECOMMERCE_PRODUCT_ONBOARDING: "ecommerce/product-onboarding",
} as const;