Function indexMessageForSearch

server/src/slack/events.ts:551–591

* Index a Slack message for local full-text search * Fetches user/channel info and stores in addie_knowledge

(event: SlackMessageEvent)

 * Fetches user/channel info and stores in addie_knowledge
 */
async function indexMessageForSearch(event: SlackMessageEvent): Promise<void> {
  try {
    // Fetch user and channel info in parallel
    const [user, channel] = await Promise.all([
      getSlackUser(event.user!),
      getChannelInfo(event.channel),
    ]);

    if (!user || !channel) {
      logger.debug(
        { userId: event.user, channelId: event.channel },
        'Skipping message index: could not fetch user or channel info'
      );
      return;
    }

    // Construct permalink
    // Format: https://workspace.slack.com/archives/CHANNEL_ID/pTIMESTAMP
    // The timestamp needs dots removed
    const tsForLink = event.ts.replace('.', '');
    const permalink = `https://agenticads.slack.com/archives/${event.channel}/p${tsForLink}`;

    await addieDb.indexSlackMessage({
      channel_id: event.channel,
      channel_name: channel.name || 'unknown',
      user_id: event.user!,
      username: user.profile?.display_name || user.profile?.real_name || user.name || 'unknown',
      ts: event.ts,
      text: event.text!,
      permalink,
    });

    logger.debug(
      { channelName: channel.name, username: user.name },
      'Indexed Slack message for search'
    );
  } catch (error) {
    // Don't fail the main event handler if indexing fails
    logger.error({ error, channelId: event.channel }, 'Failed to index Slack message for search');
  }
}

/**
 * Handle reaction_added event