Welcome new Discord members

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

export const welcomeNewDiscordMembers = defineJourney({
  meta: {
    id: "welcome-new-discord-members",
    name: "Onboarding — welcome new Discord members",
    enabled: true,
    // The join event the Discord connector emits on GUILD_MEMBER_ADD.
    trigger: { event: Events.DISCORD_MEMBER_JOINED }, // "discord.member_joined"
    entryLimit: "once",
    suppress: hours(12),
    exitOn: [{ event: Events.DISCORD_MEMBER_LEFT }],
  },

  run: async (user, ctx) => {
    // A fresh join has a discord_id but usually no linked email yet. Park on
    // the link event the /link → /verify loop fires when it resolves the
    // contact; lookback covers a member who linked seconds before this wait.
    const linked = await ctx.waitForEvent({
      event: Events.CONTACT_LINKED, // "contact.linked"
      timeout: days(2),
      lookback: minutes(30),
    });

    if (linked.timedOut) {
      // Two days, still no email: nudge IN Discord via the destination, since
      // there is no address to email. The destination posts to the channel.
      await ctx.trigger({
        event: Events.DISCORD_NUDGE_LINK,
        userId: user.id,
        properties: { reason: "unlinked-2d" },
      });
      return;
    }

    // They linked — user.email is now an address we can send to.
    if (!(await ctx.guard.isSubscribed())) return;

    await sendEmail({
      to: user.email,
      userId: user.id,
      journeyStateId: user.stateId,
      template: Templates.DISCORD_WELCOME, // "discord/welcome"
      subject: "Welcome to the community — here's where to start",
      journeyName: user.journeyName,
    });
  },
});

// src/journeys/emit-contact-linked.ts
import { defineJourney, hours } from "@hogsend/engine";
import { Events } from "./constants/index.js";

export const emitContactLinked = defineJourney({
  meta: {
    id: "emit-contact-linked",
    name: "Discord — emit contact.linked once linked",
    enabled: true,
    // Any post-link Discord activity now resolves to a contact WITH an email
    // (the /link → /verify loop folded the address onto the discord_id).
    trigger: { event: Events.DISCORD_MESSAGE_SENT }, // "discord.message_sent"
    entryLimit: "once",
    suppress: hours(12),
  },

  run: async (user, ctx) => {
    // Only emit once the contact is emailable — i.e. the link loop has run.
    if (!user.email) return;

    // ctx.trigger injects registry/hatchet/logger and runs the full ingest
    // pipeline, so the welcome journey's waitForEvent resumes the instant this
    // lands. A raw ingestEvent() call would need those dependencies, which a
    // consumer callback can't reach.
    await ctx.trigger({
      event: Events.CONTACT_LINKED, // "contact.linked"
      userId: user.id,
      properties: { source: "discord", method: "verify" },
    });
  },
});

// src/journeys/constants/index.ts
export const Events = {
  DISCORD_MEMBER_JOINED: "discord.member_joined",
  DISCORD_MEMBER_LEFT: "discord.member_left",
  DISCORD_MESSAGE_SENT: "discord.message_sent",
  CONTACT_LINKED: "contact.linked",
  DISCORD_NUDGE_LINK: "discord.nudge_link",
} as const;

export const Templates = {
  DISCORD_WELCOME: "discord/welcome",
} as const;