Function handleAssistantMessage

server/src/addie/handler.ts:523–706

(
  event: AssistantMessageEvent,
  channelId: string
)

 * Handle message in Assistant thread
 */
export async function handleAssistantMessage(
  event: AssistantMessageEvent,
  channelId: string
): Promise<void> {
  if (!initialized || !claudeClient) {
    logger.warn('Addie: Not initialized, ignoring message');
    return;
  }

  // Skip Slackbot system messages (e.g., "added you to #channel")
  if (event.user === SLACKBOT_USER_ID) {
    logger.debug({ messageText: event.text?.substring(0, 50) }, 'Addie: Ignoring Slackbot system message');
    return;
  }

  const startTime = Date.now();
  const interactionId = generateInteractionId();

  // Check if user is an AAO admin (for admin-only tools access)
  const isAAOAdmin = await isSlackUserAAOAdmin(event.user);
  logger.debug({ userId: event.user, isAAOAdmin }, 'Addie: Checked admin status');

  // Resolve user mentions to include names (e.g., <@U123> -> <@U123|John>)
  const textWithResolvedMentions = await resolveSlackMentions(event.text, lookupSlackUserName);

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

  // Set status to thinking
  try {
    await setAssistantStatus(channelId, STATUS_MESSAGES.thinking);
  } catch {
    // Status update failed, continue anyway
  }

  // Build per-request context for system prompt
  const { requestContext, memberContext, personId } = await buildRequestContext(event.user);

  // Heuristic click telemetry: if the incoming message text matches a
  // known suggested-prompt verbatim, record a click against that rule.
  const matchedRuleId = matchRuleIdFromMessage(event.text);
  const messageWorkosUserId = memberContext?.workos_user?.workos_user_id;
  if (matchedRuleId && messageWorkosUserId) {
    void recordPromptClicked(messageWorkosUserId, matchedRuleId);
  }

  // Record the user's message in the relationship and event log
  if (personId) {
    relationshipDb.recordPersonMessage(personId, 'slack')
      .then(() => relationshipDb.deriveSentiment(personId))
      .catch(error => {
        logger.warn({ error, personId }, 'Addie: Failed to record person message');
      });
    personEvents.recordEvent(personId, 'message_received', {
      channel: 'slack',
      data: { source: 'dm', text_length: textWithResolvedMentions.length },
    }).catch(err => logger.warn({ err, personId }, 'Addie: Failed to record message_received event'));
  }