fixed a bug where downstream nodes cant reference values via node id, and a lowercase headers issue

Author: jchui-wd

packages/components/nodes/agentflow/Start/Start.ts

@@ -352,7 +352,12 @@ class Start_Agentflow implements INode {
 
         if (startInputType === 'webhookTrigger') {
             inputData.webhook = input
-            let webhookOutput = input
+            let webhookOutput: string | Record<string, any> = input
+            try {
+                webhookOutput = typeof input === 'string' ? JSON.parse(input) : input
+            } catch (_) {
+                /* keep as-is */
+            }
             if (options.agentflowRuntime?.webhook && Object.keys(options.agentflowRuntime.webhook).length) {
                 webhookOutput = options.agentflowRuntime.webhook
             }

packages/server/src/services/webhook/index.ts

@@ -34,7 +34,8 @@ const validateWebhookChatflow = async (
 
         // Content-Type validation (startsWith handles "application/json; charset=utf-8" variants)
         const webhookContentType = startNode?.data?.inputs?.webhookContentType
-        if (webhookContentType && !headers?.['content-type']?.startsWith(webhookContentType)) {
+        const incomingContentType = (headers?.['content-type'] ?? '').toLowerCase()
+        if (webhookContentType && !incomingContentType.startsWith(webhookContentType)) {
             throw new InternalFlowiseError(
                 StatusCodes.UNSUPPORTED_MEDIA_TYPE,
                 `Content-Type ${headers?.['content-type']} not allowed. Expected ${webhookContentType}`
@@ -44,7 +45,7 @@ const validateWebhookChatflow = async (
         // Required header validation
         const rawHeaderParams = startNode?.data?.inputs?.webhookHeaderParams
         const webhookHeaderParams: Array<{ name: string; required: boolean }> = Array.isArray(rawHeaderParams) ? rawHeaderParams : []
-        const missingHeaders = webhookHeaderParams.filter((p) => p.required && headers?.[p.name] == null).map((p) => p.name)
+        const missingHeaders = webhookHeaderParams.filter((p) => p.required && headers?.[p.name.toLowerCase()] == null).map((p) => p.name)
         if (missingHeaders.length > 0) {
             throw new InternalFlowiseError(StatusCodes.BAD_REQUEST, `Missing required headers: ${missingHeaders.join(', ')}`)
         }