src/slack/monitor/events/pins.ts

import type { SlackEventMiddlewareArgs } from "@slack/bolt";
import type { SlackMonitorContext } from "../context.js";
import type { SlackPinEvent } from "../types.js";
import { danger } from "../../../globals.js";
import { enqueueSystemEvent } from "../../../infra/system-events.js";
import { resolveSlackChannelLabel } from "../channel-config.js";

export function registerSlackPinEvents(params: { ctx: SlackMonitorContext }) {
  const { ctx } = params;

  ctx.app.event("pin_added", async ({ event, body }: SlackEventMiddlewareArgs<"pin_added">) => {
    try {
      if (ctx.shouldDropMismatchedSlackEvent(body)) {
        return;
      }

      const payload = event as SlackPinEvent;
      const channelId = payload.channel_id;
      const channelInfo = channelId ? await ctx.resolveChannelName(channelId) : {};
      if (
        !ctx.isChannelAllowed({
          channelId,
          channelName: channelInfo?.name,
          channelType: channelInfo?.type,
        })
      ) {
        return;
      }
      const label = resolveSlackChannelLabel({
        channelId,
        channelName: channelInfo?.name,
      });
      const userInfo = payload.user ? await ctx.resolveUserName(payload.user) : {};
      const userLabel = userInfo?.name ?? payload.user ?? "someone";
      const itemType = payload.item?.type ?? "item";
      const messageId = payload.item?.message?.ts ?? payload.event_ts;
      const sessionKey = ctx.resolveSlackSystemEventSessionKey({
        channelId,
        channelType: channelInfo?.type ?? undefined,
      });
      enqueueSystemEvent(`Slack: ${userLabel} pinned a ${itemType} in ${label}.`, {
        sessionKey,
        contextKey: `slack:pin:added:${channelId ?? "unknown"}:${messageId ?? "unknown"}`,
      });
    } catch (err) {
      ctx.runtime.error?.(danger(`slack pin added handler failed: ${String(err)}`));
    }
  });

  ctx.app.event("pin_removed", async ({ event, body }: SlackEventMiddlewareArgs<"pin_removed">) => {
    try {
      if (ctx.shouldDropMismatchedSlackEvent(body)) {
        return;
      }

      const payload = event as SlackPinEvent;
      const channelId = payload.channel_id;
      const channelInfo = channelId ? await ctx.resolveChannelName(channelId) : {};
      if (
        !ctx.isChannelAllowed({
          channelId,
          channelName: channelInfo?.name,
          channelType: channelInfo?.type,
        })
      ) {
        return;
      }
      const label = resolveSlackChannelLabel({
        channelId,
        channelName: channelInfo?.name,
      });
      const userInfo = payload.user ? await ctx.resolveUserName(payload.user) : {};
      const userLabel = userInfo?.name ?? payload.user ?? "someone";
      const itemType = payload.item?.type ?? "item";
      const messageId = payload.item?.message?.ts ?? payload.event_ts;
      const sessionKey = ctx.resolveSlackSystemEventSessionKey({
        channelId,
        channelType: channelInfo?.type ?? undefined,
      });
      enqueueSystemEvent(`Slack: ${userLabel} unpinned a ${itemType} in ${label}.`, {
        sessionKey,
        contextKey: `slack:pin:removed:${channelId ?? "unknown"}:${messageId ?? "unknown"}`,
      });
    } catch (err) {
      ctx.runtime.error?.(danger(`slack pin removed handler failed: ${String(err)}`));
    }
  });
}