Add some logging to help identify bug where sending input does nothing

Author: jahooma

cli/src/hooks/use-message-queue.ts

@@ -1,5 +1,7 @@
 import { useCallback, useEffect, useRef, useState } from 'react'
 
+import { logger } from '../utils/logger'
+
 import type { PendingImage } from '../state/chat-store'
 
 export type StreamStatus = 'idle' | 'waiting' | 'streaming'
@@ -54,14 +56,52 @@ export const useMessageQueue = (
   }, [clearStreaming])
 
   useEffect(() => {
-    if (!canProcessQueue || queuePaused) return
-    if (streamStatus !== 'idle') return
-    if (streamMessageIdRef.current) return
-    if (isChainInProgressRef.current) return
-    if (activeAgentStreamsRef.current > 0) return
-
     const queuedList = queuedMessagesRef.current
-    if (queuedList.length === 0) return
+    const queueLength = queuedList.length
+
+    if (queueLength === 0) return
+
+    // Log why queue is blocked (only when there are messages waiting)
+    if (!canProcessQueue || queuePaused) {
+      logger.debug(
+        { queueLength, canProcessQueue, queuePaused },
+        '[message-queue] Queue blocked: canProcessQueue or paused',
+      )
+      return
+    }
+    if (streamStatus !== 'idle') {
+      logger.debug(
+        { queueLength, streamStatus },
+        '[message-queue] Queue blocked: stream not idle',
+      )
+      return
+    }
+    if (streamMessageIdRef.current) {
+      logger.debug(
+        { queueLength, streamMessageId: streamMessageIdRef.current },
+        '[message-queue] Queue blocked: streamMessageId set',
+      )
+      return
+    }
+    if (isChainInProgressRef.current) {
+      logger.debug(
+        { queueLength, isChainInProgress: isChainInProgressRef.current },
+        '[message-queue] Queue blocked: chain in progress',
+      )
+      return
+    }
+    if (activeAgentStreamsRef.current > 0) {
+      logger.debug(
+        { queueLength, activeAgentStreams: activeAgentStreamsRef.current },
+        '[message-queue] Queue blocked: active agent streams',
+      )
+      return
+    }
+
+    logger.info(
+      { queueLength },
+      '[message-queue] Processing next message from queue',
+    )
 
     const timeoutId = setTimeout(() => {
       const nextMessage = queuedList[0]
@@ -86,6 +126,10 @@ export const useMessageQueue = (
     const newQueue = [...queuedMessagesRef.current, queuedMessage]
     queuedMessagesRef.current = newQueue
     setQueuedMessages(newQueue)
+    logger.info(
+      { newQueueLength: newQueue.length, messageLength: message.length },
+      '[message-queue] Message added to queue',
+    )
   }, [])
 
   const pauseQueue = useCallback(() => {

cli/src/hooks/use-send-message.ts

@@ -237,19 +237,27 @@ export const useSendMessage = ({
       setIsRetrying(false)
 
       // Prepare user message (bash context, images, mode divider)
-      const { userMessageId, messageContent, bashContextForPrompt, finalContent } =
-        await prepareUserMessage({
-          content,
-          agentMode,
-          postUserMessage,
-          attachedImages,
-        })
+      const {
+        userMessageId,
+        messageContent,
+        bashContextForPrompt,
+        finalContent,
+      } = await prepareUserMessage({
+        content,
+        agentMode,
+        postUserMessage,
+        attachedImages,
+      })
 
       // Validate before sending (e.g., agent config checks)
       try {
         const validationResult = await onBeforeMessageSend()
 
         if (!validationResult.success) {
+          logger.warn(
+            { errors: validationResult.errors },
+            '[send-message] Validation failed',
+          )
           const errorsToAttach =
             validationResult.errors.length === 0
               ? [
@@ -277,7 +285,7 @@ export const useSendMessage = ({
       } catch (error) {
         logger.error(
           { error },
-          'Validation before message send failed with exception',
+          '[send-message] Validation before message send failed with exception',
         )
 
         setMessages((prev) => [
@@ -303,7 +311,7 @@ export const useSendMessage = ({
       if (!client) {
         logger.error(
           {},
-          'No Codebuff client available. Please ensure you are authenticated.',
+          '[send-message] No Codebuff client available. Please ensure you are authenticated.',
         )
         return
       }
@@ -376,6 +384,7 @@ export const useSendMessage = ({
           signal: abortController.signal,
         })
 
+        logger.info({ runConfig }, '[send-message] Sending message with sdk run config')
         const runState = await client.run(runConfig)
 
         // Finalize: persist state and mark complete
@@ -413,6 +422,17 @@ export const useSendMessage = ({
           updateChainInProgress,
         })
       } finally {
+        // Defensive reset: ensure chain state is always cleared even if handlers throw.
+        // This prevents the system from getting stuck in "chain in progress" state.
+        if (isChainInProgressRef.current) {
+          logger.warn(
+            {},
+            '[send-message] Chain still in progress after try/catch, forcing reset',
+          )
+          updateChainInProgress(false)
+          setStreamStatus('idle')
+          setCanProcessQueue(!isQueuePausedRef?.current)
+        }
         // Ensure the batched updater's flush interval is always cleaned up,
         // even if handleRunCompletion or handleRunError throw unexpectedly.
         // dispose() is safe to call multiple times.