@agentick/client
Advanced tools
+4
-64
| /** | ||
| * Client Transport Interface | ||
| * | ||
| * Abstracts the connection layer (SSE/HTTP vs WebSocket) from client business logic. | ||
| * Re-exports from @agentick/shared where the canonical definitions live. | ||
| * | ||
| * @module @agentick/client/transport | ||
| */ | ||
| import type { SendInput, ChannelEvent, ToolConfirmationResponse } from "./types.js"; | ||
| export interface TransportEventData { | ||
| type: string; | ||
| sessionId?: string; | ||
| executionId?: string; | ||
| [key: string]: unknown; | ||
| } | ||
| export type TransportEventHandler = (event: TransportEventData) => void; | ||
| /** | ||
| * Transport connection state. | ||
| */ | ||
| export type TransportState = "disconnected" | "connecting" | "connected" | "error"; | ||
| /** | ||
| * Transport interface - abstracts SSE/HTTP vs WebSocket. | ||
| */ | ||
| export interface ClientTransport { | ||
| /** Current connection state */ | ||
| readonly state: TransportState; | ||
| /** Connection ID (if assigned by server) */ | ||
| readonly connectionId: string | undefined; | ||
| /** Connect to the server */ | ||
| connect(): Promise<void>; | ||
| /** Disconnect from the server */ | ||
| disconnect(): void; | ||
| /** | ||
| * Send a message and return a stream of events. | ||
| * Returns an async iterator of events for this execution. | ||
| */ | ||
| send(input: SendInput, sessionId?: string): AsyncIterable<TransportEventData> & { | ||
| /** Abort the current send operation */ | ||
| abort(reason?: string): void; | ||
| }; | ||
| /** Subscribe to session events */ | ||
| subscribeToSession(sessionId: string): Promise<void>; | ||
| /** Unsubscribe from session events */ | ||
| unsubscribeFromSession(sessionId: string): Promise<void>; | ||
| /** Abort a session's execution */ | ||
| abortSession(sessionId: string, reason?: string): Promise<void>; | ||
| /** Close a session */ | ||
| closeSession(sessionId: string): Promise<void>; | ||
| /** Submit tool result */ | ||
| submitToolResult(sessionId: string, toolUseId: string, result: ToolConfirmationResponse): Promise<void>; | ||
| /** Publish to a channel */ | ||
| publishToChannel(sessionId: string, channel: string, event: ChannelEvent): Promise<void>; | ||
| /** Subscribe to a channel */ | ||
| subscribeToChannel(sessionId: string, channel: string): Promise<void>; | ||
| /** Register event handler for incoming events */ | ||
| onEvent(handler: TransportEventHandler): () => void; | ||
| /** Register state change handler */ | ||
| onStateChange(handler: (state: TransportState) => void): () => void; | ||
| } | ||
| export interface TransportConfig { | ||
| /** Base URL for the server */ | ||
| baseUrl: string; | ||
| /** Authentication token */ | ||
| token?: string; | ||
| /** Custom headers */ | ||
| headers?: Record<string, string>; | ||
| /** Request timeout in ms */ | ||
| timeout?: number; | ||
| /** Send credentials with requests */ | ||
| withCredentials?: boolean; | ||
| } | ||
| export type { ClientTransport, TransportConfig, TransportState, TransportEventData, TransportEventHandler, } from "@agentick/shared"; | ||
| //# sourceMappingURL=transport.d.ts.map |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"transport.d.ts","sourceRoot":"","sources":["../src/transport.ts"],"names":[],"mappings":"AAAA;;;;GAIG;AAEH,OAAO,KAAK,EAAE,SAAS,EAAE,YAAY,EAAE,wBAAwB,EAAE,MAAM,YAAY,CAAC;AAMpF,MAAM,WAAW,kBAAkB;IACjC,IAAI,EAAE,MAAM,CAAC;IACb,SAAS,CAAC,EAAE,MAAM,CAAC;IACnB,WAAW,CAAC,EAAE,MAAM,CAAC;IACrB,CAAC,GAAG,EAAE,MAAM,GAAG,OAAO,CAAC;CACxB;AAED,MAAM,MAAM,qBAAqB,GAAG,CAAC,KAAK,EAAE,kBAAkB,KAAK,IAAI,CAAC;AAMxE;;GAEG;AACH,MAAM,MAAM,cAAc,GAAG,cAAc,GAAG,YAAY,GAAG,WAAW,GAAG,OAAO,CAAC;AAEnF;;GAEG;AACH,MAAM,WAAW,eAAe;IAC9B,+BAA+B;IAC/B,QAAQ,CAAC,KAAK,EAAE,cAAc,CAAC;IAE/B,4CAA4C;IAC5C,QAAQ,CAAC,YAAY,EAAE,MAAM,GAAG,SAAS,CAAC;IAE1C,4BAA4B;IAC5B,OAAO,IAAI,OAAO,CAAC,IAAI,CAAC,CAAC;IAEzB,iCAAiC;IACjC,UAAU,IAAI,IAAI,CAAC;IAEnB;;;OAGG;IACH,IAAI,CACF,KAAK,EAAE,SAAS,EAChB,SAAS,CAAC,EAAE,MAAM,GACjB,aAAa,CAAC,kBAAkB,CAAC,GAAG;QACrC,uCAAuC;QACvC,KAAK,CAAC,MAAM,CAAC,EAAE,MAAM,GAAG,IAAI,CAAC;KAC9B,CAAC;IAEF,kCAAkC;IAClC,kBAAkB,CAAC,SAAS,EAAE,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC;IAErD,sCAAsC;IACtC,sBAAsB,CAAC,SAAS,EAAE,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC;IAEzD,kCAAkC;IAClC,YAAY,CAAC,SAAS,EAAE,MAAM,EAAE,MAAM,CAAC,EAAE,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC;IAEhE,sBAAsB;IACtB,YAAY,CAAC,SAAS,EAAE,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC;IAE/C,yBAAyB;IACzB,gBAAgB,CACd,SAAS,EAAE,MAAM,EACjB,SAAS,EAAE,MAAM,EACjB,MAAM,EAAE,wBAAwB,GAC/B,OAAO,CAAC,IAAI,CAAC,CAAC;IAEjB,2BAA2B;IAC3B,gBAAgB,CAAC,SAAS,EAAE,MAAM,EAAE,OAAO,EAAE,MAAM,EAAE,KAAK,EAAE,YAAY,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC;IAEzF,6BAA6B;IAC7B,kBAAkB,CAAC,SAAS,EAAE,MAAM,EAAE,OAAO,EAAE,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC;IAEtE,iDAAiD;IACjD,OAAO,CAAC,OAAO,EAAE,qBAAqB,GAAG,MAAM,IAAI,CAAC;IAEpD,oCAAoC;IACpC,aAAa,CAAC,OAAO,EAAE,CAAC,KAAK,EAAE,cAAc,KAAK,IAAI,GAAG,MAAM,IAAI,CAAC;CACrE;AAMD,MAAM,WAAW,eAAe;IAC9B,8BAA8B;IAC9B,OAAO,EAAE,MAAM,CAAC;IAEhB,2BAA2B;IAC3B,KAAK,CAAC,EAAE,MAAM,CAAC;IAEf,qBAAqB;IACrB,OAAO,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,MAAM,CAAC,CAAC;IAEjC,4BAA4B;IAC5B,OAAO,CAAC,EAAE,MAAM,CAAC;IAEjB,qCAAqC;IACrC,eAAe,CAAC,EAAE,OAAO,CAAC;CAC3B"} | ||
| {"version":3,"file":"transport.d.ts","sourceRoot":"","sources":["../src/transport.ts"],"names":[],"mappings":"AAAA;;;;;;GAMG;AAEH,YAAY,EACV,eAAe,EACf,eAAe,EACf,cAAc,EACd,kBAAkB,EAClB,qBAAqB,GACtB,MAAM,kBAAkB,CAAC"} |
| /** | ||
| * Client Transport Interface | ||
| * | ||
| * Abstracts the connection layer (SSE/HTTP vs WebSocket) from client business logic. | ||
| * Re-exports from @agentick/shared where the canonical definitions live. | ||
| * | ||
| * @module @agentick/client/transport | ||
| */ | ||
| //# sourceMappingURL=transport.js.map |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"transport.js","sourceRoot":"","sources":["../src/transport.ts"],"names":[],"mappings":"AAAA;;;;GAIG"} | ||
| {"version":3,"file":"transport.js","sourceRoot":"","sources":["../src/transport.ts"],"names":[],"mappings":"AAAA;;;;;;GAMG"} |
+3
-3
| { | ||
| "name": "@agentick/client", | ||
| "version": "0.2.1", | ||
| "version": "0.4.0", | ||
| "description": "Client SDK for Agentick - multiplexed sessions over SSE", | ||
@@ -13,3 +13,3 @@ "keywords": [ | ||
| ], | ||
| "license": "ISC", | ||
| "license": "MIT", | ||
| "author": "Ryan Lindgren", | ||
@@ -36,3 +36,3 @@ "repository": { | ||
| "dependencies": { | ||
| "@agentick/shared": "0.2.1" | ||
| "@agentick/shared": "0.4.0" | ||
| }, | ||
@@ -39,0 +39,0 @@ "devDependencies": { |
Mixed license
LicensePackage contains multiple licenses.
Found 1 instance in 1 package
0
-100%198004
-1.99%3016
-1.89%+ Added
- Removed
Updated