diff --git a/packages/service/core/app/mcp.ts b/packages/service/core/app/mcp.ts index 4ea6c544e..3c5239b15 100644 --- a/packages/service/core/app/mcp.ts +++ b/packages/service/core/app/mcp.ts @@ -41,14 +41,23 @@ export class MCPClient { }, eventSourceInit: { fetch: (url, init) => { - const headers = new Headers({ - ...init?.headers, + const mergedHeaders: Record = { ...this.headers - }); + }; + + if (init?.headers) { + if (init.headers instanceof Headers) { + init.headers.forEach((value, key) => { + mergedHeaders[key] = value; + }); + } else if (typeof init.headers === 'object') { + Object.assign(mergedHeaders, init.headers); + } + } return fetch(url, { ...init, - headers + headers: mergedHeaders }); } } diff --git a/projects/app/src/pageComponents/app/detail/WorkflowComponents/context/workflowInitContext.tsx b/projects/app/src/pageComponents/app/detail/WorkflowComponents/context/workflowInitContext.tsx index 72d02ab11..6a8e69dae 100644 --- a/projects/app/src/pageComponents/app/detail/WorkflowComponents/context/workflowInitContext.tsx +++ b/projects/app/src/pageComponents/app/detail/WorkflowComponents/context/workflowInitContext.tsx @@ -150,6 +150,9 @@ const WorkflowInitContextProvider = ({ name: node.data.name, parentNodeId: node.data.parentNodeId, flowNodeType: node.data.flowNodeType, + version: node.data.version, + versionLabel: node.data.versionLabel, + isLatestVersion: node.data.isLatestVersion, inputs: node.data.inputs.map((input) => { return { key: input.key,