(message: string, ...args: unknown[])

(message: string, mode: T)

(params: { userId: string; eventName: 'update' | 'ephemeral'; payload: any; re

(src: any, ...args: any[])

(buffer: Uint8Array, variant: 'base64' | 'base64url' = 'base64')

(error: Error)

(base64: string, variant: 'base64' | 'base64url' = 'base64')

(key: Uint8Array, variant: 'legacy' | 'dataKey', data: Uint8Array)

(accountId: string)

(params: { userId: string; payload: UpdatePayload; recipientFilter?: RecipientFilter;

(key: Uint8Array, variant: 'legacy' | 'dataKey', data: any)

(length: number = 24)

(value: T)

(data: Uint8Array)

(str: string)

(params: { userId: string; payload: EphemeralPayload; recipientFilter?: RecipientFilte

(size: number)

()

(event: { type: 'switch', mode: 'local' | 'remote' } | { type: 'message', message: string

()

()

(credential: Credentials)

( key: Uint8Array, variant: 'legacy' | 'dataKey', data: Uint8Array, )

()

(size: number)

(thinking: boolean, mode: 'local' | 'remote')

(error: Error)

(handler: (metadata: Metadata) => Metadata)

(newThinking: boolean)

(token: string)

(machineId: string, active: boolean, activeAt: number)

(machineId: string, updateSeq: number, updateId: string, metadata?: { value: string; version: number }, daemon

(buffer: Uint8Array)

(level: 'debug' | 'error' | 'info' | 'warn', prefix: string, message: string, ...args: unknown[])

(value: T)

( method: string, handler: RpcHandler<TRequest, TResponse> )

(reason?: any)

( stored: StoredCredentials, )

()

(message: string, ...args: unknown[])

()

( serverUrl: string, existingSecret?: Uint8Array, )

(sessionId: string, active: boolean, activeAt: number, thinking?: boolean)

(sessionId: string, updateSeq: number, updateId: string, metadata?: { value: string; version: number }, agentS

()

()

()

( token: string, callbacks: SocketCallbacks, scope: | { type: 'user-scoped' } | { type: 'session

(userId: string, extras?: any)

(ms: number)

( key: Uint8Array, variant: 'legacy' | 'dataKey', data: unknown, )

( credentials: Credentials, )

()

(dataKey: Uint8Array)

()

()

(method: string)

()

(func: () => Promise<T> | T)

(message: string, ...args: unknown[])

()

(prefix: string, message: string, ...args: unknown[])

()

()

(handler: (metadata: AgentState) => AgentState)

(token: string)

(userId: string, connection: ClientConnection)

(tx: Tx, callback: () => void)

(sessionId: string)

()

(secret: Uint8Array)

(secret: Uint8Array)

(app: Fastify)

(sessionId: string, updateSeq: number, updateId: string)

(machine: { id: string; seq: number; metadata: string; metadataVersion: number; daemonStat

(message: { id: string; seq: number; content: any; localId: string | null; createdAt: Date

(session: { id: string; seq: number; metadata: string; metadataVersion: number; agentState

(opts: { sessionId: string | null, path: string, mcpServers?: Record<string, any>, claudeEnvVa

(session: Session)

()

()

( opts?: { onError?: (e: any, failuresCount: number) => void, minDelay?: number, m

(date: Date = new Date())

(date: Date = new Date())

( bundle: Uint8Array, recipientSecretKey: Uint8Array, )

( data: Uint8Array, secret: Uint8Array, )

(data: Uint8Array, secret: Uint8Array)

( event: Extract<UpdateEvent, { type: 'new-message' }>, session: DecryptedSession, )

( bundle: Uint8Array, dataKey: Uint8Array, )

(bundle: Uint8Array, dataKey: Uint8Array)

(encryptedBundle: Uint8Array, recipientSecretKey: Uint8Array)

( credentials: Credentials, sessionId: string, )

(obj: any)

(url: string)

()

()

(app: Fastify)

(data: unknown, secret: Uint8Array)