diff --git a/libs/sdk-js/src/index.ts b/libs/sdk-js/src/index.ts index 956f5f64b..eb399a9b2 100644 --- a/libs/sdk-js/src/index.ts +++ b/libs/sdk-js/src/index.ts @@ -36,6 +36,7 @@ export type { MessagesStreamEvent, DebugStreamEvent, EventsStreamEvent, + ErrorStreamEvent, } from "./types.stream.js"; export type { Message, diff --git a/libs/sdk-js/src/types.stream.ts b/libs/sdk-js/src/types.stream.ts index 4a36652d7..7ca7742d1 100644 --- a/libs/sdk-js/src/types.stream.ts +++ b/libs/sdk-js/src/types.stream.ts @@ -64,6 +64,17 @@ export type MetadataStreamEvent = { /** @internal */ export type SubgraphMetadataStreamEvent = AsSubgraph; +/** + * Stream event with error information. + */ +export type ErrorStreamEvent = { + event: "error"; + data: { error: string; message: string }; +}; + +/** @internal */ +export type SubgraphErrorStreamEvent = AsSubgraph; + /** * Stream event with updates to the state after each step. * The streamed outputs include the name of the node that @@ -146,7 +157,8 @@ type GetStreamModeMap< "messages-tuple": MessagesTupleStreamEvent; events: EventsStreamEvent; }[TStreamMode extends StreamMode[] ? TStreamMode[number] : TStreamMode] - | MetadataStreamEvent; + | MetadataStreamEvent + | ErrorStreamEvent; type GetSubgraphsStreamModeMap< TStreamMode extends StreamMode | StreamMode[], @@ -163,7 +175,8 @@ type GetSubgraphsStreamModeMap< "messages-tuple": SubgraphMessagesTupleStreamEvent; events: SubgraphEventsStreamEvent; }[TStreamMode extends StreamMode[] ? TStreamMode[number] : TStreamMode] - | SubgraphMetadataStreamEvent; + | SubgraphMetadataStreamEvent + | SubgraphErrorStreamEvent; export type TypedAsyncGenerator< TStreamMode extends StreamMode | StreamMode[] = [],