From 369c4b247bd5db0a0f7680f8928ed7a199896554 Mon Sep 17 00:00:00 2001
From: sd0ric4 <1286518974@qq.com>
Date: Tue, 25 Mar 2025 18:42:23 +0800
Subject: [PATCH] feat: add realmode parameter to workflow dispatch and update
 interactive handling

---
 .../global/core/workflow/runtime/type.d.ts    |   1 +
 .../service/core/workflow/dispatch/index.ts   |   3 +-
 .../dispatch/interactive/formInput.ts         |   4 +-
 .../dispatch/interactive/userSelect.ts        |   4 +-
 .../app/src/pages/api/core/workflow/debug.ts  | 254 +-----------------
 5 files changed, 20 insertions(+), 246 deletions(-)

diff --git a/packages/global/core/workflow/runtime/type.d.ts b/packages/global/core/workflow/runtime/type.d.ts
index f5db3a89c..b2d6068cb 100644
--- a/packages/global/core/workflow/runtime/type.d.ts
+++ b/packages/global/core/workflow/runtime/type.d.ts
@@ -65,6 +65,7 @@ export type ModuleDispatchProps<T> = ChatDispatchProps & {
   runtimeNodes: RuntimeNodeItemType[];
   runtimeEdges: RuntimeEdgeItemType[];
   params: T;
+  realmode?: 'test' | 'chat' | 'debug';
 };
 
 export type SystemVariablesType = {
diff --git a/packages/service/core/workflow/dispatch/index.ts b/packages/service/core/workflow/dispatch/index.ts
index 24b279f5c..ff3f9d4f4 100644
--- a/packages/service/core/workflow/dispatch/index.ts
+++ b/packages/service/core/workflow/dispatch/index.ts
@@ -581,7 +581,8 @@ export async function dispatchWorkFlow(data: Props): Promise<DispatchFlowRespons
       runtimeNodes,
       runtimeEdges,
       params,
-      mode: props.mode === 'debug' ? 'test' : props.mode
+      mode: props.mode === 'debug' ? 'test' : props.mode,
+      realmode: props.mode
     };
 
     // run module
diff --git a/packages/service/core/workflow/dispatch/interactive/formInput.ts b/packages/service/core/workflow/dispatch/interactive/formInput.ts
index 50b9c8d75..24bf48f88 100644
--- a/packages/service/core/workflow/dispatch/interactive/formInput.ts
+++ b/packages/service/core/workflow/dispatch/interactive/formInput.ts
@@ -32,11 +32,11 @@ export const dispatchFormInput = async (props: Props): Promise<FormInputResponse
     query
   } = props;
   const { isEntry } = node;
-
+  const mode = props.realmode;
   const interactive = getLastInteractiveValue(histories);
 
   // Interactive node is not the entry node, return interactive result
-  if (!isEntry || interactive?.type !== 'userInput') {
+  if ((!isEntry || interactive?.type !== 'userInput') && mode !== 'debug') {
     return {
       [DispatchNodeResponseKeyEnum.interactive]: {
         type: 'userInput',
diff --git a/packages/service/core/workflow/dispatch/interactive/userSelect.ts b/packages/service/core/workflow/dispatch/interactive/userSelect.ts
index 02ae94f8e..1e0f9963e 100644
--- a/packages/service/core/workflow/dispatch/interactive/userSelect.ts
+++ b/packages/service/core/workflow/dispatch/interactive/userSelect.ts
@@ -30,11 +30,11 @@ export const dispatchUserSelect = async (props: Props): Promise<UserSelectRespon
     query
   } = props;
   const { nodeId, isEntry } = node;
-
+  const mode = props.realmode;
   const interactive = getLastInteractiveValue(histories);
 
   // Interactive node is not the entry node, return interactive result
-  if (!isEntry || interactive?.type !== 'userSelect') {
+  if ((!isEntry || interactive?.type !== 'userSelect') && mode !== 'debug') {
     return {
       [DispatchNodeResponseKeyEnum.interactive]: {
         type: 'userSelect',
diff --git a/projects/app/src/pages/api/core/workflow/debug.ts b/projects/app/src/pages/api/core/workflow/debug.ts
index b098f5d03..5fe8d92b1 100644
--- a/projects/app/src/pages/api/core/workflow/debug.ts
+++ b/projects/app/src/pages/api/core/workflow/debug.ts
@@ -48,246 +48,18 @@ async function handler(
       }
     }
   ];
-  const histories_form_input: ChatItemType[] = requestHistories || [
-    {
-      dataId: 'j2ywiLkIbMivBll5fzYvkuGK',
-      obj: ChatRoleEnum.Human,
-      value: [
-        {
-          type: ChatItemValueTypeEnum.text,
-          text: {
-            content: '123213'
-          }
-        }
-      ]
-    },
-    {
-      dataId: 'lRXcu9MtfCHlpUqeQWGSY4gu',
-      obj: ChatRoleEnum.AI,
-      value: [
-        {
-          type: ChatItemValueTypeEnum.interactive,
-          interactive: {
-            type: 'userInput',
-            params: {
-              description: '这是个表单输入',
-              inputForm: [
-                {
-                  type: 'input',
-                  key: '未知',
-                  label: '未知',
-                  description: '未知',
-                  value: '',
-                  maxLength: 20,
-                  defaultValue: '未知',
-                  valueType: 'string',
-                  required: true,
-                  list: [
-                    {
-                      label: '',
-                      value: ''
-                    }
-                  ]
-                },
-                {
-                  type: 'numberInput',
-                  key: '数字',
-                  label: '数字',
-                  description: '数字',
-                  value: '',
-                  defaultValue: 2,
-                  valueType: 'number',
-                  required: false,
-                  list: [
-                    {
-                      label: '',
-                      value: ''
-                    }
-                  ],
-                  max: 2,
-                  min: 2
-                }
-              ]
-            },
-            entryNodeIds: ['mYvt4SN5KFwZ'],
-            memoryEdges: [
-              {
-                source: 'workflowStartNodeId',
-                target: 'oQKWr1cGFVBG',
-                sourceHandle: 'workflowStartNodeId-source-right',
-                targetHandle: 'oQKWr1cGFVBG-target-left',
-                status: 'waiting'
-              },
-              {
-                source: 'oQKWr1cGFVBG',
-                target: 'uFnqha6Nx9qw',
-                sourceHandle: 'oQKWr1cGFVBG-source-option1',
-                targetHandle: 'uFnqha6Nx9qw-target-left',
-                status: 'waiting'
-              },
-              {
-                source: 'oQKWr1cGFVBG',
-                target: '7kwgL1dVlwG6',
-                sourceHandle: 'oQKWr1cGFVBG-source-option2',
-                targetHandle: '7kwgL1dVlwG6-target-left',
-                status: 'waiting'
-              },
-              {
-                source: '7kwgL1dVlwG6',
-                target: 'dZpDaSXFO0td',
-                sourceHandle: '7kwgL1dVlwG6-source-right',
-                targetHandle: 'dZpDaSXFO0td-target-left',
-                status: 'waiting'
-              },
-              {
-                source: 'dZpDaSXFO0td',
-                target: 'uFnqha6Nx9qw',
-                sourceHandle: 'dZpDaSXFO0td-source-option2',
-                targetHandle: 'uFnqha6Nx9qw-target-left',
-                status: 'waiting'
-              },
-              {
-                source: 'workflowStartNodeId',
-                target: 'mYvt4SN5KFwZ',
-                sourceHandle: 'workflowStartNodeId-source-right',
-                targetHandle: 'mYvt4SN5KFwZ-target-left',
-                status: 'waiting'
-              },
-              {
-                source: 'mYvt4SN5KFwZ',
-                target: 'dfh8AqxAkoL4',
-                sourceHandle: 'mYvt4SN5KFwZ-source-right',
-                targetHandle: 'dfh8AqxAkoL4-target-left',
-                status: 'waiting'
-              }
-            ],
-            nodeOutputs: [
-              {
-                nodeId: 'workflowStartNodeId',
-                key: NodeOutputKeyEnum.userChatInput,
-                value: '123213'
-              }
-            ]
-          }
-        }
-      ]
-    }
-  ];
-  const query: UserChatItemValueItemType[] = requestQuery || [];
-  const histories: ChatItemType[] = requestHistories || [];
-  // || [
-  //   {
-  //     dataId: 'debug-history-1',
-  //     obj: ChatRoleEnum.Human,
-  //     value: [
-  //       {
-  //         type: ChatItemValueTypeEnum.text,
-  //         text: {
-  //           content: '启动工作流'
-  //         }
-  //       }
-  //     ]
-  //   },
-  //   {
-  //     dataId: 'debug-history-2',
-  //     obj: ChatRoleEnum.AI,
-  //     value: [
-  //       {
-  //         type: ChatItemValueTypeEnum.interactive,
-  //         interactive: {
-  //           type: 'userSelect',
-  //           params: {
-  //             description: '请选择操作',
-  //             userSelectOptions: [
-  //               { value: 'Confirm', key: 'option1' },
-  //               { value: 'Cancel', key: 'option2' }
-  //             ],
-  //             // 已选择的值，使得此交互不会被getLastInteractiveValue返回
-  //             userSelectedVal: 'Confirm'
-  //           },
-  //           entryNodeIds: ['nodeId1'],
-  //           memoryEdges: [
-  //             {
-  //               source: 'workflowStartNodeId',
-  //               target: 'nodeId1',
-  //               sourceHandle: 'workflowStartNodeId-source-right',
-  //               targetHandle: 'nodeId1-target-left',
-  //               status: 'active'
-  //             }
-  //           ],
-  //           nodeOutputs: [
-  //             {
-  //               nodeId: 'workflowStartNodeId',
-  //               key: NodeOutputKeyEnum.userChatInput,
-  //               value: '启动工作流'
-  //             }
-  //           ]
-  //         }
-  //       }
-  //     ]
-  //   },
-  //   {
-  //     dataId: 'bglb040v1wPQ3C1iNaDStPhm',
-  //     obj: ChatRoleEnum.AI, // 使用枚举值
-  //     value: [
-  //       {
-  //         type: ChatItemValueTypeEnum.interactive, // 使用枚举值
-  //         interactive: {
-  //           type: 'userSelect',
-  //           params: {
-  //             description: '你是谁',
-  //             userSelectOptions: [
-  //               {
-  //                 value: 'Confirm',
-  //                 key: 'option1'
-  //               },
-  //               {
-  //                 value: 'Cancel',
-  //                 key: 'option2'
-  //               },
-  //               {
-  //                 value: 'wqeqweqwe',
-  //                 key: 'y7eOdrYzYS5C'
-  //               }
-  //             ]
-  //             // 重要：这里没有 userSelectedVal，所以这个交互会被getLastInteractiveValue返回
-  //           },
-  //           entryNodeIds: ['oQKWr1cGFVBG'],
-  //           memoryEdges: [
-  //             {
-  //               source: 'workflowStartNodeId',
-  //               target: 'oQKWr1cGFVBG',
-  //               sourceHandle: 'workflowStartNodeId-source-right',
-  //               targetHandle: 'oQKWr1cGFVBG-target-left',
-  //               status: 'waiting'
-  //             },
-  //             {
-  //               source: 'oQKWr1cGFVBG',
-  //               target: 'uFnqha6Nx9qw',
-  //               sourceHandle: 'oQKWr1cGFVBG-source-option1',
-  //               targetHandle: 'uFnqha6Nx9qw-target-left',
-  //               status: 'waiting'
-  //             },
-  //             {
-  //               source: 'oQKWr1cGFVBG',
-  //               target: '7kwgL1dVlwG6',
-  //               sourceHandle: 'oQKWr1cGFVBG-source-option2',
-  //               targetHandle: '7kwgL1dVlwG6-target-left',
-  //               status: 'waiting'
-  //             }
-  //           ],
-  //           nodeOutputs: [
-  //             {
-  //               nodeId: 'workflowStartNodeId',
-  //               key: NodeOutputKeyEnum.userChatInput,
-  //               value: 'Confirm'
-  //             }
-  //           ]
-  //         }
-  //       }
-  //     ]
-  //   }
-  // ];
+
+  const query: UserChatItemValueItemType[] =
+    requestQuery ||
+    [
+      // {
+      //   type: ChatItemValueTypeEnum.text,
+      //   text: {
+      //     content: 'Cancel'
+      //   }
+      // }
+    ];
+
   /* user auth */
   const [{ teamId, tmbId }, { app }] = await Promise.all([
     authCert({
@@ -324,7 +96,7 @@ async function handler(
     variables,
     query: query,
     chatConfig: defaultApp.chatConfig,
-    histories: histories,
+    histories: [],
     stream: false,
     maxRunTimes: WORKFLOW_MAX_RUN_TIMES
   });