feat: toolcall stream response (#6009)

packages/service/core/workflow/dispatch/ai/tool/index.ts

@@ -57,7 +57,8 @@ export const dispatchRunTools = async (props: DispatchToolModuleProps): Promise<
       history = 6,
       fileUrlList: fileLinks,
       aiChatVision,
-      aiChatReasoning
+      aiChatReasoning,
+      isResponseAnswerText = true
     }
   } = props;
 
@@ -235,7 +236,9 @@ export const dispatchRunTools = async (props: DispatchToolModuleProps): Promise<
         (sum, item) => sum + item.runTimes,
         0
       ),
-      [DispatchNodeResponseKeyEnum.assistantResponses]: previewAssistantResponses,
+      [DispatchNodeResponseKeyEnum.assistantResponses]: isResponseAnswerText
+        ? previewAssistantResponses
+        : undefined,
       [DispatchNodeResponseKeyEnum.nodeResponse]: {
         // 展示的积分消耗
         totalPoints: totalPointsUsage,

packages/service/core/workflow/dispatch/ai/tool/toolCall.ts

@@ -33,7 +33,8 @@ export const runToolCall = async (props: DispatchToolModuleProps): Promise<RunTo
       aiChatStopSign,
       aiChatResponseFormat,
       aiChatJsonSchema,
-      aiChatReasoning
+      aiChatReasoning,
+      isResponseAnswerText = true
     }
   } = workflowProps;
 
@@ -141,6 +142,7 @@ export const runToolCall = async (props: DispatchToolModuleProps): Promise<RunTo
       });
     },
     onStreaming({ text }) {
+      if (!isResponseAnswerText) return;
       workflowStreamResponse?.({
         write,
         event: SseResponseEventEnum.answer,
@@ -150,6 +152,7 @@ export const runToolCall = async (props: DispatchToolModuleProps): Promise<RunTo
       });
     },
     onToolCall({ call }) {
+      if (!isResponseAnswerText) return;
       const toolNode = toolNodesMap.get(call.function.name);
       if (toolNode) {
         workflowStreamResponse?.({
@@ -168,6 +171,7 @@ export const runToolCall = async (props: DispatchToolModuleProps): Promise<RunTo
       }
     },
     onToolParam({ tool, params }) {
+      if (!isResponseAnswerText) return;
       workflowStreamResponse?.({
         write,
         event: SseResponseEventEnum.toolParams,
@@ -209,18 +213,20 @@ export const runToolCall = async (props: DispatchToolModuleProps): Promise<RunTo
       // Format tool response
       const stringToolResponse = formatToolResponse(toolRunResponse.toolResponses);
 
-      workflowStreamResponse?.({
-        event: SseResponseEventEnum.toolResponse,
-        data: {
-          tool: {
-            id: call.id,
-            toolName: '',
-            toolAvatar: '',
-            params: '',
-            response: sliceStrStartEnd(stringToolResponse, 5000, 5000)
+      if (isResponseAnswerText) {
+        workflowStreamResponse?.({
+          event: SseResponseEventEnum.toolResponse,
+          data: {
+            tool: {
+              id: call.id,
+              toolName: '',
+              toolAvatar: '',
+              params: '',
+              response: sliceStrStartEnd(stringToolResponse, 5000, 5000)
+            }
           }
-        }
-      });
+        });
+      }
 
       toolRunResponses.push(toolRunResponse);
 
@@ -258,18 +264,20 @@ export const runToolCall = async (props: DispatchToolModuleProps): Promise<RunTo
       // console.dir(runtimeEdges, { depth: null });
       const stringToolResponse = formatToolResponse(toolRunResponse.toolResponses);
 
-      workflowStreamResponse?.({
-        event: SseResponseEventEnum.toolResponse,
-        data: {
-          tool: {
-            id: toolParams.toolCallId,
-            toolName: '',
-            toolAvatar: '',
-            params: '',
-            response: sliceStrStartEnd(stringToolResponse, 5000, 5000)
+      if (isResponseAnswerText) {
+        workflowStreamResponse?.({
+          event: SseResponseEventEnum.toolResponse,
+          data: {
+            tool: {
+              id: toolParams.toolCallId,
+              toolName: '',
+              toolAvatar: '',
+              params: '',
+              response: sliceStrStartEnd(stringToolResponse, 5000, 5000)
+            }
           }
-        }
-      });
+        });
+      }
 
       toolRunResponses.push(toolRunResponse);
       const assistantMessages = chats2GPTMessages({

packages/service/core/workflow/dispatch/ai/tool/type.d.ts

@@ -31,6 +31,7 @@ export type DispatchToolModuleProps = ModuleDispatchProps<{
   [NodeInputKeyEnum.aiSystemPrompt]: string;
   [NodeInputKeyEnum.aiChatTemperature]: number;
   [NodeInputKeyEnum.aiChatMaxToken]: number;
+  [NodeInputKeyEnum.aiChatIsResponseText]: boolean;
   [NodeInputKeyEnum.aiChatVision]?: boolean;
   [NodeInputKeyEnum.aiChatReasoning]?: boolean;
   [NodeInputKeyEnum.aiChatTopP]?: number;