Function handleActiveThreadReply

server/src/addie/bolt-app.ts:3338–3700

* Handle replies in threads where Addie has already participated. * * When a user replies to a thread where Addie has already responded, * we treat it as an implicit @mention and respond directly. This creates * natural conversational flow - users don't need to explicitly @mention * Addie to co

({
  event,
  context,
  channelId,
  userId,
  messageText,
  threadTs,
  startTime,
  threadService,
  slackThreadMessages,
}: {
  event: SlackEventMiddlewareArgs<'message'>['event'];
  context: { botUserId?: string };
  channelId: string;
  userId: string;
  messageText: string;
  threadTs: string;
  startTime: number;
  threadService: ReturnType<typeof getThreadService>;
  slackThreadMessages: Awaited<ReturnType<typeof getThreadReplies>>;
})

 * This is similar to DM handling but with thread context included.
 */
async function handleActiveThreadReply({
  event,
  context,
  channelId,
  userId,
  messageText,
  threadTs,
  startTime,
  threadService,
  slackThreadMessages,
}: {
  event: SlackEventMiddlewareArgs<'message'>['event'];
  context: { botUserId?: string };
  channelId: string;
  userId: string;
  messageText: string;
  threadTs: string;
  startTime: number;
  threadService: ReturnType<typeof getThreadService>;
  slackThreadMessages: Awaited<ReturnType<typeof getThreadReplies>>;
}): Promise<void> {
  if (!claudeClient || !boltApp) {
    logger.warn('Addie Bolt: Not initialized for active thread reply');
    return;
  }

  // Build external ID for thread: channel_id:thread_ts
  const externalId = `${channelId}:${threadTs}`;

  // Sanitize input
  const inputValidation = sanitizeInput(messageText);

  // Fetch channel context (includes working group if channel is linked to one)
  let channelContext: ThreadContext | undefined;
  try {
    channelContext = await buildChannelContext(channelId);
  } catch (error) {
    logger.debug({ error, channelId }, 'Addie Bolt: Could not get channel context for active thread reply');
  }

  // Build thread context from the messages already fetched (avoid duplicate API call)
  const MAX_THREAD_CONTEXT_MESSAGES = 25;
  let threadContext = '';

  if (slackThreadMessages.length > 0) {
    // Include all messages (including Addie's) for full context
    // but exclude the current message
    const filteredMessages = slackThreadMessages
      .filter(msg => msg.ts !== event.ts) // Exclude current message
      .filter(msg => (msg.text || '').trim().length > 0)
      .slice(-MAX_THREAD_CONTEXT_MESSAGES);

    // Collect user IDs for display name lookup
    const mentionedUserIds = new Set<string>();
    for (const msg of filteredMessages) {
      if (msg.user && msg.user !== context.botUserId) {
        mentionedUserIds.add(msg.user);
      }