add v2 completions (#4364)

* add v2 completions

* completion config

* config version

* fix

* frontend

* doc

* fix

Author: newfish-cmyk

docSite/content/zh-cn/docs/development/openapi/chat.md

@@ -5,6 +5,7 @@ export enum SseResponseEventEnum {
   answer = 'answer', // animation stream
   fastAnswer = 'fastAnswer', // direct answer text, not animation
   flowNodeStatus = 'flowNodeStatus', // update node status
+  flowNodeResponse = 'flowNodeResponse', // node response
 
   toolCall = 'toolCall', // tool start
   toolParams = 'toolParams', // tool params return

packages/global/core/workflow/runtime/constants.ts

@@ -59,6 +59,7 @@ export type ChatDispatchProps = {
   isToolCall?: boolean;
   workflowStreamResponse?: WorkflowResponseType;
   workflowDispatchDeep?: number;
+  version?: 'v1' | 'v2';
 };
 
 export type ModuleDispatchProps<T> = ChatDispatchProps & {

packages/global/core/workflow/runtime/type.d.ts

@@ -129,19 +129,29 @@ export function responseWrite({
   res,
   write,
   event,
-  data
+  data,
+  version = 'v1'
 }: {
   res?: NextApiResponse;
   write?: (text: string) => void;
   event?: string;
   data: string;
+  version?: 'v1' | 'v2';
 }) {
   const Write = write || res?.write;
 
   if (!Write) return;
 
-  event && Write(`event: ${event}\n`);
-  Write(`data: ${data}\n\n`);
+  if (version === 'v1') {
+    event && Write(`event: ${event}\n`);
+    Write(`data: ${data}\n\n`);
+  } else {
+    const dataJSON = {
+      event,
+      data
+    };
+    Write(`data: ${JSON.stringify(dataJSON)}\n\n`);
+  }
 }
 
 export const responseWriteNodeStatus = ({

packages/service/common/response/index.ts

@@ -130,6 +130,7 @@ export async function dispatchWorkFlow(data: Props): Promise<DispatchFlowRespons
     timezone,
     externalProvider,
     stream = false,
+    version = 'v1',
     ...props
   } = data;
 
@@ -626,6 +627,20 @@ export async function dispatchWorkFlow(data: Props): Promise<DispatchFlowRespons
       };
     })();
 
+    if (
+      !props.isToolCall &&
+      version === 'v2' &&
+      !props.runningAppInfo.isChildApp &&
+      formatResponseData
+    ) {
+      props.workflowStreamResponse?.({
+        event: SseResponseEventEnum.flowNodeResponse,
+        data: {
+          ...formatResponseData
+        }
+      });
+    }
+
     // Add output default value
     node.outputs.forEach((item) => {
       if (!item.required) return;

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

@@ -21,13 +21,15 @@ export const getWorkflowResponseWrite = ({
   detail,
   streamResponse,
   id = getNanoid(24),
-  showNodeStatus = true
+  showNodeStatus = true,
+  version = 'v1'
 }: {
   res?: NextApiResponse;
   detail: boolean;
   streamResponse: boolean;
   id?: string;
   showNodeStatus?: boolean;
+  version?: 'v1' | 'v2';
 }) => {
   return ({
     write,
@@ -70,7 +72,8 @@ export const getWorkflowResponseWrite = ({
       res,
       write,
       event: detail ? event : undefined,
-      data: JSON.stringify(data)
+      data: JSON.stringify(data),
+      version
     });
   };
 };

packages/service/core/workflow/dispatch/utils.ts

@@ -150,7 +150,8 @@ async function handler(req: NextApiRequest, res: NextApiResponse) {
       detail: true,
       streamResponse: true,
       id: chatId,
-      showNodeStatus: true
+      showNodeStatus: true,
+      version: 'v2'
     });
 
     /* start process */
@@ -182,7 +183,8 @@ async function handler(req: NextApiRequest, res: NextApiResponse) {
       histories: newHistories,
       stream: true,
       maxRunTimes: WORKFLOW_MAX_RUN_TIMES,
-      workflowStreamResponse: workflowResponseWrite
+      workflowStreamResponse: workflowResponseWrite,
+      version: 'v2'
     });
 
     workflowResponseWrite({
@@ -195,12 +197,8 @@ async function handler(req: NextApiRequest, res: NextApiResponse) {
     responseWrite({
       res,
       event: SseResponseEventEnum.answer,
-      data: '[DONE]'
-    });
-    responseWrite({
-      res,
-      event: SseResponseEventEnum.flowResponses,
-      data: JSON.stringify(flowResponses)
+      data: '[DONE]',
+      version: 'v2'
     });
 
     // save chat