Properly handle event source errors (#687)

* Properly handle event source errors

* Changeset

* Fix TS

Author: SamyPesse

.changeset/heavy-olives-divide.md

@@ -0,0 +1,5 @@
+---
+'@gitbook/api': patch
+---
+
+Improve error handling for streamed API operations.

bun.lockb

@@ -13,7 +13,7 @@
     ],
     "dependencies": {
         "event-iterator": "^2.0.0",
-        "eventsource-parser": "^1.1.1"
+        "eventsource-parser": "^3.0.0"
     },
     "devDependencies": {
         "swagger-typescript-api": "^13.0.3",

packages/api/package.json

@@ -2,7 +2,7 @@
 const { apiConfig, generateResponses, config } = it;
 %>
 import { EventIterator } from 'event-iterator';
-import { createParser, type ParsedEvent, type ReconnectInterval } from 'eventsource-parser';
+import { createParser, type EventSourceMessage } from 'eventsource-parser';
 
 export type QueryParamsType = Record<string | number, any>;
 export type ResponseFormat = keyof Omit<Body, "body" | "bodyUsed">;
@@ -277,15 +277,23 @@ export class HttpClient<SecurityDataType = unknown> {
                         queue.stop();
                     }
 
-                    const parser = createParser((event: ParsedEvent | ReconnectInterval) => {
-                        if (event.type === 'event') {
-                            if (event.data === 'done') {
+                    const parser = createParser({
+                        onEvent: (event: EventSourceMessage) => {
+                            if (event.event === 'done') {
                                 stop();
+                            } else if (event.event === 'error') {
+                                const data = JSON.parse(event.data);
+                                reader.cancel();
+                                queue.fail(new Error(data.error.message));
                             } else {
                                 const data = JSON.parse(event.data);
                                 queue.push(data);
                             }
-                        }
+                        },
+                        onError: (error) => {
+                            reader.cancel();
+                            queue.fail(error);
+                        },
                     })
 
                     const decoder = new TextDecoder();