Function handleUserMessage

server/src/addie/bolt-app.ts:1355–1936

* Handle user message in assistant thread * Uses streaming to show response as it's generated

({
  event,
  client,
  context,
  say,
  setStatus,
  setTitle,
  getThreadContext,
}: AllAssistantMiddlewareArgs<AssistantUserMessageMiddlewareArgs>)

 * Uses streaming to show response as it's generated
 */
async function handleUserMessage({
  event,
  client,
  context,
  say,
  setStatus,
  setTitle,
  getThreadContext,
}: AllAssistantMiddlewareArgs<AssistantUserMessageMiddlewareArgs>): Promise<void> {
  // Log entry into Assistant's userMessage handler for debugging
  logger.debug({
    channelId: 'channel' in event ? event.channel : undefined,
    userId: 'user' in event ? event.user : undefined,
    threadTs: 'thread_ts' in event ? event.thread_ts : undefined,
    ts: 'ts' in event ? event.ts : undefined,
    hasText: 'text' in event && !!event.text,
    channelType: 'channel_type' in event ? event.channel_type : undefined,
  }, 'Addie Bolt: handleUserMessage called (Assistant handler)');

  if (!claudeClient) {
    logger.warn('Addie Bolt: Claude client not initialized');
    return;
  }

  // Skip bot messages to prevent loops (Addie talking to herself)
  if ('bot_id' in event && event.bot_id) {
    logger.debug({ botId: event.bot_id }, 'Addie Bolt: Ignoring assistant message from bot');
    return;
  }

  // Extract fields safely - not all message events have these fields
  const userId = 'user' in event ? event.user : undefined;
  const messageText = 'text' in event ? event.text : undefined;
  const threadTs = 'thread_ts' in event ? event.thread_ts : ('ts' in event ? event.ts : undefined);

  // Skip if not a user message
  if (!userId || !messageText) {
    logger.debug({ userId, hasText: !!messageText }, 'Addie Bolt: Ignoring message event without user or text');
    return;
  }

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

  // Skip DMs without thread_ts - these are handled by handleDirectMessage via middleware.
  // The Assistant framework receives message.im events through a separate pipeline from
  // the global middleware chain, so both handlers can fire for the same event.
  // First DMs (without thread_ts) are handled by handleDirectMessage; skip them here.
  const channelType = 'channel_type' in event ? event.channel_type : undefined;
  const hasRealThreadTs = 'thread_ts' in event && event.thread_ts !== undefined;
  if (channelType === 'im' && !hasRealThreadTs) {
    logger.debug({ channelType, hasThreadTs: hasRealThreadTs }, 'Addie Bolt: Skipping DM without thread_ts in Assistant handler (handled by middleware)');
    return;
  }