feat: enhance reasoning handling in translation process

Author: caozhiyuan

src/routes/messages/stream-translation.ts

@@ -62,8 +62,11 @@ function handleFinish(
         index: state.contentBlockIndex,
       })
       state.contentBlockOpen = false
+      state.contentBlockIndex++
     }
 
+    handleReasoningOpaque(choice.delta, events, state)
+
     events.push(
       {
         type: "message_delta",
@@ -96,7 +99,11 @@ function handleToolCalls(
   events: Array<AnthropicStreamEventData>,
 ) {
   if (delta.tool_calls && delta.tool_calls.length > 0) {
-    closeThinkingBlockIfOpen(delta, state, events)
+    closeThinkingBlockIfOpen(state, events)
+
+    if (!state.contentBlockOpen) {
+      handleReasoningOpaque(delta, events, state)
+    }
 
     for (const toolCall of delta.tool_calls) {
       if (toolCall.id && toolCall.function?.name) {
@@ -156,7 +163,7 @@ function handleContent(
   events: Array<AnthropicStreamEventData>,
 ) {
   if (delta.content && delta.content.length > 0) {
-    closeThinkingBlockIfOpen(delta, state, events)
+    closeThinkingBlockIfOpen(state, events)
 
     if (isToolBlockOpen(state)) {
       // A tool block was open, so close it before starting a text block.
@@ -312,7 +319,6 @@ function handleThinkingText(
 }
 
 function closeThinkingBlockIfOpen(
-  delta: Delta,
   state: AnthropicStreamState,
   events: Array<AnthropicStreamEventData>,
 ): void {
@@ -334,7 +340,6 @@ function closeThinkingBlockIfOpen(
     state.contentBlockIndex++
     state.thinkingBlockOpen = false
   }
-  handleReasoningOpaque(delta, events, state)
 }
 
 export function translateErrorToAnthropicErrorEvent(): AnthropicStreamEventData {