Link a Discord account to an email

// src/discord.ts
import {
  createLinkCode,
  getEmailService,
  redeemLinkCode,
  resolveOrCreateContact,
} from "@hogsend/engine";
import { createDiscordConnector } from "@hogsend/plugin-discord";

export const discordConnector = createDiscordConnector({
  applicationId: env.DISCORD_APPLICATION_ID,
  clientSecret: env.DISCORD_CLIENT_SECRET,
  publicKeyHex: env.DISCORD_PUBLIC_KEY,
  redirectUri: `${base}/v1/connectors/discord/oauth/callback`,
  studioIntegrationsUrl: `${base}/studio/integrations`,
  saveDerived: async (patch) => {
    /* read-merge-write into the derived credential */
  },

  // Mint a single-use code. The engine runs the anti-email-bomb throttle
  // (5/user + 3/email per 15 min) BEFORE minting; over-cap returns ok:false.
  mintCode: async ({ discordUserId, email }) => {
    const r = await createLinkCode({
      db: requireDb(),
      connectorId: "discord",
      platformUserId: discordUserId,
      email,
    });
    return r.ok
      ? { ok: true, code: r.code }
      : { ok: false, reason: "throttled" };
  },

  // TRANSACTIONAL send — skipPreferenceCheck so a verification code is NEVER
  // dropped by unsubscribe/frequency suppression.
  sendLinkCode: async ({ email, code }) => {
    await getEmailService().send({
      template: "transactional/discord-link-code",
      props: { code },
      to: email,
      userId: email,
      userEmail: email,
      subject: "Your Discord verification code",
      category: "transactional",
      skipPreferenceCheck: true,
    });
  },

  // Redeem — single-use (atomic claim), 15-min TTL, identity-bound to the
  // invoking Discord user (constant-time). Resolves through the discord Kind.
  redeemCode: ({ discordUserId, code }) =>
    redeemLinkCode({
      db: requireDb(),
      connectorId: "discord",
      platformUserId: discordUserId,
      code,
    }),
});

// src/journeys/react-to-linked-state.ts
import { contacts } from "@hogsend/db";
import { days, defineJourney, getDb, hours, sendEmail } from "@hogsend/engine";
import { eq } from "drizzle-orm";
import { Events, Templates } from "./constants/index.js";

export const reactToLinkedState = defineJourney({
  meta: {
    id: "react-to-linked-state",
    name: "Discord — react to link state",
    enabled: true,
    trigger: { event: Events.DISCORD_MESSAGE_SENT }, // "discord.message_sent"
    entryLimit: "once_per_period",
    entryPeriod: days(7),
    suppress: hours(12),
  },

  run: async (user, ctx) => {
    const db = getDb();
    const contact = await db.query.contacts.findFirst({
      where: eq(contacts.id, user.id),
    });

    const meta = (contact?.properties?.discord ?? {}) as {
      username?: string;
    };

    if (!contact?.email) {
      // Discord-only — no address. Nudge to link via the channel.
      await ctx.trigger({
        event: Events.DISCORD_NUDGE_LINK,
        userId: user.id,
        properties: { username: meta.username ?? null },
      });
      return;
    }

    await sendEmail({
      to: contact.email,
      userId: user.id,
      journeyStateId: user.stateId,
      template: Templates.DISCORD_ACTIVE_THANKS,
      subject: `Thanks for being active, ${meta.username ?? "friend"}`,
      journeyName: user.journeyName,
    });
  },
});