Feat/stream flow variables (FlowiseAI#4022)

HenryHengZJ · tenuar · commit 8c20e08082e6 · 2025-02-14T13:11:13.000+02:00
stream flow variables
diff --git a/packages/server/src/utils/SSEStreamer.ts b/packages/server/src/utils/SSEStreamer.ts
@@ -194,7 +194,12 @@ export class SSEStreamer implements IServerSideEventStreamer {
             metadataJson['memoryType'] = apiResponse.memoryType
         }
         if (apiResponse.followUpPrompts) {
-            metadataJson['followUpPrompts'] = JSON.parse(apiResponse.followUpPrompts)
+            metadataJson['followUpPrompts'] =
+                typeof apiResponse.followUpPrompts === 'string' ? JSON.parse(apiResponse.followUpPrompts) : apiResponse.followUpPrompts
+        }
+        if (apiResponse.flowVariables) {
+            metadataJson['flowVariables'] =
+                typeof apiResponse.flowVariables === 'string' ? JSON.parse(apiResponse.flowVariables) : apiResponse.flowVariables
         }
         if (Object.keys(metadataJson).length > 0) {
             this.streamCustomEvent(chatId, 'metadata', metadataJson)

Original file line number	Diff line number	Diff line change
`@@ -194,7 +194,12 @@ export class SSEStreamer implements IServerSideEventStreamer {`
`194`	`194`	`metadataJson['memoryType'] = apiResponse.memoryType`
`195`	`195`	`}`
`196`	`196`	`if (apiResponse.followUpPrompts) {`
`197`		`- metadataJson['followUpPrompts'] = JSON.parse(apiResponse.followUpPrompts)`
	`197`	`+ metadataJson['followUpPrompts'] =`
	`198`	`+ typeof apiResponse.followUpPrompts === 'string' ? JSON.parse(apiResponse.followUpPrompts) : apiResponse.followUpPrompts`
	`199`	`+ }`
	`200`	`+ if (apiResponse.flowVariables) {`
	`201`	`+ metadataJson['flowVariables'] =`
	`202`	`+ typeof apiResponse.flowVariables === 'string' ? JSON.parse(apiResponse.flowVariables) : apiResponse.flowVariables`
`198`	`203`	`}`
`199`	`204`	`if (Object.keys(metadataJson).length > 0) {`
`200`	`205`	`this.streamCustomEvent(chatId, 'metadata', metadataJson)`