fix: let error events pass (#411)

* fix: allow error events pass the stream mode filter

* chore: release alpha version for langgraph integration

Author: ranst91

typescript-sdk/integrations/langgraph/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@ag-ui/langgraph",
-  "version": "0.0.16",
+  "version": "0.0.17-alpha.0",
   "main": "./dist/index.js",
   "module": "./dist/index.mjs",
   "types": "./dist/index.d.ts",

typescript-sdk/integrations/langgraph/src/agent.ts

@@ -179,7 +179,7 @@ export class LangGraphAgent extends AbstractAgent {
       return subscriber.error("No stream to regenerate");
     }
 
-    await this.handleStreamEvents(preparedStream, threadId, subscriber, input, streamMode);
+    await this.handleStreamEvents(preparedStream, threadId, subscriber, input, Array.isArray(streamMode) ? streamMode : [streamMode]);
   }
 
   async prepareRegenerateStream(input: RegenerateInput, streamMode: StreamMode | StreamMode[]) {
@@ -376,7 +376,7 @@ export class LangGraphAgent extends AbstractAgent {
     threadId: string,
     subscriber: Subscriber<ProcessedEvents>,
     input: RunAgentExtendedInput,
-    streamMode: StreamMode | StreamMode[],
+    streamModes: StreamMode | StreamMode[],
   ) {
     const { forwardedProps } = input;
     const nodeNameInput = forwardedProps?.nodeName;
@@ -406,7 +406,7 @@ export class LangGraphAgent extends AbstractAgent {
             streamResponseChunk.event.startsWith("values"));
 
         // @ts-ignore
-        if (!streamMode.includes(streamResponseChunk.event as StreamMode) && !isSubgraphStream) {
+        if (!streamModes.includes(streamResponseChunk.event as StreamMode) && !isSubgraphStream && streamResponseChunk.event !== 'error') {
           continue;
         }