@agentick/shared - npm Package Compare versions

Comparing version 0.8.0 to 0.9.0

dist/embeddings.d.ts

+/** Wire-safe embedding output — shared across all embedding adapters. */
+export interface EmbedResult {
+    embeddings: number[][];
+    dimensions: number;
+    model: string;
+    usage?: {
+        totalTokens: number;
+    };
+}
+//# sourceMappingURL=embeddings.d.ts.map

dist/embeddings.d.ts.map

+{"version":3,"file":"embeddings.d.ts","sourceRoot":"","sources":["../src/embeddings.ts"],"names":[],"mappings":"AAAA,yEAAyE;AACzE,MAAM,WAAW,WAAW;IAC1B,UAAU,EAAE,MAAM,EAAE,EAAE,CAAC;IACvB,UAAU,EAAE,MAAM,CAAC;IACnB,KAAK,EAAE,MAAM,CAAC;IACd,KAAK,CAAC,EAAE;QAAE,WAAW,EAAE,MAAM,CAAA;KAAE,CAAC;CACjC"}

dist/embeddings.js

+//# sourceMappingURL=embeddings.js.map

dist/embeddings.js.map

+{"version":3,"file":"embeddings.js","sourceRoot":"","sources":["../src/embeddings.ts"],"names":[],"mappings":""}

dist/rpc-transport.d.ts

+/**
+ * RPC Client Transport
+ *
+ * Shared protocol machinery for all bidirectional client transports
+ * (WebSocket, Unix socket, etc.). Each transport provides a delegate that
+ * handles wire-specific I/O (open/send/close); this module provides
+ * everything else: state machine, request correlation, event streaming,
+ * send streams, reconnection, session operations.
+ *
+ * This eliminates the massive duplication between WSTransport and
+ * UnixSocketClientTransport — the only real difference is how bytes
+ * hit the wire.
+ */
+import type { ClientTransport } from "./transport";
+/** Handle to an open connection. Provided by the delegate after open(). */
+export interface RPCConnectionHandle {
+    /** Send a JSON-serializable object over the wire */
+    send(data: Record<string, unknown>): void;
+    /** Close the connection */
+    close(): void;
+}
+/** Callbacks the delegate invokes when data arrives or the connection drops. */
+export interface RPCTransportCallbacks {
+    onMessage(data: Record<string, unknown>): void;
+    onClose(): void;
+    onError(error: Error): void;
+}
+/**
+ * Wire-specific delegate. Implementations exist for WebSocket, Unix socket, etc.
+ * The delegate is responsible ONLY for opening the raw connection, sending bytes,
+ * and forwarding received messages/close/error events to the callbacks.
+ */
+export interface RPCTransportDelegate {
+    /**
+     * Open a connection to the server.
+     * Must call callbacks.onMessage for each received message (already parsed JSON).
+     * Must call callbacks.onClose when connection drops.
+     * Must call callbacks.onError on connection errors.
+     * Returns a handle for sending data and closing.
+     */
+    open(callbacks: RPCTransportCallbacks): Promise<RPCConnectionHandle>;
+}
+export interface RPCTransportConfig {
+    /** Client ID sent in the connect message */
+    clientId?: string;
+    /** Authentication token */
+    token?: string;
+    /** Request timeout in ms (default: 30000) */
+    timeout?: number;
+    /** Reconnection settings */
+    reconnect?: {
+        enabled?: boolean;
+        maxAttempts?: number;
+        delay?: number;
+    };
+}
+/**
+ * Create a ClientTransport backed by an RPC delegate.
+ *
+ * The delegate handles wire I/O (WebSocket, Unix socket, etc.).
+ * This function handles the full gateway RPC protocol:
+ * request/response correlation, event streaming, reconnection,
+ * and all session operations.
+ */
+export declare function createRPCTransport(config: RPCTransportConfig, delegate: RPCTransportDelegate): ClientTransport;
+//# sourceMappingURL=rpc-transport.d.ts.map

dist/rpc-transport.d.ts.map

+{"version":3,"file":"rpc-transport.d.ts","sourceRoot":"","sources":["../src/rpc-transport.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;GAYG;AAEH,OAAO,KAAK,EACV,eAAe,EAIhB,MAAM,aAAa,CAAC;AAQrB,2EAA2E;AAC3E,MAAM,WAAW,mBAAmB;IAClC,oDAAoD;IACpD,IAAI,CAAC,IAAI,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,GAAG,IAAI,CAAC;IAC1C,2BAA2B;IAC3B,KAAK,IAAI,IAAI,CAAC;CACf;AAED,gFAAgF;AAChF,MAAM,WAAW,qBAAqB;IACpC,SAAS,CAAC,IAAI,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,GAAG,IAAI,CAAC;IAC/C,OAAO,IAAI,IAAI,CAAC;IAChB,OAAO,CAAC,KAAK,EAAE,KAAK,GAAG,IAAI,CAAC;CAC7B;AAED;;;;GAIG;AACH,MAAM,WAAW,oBAAoB;IACnC;;;;;;OAMG;IACH,IAAI,CAAC,SAAS,EAAE,qBAAqB,GAAG,OAAO,CAAC,mBAAmB,CAAC,CAAC;CACtE;AAMD,MAAM,WAAW,kBAAkB;IACjC,4CAA4C;IAC5C,QAAQ,CAAC,EAAE,MAAM,CAAC;IAClB,2BAA2B;IAC3B,KAAK,CAAC,EAAE,MAAM,CAAC;IACf,6CAA6C;IAC7C,OAAO,CAAC,EAAE,MAAM,CAAC;IACjB,4BAA4B;IAC5B,SAAS,CAAC,EAAE;QACV,OAAO,CAAC,EAAE,OAAO,CAAC;QAClB,WAAW,CAAC,EAAE,MAAM,CAAC;QACrB,KAAK,CAAC,EAAE,MAAM,CAAC;KAChB,CAAC;CACH;AAsBD;;;;;;;GAOG;AACH,wBAAgB,kBAAkB,CAChC,MAAM,EAAE,kBAAkB,EAC1B,QAAQ,EAAE,oBAAoB,GAC7B,eAAe,CAoXjB"}

dist/rpc-transport.js

+/**
+ * RPC Client Transport
+ *
+ * Shared protocol machinery for all bidirectional client transports
+ * (WebSocket, Unix socket, etc.). Each transport provides a delegate that
+ * handles wire-specific I/O (open/send/close); this module provides
+ * everything else: state machine, request correlation, event streaming,
+ * send streams, reconnection, session operations.
+ *
+ * This eliminates the massive duplication between WSTransport and
+ * UnixSocketClientTransport — the only real difference is how bytes
+ * hit the wire.
+ */
+import { unwrapEventMessage, extractSendMessage } from "./transport-utils";
+// ============================================================================
+// Factory
+// ============================================================================
+/**
+ * Create a ClientTransport backed by an RPC delegate.
+ *
+ * The delegate handles wire I/O (WebSocket, Unix socket, etc.).
+ * This function handles the full gateway RPC protocol:
+ * request/response correlation, event streaming, reconnection,
+ * and all session operations.
+ */
+export function createRPCTransport(config, delegate) {
+    let connection = null;
+    let state = "disconnected";
+    let connectionId;
+    let connectionPromise;
+    let reconnectAttempts = 0;
+    let requestCounter = 0;
+    const pendingRequests = new Map();
+    const eventHandlers = new Set();
+    const stateHandlers = new Set();
+    const subscriptions = new Set();
+    const sendStreams = new Map();
+    const requestTimeout = config.timeout ?? 30000;
+    // ──────────────────────────────────────────────────────────────────────────
+    // State management
+    // ──────────────────────────────────────────────────────────────────────────
+    function setState(newState) {
+        if (state === newState)
+            return;
+        state = newState;
+        for (const handler of stateHandlers) {
+            try {
+                handler(newState);
+            }
+            catch (error) {
+                console.error("Error in state handler:", error);
+            }
+        }
+    }
+    // ──────────────────────────────────────────────────────────────────────────
+    // Message handling
+    // ──────────────────────────────────────────────────────────────────────────
+    function handleMessage(data) {
+        const type = data.type;
+        // Response to pending request
+        if (type === "res") {
+            const id = data.id;
+            const pending = pendingRequests.get(id);
+            if (pending) {
+                clearTimeout(pending.timeout);
+                pendingRequests.delete(id);
+                pending.resolve(data);
+                return;
+            }
+        }
+        // Pong — swallow
+        if (type === "pong")
+            return;
+        // Gateway error
+        if (type === "error") {
+            console.error("Gateway error:", data.message);
+            return;
+        }
+        // Session events — unwrap and distribute to streams + handlers
+        if (type === "event") {
+            const eventData = unwrapEventMessage(data);
+            for (const [, stream] of sendStreams) {
+                if (!stream.closed) {
+                    const resolver = stream.resolvers.shift();
+                    if (resolver) {
+                        resolver({ value: eventData, done: false });
+                    }
+                    else {
+                        stream.events.push(eventData);
+                    }
+                }
+            }
+            dispatchEvent(eventData);
+            return;
+        }
+        // All other messages — forward to event handlers
+        dispatchEvent(data);
+    }
+    function dispatchEvent(event) {
+        for (const handler of eventHandlers) {
+            try {
+                handler(event);
+            }
+            catch (error) {
+                console.error("Error in event handler:", error);
+            }
+        }
+    }
+    // ──────────────────────────────────────────────────────────────────────────
+    // Connection lifecycle
+    // ──────────────────────────────────────────────────────────────────────────
+    function handleClose() {
+        const wasConnected = state === "connected";
+        connectionId = undefined;
+        connection = null;
+        subscriptions.clear();
+        setState("disconnected");
+        // Attempt reconnection
+        const reconnect = config.reconnect;
+        if (wasConnected && reconnect?.enabled !== false) {
+            const maxAttempts = reconnect?.maxAttempts ?? 5;
+            const delay = reconnect?.delay ?? 1000;
+            if (reconnectAttempts < maxAttempts) {
+                reconnectAttempts++;
+                setTimeout(() => {
+                    transport.connect().catch((error) => {
+                        console.error("Reconnection failed:", error);
+                    });
+                }, delay * reconnectAttempts);
+            }
+        }
+    }
+    function closeConnection() {
+        // Clear pending requests
+        for (const [, pending] of pendingRequests) {
+            clearTimeout(pending.timeout);
+            pending.reject(new Error("Connection closed"));
+        }
+        pendingRequests.clear();
+        // Close send streams
+        for (const [, stream] of sendStreams) {
+            stream.closed = true;
+            for (const resolver of stream.resolvers) {
+                resolver({ value: undefined, done: true });
+            }
+        }
+        sendStreams.clear();
+        connection?.close();
+        connection = null;
+        connectionId = undefined;
+        subscriptions.clear();
+        setState("disconnected");
+    }
+    async function openConnection() {
+        closeConnection();
+        const handle = await delegate.open({
+            onMessage: handleMessage,
+            onClose: handleClose,
+            onError: (error) => {
+                console.error("Transport error:", error);
+            },
+        });
+        connection = handle;
+        // Send connect message
+        const clientId = config.clientId ?? `client-${Date.now().toString(36)}`;
+        handle.send({
+            type: "connect",
+            clientId,
+            token: config.token,
+        });
+        connectionId = clientId;
+    }
+    // ──────────────────────────────────────────────────────────────────────────
+    // Request/response
+    // ──────────────────────────────────────────────────────────────────────────
+    async function sendRequest(method, params = {}) {
+        await transport.connect();
+        const id = `req-${++requestCounter}`;
+        return new Promise((resolve, reject) => {
+            const timer = setTimeout(() => {
+                pendingRequests.delete(id);
+                reject(new Error(`Request ${method} timed out`));
+            }, requestTimeout);
+            pendingRequests.set(id, { resolve, reject, timeout: timer });
+            connection.send({
+                type: "req",
+                id,
+                method,
+                params,
+            });
+        });
+    }
+    // ──────────────────────────────────────────────────────────────────────────
+    // Transport object
+    // ──────────────────────────────────────────────────────────────────────────
+    const transport = {
+        get state() {
+            return state;
+        },
+        get connectionId() {
+            return connectionId;
+        },
+        async connect() {
+            if (state === "connected")
+                return;
+            if (connectionPromise) {
+                await connectionPromise;
+                return;
+            }
+            setState("connecting");
+            connectionPromise = openConnection();
+            try {
+                await connectionPromise;
+                setState("connected");
+                reconnectAttempts = 0;
+            }
+            catch (error) {
+                setState("error");
+                throw error;
+            }
+            finally {
+                connectionPromise = undefined;
+            }
+        },
+        disconnect() {
+            closeConnection();
+        },
+        send(input, sessionId) {
+            const streamId = `stream-${++requestCounter}`;
+            const stream = {
+                events: [],
+                resolvers: [],
+                closed: false,
+            };
+            sendStreams.set(streamId, stream);
+            let aborted = false;
+            let sessionIdFromResponse;
+            // Start the send request
+            const sendPromise = sendRequest("send", {
+                sessionId: sessionId ?? "main",
+                message: extractSendMessage(input),
+            });
+            sendPromise
+                .then((response) => {
+                if (response.ok && response.payload) {
+                    sessionIdFromResponse = response.payload.sessionId;
+                }
+            })
+                .catch((error) => {
+                stream.closed = true;
+                const errorEvent = { type: "error", error: error.message };
+                const resolver = stream.resolvers.shift();
+                if (resolver) {
+                    resolver({ value: errorEvent, done: false });
+                }
+                for (const r of stream.resolvers) {
+                    r({ value: undefined, done: true });
+                }
+                stream.resolvers = [];
+            });
+            const iterable = {
+                async *[Symbol.asyncIterator]() {
+                    try {
+                        while (!stream.closed && !aborted) {
+                            if (stream.events.length > 0) {
+                                const event = stream.events.shift();
+                                yield event;
+                                if (event.type === "execution_end" || event.type === "message_end")
+                                    break;
+                                continue;
+                            }
+                            const result = await new Promise((resolve) => {
+                                stream.resolvers.push(resolve);
+                            });
+                            if (result.done)
+                                break;
+                            yield result.value;
+                            if (result.value.type === "execution_end" || result.value.type === "message_end") {
+                                break;
+                            }
+                        }
+                    }
+                    finally {
+                        stream.closed = true;
+                        sendStreams.delete(streamId);
+                    }
+                },
+                abort(reason) {
+                    aborted = true;
+                    stream.closed = true;
+                    for (const resolver of stream.resolvers) {
+                        resolver({ value: undefined, done: true });
+                    }
+                    stream.resolvers = [];
+                    if (sessionIdFromResponse) {
+                        transport.abortSession(sessionIdFromResponse, reason).catch(() => { });
+                    }
+                },
+            };
+            return iterable;
+        },
+        async subscribeToSession(sessionId) {
+            if (subscriptions.has(sessionId))
+                return;
+            await sendRequest("subscribe", { sessionId });
+            subscriptions.add(sessionId);
+        },
+        async unsubscribeFromSession(sessionId) {
+            if (!subscriptions.has(sessionId))
+                return;
+            await sendRequest("unsubscribe", { sessionId });
+            subscriptions.delete(sessionId);
+        },
+        async abortSession(sessionId, reason) {
+            await sendRequest("abort", { sessionId, reason });
+        },
+        async closeSession(sessionId) {
+            await sendRequest("close", { sessionId });
+            subscriptions.delete(sessionId);
+        },
+        async submitToolResult(sessionId, toolUseId, result) {
+            await sendRequest("tool-response", { sessionId, toolUseId, result });
+        },
+        async publishToChannel(sessionId, channel, event) {
+            await sendRequest("channel", {
+                sessionId,
+                channel,
+                type: event.type,
+                payload: event.payload,
+                id: event.id,
+                metadata: event.metadata,
+            });
+        },
+        async subscribeToChannel(sessionId, channel) {
+            await sendRequest("channel-subscribe", { sessionId, channel });
+        },
+        onEvent(handler) {
+            eventHandlers.add(handler);
+            return () => {
+                eventHandlers.delete(handler);
+            };
+        },
+        onStateChange(handler) {
+            stateHandlers.add(handler);
+            return () => {
+                stateHandlers.delete(handler);
+            };
+        },
+    };
+    return transport;
+}
+//# sourceMappingURL=rpc-transport.js.map

dist/rpc-transport.js.map

+{"version":3,"file":"rpc-transport.js","sourceRoot":"","sources":["../src/rpc-transport.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;GAYG;AASH,OAAO,EAAE,kBAAkB,EAAE,kBAAkB,EAAE,MAAM,mBAAmB,CAAC;AAwE3E,+EAA+E;AAC/E,UAAU;AACV,+EAA+E;AAE/E;;;;;;;GAOG;AACH,MAAM,UAAU,kBAAkB,CAChC,MAA0B,EAC1B,QAA8B;IAE9B,IAAI,UAAU,GAA+B,IAAI,CAAC;IAClD,IAAI,KAAK,GAAmB,cAAc,CAAC;IAC3C,IAAI,YAAgC,CAAC;IACrC,IAAI,iBAA4C,CAAC;IACjD,IAAI,iBAAiB,GAAG,CAAC,CAAC;IAE1B,IAAI,cAAc,GAAG,CAAC,CAAC;IACvB,MAAM,eAAe,GAAG,IAAI,GAAG,EAA0B,CAAC;IAC1D,MAAM,aAAa,GAAG,IAAI,GAAG,EAAyB,CAAC;IACvD,MAAM,aAAa,GAAG,IAAI,GAAG,EAAmC,CAAC;IACjE,MAAM,aAAa,GAAG,IAAI,GAAG,EAAU,CAAC;IACxC,MAAM,WAAW,GAAG,IAAI,GAAG,EAAsB,CAAC;IAElD,MAAM,cAAc,GAAG,MAAM,CAAC,OAAO,IAAI,KAAK,CAAC;IAE/C,6EAA6E;IAC7E,mBAAmB;IACnB,6EAA6E;IAE7E,SAAS,QAAQ,CAAC,QAAwB;QACxC,IAAI,KAAK,KAAK,QAAQ;YAAE,OAAO;QAC/B,KAAK,GAAG,QAAQ,CAAC;QACjB,KAAK,MAAM,OAAO,IAAI,aAAa,EAAE,CAAC;YACpC,IAAI,CAAC;gBACH,OAAO,CAAC,QAAQ,CAAC,CAAC;YACpB,CAAC;YAAC,OAAO,KAAK,EAAE,CAAC;gBACf,OAAO,CAAC,KAAK,CAAC,yBAAyB,EAAE,KAAK,CAAC,CAAC;YAClD,CAAC;QACH,CAAC;IACH,CAAC;IAED,6EAA6E;IAC7E,mBAAmB;IACnB,6EAA6E;IAE7E,SAAS,aAAa,CAAC,IAA6B;QAClD,MAAM,IAAI,GAAG,IAAI,CAAC,IAAc,CAAC;QAEjC,8BAA8B;QAC9B,IAAI,IAAI,KAAK,KAAK,EAAE,CAAC;YACnB,MAAM,EAAE,GAAG,IAAI,CAAC,EAAY,CAAC;YAC7B,MAAM,OAAO,GAAG,eAAe,CAAC,GAAG,CAAC,EAAE,CAAC,CAAC;YACxC,IAAI,OAAO,EAAE,CAAC;gBACZ,YAAY,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC;gBAC9B,eAAe,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;gBAC3B,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;gBACtB,OAAO;YACT,CAAC;QACH,CAAC;QAED,iBAAiB;QACjB,IAAI,IAAI,KAAK,MAAM;YAAE,OAAO;QAE5B,gBAAgB;QAChB,IAAI,IAAI,KAAK,OAAO,EAAE,CAAC;YACrB,OAAO,CAAC,KAAK,CAAC,gBAAgB,EAAE,IAAI,CAAC,OAAO,CAAC,CAAC;YAC9C,OAAO;QACT,CAAC;QAED,+DAA+D;QAC/D,IAAI,IAAI,KAAK,OAAO,EAAE,CAAC;YACrB,MAAM,SAAS,GAAG,kBAAkB,CAAC,IAAI,CAAuB,CAAC;YAEjE,KAAK,MAAM,CAAC,EAAE,MAAM,CAAC,IAAI,WAAW,EAAE,CAAC;gBACrC,IAAI,CAAC,MAAM,CAAC,MAAM,EAAE,CAAC;oBACnB,MAAM,QAAQ,GAAG,MAAM,CAAC,SAAS,CAAC,KAAK,EAAE,CAAC;oBAC1C,IAAI,QAAQ,EAAE,CAAC;wBACb,QAAQ,CAAC,EAAE,KAAK,EAAE,SAAS,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC,CAAC;oBAC9C,CAAC;yBAAM,CAAC;wBACN,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC;oBAChC,CAAC;gBACH,CAAC;YACH,CAAC;YAED,aAAa,CAAC,SAAS,CAAC,CAAC;YACzB,OAAO;QACT,CAAC;QAED,iDAAiD;QACjD,aAAa,CAAC,IAA0B,CAAC,CAAC;IAC5C,CAAC;IAED,SAAS,aAAa,CAAC,KAAyB;QAC9C,KAAK,MAAM,OAAO,IAAI,aAAa,EAAE,CAAC;YACpC,IAAI,CAAC;gBACH,OAAO,CAAC,KAAK,CAAC,CAAC;YACjB,CAAC;YAAC,OAAO,KAAK,EAAE,CAAC;gBACf,OAAO,CAAC,KAAK,CAAC,yBAAyB,EAAE,KAAK,CAAC,CAAC;YAClD,CAAC;QACH,CAAC;IACH,CAAC;IAED,6EAA6E;IAC7E,uBAAuB;IACvB,6EAA6E;IAE7E,SAAS,WAAW;QAClB,MAAM,YAAY,GAAG,KAAK,KAAK,WAAW,CAAC;QAC3C,YAAY,GAAG,SAAS,CAAC;QACzB,UAAU,GAAG,IAAI,CAAC;QAClB,aAAa,CAAC,KAAK,EAAE,CAAC;QACtB,QAAQ,CAAC,cAAc,CAAC,CAAC;QAEzB,uBAAuB;QACvB,MAAM,SAAS,GAAG,MAAM,CAAC,SAAS,CAAC;QACnC,IAAI,YAAY,IAAI,SAAS,EAAE,OAAO,KAAK,KAAK,EAAE,CAAC;YACjD,MAAM,WAAW,GAAG,SAAS,EAAE,WAAW,IAAI,CAAC,CAAC;YAChD,MAAM,KAAK,GAAG,SAAS,EAAE,KAAK,IAAI,IAAI,CAAC;YAEvC,IAAI,iBAAiB,GAAG,WAAW,EAAE,CAAC;gBACpC,iBAAiB,EAAE,CAAC;gBACpB,UAAU,CAAC,GAAG,EAAE;oBACd,SAAS,CAAC,OAAO,EAAE,CAAC,KAAK,CAAC,CAAC,KAAK,EAAE,EAAE;wBAClC,OAAO,CAAC,KAAK,CAAC,sBAAsB,EAAE,KAAK,CAAC,CAAC;oBAC/C,CAAC,CAAC,CAAC;gBACL,CAAC,EAAE,KAAK,GAAG,iBAAiB,CAAC,CAAC;YAChC,CAAC;QACH,CAAC;IACH,CAAC;IAED,SAAS,eAAe;QACtB,yBAAyB;QACzB,KAAK,MAAM,CAAC,EAAE,OAAO,CAAC,IAAI,eAAe,EAAE,CAAC;YAC1C,YAAY,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC;YAC9B,OAAO,CAAC,MAAM,CAAC,IAAI,KAAK,CAAC,mBAAmB,CAAC,CAAC,CAAC;QACjD,CAAC;QACD,eAAe,CAAC,KAAK,EAAE,CAAC;QAExB,qBAAqB;QACrB,KAAK,MAAM,CAAC,EAAE,MAAM,CAAC,IAAI,WAAW,EAAE,CAAC;YACrC,MAAM,CAAC,MAAM,GAAG,IAAI,CAAC;YACrB,KAAK,MAAM,QAAQ,IAAI,MAAM,CAAC,SAAS,EAAE,CAAC;gBACxC,QAAQ,CAAC,EAAE,KAAK,EAAE,SAA0C,EAAE,IAAI,EAAE,IAAI,EAAE,CAAC,CAAC;YAC9E,CAAC;QACH,CAAC;QACD,WAAW,CAAC,KAAK,EAAE,CAAC;QAEpB,UAAU,EAAE,KAAK,EAAE,CAAC;QACpB,UAAU,GAAG,IAAI,CAAC;QAClB,YAAY,GAAG,SAAS,CAAC;QACzB,aAAa,CAAC,KAAK,EAAE,CAAC;QACtB,QAAQ,CAAC,cAAc,CAAC,CAAC;IAC3B,CAAC;IAED,KAAK,UAAU,cAAc;QAC3B,eAAe,EAAE,CAAC;QAElB,MAAM,MAAM,GAAG,MAAM,QAAQ,CAAC,IAAI,CAAC;YACjC,SAAS,EAAE,aAAa;YACxB,OAAO,EAAE,WAAW;YACpB,OAAO,EAAE,CAAC,KAAK,EAAE,EAAE;gBACjB,OAAO,CAAC,KAAK,CAAC,kBAAkB,EAAE,KAAK,CAAC,CAAC;YAC3C,CAAC;SACF,CAAC,CAAC;QAEH,UAAU,GAAG,MAAM,CAAC;QAEpB,uBAAuB;QACvB,MAAM,QAAQ,GAAG,MAAM,CAAC,QAAQ,IAAI,UAAU,IAAI,CAAC,GAAG,EAAE,CAAC,QAAQ,CAAC,EAAE,CAAC,EAAE,CAAC;QACxE,MAAM,CAAC,IAAI,CAAC;YACV,IAAI,EAAE,SAAS;YACf,QAAQ;YACR,KAAK,EAAE,MAAM,CAAC,KAAK;SACpB,CAAC,CAAC;QACH,YAAY,GAAG,QAAQ,CAAC;IAC1B,CAAC;IAED,6EAA6E;IAC7E,mBAAmB;IACnB,6EAA6E;IAE7E,KAAK,UAAU,WAAW,CACxB,MAAc,EACd,SAAkC,EAAE;QAEpC,MAAM,SAAS,CAAC,OAAO,EAAE,CAAC;QAE1B,MAAM,EAAE,GAAG,OAAO,EAAE,cAAc,EAAE,CAAC;QAErC,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YACrC,MAAM,KAAK,GAAG,UAAU,CAAC,GAAG,EAAE;gBAC5B,eAAe,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;gBAC3B,MAAM,CAAC,IAAI,KAAK,CAAC,WAAW,MAAM,YAAY,CAAC,CAAC,CAAC;YACnD,CAAC,EAAE,cAAc,CAAC,CAAC;YAEnB,eAAe,CAAC,GAAG,CAAC,EAAE,EAAE,EAAE,OAAO,EAAE,MAAM,EAAE,OAAO,EAAE,KAAK,EAAE,CAAC,CAAC;YAE7D,UAAW,CAAC,IAAI,CAAC;gBACf,IAAI,EAAE,KAAK;gBACX,EAAE;gBACF,MAAM;gBACN,MAAM;aACP,CAAC,CAAC;QACL,CAAC,CAAC,CAAC;IACL,CAAC;IAED,6EAA6E;IAC7E,mBAAmB;IACnB,6EAA6E;IAE7E,MAAM,SAAS,GAAoB;QACjC,IAAI,KAAK;YACP,OAAO,KAAK,CAAC;QACf,CAAC;QAED,IAAI,YAAY;YACd,OAAO,YAAY,CAAC;QACtB,CAAC;QAED,KAAK,CAAC,OAAO;YACX,IAAI,KAAK,KAAK,WAAW;gBAAE,OAAO;YAClC,IAAI,iBAAiB,EAAE,CAAC;gBACtB,MAAM,iBAAiB,CAAC;gBACxB,OAAO;YACT,CAAC;YAED,QAAQ,CAAC,YAAY,CAAC,CAAC;YACvB,iBAAiB,GAAG,cAAc,EAAE,CAAC;YAErC,IAAI,CAAC;gBACH,MAAM,iBAAiB,CAAC;gBACxB,QAAQ,CAAC,WAAW,CAAC,CAAC;gBACtB,iBAAiB,GAAG,CAAC,CAAC;YACxB,CAAC;YAAC,OAAO,KAAK,EAAE,CAAC;gBACf,QAAQ,CAAC,OAAO,CAAC,CAAC;gBAClB,MAAM,KAAK,CAAC;YACd,CAAC;oBAAS,CAAC;gBACT,iBAAiB,GAAG,SAAS,CAAC;YAChC,CAAC;QACH,CAAC;QAED,UAAU;YACR,eAAe,EAAE,CAAC;QACpB,CAAC;QAED,IAAI,CAAC,KAAgB,EAAE,SAAkB;YACvC,MAAM,QAAQ,GAAG,UAAU,EAAE,cAAc,EAAE,CAAC;YAC9C,MAAM,MAAM,GAAe;gBACzB,MAAM,EAAE,EAAE;gBACV,SAAS,EAAE,EAAE;gBACb,MAAM,EAAE,KAAK;aACd,CAAC;YACF,WAAW,CAAC,GAAG,CAAC,QAAQ,EAAE,MAAM,CAAC,CAAC;YAElC,IAAI,OAAO,GAAG,KAAK,CAAC;YACpB,IAAI,qBAAyC,CAAC;YAE9C,yBAAyB;YACzB,MAAM,WAAW,GAAG,WAAW,CAAC,MAAM,EAAE;gBACtC,SAAS,EAAE,SAAS,IAAI,MAAM;gBAC9B,OAAO,EAAE,kBAAkB,CAAC,KAAK,CAAC;aACnC,CAAC,CAAC;YAEH,WAAW;iBACR,IAAI,CAAC,CAAC,QAAQ,EAAE,EAAE;gBACjB,IAAI,QAAQ,CAAC,EAAE,IAAI,QAAQ,CAAC,OAAO,EAAE,CAAC;oBACpC,qBAAqB,GAAI,QAAQ,CAAC,OAAkC,CAAC,SAAS,CAAC;gBACjF,CAAC;YACH,CAAC,CAAC;iBACD,KAAK,CAAC,CAAC,KAAK,EAAE,EAAE;gBACf,MAAM,CAAC,MAAM,GAAG,IAAI,CAAC;gBACrB,MAAM,UAAU,GAAG,EAAE,IAAI,EAAE,OAAO,EAAE,KAAK,EAAE,KAAK,CAAC,OAAO,EAAE,CAAC;gBAC3D,MAAM,QAAQ,GAAG,MAAM,CAAC,SAAS,CAAC,KAAK,EAAE,CAAC;gBAC1C,IAAI,QAAQ,EAAE,CAAC;oBACb,QAAQ,CAAC,EAAE,KAAK,EAAE,UAAgC,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC,CAAC;gBACrE,CAAC;gBACD,KAAK,MAAM,CAAC,IAAI,MAAM,CAAC,SAAS,EAAE,CAAC;oBACjC,CAAC,CAAC,EAAE,KAAK,EAAE,SAA0C,EAAE,IAAI,EAAE,IAAI,EAAE,CAAC,CAAC;gBACvE,CAAC;gBACD,MAAM,CAAC,SAAS,GAAG,EAAE,CAAC;YACxB,CAAC,CAAC,CAAC;YAEL,MAAM,QAAQ,GAAG;gBACf,KAAK,CAAC,CAAC,CAAC,MAAM,CAAC,aAAa,CAAC;oBAC3B,IAAI,CAAC;wBACH,OAAO,CAAC,MAAM,CAAC,MAAM,IAAI,CAAC,OAAO,EAAE,CAAC;4BAClC,IAAI,MAAM,CAAC,MAAM,CAAC,MAAM,GAAG,CAAC,EAAE,CAAC;gCAC7B,MAAM,KAAK,GAAG,MAAM,CAAC,MAAM,CAAC,KAAK,EAAG,CAAC;gCACrC,MAAM,KAAK,CAAC;gCACZ,IAAI,KAAK,CAAC,IAAI,KAAK,eAAe,IAAI,KAAK,CAAC,IAAI,KAAK,aAAa;oCAAE,MAAM;gCAC1E,SAAS;4BACX,CAAC;4BAED,MAAM,MAAM,GAAG,MAAM,IAAI,OAAO,CAAqC,CAAC,OAAO,EAAE,EAAE;gCAC/E,MAAM,CAAC,SAAS,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;4BACjC,CAAC,CAAC,CAAC;4BAEH,IAAI,MAAM,CAAC,IAAI;gCAAE,MAAM;4BACvB,MAAM,MAAM,CAAC,KAAK,CAAC;4BACnB,IAAI,MAAM,CAAC,KAAK,CAAC,IAAI,KAAK,eAAe,IAAI,MAAM,CAAC,KAAK,CAAC,IAAI,KAAK,aAAa,EAAE,CAAC;gCACjF,MAAM;4BACR,CAAC;wBACH,CAAC;oBACH,CAAC;4BAAS,CAAC;wBACT,MAAM,CAAC,MAAM,GAAG,IAAI,CAAC;wBACrB,WAAW,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAC;oBAC/B,CAAC;gBACH,CAAC;gBAED,KAAK,CAAC,MAAe;oBACnB,OAAO,GAAG,IAAI,CAAC;oBACf,MAAM,CAAC,MAAM,GAAG,IAAI,CAAC;oBACrB,KAAK,MAAM,QAAQ,IAAI,MAAM,CAAC,SAAS,EAAE,CAAC;wBACxC,QAAQ,CAAC,EAAE,KAAK,EAAE,SAA0C,EAAE,IAAI,EAAE,IAAI,EAAE,CAAC,CAAC;oBAC9E,CAAC;oBACD,MAAM,CAAC,SAAS,GAAG,EAAE,CAAC;oBACtB,IAAI,qBAAqB,EAAE,CAAC;wBAC1B,SAAS,CAAC,YAAY,CAAC,qBAAqB,EAAE,MAAM,CAAC,CAAC,KAAK,CAAC,GAAG,EAAE,GAAE,CAAC,CAAC,CAAC;oBACxE,CAAC;gBACH,CAAC;aACF,CAAC;YAEF,OAAO,QAAQ,CAAC;QAClB,CAAC;QAED,KAAK,CAAC,kBAAkB,CAAC,SAAiB;YACxC,IAAI,aAAa,CAAC,GAAG,CAAC,SAAS,CAAC;gBAAE,OAAO;YACzC,MAAM,WAAW,CAAC,WAAW,EAAE,EAAE,SAAS,EAAE,CAAC,CAAC;YAC9C,aAAa,CAAC,GAAG,CAAC,SAAS,CAAC,CAAC;QAC/B,CAAC;QAED,KAAK,CAAC,sBAAsB,CAAC,SAAiB;YAC5C,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,SAAS,CAAC;gBAAE,OAAO;YAC1C,MAAM,WAAW,CAAC,aAAa,EAAE,EAAE,SAAS,EAAE,CAAC,CAAC;YAChD,aAAa,CAAC,MAAM,CAAC,SAAS,CAAC,CAAC;QAClC,CAAC;QAED,KAAK,CAAC,YAAY,CAAC,SAAiB,EAAE,MAAe;YACnD,MAAM,WAAW,CAAC,OAAO,EAAE,EAAE,SAAS,EAAE,MAAM,EAAE,CAAC,CAAC;QACpD,CAAC;QAED,KAAK,CAAC,YAAY,CAAC,SAAiB;YAClC,MAAM,WAAW,CAAC,OAAO,EAAE,EAAE,SAAS,EAAE,CAAC,CAAC;YAC1C,aAAa,CAAC,MAAM,CAAC,SAAS,CAAC,CAAC;QAClC,CAAC;QAED,KAAK,CAAC,gBAAgB,CAAC,SAAiB,EAAE,SAAiB,EAAE,MAAgC;YAC3F,MAAM,WAAW,CAAC,eAAe,EAAE,EAAE,SAAS,EAAE,SAAS,EAAE,MAAM,EAAE,CAAC,CAAC;QACvE,CAAC;QAED,KAAK,CAAC,gBAAgB,CAAC,SAAiB,EAAE,OAAe,EAAE,KAAmB;YAC5E,MAAM,WAAW,CAAC,SAAS,EAAE;gBAC3B,SAAS;gBACT,OAAO;gBACP,IAAI,EAAE,KAAK,CAAC,IAAI;gBAChB,OAAO,EAAE,KAAK,CAAC,OAAO;gBACtB,EAAE,EAAE,KAAK,CAAC,EAAE;gBACZ,QAAQ,EAAE,KAAK,CAAC,QAAQ;aACzB,CAAC,CAAC;QACL,CAAC;QAED,KAAK,CAAC,kBAAkB,CAAC,SAAiB,EAAE,OAAe;YACzD,MAAM,WAAW,CAAC,mBAAmB,EAAE,EAAE,SAAS,EAAE,OAAO,EAAE,CAAC,CAAC;QACjE,CAAC;QAED,OAAO,CAAC,OAA8B;YACpC,aAAa,CAAC,GAAG,CAAC,OAAO,CAAC,CAAC;YAC3B,OAAO,GAAG,EAAE;gBACV,aAAa,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC;YAChC,CAAC,CAAC;QACJ,CAAC;QAED,aAAa,CAAC,OAAwC;YACpD,aAAa,CAAC,GAAG,CAAC,OAAO,CAAC,CAAC;YAC3B,OAAO,GAAG,EAAE;gBACV,aAAa,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC;YAChC,CAAC,CAAC;QACJ,CAAC;KACF,CAAC;IAEF,OAAO,SAAS,CAAC;AACnB,CAAC"}

dist/split-message.d.ts

+export interface SplitOptions {
+    /** Platform character limit. */
+    maxLength: number;
+    /** Preferred split points, tried in order. Default: ["\n\n", "\n", ". ", " "]. */
+    splitOn?: string[];
+    /** Appended to all chunks except the last. Default: "". */
+    continuation?: string;
+}
+/**
+ * Split text to fit within a platform's character limit.
+ *
+ * Greedy algorithm: finds the last occurrence of the highest-priority
+ * split point before maxLength, splits there, repeats for the remainder.
+ */
+export declare function splitMessage(text: string, options: SplitOptions): string[];
+//# sourceMappingURL=split-message.d.ts.map

dist/split-message.d.ts.map

+{"version":3,"file":"split-message.d.ts","sourceRoot":"","sources":["../src/split-message.ts"],"names":[],"mappings":"AAAA,MAAM,WAAW,YAAY;IAC3B,gCAAgC;IAChC,SAAS,EAAE,MAAM,CAAC;IAClB,kFAAkF;IAClF,OAAO,CAAC,EAAE,MAAM,EAAE,CAAC;IACnB,2DAA2D;IAC3D,YAAY,CAAC,EAAE,MAAM,CAAC;CACvB;AAID;;;;;GAKG;AACH,wBAAgB,YAAY,CAAC,IAAI,EAAE,MAAM,EAAE,OAAO,EAAE,YAAY,GAAG,MAAM,EAAE,CAwC1E"}

dist/split-message.js

+const DEFAULT_SPLIT_POINTS = ["\n\n", "\n", ". ", " "];
+/**
+ * Split text to fit within a platform's character limit.
+ *
+ * Greedy algorithm: finds the last occurrence of the highest-priority
+ * split point before maxLength, splits there, repeats for the remainder.
+ */
+export function splitMessage(text, options) {
+    const { maxLength, continuation = "" } = options;
+    const splitOn = options.splitOn ?? DEFAULT_SPLIT_POINTS;
+    if (text.length <= maxLength)
+        return [text];
+    const effectiveMax = maxLength - continuation.length;
+    if (effectiveMax <= 0) {
+        throw new Error("maxLength must be greater than continuation length");
+    }
+    const chunks = [];
+    let remaining = text;
+    while (remaining.length > maxLength) {
+        let splitIndex = -1;
+        for (const delimiter of splitOn) {
+            const idx = remaining.lastIndexOf(delimiter, effectiveMax);
+            if (idx > 0) {
+                splitIndex = idx + delimiter.length;
+                break;
+            }
+        }
+        // No split point found — hard break at effectiveMax
+        if (splitIndex <= 0) {
+            splitIndex = effectiveMax;
+        }
+        const chunk = remaining.slice(0, splitIndex).trimEnd();
+        chunks.push(chunk + continuation);
+        remaining = remaining.slice(splitIndex).trimStart();
+    }
+    if (remaining.length > 0) {
+        chunks.push(remaining);
+    }
+    return chunks;
+}
+//# sourceMappingURL=split-message.js.map

dist/split-message.js.map

+{"version":3,"file":"split-message.js","sourceRoot":"","sources":["../src/split-message.ts"],"names":[],"mappings":"AASA,MAAM,oBAAoB,GAAG,CAAC,MAAM,EAAE,IAAI,EAAE,IAAI,EAAE,GAAG,CAAC,CAAC;AAEvD;;;;;GAKG;AACH,MAAM,UAAU,YAAY,CAAC,IAAY,EAAE,OAAqB;IAC9D,MAAM,EAAE,SAAS,EAAE,YAAY,GAAG,EAAE,EAAE,GAAG,OAAO,CAAC;IACjD,MAAM,OAAO,GAAG,OAAO,CAAC,OAAO,IAAI,oBAAoB,CAAC;IAExD,IAAI,IAAI,CAAC,MAAM,IAAI,SAAS;QAAE,OAAO,CAAC,IAAI,CAAC,CAAC;IAE5C,MAAM,YAAY,GAAG,SAAS,GAAG,YAAY,CAAC,MAAM,CAAC;IACrD,IAAI,YAAY,IAAI,CAAC,EAAE,CAAC;QACtB,MAAM,IAAI,KAAK,CAAC,oDAAoD,CAAC,CAAC;IACxE,CAAC;IAED,MAAM,MAAM,GAAa,EAAE,CAAC;IAC5B,IAAI,SAAS,GAAG,IAAI,CAAC;IAErB,OAAO,SAAS,CAAC,MAAM,GAAG,SAAS,EAAE,CAAC;QACpC,IAAI,UAAU,GAAG,CAAC,CAAC,CAAC;QAEpB,KAAK,MAAM,SAAS,IAAI,OAAO,EAAE,CAAC;YAChC,MAAM,GAAG,GAAG,SAAS,CAAC,WAAW,CAAC,SAAS,EAAE,YAAY,CAAC,CAAC;YAC3D,IAAI,GAAG,GAAG,CAAC,EAAE,CAAC;gBACZ,UAAU,GAAG,GAAG,GAAG,SAAS,CAAC,MAAM,CAAC;gBACpC,MAAM;YACR,CAAC;QACH,CAAC;QAED,oDAAoD;QACpD,IAAI,UAAU,IAAI,CAAC,EAAE,CAAC;YACpB,UAAU,GAAG,YAAY,CAAC;QAC5B,CAAC;QAED,MAAM,KAAK,GAAG,SAAS,CAAC,KAAK,CAAC,CAAC,EAAE,UAAU,CAAC,CAAC,OAAO,EAAE,CAAC;QACvD,MAAM,CAAC,IAAI,CAAC,KAAK,GAAG,YAAY,CAAC,CAAC;QAClC,SAAS,GAAG,SAAS,CAAC,KAAK,CAAC,UAAU,CAAC,CAAC,SAAS,EAAE,CAAC;IACtD,CAAC;IAED,IAAI,SAAS,CAAC,MAAM,GAAG,CAAC,EAAE,CAAC;QACzB,MAAM,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC;IACzB,CAAC;IAED,OAAO,MAAM,CAAC;AAChB,CAAC"}

dist/transport-utils.d.ts

+/**
+ * Transport Utilities
+ *
+ * Shared helpers used by all client-side transports (WS, Unix socket, etc.).
+ * Canonical home for wire-format normalization.
+ */
+/**
+ * Normalizes EventMessage wire format to flat event format.
+ *
+ * EventMessage: { type: "event", event: "content_delta", sessionId, data: { ... } }
+ * Flat:         { type: "content_delta", sessionId, ... }
+ *
+ * Non-EventMessage data (e.g., connection, pong) passes through unchanged.
+ */
+export declare function unwrapEventMessage(data: Record<string, unknown>): Record<string, unknown>;
+/**
+ * Extract a plain text message from SendInput for the wire protocol.
+ * Handles string input, object input with message field, and content block arrays.
+ */
+export declare function extractSendMessage(input: unknown): string;
+//# sourceMappingURL=transport-utils.d.ts.map

dist/transport-utils.d.ts.map

+{"version":3,"file":"transport-utils.d.ts","sourceRoot":"","sources":["../src/transport-utils.ts"],"names":[],"mappings":"AAAA;;;;;GAKG;AAEH;;;;;;;GAOG;AACH,wBAAgB,kBAAkB,CAAC,IAAI,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,GAAG,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAUzF;AAED;;;GAGG;AACH,wBAAgB,kBAAkB,CAAC,KAAK,EAAE,OAAO,GAAG,MAAM,CAuBzD"}

dist/transport-utils.js

+/**
+ * Transport Utilities
+ *
+ * Shared helpers used by all client-side transports (WS, Unix socket, etc.).
+ * Canonical home for wire-format normalization.
+ */
+/**
+ * Normalizes EventMessage wire format to flat event format.
+ *
+ * EventMessage: { type: "event", event: "content_delta", sessionId, data: { ... } }
+ * Flat:         { type: "content_delta", sessionId, ... }
+ *
+ * Non-EventMessage data (e.g., connection, pong) passes through unchanged.
+ */
+export function unwrapEventMessage(data) {
+    if (data.type === "event" && typeof data.event === "string") {
+        return {
+            // Data fields spread first, then envelope fields overwrite to prevent collision
+            ...(data.data && typeof data.data === "object" ? data.data : {}),
+            type: data.event,
+            ...(data.sessionId != null && { sessionId: data.sessionId }),
+        };
+    }
+    return data;
+}
+/**
+ * Extract a plain text message from SendInput for the wire protocol.
+ * Handles string input, object input with message field, and content block arrays.
+ */
+export function extractSendMessage(input) {
+    if (typeof input === "string")
+        return input;
+    if (!input || typeof input !== "object")
+        return "";
+    const obj = input;
+    if ("message" in obj && obj.message) {
+        const msg = obj.message;
+        if (typeof msg === "string")
+            return msg;
+        if (msg &&
+            typeof msg === "object" &&
+            "content" in msg &&
+            Array.isArray(msg.content)) {
+            const content = msg.content;
+            const textBlock = content.find((b) => b.type === "text");
+            return textBlock?.text ?? "";
+        }
+    }
+    return "";
+}
+//# sourceMappingURL=transport-utils.js.map

dist/transport-utils.js.map

+{"version":3,"file":"transport-utils.js","sourceRoot":"","sources":["../src/transport-utils.ts"],"names":[],"mappings":"AAAA;;;;;GAKG;AAEH;;;;;;;GAOG;AACH,MAAM,UAAU,kBAAkB,CAAC,IAA6B;IAC9D,IAAI,IAAI,CAAC,IAAI,KAAK,OAAO,IAAI,OAAO,IAAI,CAAC,KAAK,KAAK,QAAQ,EAAE,CAAC;QAC5D,OAAO;YACL,gFAAgF;YAChF,GAAG,CAAC,IAAI,CAAC,IAAI,IAAI,OAAO,IAAI,CAAC,IAAI,KAAK,QAAQ,CAAC,CAAC,CAAE,IAAI,CAAC,IAAe,CAAC,CAAC,CAAC,EAAE,CAAC;YAC5E,IAAI,EAAE,IAAI,CAAC,KAAK;YAChB,GAAG,CAAC,IAAI,CAAC,SAAS,IAAI,IAAI,IAAI,EAAE,SAAS,EAAE,IAAI,CAAC,SAAS,EAAE,CAAC;SAC7D,CAAC;IACJ,CAAC;IACD,OAAO,IAAI,CAAC;AACd,CAAC;AAED;;;GAGG;AACH,MAAM,UAAU,kBAAkB,CAAC,KAAc;IAC/C,IAAI,OAAO,KAAK,KAAK,QAAQ;QAAE,OAAO,KAAK,CAAC;IAC5C,IAAI,CAAC,KAAK,IAAI,OAAO,KAAK,KAAK,QAAQ;QAAE,OAAO,EAAE,CAAC;IAEnD,MAAM,GAAG,GAAG,KAAgC,CAAC;IAC7C,IAAI,SAAS,IAAI,GAAG,IAAI,GAAG,CAAC,OAAO,EAAE,CAAC;QACpC,MAAM,GAAG,GAAG,GAAG,CAAC,OAAO,CAAC;QACxB,IAAI,OAAO,GAAG,KAAK,QAAQ;YAAE,OAAO,GAAG,CAAC;QACxC,IACE,GAAG;YACH,OAAO,GAAG,KAAK,QAAQ;YACvB,SAAS,IAAI,GAAG;YAChB,KAAK,CAAC,OAAO,CAAE,GAA+B,CAAC,OAAO,CAAC,EACvD,CAAC;YACD,MAAM,OAAO,GAAI,GAA+B,CAAC,OAG/C,CAAC;YACH,MAAM,SAAS,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,EAAuC,EAAE,CAAC,CAAC,CAAC,IAAI,KAAK,MAAM,CAAC,CAAC;YAC9F,OAAO,SAAS,EAAE,IAAI,IAAI,EAAE,CAAC;QAC/B,CAAC;IACH,CAAC;IACD,OAAO,EAAE,CAAC;AACZ,CAAC"}

dist/index.d.ts

@@ -59,2 +59,6 @@ /**
 export * from "./secrets";
+export * from "./split-message";
+export * from "./embeddings";
+export * from "./transport-utils";
+export * from "./rpc-transport";
 //# sourceMappingURL=index.d.ts.map

dist/index.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GAyCG;AAEH,cAAc,eAAe,CAAC;AAC9B,cAAc,UAAU,CAAC;AACzB,cAAc,YAAY,CAAC;AAC3B,cAAc,aAAa,CAAC;AAC5B,cAAc,SAAS,CAAC;AACxB,cAAc,UAAU,CAAC;AACzB,cAAc,SAAS,CAAC;AACxB,cAAc,YAAY,CAAC;AAC3B,cAAc,UAAU,CAAC;AACzB,cAAc,YAAY,CAAC;AAC3B,cAAc,YAAY,CAAC;AAC3B,cAAc,YAAY,CAAC;AAC3B,cAAc,iBAAiB,CAAC;AAChC,cAAc,aAAa,CAAC;AAC5B,cAAc,WAAW,CAAC;AAC1B,cAAc,WAAW,CAAC"}
+{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GAyCG;AAEH,cAAc,eAAe,CAAC;AAC9B,cAAc,UAAU,CAAC;AACzB,cAAc,YAAY,CAAC;AAC3B,cAAc,aAAa,CAAC;AAC5B,cAAc,SAAS,CAAC;AACxB,cAAc,UAAU,CAAC;AACzB,cAAc,SAAS,CAAC;AACxB,cAAc,YAAY,CAAC;AAC3B,cAAc,UAAU,CAAC;AACzB,cAAc,YAAY,CAAC;AAC3B,cAAc,YAAY,CAAC;AAC3B,cAAc,YAAY,CAAC;AAC3B,cAAc,iBAAiB,CAAC;AAChC,cAAc,aAAa,CAAC;AAC5B,cAAc,WAAW,CAAC;AAC1B,cAAc,WAAW,CAAC;AAC1B,cAAc,iBAAiB,CAAC;AAChC,cAAc,cAAc,CAAC;AAC7B,cAAc,mBAAmB,CAAC;AAClC,cAAc,iBAAiB,CAAC"}

dist/index.js

@@ -59,2 +59,6 @@ /**
 export * from "./secrets";
+export * from "./split-message";
+export * from "./embeddings";
+export * from "./transport-utils";
+export * from "./rpc-transport";
 //# sourceMappingURL=index.js.map

dist/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GAyCG;AAEH,cAAc,eAAe,CAAC;AAC9B,cAAc,UAAU,CAAC;AACzB,cAAc,YAAY,CAAC;AAC3B,cAAc,aAAa,CAAC;AAC5B,cAAc,SAAS,CAAC;AACxB,cAAc,UAAU,CAAC;AACzB,cAAc,SAAS,CAAC;AACxB,cAAc,YAAY,CAAC;AAC3B,cAAc,UAAU,CAAC;AACzB,cAAc,YAAY,CAAC;AAC3B,cAAc,YAAY,CAAC;AAC3B,cAAc,YAAY,CAAC;AAC3B,cAAc,iBAAiB,CAAC;AAChC,cAAc,aAAa,CAAC;AAC5B,cAAc,WAAW,CAAC;AAC1B,cAAc,WAAW,CAAC"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GAyCG;AAEH,cAAc,eAAe,CAAC;AAC9B,cAAc,UAAU,CAAC;AACzB,cAAc,YAAY,CAAC;AAC3B,cAAc,aAAa,CAAC;AAC5B,cAAc,SAAS,CAAC;AACxB,cAAc,UAAU,CAAC;AACzB,cAAc,SAAS,CAAC;AACxB,cAAc,YAAY,CAAC;AAC3B,cAAc,UAAU,CAAC;AACzB,cAAc,YAAY,CAAC;AAC3B,cAAc,YAAY,CAAC;AAC3B,cAAc,YAAY,CAAC;AAC3B,cAAc,iBAAiB,CAAC;AAChC,cAAc,aAAa,CAAC;AAC5B,cAAc,WAAW,CAAC;AAC1B,cAAc,WAAW,CAAC;AAC1B,cAAc,iBAAiB,CAAC;AAChC,cAAc,cAAc,CAAC;AAC7B,cAAc,mBAAmB,CAAC;AAClC,cAAc,iBAAiB,CAAC"}

dist/streaming.d.ts

@@ -509,2 +509,20 @@ /**
 /**
+ * Entry committed event — fires when a timeline entry is pushed to the session timeline.
+ *
+ * Emitted from session.ingestTickResult() after each _timeline.push().
+ * Carries the full entry with a stable ID for incremental persistence.
+ *
+ * Event ordering guarantee: fires AFTER execution_start and tick_start,
+ * BEFORE tick_end. Safe to INSERT with execution_id FK.
+ */
+export type EntryCommittedEvent = {
+    type: "entry_committed";
+    /** The timeline entry (COMTimelineEntry at runtime, unknown for wire safety) */
+    entry: unknown;
+    /** Execution this entry belongs to */
+    executionId: string;
+    /** Absolute position in session._timeline */
+    timelineIndex: number;
+} & StreamEventBase;
+/**
  * Engine error event
@@ -635,3 +653,3 @@ */
  */
-export type OrchestrationStreamEvent = ExecutionStartEvent | ExecutionEndEvent | ExecutionEvent | TickStartEvent | TickEndEvent | TickEvent | ToolResultStartEvent | ToolResultEvent | ToolConfirmationRequiredEvent | ToolConfirmationResultEvent | CompiledEvent | ModelRequestEvent | ProviderRequestEvent | ModelResponseEvent | ContextUpdateEvent | ForkStartEvent | ForkEndEvent | SpawnStartEvent | SpawnEndEvent | EngineErrorEvent;
+export type OrchestrationStreamEvent = ExecutionStartEvent | ExecutionEndEvent | ExecutionEvent | TickStartEvent | TickEndEvent | TickEvent | ToolResultStartEvent | ToolResultEvent | ToolConfirmationRequiredEvent | ToolConfirmationResultEvent | CompiledEvent | ModelRequestEvent | ProviderRequestEvent | ModelResponseEvent | ContextUpdateEvent | ForkStartEvent | ForkEndEvent | SpawnStartEvent | SpawnEndEvent | EntryCommittedEvent | EngineErrorEvent;
 /**
@@ -638,0 +656,0 @@ * Final execution result.

dist/streaming.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"streaming.d.ts","sourceRoot":"","sources":["../src/streaming.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;;;;;;;;;;;;GAuBG;AAEH,OAAO,KAAK,EAAE,YAAY,EAAE,MAAM,UAAU,CAAC;AAC7C,OAAO,KAAK,EAAE,SAAS,EAAE,MAAM,eAAe,CAAC;AAC/C,OAAO,KAAK,EAAE,OAAO,EAAE,MAAM,YAAY,CAAC;AAC1C,OAAO,KAAK,EAAE,UAAU,EAAE,MAAM,UAAU,CAAC;AAC3C,OAAO,KAAK,EAAE,YAAY,EAAE,MAAM,SAAS,CAAC;AAC5C,OAAO,KAAK,EAAE,oBAAoB,EAAE,MAAM,YAAY,CAAC;AAMvD;;;;;;;GAOG;AACH,MAAM,WAAW,eAAe;IAC9B,0CAA0C;IAC1C,IAAI,EAAE,MAAM,CAAC;IACb,8BAA8B;IAC9B,GAAG,CAAC,EAAE,MAAM,CAAC;IACb,wBAAwB;IACxB,KAAK,CAAC,EAAE,MAAM,CAAC;IACf,0DAA0D;IAC1D,UAAU,CAAC,EAAE,MAAM,CAAC;IACpB,wDAAwD;IACxD,QAAQ,CAAC,EAAE,MAAM,CAAC;CACnB;AAED;;;;GAIG;AACH,MAAM,WAAW,iBAAiB;IAChC,mEAAmE;IACnE,IAAI,EAAE,MAAM,CAAC;IACb,8BAA8B;IAC9B,IAAI,EAAE,MAAM,CAAC;IACb,iCAAiC;IACjC,UAAU,CAAC,EAAE,MAAM,CAAC;IACpB,+BAA+B;IAC/B,QAAQ,CAAC,EAAE,MAAM,CAAC;IAClB,0CAA0C;IAC1C,IAAI,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;CAChC;AAED;;;;;;;;;GASG;AACH,MAAM,WAAW,eAAe;IAC9B,gDAAgD;IAChD,SAAS,CAAC,EAAE,eAAe,EAAE,CAAC;IAE9B,gDAAgD;IAChD,WAAW,CAAC,EAAE,iBAAiB,EAAE,CAAC;IAElC,6CAA6C;IAC7C,QAAQ,CAAC,EAAE,MAAM,CAAC;IAElB,qBAAqB;IACrB,QAAQ,CAAC,EAAE,MAAM,CAAC;IAElB,oDAAoD;IACpD,UAAU,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;CACtC;AAMD;;;;;;;;;;;GAWG;AACH,oBAAY,UAAU;IACpB,UAAU,eAAe;IACzB,aAAa,kBAAkB;IAC/B,cAAc,mBAAmB;IACjC,QAAQ,aAAa;IACrB,aAAa,kBAAkB;IAC/B,WAAW,gBAAgB;IAC3B,KAAK,UAAU;IACf,IAAI,SAAS;IACb,MAAM,WAAW;IACjB,YAAY,iBAAiB;IAC7B,cAAc,mBAAmB;IACjC,UAAU,eAAe;IACzB,mBAAmB,wBAAwB;IAC3C,kBAAkB,uBAAuB;IACzC,KAAK,UAAU;CAChB;AAMD;;GAEG;AACH,MAAM,WAAW,eAAe;IAC9B,oFAAoF;IACpF,EAAE,EAAE,MAAM,CAAC;IAEX;;;;;;;;;;OAUG;IACH,QAAQ,EAAE,MAAM,CAAC;IAEjB,oEAAoE;IACpE,IAAI,EAAE,MAAM,CAAC;IAEb,wDAAwD;IACxD,SAAS,EAAE,MAAM,CAAC;IAElB,6FAA6F;IAC7F,GAAG,CAAC,EAAE,OAAO,CAAC;IAEd,gCAAgC;IAChC,4DAA4D;IAC5D,SAAS,CAAC,EAAE,MAAM,CAAC;IAEnB,2EAA2E;IAC3E,SAAS,CAAC,EAAE,MAAM,EAAE,CAAC;CACtB;AAMD;;;;;GAKG;AACH,MAAM,MAAM,iBAAiB,GAAG;IAC9B,IAAI,EAAE,eAAe,CAAC;IACtB,SAAS,EAAE,SAAS,CAAC;IACrB,UAAU,EAAE,MAAM,CAAC;IACnB,gEAAgE;IAChE,QAAQ,CAAC,EAAE,eAAe,CAAC;CAC5B,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,iBAAiB,GAAG;IAC9B,IAAI,EAAE,eAAe,CAAC;IACtB,SAAS,EAAE,SAAS,CAAC;IACrB,UAAU,EAAE,MAAM,CAAC;IACnB,KAAK,EAAE,MAAM,CAAC;CAEf,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,eAAe,GAAG;IAC5B,IAAI,EAAE,aAAa,CAAC;IACpB,SAAS,EAAE,SAAS,CAAC;IACrB,UAAU,EAAE,MAAM,CAAC;IACnB,gEAAgE;IAChE,QAAQ,CAAC,EAAE,eAAe,CAAC;CAC5B,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,YAAY,GAAG;IACzB,IAAI,EAAE,SAAS,CAAC;IAChB,UAAU,EAAE,MAAM,CAAC;IACnB,OAAO,EAAE,YAAY,CAAC;IACtB,gEAAgE;IAChE,QAAQ,CAAC,EAAE,eAAe,CAAC;IAC3B,SAAS,EAAE,MAAM,CAAC;IAClB,WAAW,EAAE,MAAM,CAAC;CACrB,GAAG,eAAe,CAAC;AAEpB;;;;;GAKG;AACH,MAAM,MAAM,mBAAmB,GAAG;IAChC,IAAI,EAAE,iBAAiB,CAAC;IACxB,UAAU,EAAE,MAAM,CAAC;IACnB,kDAAkD;IAClD,QAAQ,CAAC,EAAE,eAAe,CAAC;CAC5B,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,mBAAmB,GAAG;IAChC,IAAI,EAAE,iBAAiB,CAAC;IACxB,UAAU,EAAE,MAAM,CAAC;IACnB,KAAK,EAAE,MAAM,CAAC;CAEf,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,iBAAiB,GAAG;IAC9B,IAAI,EAAE,eAAe,CAAC;IACtB,UAAU,EAAE,MAAM,CAAC;IACnB,kDAAkD;IAClD,QAAQ,CAAC,EAAE,eAAe,CAAC;CAC5B,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,cAAc,GAAG;IAC3B,IAAI,EAAE,WAAW,CAAC;IAClB,UAAU,EAAE,MAAM,CAAC;IACnB,SAAS,EAAE,MAAM,CAAC;IAClB,kDAAkD;IAClD,QAAQ,CAAC,EAAE,eAAe,CAAC;IAC3B,SAAS,EAAE,MAAM,CAAC;IAClB,WAAW,EAAE,MAAM,CAAC;CACrB,GAAG,eAAe,CAAC;AAEpB;;GAEG;AACH,MAAM,MAAM,iBAAiB,GAAG;IAC9B,IAAI,EAAE,eAAe,CAAC;IACtB,IAAI,EAAE,WAAW,CAAC;IAClB,KAAK,CAAC,EAAE,MAAM,CAAC;CAChB,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,eAAe,GAAG;IAC5B,IAAI,EAAE,aAAa,CAAC;IACpB,UAAU,EAAE,UAAU,CAAC;IACvB,KAAK,CAAC,EAAE,UAAU,CAAC;CACpB,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,YAAY,GAAG;IACzB,IAAI,EAAE,SAAS,CAAC;IAChB,OAAO,EAAE,OAAO,CAAC;IACjB,UAAU,EAAE,UAAU,CAAC;IACvB,KAAK,CAAC,EAAE,UAAU,CAAC;IACnB,KAAK,CAAC,EAAE,MAAM,CAAC;IACf,sFAAsF;IACtF,GAAG,CAAC,EAAE,OAAO,CAAC;IACd,SAAS,EAAE,MAAM,CAAC;IAClB,WAAW,EAAE,MAAM,CAAC;CACrB,GAAG,eAAe,CAAC;AAEpB;;GAEG;AACH,MAAM,MAAM,kBAAkB,GAAG;IAC/B,IAAI,EAAE,iBAAiB,CAAC;IACxB,MAAM,EAAE,MAAM,CAAC;IACf,IAAI,EAAE,MAAM,CAAC;IACb,UAAU,EAAE,MAAM,CAAC;CACpB,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,kBAAkB,GAAG;IAC/B,IAAI,EAAE,iBAAiB,CAAC;IACxB,MAAM,EAAE,MAAM,CAAC;IACf,UAAU,EAAE,MAAM,CAAC;IACnB,KAAK,EAAE,MAAM,CAAC;CACf,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,gBAAgB,GAAG;IAC7B,IAAI,EAAE,eAAe,CAAC;IACtB,MAAM,EAAE,MAAM,CAAC;IACf,UAAU,EAAE,MAAM,CAAC;CACpB,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,aAAa,GAAG;IAC1B,IAAI,EAAE,WAAW,CAAC;IAClB,MAAM,EAAE,MAAM,CAAC;IACf,UAAU,EAAE,MAAM,CAAC;IACnB,IAAI,EAAE,MAAM,CAAC;IACb,KAAK,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;IAC/B,OAAO,CAAC,EAAE,MAAM,CAAC;IACjB,SAAS,EAAE,MAAM,CAAC;IAClB,WAAW,EAAE,MAAM,CAAC;CACrB,GAAG,eAAe,CAAC;AAEpB;;GAEG;AACH,MAAM,MAAM,gBAAgB,GAAG;IAC7B,IAAI,EAAE,OAAO,CAAC;IACd,KAAK,EAAE;QACL,OAAO,EAAE,MAAM,CAAC;QAChB,IAAI,CAAC,EAAE,MAAM,CAAC;KACf,CAAC;CACH,GAAG,eAAe,CAAC;AAEpB;;;;;;GAMG;AACH,MAAM,MAAM,UAAU,GAAG;IACvB,IAAI,EAAE,OAAO,CAAC;IACd,KAAK,EAAE;QACL,WAAW,EAAE,MAAM,CAAC;QACpB,YAAY,EAAE,MAAM,CAAC;QACrB,WAAW,EAAE,MAAM,CAAC;KACrB,CAAC;CACH,GAAG,eAAe,CAAC;AAEpB;;;;GAIG;AACH,MAAM,MAAM,gBAAgB,GAExB,iBAAiB,GACjB,iBAAiB,GACjB,eAAe,GACf,YAAY,GAEZ,mBAAmB,GACnB,mBAAmB,GACnB,iBAAiB,GACjB,cAAc,GAEd,iBAAiB,GACjB,eAAe,GACf,YAAY,GAEZ,kBAAkB,GAClB,kBAAkB,GAClB,gBAAgB,GAChB,aAAa,GAEb,UAAU,GAEV,gBAAgB,CAAC;AAMrB;;;;;GAKG;AACH,MAAM,MAAM,mBAAmB,GAAG;IAChC,IAAI,EAAE,iBAAiB,CAAC;IACxB,WAAW,EAAE,MAAM,CAAC;IACpB,SAAS,CAAC,EAAE,MAAM,CAAC;IACnB,iBAAiB,CAAC,EAAE,MAAM,CAAC;IAC3B,eAAe,CAAC,EAAE,MAAM,CAAC;IACzB,aAAa,CAAC,EAAE,MAAM,CAAC;IACvB,+DAA+D;IAC/D,QAAQ,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;CACpC,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,iBAAiB,GAAG;IAC9B,IAAI,EAAE,eAAe,CAAC;IACtB,WAAW,EAAE,MAAM,CAAC;IACpB,SAAS,CAAC,EAAE,MAAM,CAAC;IACnB,iBAAiB,CAAC,EAAE,MAAM,CAAC;IAC3B,eAAe,CAAC,EAAE,MAAM,CAAC;IACzB,gCAAgC;IAChC,UAAU,CAAC,EAAE,UAAU,GAAG,MAAM,CAAC;IACjC,oCAAoC;IACpC,OAAO,CAAC,EAAE,OAAO,CAAC;IAClB,mFAAmF;IACnF,KAAK,CAAC,EAAE;QAAE,OAAO,EAAE,MAAM,CAAC;QAAC,IAAI,EAAE,MAAM,CAAA;KAAE,CAAC;IAC1C,MAAM,EAAE,OAAO,CAAC;IAChB,8EAA8E;IAC9E,kBAAkB,CAAC,EAAE,OAAO,EAAE,CAAC;IAC/B,+DAA+D;IAC/D,QAAQ,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;CACpC,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,cAAc,GAAG;IAC3B,IAAI,EAAE,WAAW,CAAC;IAClB,WAAW,EAAE,MAAM,CAAC;IACpB,SAAS,CAAC,EAAE,MAAM,CAAC;IACnB,iBAAiB,CAAC,EAAE,MAAM,CAAC;IAC3B,eAAe,CAAC,EAAE,MAAM,CAAC;IACzB,MAAM,EAAE,OAAO,CAAC;IAChB,KAAK,EAAE,UAAU,CAAC;IAClB,UAAU,EAAE,UAAU,CAAC;IACvB,+DAA+D;IAC/D,QAAQ,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;IACnC,KAAK,EAAE,MAAM,CAAC;IACd,SAAS,EAAE,MAAM,CAAC;IAClB,WAAW,EAAE,MAAM,CAAC;CACrB,GAAG,eAAe,CAAC;AAEpB;;GAEG;AACH,MAAM,MAAM,cAAc,GAAG;IAC3B,IAAI,EAAE,YAAY,CAAC;IACnB,IAAI,EAAE,MAAM,CAAC;IACb,WAAW,CAAC,EAAE,MAAM,CAAC;CACtB,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,YAAY,GAAG;IACzB,IAAI,EAAE,UAAU,CAAC;IACjB,IAAI,EAAE,MAAM,CAAC;IACb,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,wCAAwC;IACxC,cAAc,CAAC,EAAE,OAAO,CAAC;IACzB,KAAK,CAAC,EAAE,UAAU,CAAC;IACnB,oEAAoE;IACpE,QAAQ,CAAC,EAAE;QACT,kBAAkB,CAAC,EAAE,OAAO,EAAE,CAAC;KAChC,CAAC;IACF,4BAA4B;IAC5B,UAAU,CAAC,EAAE,UAAU,GAAG,MAAM,CAAC;IACjC,kCAAkC;IAClC,KAAK,CAAC,EAAE,MAAM,CAAC;CAChB,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,SAAS,GAAG;IACtB,IAAI,EAAE,MAAM,CAAC;IACb,IAAI,EAAE,MAAM,CAAC;IACb,KAAK,EAAE,UAAU,CAAC;IAClB,UAAU,EAAE,UAAU,CAAC;IACvB,SAAS,EAAE,MAAM,CAAC;IAClB,WAAW,EAAE,MAAM,CAAC;CACrB,GAAG,eAAe,CAAC;AAEpB;;;;;GAKG;AACH,MAAM,MAAM,oBAAoB,GAAG;IACjC,IAAI,EAAE,mBAAmB,CAAC;IAC1B,MAAM,EAAE,MAAM,CAAC;IACf,IAAI,EAAE,MAAM,CAAC;CACd,GAAG,eAAe,CAAC;AAEpB;;GAEG;AACH,MAAM,MAAM,eAAe,GAAG;IAC5B,IAAI,EAAE,aAAa,CAAC;IACpB,MAAM,EAAE,MAAM,CAAC;IACf,IAAI,EAAE,MAAM,CAAC;IACb,MAAM,EAAE,OAAO,CAAC;IAChB,OAAO,CAAC,EAAE,OAAO,CAAC;IAClB,UAAU,EAAE,YAAY,CAAC;IACzB,SAAS,EAAE,MAAM,CAAC;IAClB,WAAW,EAAE,MAAM,CAAC;CACrB,GAAG,eAAe,CAAC;AAEpB;;;;;;GAMG;AACH,MAAM,WAAW,mBAAmB;IAClC,IAAI,EAAE,MAAM,CAAC;IACb,QAAQ,EAAE,MAAM,CAAC;IACjB,KAAK,EAAE,MAAM,CAAC;IACd,SAAS,EAAE,OAAO,CAAC;CACpB;AAED;;GAEG;AACH,MAAM,MAAM,6BAA6B,GAAG;IAC1C,IAAI,EAAE,4BAA4B,CAAC;IACnC,MAAM,EAAE,MAAM,CAAC;IACf,IAAI,EAAE,MAAM,CAAC;IACb,KAAK,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;IAC/B,OAAO,EAAE,MAAM,CAAC;IAChB,QAAQ,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;CACpC,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,2BAA2B,GAAG;IACxC,IAAI,EAAE,0BAA0B,CAAC;IACjC,MAAM,EAAE,MAAM,CAAC;IACf,SAAS,EAAE,OAAO,CAAC;IACnB,MAAM,CAAC,EAAE,OAAO,CAAC;IACjB,MAAM,CAAC,EAAE,MAAM,CAAC;CACjB,GAAG,eAAe,CAAC;AAEpB;;GAEG;AACH,MAAM,MAAM,aAAa,GAAG;IAC1B,IAAI,EAAE,UAAU,CAAC;IACjB,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,mCAAmC;IACnC,MAAM,CAAC,EAAE,MAAM,CAAC;IAChB,mCAAmC;IACnC,QAAQ,CAAC,EAAE,OAAO,EAAE,CAAC;IACrB,sBAAsB;IACtB,KAAK,CAAC,EAAE,KAAK,CAAC;QAAE,IAAI,CAAC,EAAE,MAAM,CAAC;QAAC,WAAW,CAAC,EAAE,MAAM,CAAA;KAAE,CAAC,CAAC;CACxD,GAAG,eAAe,CAAC;AAEpB;;GAEG;AACH,MAAM,MAAM,iBAAiB,GAAG;IAC9B,IAAI,EAAE,eAAe,CAAC;IACtB,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,uBAAuB;IACvB,OAAO,CAAC,EAAE,MAAM,CAAC;IACjB,oDAAoD;IACpD,KAAK,EAAE,OAAO,CAAC;CAChB,GAAG,eAAe,CAAC;AAEpB;;GAEG;AACH,MAAM,MAAM,oBAAoB,GAAG;IACjC,IAAI,EAAE,kBAAkB,CAAC;IACzB,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,uBAAuB;IACvB,OAAO,CAAC,EAAE,MAAM,CAAC;IACjB,4DAA4D;IAC5D,QAAQ,CAAC,EAAE,MAAM,CAAC;IAClB,oEAAoE;IACpE,aAAa,EAAE,OAAO,CAAC;CACxB,GAAG,eAAe,CAAC;AAEpB;;GAEG;AACH,MAAM,MAAM,kBAAkB,GAAG;IAC/B,IAAI,EAAE,gBAAgB,CAAC;IACvB,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,6EAA6E;IAC7E,cAAc,CAAC,EAAE,OAAO,CAAC;IACzB,+CAA+C;IAC/C,WAAW,CAAC,EAAE;QACZ,KAAK,CAAC,EAAE,MAAM,CAAC;QACf,OAAO,CAAC,EAAE,OAAO,CAAC;QAClB,KAAK,CAAC,EAAE,UAAU,CAAC;QACnB,UAAU,CAAC,EAAE,MAAM,CAAC;QACpB,SAAS,CAAC,EAAE,KAAK,CAAC;YAAE,EAAE,EAAE,MAAM,CAAC;YAAC,IAAI,EAAE,MAAM,CAAC;YAAC,KAAK,EAAE,OAAO,CAAA;SAAE,CAAC,CAAC;KACjE,CAAC;IACF,4DAA4D;IAC5D,WAAW,CAAC,EAAE;QACZ,kBAAkB,CAAC,EAAE,OAAO,EAAE,CAAC;QAC/B,SAAS,CAAC,EAAE,OAAO,EAAE,CAAC;QACtB,UAAU,CAAC,EAAE,OAAO,CAAC;QACrB,UAAU,CAAC,EAAE,OAAO,CAAC;KACtB,CAAC;CACH,GAAG,eAAe,CAAC;AAEpB;;GAEG;AACH,MAAM,MAAM,gBAAgB,GAAG;IAC7B,IAAI,EAAE,cAAc,CAAC;IACrB,KAAK,EAAE;QACL,OAAO,EAAE,MAAM,CAAC;QAChB,IAAI,CAAC,EAAE,MAAM,CAAC;KACf,CAAC;CACH,GAAG,eAAe,CAAC;AAEpB;;;;;GAKG;AACH,MAAM,MAAM,kBAAkB,GAAG;IAC/B,IAAI,EAAE,gBAAgB,CAAC;IACvB,8DAA8D;IAC9D,OAAO,EAAE,MAAM,CAAC;IAChB,gCAAgC;IAChC,SAAS,CAAC,EAAE,MAAM,CAAC;IACnB,oBAAoB;IACpB,QAAQ,CAAC,EAAE,MAAM,CAAC;IAClB,oCAAoC;IACpC,aAAa,CAAC,EAAE,MAAM,CAAC;IACvB,kCAAkC;IAClC,WAAW,EAAE,MAAM,CAAC;IACpB,wCAAwC;IACxC,YAAY,EAAE,MAAM,CAAC;IACrB,6BAA6B;IAC7B,WAAW,EAAE,MAAM,CAAC;IACpB,6CAA6C;IAC7C,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,wBAAwB;IACxB,eAAe,CAAC,EAAE,MAAM,CAAC;IACzB,yBAAyB;IACzB,cAAc,CAAC,EAAE,OAAO,CAAC;IACzB,eAAe,CAAC,EAAE,OAAO,CAAC;IAC1B,gBAAgB,CAAC,EAAE,OAAO,CAAC;IAC3B,0DAA0D;IAC1D,eAAe,CAAC,EAAE;QAChB,WAAW,EAAE,MAAM,CAAC;QACpB,YAAY,EAAE,MAAM,CAAC;QACrB,WAAW,EAAE,MAAM,CAAC;QACpB,KAAK,EAAE,MAAM,CAAC;KACf,CAAC;CACH,GAAG,eAAe,CAAC;AAEpB;;;;;;GAMG;AACH,MAAM,MAAM,cAAc,GAAG;IAC3B,IAAI,EAAE,YAAY,CAAC;IACnB,gDAAgD;IAChD,MAAM,EAAE,MAAM,CAAC;IACf,+CAA+C;IAC/C,iBAAiB,EAAE,MAAM,CAAC;IAC1B,2CAA2C;IAC3C,QAAQ,EAAE,MAAM,GAAG,MAAM,GAAG,KAAK,CAAC;IAClC,6DAA6D;IAC7D,QAAQ,EAAE,MAAM,EAAE,CAAC;IACnB,kCAAkC;IAClC,WAAW,EAAE,MAAM,CAAC;IACpB,sEAAsE;IACtE,KAAK,CAAC,EAAE,OAAO,CAAC;CACjB,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,YAAY,GAAG;IACzB,IAAI,EAAE,UAAU,CAAC;IACjB,gDAAgD;IAChD,MAAM,EAAE,MAAM,CAAC;IACf,+CAA+C;IAC/C,iBAAiB,EAAE,MAAM,CAAC;IAC1B,6DAA6D;IAC7D,cAAc,CAAC,EAAE,MAAM,CAAC;IACxB,2CAA2C;IAC3C,OAAO,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;IACjC,iDAAiD;IACjD,KAAK,CAAC,EAAE,UAAU,CAAC;CACpB,GAAG,eAAe,CAAC;AAEpB;;;;;GAKG;AACH,MAAM,MAAM,eAAe,GAAG;IAC5B,IAAI,EAAE,aAAa,CAAC;IACpB,iDAAiD;IACjD,OAAO,EAAE,MAAM,CAAC;IAChB,gDAAgD;IAChD,iBAAiB,EAAE,MAAM,CAAC;IAC1B,yBAAyB;IACzB,gBAAgB,EAAE,MAAM,CAAC;IACzB,0CAA0C;IAC1C,aAAa,CAAC,EAAE,MAAM,CAAC;IACvB,oCAAoC;IACpC,KAAK,CAAC,EAAE,MAAM,CAAC;IACf,4CAA4C;IAC5C,KAAK,CAAC,EAAE,OAAO,CAAC;IAChB,gFAAgF;IAChF,YAAY,CAAC,EAAE,MAAM,CAAC;CACvB,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,aAAa,GAAG;IAC1B,IAAI,EAAE,WAAW,CAAC;IAClB,iDAAiD;IACjD,OAAO,EAAE,MAAM,CAAC;IAChB,gDAAgD;IAChD,iBAAiB,EAAE,MAAM,CAAC;IAC1B,yBAAyB;IACzB,gBAAgB,EAAE,MAAM,CAAC;IACzB,wCAAwC;IACxC,MAAM,EAAE,OAAO,CAAC;IAChB,gCAAgC;IAChC,OAAO,CAAC,EAAE,OAAO,CAAC;IAClB,6CAA6C;IAC7C,KAAK,CAAC,EAAE,UAAU,CAAC;CACpB,GAAG,eAAe,CAAC;AAEpB;;;;GAIG;AACH,MAAM,MAAM,wBAAwB,GAEhC,mBAAmB,GACnB,iBAAiB,GACjB,cAAc,GAEd,cAAc,GACd,YAAY,GACZ,SAAS,GAET,oBAAoB,GACpB,eAAe,GACf,6BAA6B,GAC7B,2BAA2B,GAE3B,aAAa,GACb,iBAAiB,GACjB,oBAAoB,GACpB,kBAAkB,GAElB,kBAAkB,GAElB,cAAc,GACd,YAAY,GACZ,eAAe,GACf,aAAa,GAEb,gBAAgB,CAAC;AAMrB;;GAEG;AACH,MAAM,MAAM,iBAAiB,GAAG;IAC9B,IAAI,EAAE,QAAQ,CAAC;IACf,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,MAAM,EAAE,oBAAoB,CAAC;CAC9B,GAAG,eAAe,CAAC;AAMpB;;;;GAIG;AACH,MAAM,MAAM,WAAW,GAAG,gBAAgB,GAAG,wBAAwB,GAAG,iBAAiB,CAAC;AAM1F;;GAEG;AACH,wBAAgB,kBAAkB,CAAC,KAAK,EAAE,WAAW,GAAG,KAAK,IAAI,gBAAgB,CAoBhF;AAED;;GAEG;AACH,wBAAgB,0BAA0B,CAAC,KAAK,EAAE,WAAW,GAAG,KAAK,IAAI,wBAAwB,CAsBhG;AAED;;GAEG;AACH,wBAAgB,WAAW,CAAC,KAAK,EAAE,WAAW,GAAG,KAAK,IAAI,cAAc,GAAG,YAAY,CAEtF;AAED;;GAEG;AACH,wBAAgB,YAAY,CAAC,KAAK,EAAE,WAAW,GAAG,KAAK,IAAI,eAAe,GAAG,aAAa,CAEzF;AAED;;GAEG;AACH,wBAAgB,YAAY,CAC1B,KAAK,EAAE,WAAW,GACjB,KAAK,IAAI,iBAAiB,GAAG,mBAAmB,GAAG,kBAAkB,CAEvE;AAED;;GAEG;AACH,wBAAgB,YAAY,CAC1B,KAAK,EAAE,WAAW,GACjB,KAAK,IACJ,YAAY,GACZ,cAAc,GACd,YAAY,GACZ,aAAa,GACb,SAAS,GACT,cAAc,GACd,iBAAiB,CAIpB"}
+{"version":3,"file":"streaming.d.ts","sourceRoot":"","sources":["../src/streaming.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;;;;;;;;;;;;GAuBG;AAEH,OAAO,KAAK,EAAE,YAAY,EAAE,MAAM,UAAU,CAAC;AAC7C,OAAO,KAAK,EAAE,SAAS,EAAE,MAAM,eAAe,CAAC;AAC/C,OAAO,KAAK,EAAE,OAAO,EAAE,MAAM,YAAY,CAAC;AAC1C,OAAO,KAAK,EAAE,UAAU,EAAE,MAAM,UAAU,CAAC;AAC3C,OAAO,KAAK,EAAE,YAAY,EAAE,MAAM,SAAS,CAAC;AAC5C,OAAO,KAAK,EAAE,oBAAoB,EAAE,MAAM,YAAY,CAAC;AAMvD;;;;;;;GAOG;AACH,MAAM,WAAW,eAAe;IAC9B,0CAA0C;IAC1C,IAAI,EAAE,MAAM,CAAC;IACb,8BAA8B;IAC9B,GAAG,CAAC,EAAE,MAAM,CAAC;IACb,wBAAwB;IACxB,KAAK,CAAC,EAAE,MAAM,CAAC;IACf,0DAA0D;IAC1D,UAAU,CAAC,EAAE,MAAM,CAAC;IACpB,wDAAwD;IACxD,QAAQ,CAAC,EAAE,MAAM,CAAC;CACnB;AAED;;;;GAIG;AACH,MAAM,WAAW,iBAAiB;IAChC,mEAAmE;IACnE,IAAI,EAAE,MAAM,CAAC;IACb,8BAA8B;IAC9B,IAAI,EAAE,MAAM,CAAC;IACb,iCAAiC;IACjC,UAAU,CAAC,EAAE,MAAM,CAAC;IACpB,+BAA+B;IAC/B,QAAQ,CAAC,EAAE,MAAM,CAAC;IAClB,0CAA0C;IAC1C,IAAI,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;CAChC;AAED;;;;;;;;;GASG;AACH,MAAM,WAAW,eAAe;IAC9B,gDAAgD;IAChD,SAAS,CAAC,EAAE,eAAe,EAAE,CAAC;IAE9B,gDAAgD;IAChD,WAAW,CAAC,EAAE,iBAAiB,EAAE,CAAC;IAElC,6CAA6C;IAC7C,QAAQ,CAAC,EAAE,MAAM,CAAC;IAElB,qBAAqB;IACrB,QAAQ,CAAC,EAAE,MAAM,CAAC;IAElB,oDAAoD;IACpD,UAAU,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;CACtC;AAMD;;;;;;;;;;;GAWG;AACH,oBAAY,UAAU;IACpB,UAAU,eAAe;IACzB,aAAa,kBAAkB;IAC/B,cAAc,mBAAmB;IACjC,QAAQ,aAAa;IACrB,aAAa,kBAAkB;IAC/B,WAAW,gBAAgB;IAC3B,KAAK,UAAU;IACf,IAAI,SAAS;IACb,MAAM,WAAW;IACjB,YAAY,iBAAiB;IAC7B,cAAc,mBAAmB;IACjC,UAAU,eAAe;IACzB,mBAAmB,wBAAwB;IAC3C,kBAAkB,uBAAuB;IACzC,KAAK,UAAU;CAChB;AAMD;;GAEG;AACH,MAAM,WAAW,eAAe;IAC9B,oFAAoF;IACpF,EAAE,EAAE,MAAM,CAAC;IAEX;;;;;;;;;;OAUG;IACH,QAAQ,EAAE,MAAM,CAAC;IAEjB,oEAAoE;IACpE,IAAI,EAAE,MAAM,CAAC;IAEb,wDAAwD;IACxD,SAAS,EAAE,MAAM,CAAC;IAElB,6FAA6F;IAC7F,GAAG,CAAC,EAAE,OAAO,CAAC;IAEd,gCAAgC;IAChC,4DAA4D;IAC5D,SAAS,CAAC,EAAE,MAAM,CAAC;IAEnB,2EAA2E;IAC3E,SAAS,CAAC,EAAE,MAAM,EAAE,CAAC;CACtB;AAMD;;;;;GAKG;AACH,MAAM,MAAM,iBAAiB,GAAG;IAC9B,IAAI,EAAE,eAAe,CAAC;IACtB,SAAS,EAAE,SAAS,CAAC;IACrB,UAAU,EAAE,MAAM,CAAC;IACnB,gEAAgE;IAChE,QAAQ,CAAC,EAAE,eAAe,CAAC;CAC5B,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,iBAAiB,GAAG;IAC9B,IAAI,EAAE,eAAe,CAAC;IACtB,SAAS,EAAE,SAAS,CAAC;IACrB,UAAU,EAAE,MAAM,CAAC;IACnB,KAAK,EAAE,MAAM,CAAC;CAEf,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,eAAe,GAAG;IAC5B,IAAI,EAAE,aAAa,CAAC;IACpB,SAAS,EAAE,SAAS,CAAC;IACrB,UAAU,EAAE,MAAM,CAAC;IACnB,gEAAgE;IAChE,QAAQ,CAAC,EAAE,eAAe,CAAC;CAC5B,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,YAAY,GAAG;IACzB,IAAI,EAAE,SAAS,CAAC;IAChB,UAAU,EAAE,MAAM,CAAC;IACnB,OAAO,EAAE,YAAY,CAAC;IACtB,gEAAgE;IAChE,QAAQ,CAAC,EAAE,eAAe,CAAC;IAC3B,SAAS,EAAE,MAAM,CAAC;IAClB,WAAW,EAAE,MAAM,CAAC;CACrB,GAAG,eAAe,CAAC;AAEpB;;;;;GAKG;AACH,MAAM,MAAM,mBAAmB,GAAG;IAChC,IAAI,EAAE,iBAAiB,CAAC;IACxB,UAAU,EAAE,MAAM,CAAC;IACnB,kDAAkD;IAClD,QAAQ,CAAC,EAAE,eAAe,CAAC;CAC5B,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,mBAAmB,GAAG;IAChC,IAAI,EAAE,iBAAiB,CAAC;IACxB,UAAU,EAAE,MAAM,CAAC;IACnB,KAAK,EAAE,MAAM,CAAC;CAEf,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,iBAAiB,GAAG;IAC9B,IAAI,EAAE,eAAe,CAAC;IACtB,UAAU,EAAE,MAAM,CAAC;IACnB,kDAAkD;IAClD,QAAQ,CAAC,EAAE,eAAe,CAAC;CAC5B,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,cAAc,GAAG;IAC3B,IAAI,EAAE,WAAW,CAAC;IAClB,UAAU,EAAE,MAAM,CAAC;IACnB,SAAS,EAAE,MAAM,CAAC;IAClB,kDAAkD;IAClD,QAAQ,CAAC,EAAE,eAAe,CAAC;IAC3B,SAAS,EAAE,MAAM,CAAC;IAClB,WAAW,EAAE,MAAM,CAAC;CACrB,GAAG,eAAe,CAAC;AAEpB;;GAEG;AACH,MAAM,MAAM,iBAAiB,GAAG;IAC9B,IAAI,EAAE,eAAe,CAAC;IACtB,IAAI,EAAE,WAAW,CAAC;IAClB,KAAK,CAAC,EAAE,MAAM,CAAC;CAChB,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,eAAe,GAAG;IAC5B,IAAI,EAAE,aAAa,CAAC;IACpB,UAAU,EAAE,UAAU,CAAC;IACvB,KAAK,CAAC,EAAE,UAAU,CAAC;CACpB,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,YAAY,GAAG;IACzB,IAAI,EAAE,SAAS,CAAC;IAChB,OAAO,EAAE,OAAO,CAAC;IACjB,UAAU,EAAE,UAAU,CAAC;IACvB,KAAK,CAAC,EAAE,UAAU,CAAC;IACnB,KAAK,CAAC,EAAE,MAAM,CAAC;IACf,sFAAsF;IACtF,GAAG,CAAC,EAAE,OAAO,CAAC;IACd,SAAS,EAAE,MAAM,CAAC;IAClB,WAAW,EAAE,MAAM,CAAC;CACrB,GAAG,eAAe,CAAC;AAEpB;;GAEG;AACH,MAAM,MAAM,kBAAkB,GAAG;IAC/B,IAAI,EAAE,iBAAiB,CAAC;IACxB,MAAM,EAAE,MAAM,CAAC;IACf,IAAI,EAAE,MAAM,CAAC;IACb,UAAU,EAAE,MAAM,CAAC;CACpB,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,kBAAkB,GAAG;IAC/B,IAAI,EAAE,iBAAiB,CAAC;IACxB,MAAM,EAAE,MAAM,CAAC;IACf,UAAU,EAAE,MAAM,CAAC;IACnB,KAAK,EAAE,MAAM,CAAC;CACf,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,gBAAgB,GAAG;IAC7B,IAAI,EAAE,eAAe,CAAC;IACtB,MAAM,EAAE,MAAM,CAAC;IACf,UAAU,EAAE,MAAM,CAAC;CACpB,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,aAAa,GAAG;IAC1B,IAAI,EAAE,WAAW,CAAC;IAClB,MAAM,EAAE,MAAM,CAAC;IACf,UAAU,EAAE,MAAM,CAAC;IACnB,IAAI,EAAE,MAAM,CAAC;IACb,KAAK,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;IAC/B,OAAO,CAAC,EAAE,MAAM,CAAC;IACjB,SAAS,EAAE,MAAM,CAAC;IAClB,WAAW,EAAE,MAAM,CAAC;CACrB,GAAG,eAAe,CAAC;AAEpB;;GAEG;AACH,MAAM,MAAM,gBAAgB,GAAG;IAC7B,IAAI,EAAE,OAAO,CAAC;IACd,KAAK,EAAE;QACL,OAAO,EAAE,MAAM,CAAC;QAChB,IAAI,CAAC,EAAE,MAAM,CAAC;KACf,CAAC;CACH,GAAG,eAAe,CAAC;AAEpB;;;;;;GAMG;AACH,MAAM,MAAM,UAAU,GAAG;IACvB,IAAI,EAAE,OAAO,CAAC;IACd,KAAK,EAAE;QACL,WAAW,EAAE,MAAM,CAAC;QACpB,YAAY,EAAE,MAAM,CAAC;QACrB,WAAW,EAAE,MAAM,CAAC;KACrB,CAAC;CACH,GAAG,eAAe,CAAC;AAEpB;;;;GAIG;AACH,MAAM,MAAM,gBAAgB,GAExB,iBAAiB,GACjB,iBAAiB,GACjB,eAAe,GACf,YAAY,GAEZ,mBAAmB,GACnB,mBAAmB,GACnB,iBAAiB,GACjB,cAAc,GAEd,iBAAiB,GACjB,eAAe,GACf,YAAY,GAEZ,kBAAkB,GAClB,kBAAkB,GAClB,gBAAgB,GAChB,aAAa,GAEb,UAAU,GAEV,gBAAgB,CAAC;AAMrB;;;;;GAKG;AACH,MAAM,MAAM,mBAAmB,GAAG;IAChC,IAAI,EAAE,iBAAiB,CAAC;IACxB,WAAW,EAAE,MAAM,CAAC;IACpB,SAAS,CAAC,EAAE,MAAM,CAAC;IACnB,iBAAiB,CAAC,EAAE,MAAM,CAAC;IAC3B,eAAe,CAAC,EAAE,MAAM,CAAC;IACzB,aAAa,CAAC,EAAE,MAAM,CAAC;IACvB,+DAA+D;IAC/D,QAAQ,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;CACpC,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,iBAAiB,GAAG;IAC9B,IAAI,EAAE,eAAe,CAAC;IACtB,WAAW,EAAE,MAAM,CAAC;IACpB,SAAS,CAAC,EAAE,MAAM,CAAC;IACnB,iBAAiB,CAAC,EAAE,MAAM,CAAC;IAC3B,eAAe,CAAC,EAAE,MAAM,CAAC;IACzB,gCAAgC;IAChC,UAAU,CAAC,EAAE,UAAU,GAAG,MAAM,CAAC;IACjC,oCAAoC;IACpC,OAAO,CAAC,EAAE,OAAO,CAAC;IAClB,mFAAmF;IACnF,KAAK,CAAC,EAAE;QAAE,OAAO,EAAE,MAAM,CAAC;QAAC,IAAI,EAAE,MAAM,CAAA;KAAE,CAAC;IAC1C,MAAM,EAAE,OAAO,CAAC;IAChB,8EAA8E;IAC9E,kBAAkB,CAAC,EAAE,OAAO,EAAE,CAAC;IAC/B,+DAA+D;IAC/D,QAAQ,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;CACpC,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,cAAc,GAAG;IAC3B,IAAI,EAAE,WAAW,CAAC;IAClB,WAAW,EAAE,MAAM,CAAC;IACpB,SAAS,CAAC,EAAE,MAAM,CAAC;IACnB,iBAAiB,CAAC,EAAE,MAAM,CAAC;IAC3B,eAAe,CAAC,EAAE,MAAM,CAAC;IACzB,MAAM,EAAE,OAAO,CAAC;IAChB,KAAK,EAAE,UAAU,CAAC;IAClB,UAAU,EAAE,UAAU,CAAC;IACvB,+DAA+D;IAC/D,QAAQ,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;IACnC,KAAK,EAAE,MAAM,CAAC;IACd,SAAS,EAAE,MAAM,CAAC;IAClB,WAAW,EAAE,MAAM,CAAC;CACrB,GAAG,eAAe,CAAC;AAEpB;;GAEG;AACH,MAAM,MAAM,cAAc,GAAG;IAC3B,IAAI,EAAE,YAAY,CAAC;IACnB,IAAI,EAAE,MAAM,CAAC;IACb,WAAW,CAAC,EAAE,MAAM,CAAC;CACtB,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,YAAY,GAAG;IACzB,IAAI,EAAE,UAAU,CAAC;IACjB,IAAI,EAAE,MAAM,CAAC;IACb,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,wCAAwC;IACxC,cAAc,CAAC,EAAE,OAAO,CAAC;IACzB,KAAK,CAAC,EAAE,UAAU,CAAC;IACnB,oEAAoE;IACpE,QAAQ,CAAC,EAAE;QACT,kBAAkB,CAAC,EAAE,OAAO,EAAE,CAAC;KAChC,CAAC;IACF,4BAA4B;IAC5B,UAAU,CAAC,EAAE,UAAU,GAAG,MAAM,CAAC;IACjC,kCAAkC;IAClC,KAAK,CAAC,EAAE,MAAM,CAAC;CAChB,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,SAAS,GAAG;IACtB,IAAI,EAAE,MAAM,CAAC;IACb,IAAI,EAAE,MAAM,CAAC;IACb,KAAK,EAAE,UAAU,CAAC;IAClB,UAAU,EAAE,UAAU,CAAC;IACvB,SAAS,EAAE,MAAM,CAAC;IAClB,WAAW,EAAE,MAAM,CAAC;CACrB,GAAG,eAAe,CAAC;AAEpB;;;;;GAKG;AACH,MAAM,MAAM,oBAAoB,GAAG;IACjC,IAAI,EAAE,mBAAmB,CAAC;IAC1B,MAAM,EAAE,MAAM,CAAC;IACf,IAAI,EAAE,MAAM,CAAC;CACd,GAAG,eAAe,CAAC;AAEpB;;GAEG;AACH,MAAM,MAAM,eAAe,GAAG;IAC5B,IAAI,EAAE,aAAa,CAAC;IACpB,MAAM,EAAE,MAAM,CAAC;IACf,IAAI,EAAE,MAAM,CAAC;IACb,MAAM,EAAE,OAAO,CAAC;IAChB,OAAO,CAAC,EAAE,OAAO,CAAC;IAClB,UAAU,EAAE,YAAY,CAAC;IACzB,SAAS,EAAE,MAAM,CAAC;IAClB,WAAW,EAAE,MAAM,CAAC;CACrB,GAAG,eAAe,CAAC;AAEpB;;;;;;GAMG;AACH,MAAM,WAAW,mBAAmB;IAClC,IAAI,EAAE,MAAM,CAAC;IACb,QAAQ,EAAE,MAAM,CAAC;IACjB,KAAK,EAAE,MAAM,CAAC;IACd,SAAS,EAAE,OAAO,CAAC;CACpB;AAED;;GAEG;AACH,MAAM,MAAM,6BAA6B,GAAG;IAC1C,IAAI,EAAE,4BAA4B,CAAC;IACnC,MAAM,EAAE,MAAM,CAAC;IACf,IAAI,EAAE,MAAM,CAAC;IACb,KAAK,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;IAC/B,OAAO,EAAE,MAAM,CAAC;IAChB,QAAQ,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;CACpC,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,2BAA2B,GAAG;IACxC,IAAI,EAAE,0BAA0B,CAAC;IACjC,MAAM,EAAE,MAAM,CAAC;IACf,SAAS,EAAE,OAAO,CAAC;IACnB,MAAM,CAAC,EAAE,OAAO,CAAC;IACjB,MAAM,CAAC,EAAE,MAAM,CAAC;CACjB,GAAG,eAAe,CAAC;AAEpB;;GAEG;AACH,MAAM,MAAM,aAAa,GAAG;IAC1B,IAAI,EAAE,UAAU,CAAC;IACjB,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,mCAAmC;IACnC,MAAM,CAAC,EAAE,MAAM,CAAC;IAChB,mCAAmC;IACnC,QAAQ,CAAC,EAAE,OAAO,EAAE,CAAC;IACrB,sBAAsB;IACtB,KAAK,CAAC,EAAE,KAAK,CAAC;QAAE,IAAI,CAAC,EAAE,MAAM,CAAC;QAAC,WAAW,CAAC,EAAE,MAAM,CAAA;KAAE,CAAC,CAAC;CACxD,GAAG,eAAe,CAAC;AAEpB;;GAEG;AACH,MAAM,MAAM,iBAAiB,GAAG;IAC9B,IAAI,EAAE,eAAe,CAAC;IACtB,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,uBAAuB;IACvB,OAAO,CAAC,EAAE,MAAM,CAAC;IACjB,oDAAoD;IACpD,KAAK,EAAE,OAAO,CAAC;CAChB,GAAG,eAAe,CAAC;AAEpB;;GAEG;AACH,MAAM,MAAM,oBAAoB,GAAG;IACjC,IAAI,EAAE,kBAAkB,CAAC;IACzB,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,uBAAuB;IACvB,OAAO,CAAC,EAAE,MAAM,CAAC;IACjB,4DAA4D;IAC5D,QAAQ,CAAC,EAAE,MAAM,CAAC;IAClB,oEAAoE;IACpE,aAAa,EAAE,OAAO,CAAC;CACxB,GAAG,eAAe,CAAC;AAEpB;;GAEG;AACH,MAAM,MAAM,kBAAkB,GAAG;IAC/B,IAAI,EAAE,gBAAgB,CAAC;IACvB,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,6EAA6E;IAC7E,cAAc,CAAC,EAAE,OAAO,CAAC;IACzB,+CAA+C;IAC/C,WAAW,CAAC,EAAE;QACZ,KAAK,CAAC,EAAE,MAAM,CAAC;QACf,OAAO,CAAC,EAAE,OAAO,CAAC;QAClB,KAAK,CAAC,EAAE,UAAU,CAAC;QACnB,UAAU,CAAC,EAAE,MAAM,CAAC;QACpB,SAAS,CAAC,EAAE,KAAK,CAAC;YAAE,EAAE,EAAE,MAAM,CAAC;YAAC,IAAI,EAAE,MAAM,CAAC;YAAC,KAAK,EAAE,OAAO,CAAA;SAAE,CAAC,CAAC;KACjE,CAAC;IACF,4DAA4D;IAC5D,WAAW,CAAC,EAAE;QACZ,kBAAkB,CAAC,EAAE,OAAO,EAAE,CAAC;QAC/B,SAAS,CAAC,EAAE,OAAO,EAAE,CAAC;QACtB,UAAU,CAAC,EAAE,OAAO,CAAC;QACrB,UAAU,CAAC,EAAE,OAAO,CAAC;KACtB,CAAC;CACH,GAAG,eAAe,CAAC;AAEpB;;;;;;;;GAQG;AACH,MAAM,MAAM,mBAAmB,GAAG;IAChC,IAAI,EAAE,iBAAiB,CAAC;IACxB,gFAAgF;IAChF,KAAK,EAAE,OAAO,CAAC;IACf,sCAAsC;IACtC,WAAW,EAAE,MAAM,CAAC;IACpB,6CAA6C;IAC7C,aAAa,EAAE,MAAM,CAAC;CACvB,GAAG,eAAe,CAAC;AAEpB;;GAEG;AACH,MAAM,MAAM,gBAAgB,GAAG;IAC7B,IAAI,EAAE,cAAc,CAAC;IACrB,KAAK,EAAE;QACL,OAAO,EAAE,MAAM,CAAC;QAChB,IAAI,CAAC,EAAE,MAAM,CAAC;KACf,CAAC;CACH,GAAG,eAAe,CAAC;AAEpB;;;;;GAKG;AACH,MAAM,MAAM,kBAAkB,GAAG;IAC/B,IAAI,EAAE,gBAAgB,CAAC;IACvB,8DAA8D;IAC9D,OAAO,EAAE,MAAM,CAAC;IAChB,gCAAgC;IAChC,SAAS,CAAC,EAAE,MAAM,CAAC;IACnB,oBAAoB;IACpB,QAAQ,CAAC,EAAE,MAAM,CAAC;IAClB,oCAAoC;IACpC,aAAa,CAAC,EAAE,MAAM,CAAC;IACvB,kCAAkC;IAClC,WAAW,EAAE,MAAM,CAAC;IACpB,wCAAwC;IACxC,YAAY,EAAE,MAAM,CAAC;IACrB,6BAA6B;IAC7B,WAAW,EAAE,MAAM,CAAC;IACpB,6CAA6C;IAC7C,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,wBAAwB;IACxB,eAAe,CAAC,EAAE,MAAM,CAAC;IACzB,yBAAyB;IACzB,cAAc,CAAC,EAAE,OAAO,CAAC;IACzB,eAAe,CAAC,EAAE,OAAO,CAAC;IAC1B,gBAAgB,CAAC,EAAE,OAAO,CAAC;IAC3B,0DAA0D;IAC1D,eAAe,CAAC,EAAE;QAChB,WAAW,EAAE,MAAM,CAAC;QACpB,YAAY,EAAE,MAAM,CAAC;QACrB,WAAW,EAAE,MAAM,CAAC;QACpB,KAAK,EAAE,MAAM,CAAC;KACf,CAAC;CACH,GAAG,eAAe,CAAC;AAEpB;;;;;;GAMG;AACH,MAAM,MAAM,cAAc,GAAG;IAC3B,IAAI,EAAE,YAAY,CAAC;IACnB,gDAAgD;IAChD,MAAM,EAAE,MAAM,CAAC;IACf,+CAA+C;IAC/C,iBAAiB,EAAE,MAAM,CAAC;IAC1B,2CAA2C;IAC3C,QAAQ,EAAE,MAAM,GAAG,MAAM,GAAG,KAAK,CAAC;IAClC,6DAA6D;IAC7D,QAAQ,EAAE,MAAM,EAAE,CAAC;IACnB,kCAAkC;IAClC,WAAW,EAAE,MAAM,CAAC;IACpB,sEAAsE;IACtE,KAAK,CAAC,EAAE,OAAO,CAAC;CACjB,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,YAAY,GAAG;IACzB,IAAI,EAAE,UAAU,CAAC;IACjB,gDAAgD;IAChD,MAAM,EAAE,MAAM,CAAC;IACf,+CAA+C;IAC/C,iBAAiB,EAAE,MAAM,CAAC;IAC1B,6DAA6D;IAC7D,cAAc,CAAC,EAAE,MAAM,CAAC;IACxB,2CAA2C;IAC3C,OAAO,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;IACjC,iDAAiD;IACjD,KAAK,CAAC,EAAE,UAAU,CAAC;CACpB,GAAG,eAAe,CAAC;AAEpB;;;;;GAKG;AACH,MAAM,MAAM,eAAe,GAAG;IAC5B,IAAI,EAAE,aAAa,CAAC;IACpB,iDAAiD;IACjD,OAAO,EAAE,MAAM,CAAC;IAChB,gDAAgD;IAChD,iBAAiB,EAAE,MAAM,CAAC;IAC1B,yBAAyB;IACzB,gBAAgB,EAAE,MAAM,CAAC;IACzB,0CAA0C;IAC1C,aAAa,CAAC,EAAE,MAAM,CAAC;IACvB,oCAAoC;IACpC,KAAK,CAAC,EAAE,MAAM,CAAC;IACf,4CAA4C;IAC5C,KAAK,CAAC,EAAE,OAAO,CAAC;IAChB,gFAAgF;IAChF,YAAY,CAAC,EAAE,MAAM,CAAC;CACvB,GAAG,eAAe,CAAC;AAEpB,MAAM,MAAM,aAAa,GAAG;IAC1B,IAAI,EAAE,WAAW,CAAC;IAClB,iDAAiD;IACjD,OAAO,EAAE,MAAM,CAAC;IAChB,gDAAgD;IAChD,iBAAiB,EAAE,MAAM,CAAC;IAC1B,yBAAyB;IACzB,gBAAgB,EAAE,MAAM,CAAC;IACzB,wCAAwC;IACxC,MAAM,EAAE,OAAO,CAAC;IAChB,gCAAgC;IAChC,OAAO,CAAC,EAAE,OAAO,CAAC;IAClB,6CAA6C;IAC7C,KAAK,CAAC,EAAE,UAAU,CAAC;CACpB,GAAG,eAAe,CAAC;AAEpB;;;;GAIG;AACH,MAAM,MAAM,wBAAwB,GAEhC,mBAAmB,GACnB,iBAAiB,GACjB,cAAc,GAEd,cAAc,GACd,YAAY,GACZ,SAAS,GAET,oBAAoB,GACpB,eAAe,GACf,6BAA6B,GAC7B,2BAA2B,GAE3B,aAAa,GACb,iBAAiB,GACjB,oBAAoB,GACpB,kBAAkB,GAElB,kBAAkB,GAElB,cAAc,GACd,YAAY,GACZ,eAAe,GACf,aAAa,GAEb,mBAAmB,GAEnB,gBAAgB,CAAC;AAMrB;;GAEG;AACH,MAAM,MAAM,iBAAiB,GAAG;IAC9B,IAAI,EAAE,QAAQ,CAAC;IACf,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,MAAM,EAAE,oBAAoB,CAAC;CAC9B,GAAG,eAAe,CAAC;AAMpB;;;;GAIG;AACH,MAAM,MAAM,WAAW,GAAG,gBAAgB,GAAG,wBAAwB,GAAG,iBAAiB,CAAC;AAM1F;;GAEG;AACH,wBAAgB,kBAAkB,CAAC,KAAK,EAAE,WAAW,GAAG,KAAK,IAAI,gBAAgB,CAoBhF;AAED;;GAEG;AACH,wBAAgB,0BAA0B,CAAC,KAAK,EAAE,WAAW,GAAG,KAAK,IAAI,wBAAwB,CAuBhG;AAED;;GAEG;AACH,wBAAgB,WAAW,CAAC,KAAK,EAAE,WAAW,GAAG,KAAK,IAAI,cAAc,GAAG,YAAY,CAEtF;AAED;;GAEG;AACH,wBAAgB,YAAY,CAAC,KAAK,EAAE,WAAW,GAAG,KAAK,IAAI,eAAe,GAAG,aAAa,CAEzF;AAED;;GAEG;AACH,wBAAgB,YAAY,CAC1B,KAAK,EAAE,WAAW,GACjB,KAAK,IAAI,iBAAiB,GAAG,mBAAmB,GAAG,kBAAkB,CAEvE;AAED;;GAEG;AACH,wBAAgB,YAAY,CAC1B,KAAK,EAAE,WAAW,GACjB,KAAK,IACJ,YAAY,GACZ,cAAc,GACd,YAAY,GACZ,aAAa,GACb,SAAS,GACT,cAAc,GACd,iBAAiB,CAIpB"}

dist/streaming.js

@@ -108,2 +108,3 @@ /**
         "spawn_end",
+        "entry_committed",
         "engine_error",
@@ -110,0 +111,0 @@ ].includes(event.type);

dist/streaming.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"streaming.js","sourceRoot":"","sources":["../src/streaming.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;;;;;;;;;;;;GAuBG;AA+EH,+EAA+E;AAC/E,cAAc;AACd,+EAA+E;AAE/E;;;;;;;;;;;GAWG;AACH,MAAM,CAAN,IAAY,UAgBX;AAhBD,WAAY,UAAU;IACpB,uCAAyB,CAAA;IACzB,6CAA+B,CAAA;IAC/B,+CAAiC,CAAA;IACjC,mCAAqB,CAAA;IACrB,6CAA+B,CAAA;IAC/B,yCAA2B,CAAA;IAC3B,6BAAe,CAAA;IACf,2BAAa,CAAA;IACb,+BAAiB,CAAA;IACjB,2CAA6B,CAAA;IAC7B,+CAAiC,CAAA;IACjC,uCAAyB,CAAA;IACzB,yDAA2C,CAAA;IAC3C,uDAAyC,CAAA;IACzC,6BAAe,CAAA;AACjB,CAAC,EAhBW,UAAU,KAAV,UAAU,QAgBrB;AAmoBD,+EAA+E;AAC/E,oBAAoB;AACpB,+EAA+E;AAE/E;;GAEG;AACH,MAAM,UAAU,kBAAkB,CAAC,KAAkB;IACnD,OAAO;QACL,eAAe;QACf,eAAe;QACf,aAAa;QACb,SAAS;QACT,iBAAiB;QACjB,iBAAiB;QACjB,eAAe;QACf,WAAW;QACX,eAAe;QACf,aAAa;QACb,SAAS;QACT,iBAAiB;QACjB,iBAAiB;QACjB,eAAe;QACf,WAAW;QACX,OAAO;QACP,OAAO;KACR,CAAC,QAAQ,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;AACzB,CAAC;AAED;;GAEG;AACH,MAAM,UAAU,0BAA0B,CAAC,KAAkB;IAC3D,OAAO;QACL,iBAAiB;QACjB,eAAe;QACf,WAAW;QACX,YAAY;QACZ,UAAU;QACV,MAAM;QACN,mBAAmB;QACnB,aAAa;QACb,4BAA4B;QAC5B,0BAA0B;QAC1B,UAAU;QACV,eAAe;QACf,gBAAgB;QAChB,gBAAgB;QAChB,YAAY;QACZ,UAAU;QACV,aAAa;QACb,WAAW;QACX,cAAc;KACf,CAAC,QAAQ,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;AACzB,CAAC;AAED;;GAEG;AACH,MAAM,UAAU,WAAW,CAAC,KAAkB;IAC5C,OAAO,CAAC,YAAY,EAAE,UAAU,CAAC,CAAC,QAAQ,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;AACzD,CAAC;AAED;;GAEG;AACH,MAAM,UAAU,YAAY,CAAC,KAAkB;IAC7C,OAAO,CAAC,aAAa,EAAE,WAAW,CAAC,CAAC,QAAQ,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;AAC3D,CAAC;AAED;;GAEG;AACH,MAAM,UAAU,YAAY,CAC1B,KAAkB;IAElB,OAAO,CAAC,eAAe,EAAE,iBAAiB,EAAE,iBAAiB,CAAC,CAAC,QAAQ,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;AACtF,CAAC;AAED;;GAEG;AACH,MAAM,UAAU,YAAY,CAC1B,KAAkB;IASlB,OAAO,CAAC,SAAS,EAAE,WAAW,EAAE,SAAS,EAAE,WAAW,EAAE,MAAM,EAAE,WAAW,EAAE,QAAQ,CAAC,CAAC,QAAQ,CAC7F,KAAK,CAAC,IAAI,CACX,CAAC;AACJ,CAAC"}
+{"version":3,"file":"streaming.js","sourceRoot":"","sources":["../src/streaming.ts"],"names":[],"mappings":"AAAA;;;;;;;;;;;;;;;;;;;;;;;GAuBG;AA+EH,+EAA+E;AAC/E,cAAc;AACd,+EAA+E;AAE/E;;;;;;;;;;;GAWG;AACH,MAAM,CAAN,IAAY,UAgBX;AAhBD,WAAY,UAAU;IACpB,uCAAyB,CAAA;IACzB,6CAA+B,CAAA;IAC/B,+CAAiC,CAAA;IACjC,mCAAqB,CAAA;IACrB,6CAA+B,CAAA;IAC/B,yCAA2B,CAAA;IAC3B,6BAAe,CAAA;IACf,2BAAa,CAAA;IACb,+BAAiB,CAAA;IACjB,2CAA6B,CAAA;IAC7B,+CAAiC,CAAA;IACjC,uCAAyB,CAAA;IACzB,yDAA2C,CAAA;IAC3C,uDAAyC,CAAA;IACzC,6BAAe,CAAA;AACjB,CAAC,EAhBW,UAAU,KAAV,UAAU,QAgBrB;AAwpBD,+EAA+E;AAC/E,oBAAoB;AACpB,+EAA+E;AAE/E;;GAEG;AACH,MAAM,UAAU,kBAAkB,CAAC,KAAkB;IACnD,OAAO;QACL,eAAe;QACf,eAAe;QACf,aAAa;QACb,SAAS;QACT,iBAAiB;QACjB,iBAAiB;QACjB,eAAe;QACf,WAAW;QACX,eAAe;QACf,aAAa;QACb,SAAS;QACT,iBAAiB;QACjB,iBAAiB;QACjB,eAAe;QACf,WAAW;QACX,OAAO;QACP,OAAO;KACR,CAAC,QAAQ,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;AACzB,CAAC;AAED;;GAEG;AACH,MAAM,UAAU,0BAA0B,CAAC,KAAkB;IAC3D,OAAO;QACL,iBAAiB;QACjB,eAAe;QACf,WAAW;QACX,YAAY;QACZ,UAAU;QACV,MAAM;QACN,mBAAmB;QACnB,aAAa;QACb,4BAA4B;QAC5B,0BAA0B;QAC1B,UAAU;QACV,eAAe;QACf,gBAAgB;QAChB,gBAAgB;QAChB,YAAY;QACZ,UAAU;QACV,aAAa;QACb,WAAW;QACX,iBAAiB;QACjB,cAAc;KACf,CAAC,QAAQ,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;AACzB,CAAC;AAED;;GAEG;AACH,MAAM,UAAU,WAAW,CAAC,KAAkB;IAC5C,OAAO,CAAC,YAAY,EAAE,UAAU,CAAC,CAAC,QAAQ,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;AACzD,CAAC;AAED;;GAEG;AACH,MAAM,UAAU,YAAY,CAAC,KAAkB;IAC7C,OAAO,CAAC,aAAa,EAAE,WAAW,CAAC,CAAC,QAAQ,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;AAC3D,CAAC;AAED;;GAEG;AACH,MAAM,UAAU,YAAY,CAC1B,KAAkB;IAElB,OAAO,CAAC,eAAe,EAAE,iBAAiB,EAAE,iBAAiB,CAAC,CAAC,QAAQ,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;AACtF,CAAC;AAED;;GAEG;AACH,MAAM,UAAU,YAAY,CAC1B,KAAkB;IASlB,OAAO,CAAC,SAAS,EAAE,WAAW,EAAE,SAAS,EAAE,WAAW,EAAE,MAAM,EAAE,WAAW,EAAE,QAAQ,CAAC,CAAC,QAAQ,CAC7F,KAAK,CAAC,IAAI,CACX,CAAC;AACJ,CAAC"}

package.json

 {
   "name": "@agentick/shared",
-  "version": "0.8.0",
+  "version": "0.9.0",
   "description": "Shared types and utilities for Agentick",
@@ -5,0 +5,0 @@ "keywords": [

README.md

@@ -344,9 +344,13 @@ # @agentick/shared
 
-| Transport | Package            | Description                                          |
-| --------- | ------------------ | ---------------------------------------------------- |
-| SSE/HTTP  | `@agentick/client` | Default remote transport (HTTP + Server-Sent Events) |
-| Local     | `@agentick/core`   | In-process bridge via `createLocalTransport(app)`    |
+| Transport   | Package             | Description                                          |
+| ----------- | ------------------- | ---------------------------------------------------- |
+| SSE/HTTP    | `@agentick/client`  | Default remote transport (HTTP + Server-Sent Events) |
+| WebSocket   | `@agentick/client`  | Bidirectional via `createWSTransport(config)`        |
+| Unix Socket | `@agentick/gateway` | NDJSON over Unix domain socket (Node.js only)        |
+| Local       | `@agentick/core`    | In-process bridge via `createLocalTransport(app)`    |
 
-See [`packages/shared/src/transport.ts`](src/transport.ts) for the full interface definition.
+WebSocket and Unix socket transports are built on the shared `createRPCTransport` factory, which provides all protocol machinery (request correlation, event streaming, reconnection, session operations). Each transport is a thin delegate that provides wire-specific I/O.
 
+See [`packages/shared/src/transport.ts`](src/transport.ts) for the `ClientTransport` interface and [`packages/shared/src/rpc-transport.ts`](src/rpc-transport.ts) for the RPC factory.
+
 ## Tool Types
@@ -353,0 +357,0 @@

No alert changes

Improved metrics

Total package byte prevSize

536993

7.86%

Number of package files

112

16.67%

Lines of code

8566

7.22%

Number of lines in readme file

376

1.08%

No dependency changes