import { z } from 'zod'; import { EventEmitter } from 'node:events'; import { Socket } from 'socket.io-client'; import { ExpoPushMessage } from 'expo-server-sdk'; /** * Simplified schema that only validates fields actually used in the codebase * while preserving all other fields through passthrough() */ declare const UsageSchema: z.ZodObject<{ input_tokens: z.ZodNumber; cache_creation_input_tokens: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, "passthrough", z.ZodTypeAny, z.objectOutputType<{ input_tokens: z.ZodNumber; cache_creation_input_tokens: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, z.ZodTypeAny, "passthrough">, z.objectInputType<{ input_tokens: z.ZodNumber; cache_creation_input_tokens: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, z.ZodTypeAny, "passthrough">>; declare const RawJSONLinesSchema: z.ZodDiscriminatedUnion<"type", [z.ZodObject<{ type: z.ZodLiteral<"user">; isSidechain: z.ZodOptional; isMeta: z.ZodOptional; uuid: z.ZodString; message: z.ZodObject<{ content: z.ZodUnion<[z.ZodString, z.ZodAny]>; }, "passthrough", z.ZodTypeAny, z.objectOutputType<{ content: z.ZodUnion<[z.ZodString, z.ZodAny]>; }, z.ZodTypeAny, "passthrough">, z.objectInputType<{ content: z.ZodUnion<[z.ZodString, z.ZodAny]>; }, z.ZodTypeAny, "passthrough">>; }, "passthrough", z.ZodTypeAny, z.objectOutputType<{ type: z.ZodLiteral<"user">; isSidechain: z.ZodOptional; isMeta: z.ZodOptional; uuid: z.ZodString; message: z.ZodObject<{ content: z.ZodUnion<[z.ZodString, z.ZodAny]>; }, "passthrough", z.ZodTypeAny, z.objectOutputType<{ content: z.ZodUnion<[z.ZodString, z.ZodAny]>; }, z.ZodTypeAny, "passthrough">, z.objectInputType<{ content: z.ZodUnion<[z.ZodString, z.ZodAny]>; }, z.ZodTypeAny, "passthrough">>; }, z.ZodTypeAny, "passthrough">, z.objectInputType<{ type: z.ZodLiteral<"user">; isSidechain: z.ZodOptional; isMeta: z.ZodOptional; uuid: z.ZodString; message: z.ZodObject<{ content: z.ZodUnion<[z.ZodString, z.ZodAny]>; }, "passthrough", z.ZodTypeAny, z.objectOutputType<{ content: z.ZodUnion<[z.ZodString, z.ZodAny]>; }, z.ZodTypeAny, "passthrough">, z.objectInputType<{ content: z.ZodUnion<[z.ZodString, z.ZodAny]>; }, z.ZodTypeAny, "passthrough">>; }, z.ZodTypeAny, "passthrough">>, z.ZodObject<{ uuid: z.ZodString; type: z.ZodLiteral<"assistant">; message: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, "passthrough", z.ZodTypeAny, z.objectOutputType<{ input_tokens: z.ZodNumber; cache_creation_input_tokens: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, z.ZodTypeAny, "passthrough">, z.objectInputType<{ input_tokens: z.ZodNumber; cache_creation_input_tokens: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, z.ZodTypeAny, "passthrough">>>; model: z.ZodOptional; }, "passthrough", z.ZodTypeAny, z.objectOutputType<{ usage: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, "passthrough", z.ZodTypeAny, z.objectOutputType<{ input_tokens: z.ZodNumber; cache_creation_input_tokens: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, z.ZodTypeAny, "passthrough">, z.objectInputType<{ input_tokens: z.ZodNumber; cache_creation_input_tokens: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, z.ZodTypeAny, "passthrough">>>; model: z.ZodOptional; }, z.ZodTypeAny, "passthrough">, z.objectInputType<{ usage: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, "passthrough", z.ZodTypeAny, z.objectOutputType<{ input_tokens: z.ZodNumber; cache_creation_input_tokens: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, z.ZodTypeAny, "passthrough">, z.objectInputType<{ input_tokens: z.ZodNumber; cache_creation_input_tokens: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, z.ZodTypeAny, "passthrough">>>; model: z.ZodOptional; }, z.ZodTypeAny, "passthrough">>>; }, "passthrough", z.ZodTypeAny, z.objectOutputType<{ uuid: z.ZodString; type: z.ZodLiteral<"assistant">; message: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, "passthrough", z.ZodTypeAny, z.objectOutputType<{ input_tokens: z.ZodNumber; cache_creation_input_tokens: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, z.ZodTypeAny, "passthrough">, z.objectInputType<{ input_tokens: z.ZodNumber; cache_creation_input_tokens: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, z.ZodTypeAny, "passthrough">>>; model: z.ZodOptional; }, "passthrough", z.ZodTypeAny, z.objectOutputType<{ usage: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, "passthrough", z.ZodTypeAny, z.objectOutputType<{ input_tokens: z.ZodNumber; cache_creation_input_tokens: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, z.ZodTypeAny, "passthrough">, z.objectInputType<{ input_tokens: z.ZodNumber; cache_creation_input_tokens: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, z.ZodTypeAny, "passthrough">>>; model: z.ZodOptional; }, z.ZodTypeAny, "passthrough">, z.objectInputType<{ usage: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, "passthrough", z.ZodTypeAny, z.objectOutputType<{ input_tokens: z.ZodNumber; cache_creation_input_tokens: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, z.ZodTypeAny, "passthrough">, z.objectInputType<{ input_tokens: z.ZodNumber; cache_creation_input_tokens: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, z.ZodTypeAny, "passthrough">>>; model: z.ZodOptional; }, z.ZodTypeAny, "passthrough">>>; }, z.ZodTypeAny, "passthrough">, z.objectInputType<{ uuid: z.ZodString; type: z.ZodLiteral<"assistant">; message: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, "passthrough", z.ZodTypeAny, z.objectOutputType<{ input_tokens: z.ZodNumber; cache_creation_input_tokens: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, z.ZodTypeAny, "passthrough">, z.objectInputType<{ input_tokens: z.ZodNumber; cache_creation_input_tokens: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, z.ZodTypeAny, "passthrough">>>; model: z.ZodOptional; }, "passthrough", z.ZodTypeAny, z.objectOutputType<{ usage: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, "passthrough", z.ZodTypeAny, z.objectOutputType<{ input_tokens: z.ZodNumber; cache_creation_input_tokens: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, z.ZodTypeAny, "passthrough">, z.objectInputType<{ input_tokens: z.ZodNumber; cache_creation_input_tokens: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, z.ZodTypeAny, "passthrough">>>; model: z.ZodOptional; }, z.ZodTypeAny, "passthrough">, z.objectInputType<{ usage: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, "passthrough", z.ZodTypeAny, z.objectOutputType<{ input_tokens: z.ZodNumber; cache_creation_input_tokens: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, z.ZodTypeAny, "passthrough">, z.objectInputType<{ input_tokens: z.ZodNumber; cache_creation_input_tokens: z.ZodOptional; cache_read_input_tokens: z.ZodOptional; output_tokens: z.ZodNumber; service_tier: z.ZodOptional; }, z.ZodTypeAny, "passthrough">>>; model: z.ZodOptional; }, z.ZodTypeAny, "passthrough">>>; }, z.ZodTypeAny, "passthrough">>, z.ZodObject<{ type: z.ZodLiteral<"summary">; summary: z.ZodString; leafUuid: z.ZodString; }, "passthrough", z.ZodTypeAny, z.objectOutputType<{ type: z.ZodLiteral<"summary">; summary: z.ZodString; leafUuid: z.ZodString; }, z.ZodTypeAny, "passthrough">, z.objectInputType<{ type: z.ZodLiteral<"summary">; summary: z.ZodString; leafUuid: z.ZodString; }, z.ZodTypeAny, "passthrough">>, z.ZodObject<{ type: z.ZodLiteral<"system">; uuid: z.ZodString; }, "passthrough", z.ZodTypeAny, z.objectOutputType<{ type: z.ZodLiteral<"system">; uuid: z.ZodString; }, z.ZodTypeAny, "passthrough">, z.objectInputType<{ type: z.ZodLiteral<"system">; uuid: z.ZodString; }, z.ZodTypeAny, "passthrough">>]>; type RawJSONLines = z.infer; /** * Permission mode type - includes both Claude and Codex modes * Must match MessageMetaSchema.permissionMode enum values * * Claude modes: default, acceptEdits, bypassPermissions, plan * Codex modes: read-only, safe-yolo, yolo * * When calling Claude SDK, Codex modes are mapped at the SDK boundary: * - yolo → bypassPermissions * - safe-yolo → default * - read-only → default */ type PermissionMode = 'default' | 'acceptEdits' | 'bypassPermissions' | 'plan' | 'read-only' | 'safe-yolo' | 'yolo'; /** * Usage data type from Claude */ type Usage = z.infer; /** * Session information */ type Session = { id: string; seq: number; encryptionKey: Uint8Array; encryptionVariant: 'legacy' | 'dataKey'; metadata: Metadata; metadataVersion: number; agentState: AgentState | null; agentStateVersion: number; }; /** * Machine metadata - static information (rarely changes) */ declare const MachineMetadataSchema: z.ZodObject<{ host: z.ZodString; platform: z.ZodString; consortiumCliVersion: z.ZodString; homeDir: z.ZodString; consortiumHomeDir: z.ZodString; consortiumLibDir: z.ZodString; }, "strip", z.ZodTypeAny, { host: string; platform: string; consortiumCliVersion: string; homeDir: string; consortiumHomeDir: string; consortiumLibDir: string; }, { host: string; platform: string; consortiumCliVersion: string; homeDir: string; consortiumHomeDir: string; consortiumLibDir: string; }>; type MachineMetadata = z.infer; /** * Daemon state - dynamic runtime information (frequently updated) */ declare const DaemonStateSchema: z.ZodObject<{ status: z.ZodUnion<[z.ZodEnum<["running", "shutting-down"]>, z.ZodString]>; pid: z.ZodOptional; httpPort: z.ZodOptional; startedAt: z.ZodOptional; shutdownRequestedAt: z.ZodOptional; shutdownSource: z.ZodOptional, z.ZodString]>>; }, "strip", z.ZodTypeAny, { status: string; pid?: number | undefined; httpPort?: number | undefined; startedAt?: number | undefined; shutdownRequestedAt?: number | undefined; shutdownSource?: string | undefined; }, { status: string; pid?: number | undefined; httpPort?: number | undefined; startedAt?: number | undefined; shutdownRequestedAt?: number | undefined; shutdownSource?: string | undefined; }>; type DaemonState = z.infer; type Machine = { id: string; encryptionKey: Uint8Array; encryptionVariant: 'legacy' | 'dataKey'; metadata: MachineMetadata; metadataVersion: number; daemonState: DaemonState | null; daemonStateVersion: number; }; declare const UserMessageSchema: z.ZodObject<{ role: z.ZodLiteral<"user">; content: z.ZodObject<{ type: z.ZodLiteral<"text">; text: z.ZodString; }, "strip", z.ZodTypeAny, { type: "text"; text: string; }, { type: "text"; text: string; }>; localKey: z.ZodOptional; meta: z.ZodOptional; permissionMode: z.ZodOptional>; model: z.ZodOptional>; fallbackModel: z.ZodOptional>; customSystemPrompt: z.ZodOptional>; appendSystemPrompt: z.ZodOptional>; allowedTools: z.ZodOptional>>; disallowedTools: z.ZodOptional>>; }, "strip", z.ZodTypeAny, { model?: string | null | undefined; sentFrom?: string | undefined; permissionMode?: "default" | "acceptEdits" | "bypassPermissions" | "plan" | "read-only" | "safe-yolo" | "yolo" | undefined; fallbackModel?: string | null | undefined; customSystemPrompt?: string | null | undefined; appendSystemPrompt?: string | null | undefined; allowedTools?: string[] | null | undefined; disallowedTools?: string[] | null | undefined; }, { model?: string | null | undefined; sentFrom?: string | undefined; permissionMode?: "default" | "acceptEdits" | "bypassPermissions" | "plan" | "read-only" | "safe-yolo" | "yolo" | undefined; fallbackModel?: string | null | undefined; customSystemPrompt?: string | null | undefined; appendSystemPrompt?: string | null | undefined; allowedTools?: string[] | null | undefined; disallowedTools?: string[] | null | undefined; }>>; }, "strip", z.ZodTypeAny, { content: { type: "text"; text: string; }; role: "user"; localKey?: string | undefined; meta?: { model?: string | null | undefined; sentFrom?: string | undefined; permissionMode?: "default" | "acceptEdits" | "bypassPermissions" | "plan" | "read-only" | "safe-yolo" | "yolo" | undefined; fallbackModel?: string | null | undefined; customSystemPrompt?: string | null | undefined; appendSystemPrompt?: string | null | undefined; allowedTools?: string[] | null | undefined; disallowedTools?: string[] | null | undefined; } | undefined; }, { content: { type: "text"; text: string; }; role: "user"; localKey?: string | undefined; meta?: { model?: string | null | undefined; sentFrom?: string | undefined; permissionMode?: "default" | "acceptEdits" | "bypassPermissions" | "plan" | "read-only" | "safe-yolo" | "yolo" | undefined; fallbackModel?: string | null | undefined; customSystemPrompt?: string | null | undefined; appendSystemPrompt?: string | null | undefined; allowedTools?: string[] | null | undefined; disallowedTools?: string[] | null | undefined; } | undefined; }>; type UserMessage = z.infer; type Metadata = { path: string; host: string; version?: string; name?: string; os?: string; summary?: { text: string; updatedAt: number; }; machineId?: string; claudeSessionId?: string; tools?: string[]; slashCommands?: string[]; homeDir: string; consortiumHomeDir: string; consortiumLibDir: string; consortiumToolsDir: string; startedFromDaemon?: boolean; hostPid?: number; startedBy?: 'daemon' | 'terminal'; lifecycleState?: 'running' | 'archiveRequested' | 'archived' | string; lifecycleStateSince?: number; archivedBy?: string; archiveReason?: string; flavor?: string; }; type AgentState = { controlledByUser?: boolean | null | undefined; requests?: { [id: string]: { tool: string; arguments: any; createdAt: number; }; }; completedRequests?: { [id: string]: { tool: string; arguments: any; createdAt: number; completedAt: number; status: 'canceled' | 'denied' | 'approved'; reason?: string; mode?: PermissionMode; decision?: 'approved' | 'approved_for_session' | 'denied' | 'abort'; allowTools?: string[]; }; }; }; /** * Common RPC types and interfaces for both session and machine clients */ /** * Generic RPC handler function type * @template TRequest - The request data type * @template TResponse - The response data type */ type RpcHandler = (data: TRequest) => TResponse | Promise; /** * RPC request data from server */ interface RpcRequest { method: string; params: string; } /** * Configuration for RPC handler manager */ interface RpcHandlerConfig { scopePrefix: string; encryptionKey: Uint8Array; encryptionVariant: 'legacy' | 'dataKey'; logger?: (message: string, data?: any) => void; } /** * Generic RPC handler manager for session and machine clients * Manages RPC method registration, encryption/decryption, and handler execution */ declare class RpcHandlerManager { private handlers; private readonly scopePrefix; private readonly encryptionKey; private readonly encryptionVariant; private readonly logger; private socket; constructor(config: RpcHandlerConfig); /** * Register an RPC handler for a specific method * @param method - The method name (without prefix) * @param handler - The handler function */ registerHandler(method: string, handler: RpcHandler): void; /** * Handle an incoming RPC request * @param request - The RPC request data * @param callback - The response callback */ handleRequest(request: RpcRequest): Promise; onSocketConnect(socket: Socket): void; onSocketDisconnect(): void; /** * Get the number of registered handlers */ getHandlerCount(): number; /** * Check if a handler is registered * @param method - The method name (without prefix) */ hasHandler(method: string): boolean; /** * Clear all handlers */ clearHandlers(): void; /** * Get the prefixed method name * @param method - The method name */ private getPrefixedMethod; } /** * ACP (Agent Communication Protocol) message data types. * This is the unified format for all agent messages - CLI adapts each provider's format to ACP. */ type ACPMessageData = { type: 'message'; message: string; } | { type: 'reasoning'; message: string; } | { type: 'thinking'; text: string; } | { type: 'tool-call'; callId: string; name: string; input: unknown; id: string; } | { type: 'tool-result'; callId: string; output: unknown; id: string; isError?: boolean; } | { type: 'file-edit'; description: string; filePath: string; diff?: string; oldContent?: string; newContent?: string; id: string; } | { type: 'terminal-output'; data: string; callId: string; } | { type: 'task_started'; id: string; } | { type: 'task_complete'; id: string; } | { type: 'turn_aborted'; id: string; } | { type: 'permission-request'; permissionId: string; toolName: string; description: string; options?: unknown; } | { type: 'token_count'; [key: string]: unknown; }; declare class ApiSessionClient extends EventEmitter { private readonly token; readonly sessionId: string; private metadata; private metadataVersion; private agentState; private agentStateVersion; private socket; private pendingMessages; private pendingMessageCallback; readonly rpcHandlerManager: RpcHandlerManager; private agentStateLock; private metadataLock; private encryptionKey; private encryptionVariant; constructor(token: string, session: Session); onUserMessage(callback: (data: UserMessage) => void): void; /** * Send message to session * @param body - Message body (can be MessageContent or raw content for agent messages) */ sendClaudeSessionMessage(body: RawJSONLines): void; sendCodexMessage(body: any): void; /** * Send a generic agent message to the session using ACP (Agent Communication Protocol) format. * Works for any agent type (Gemini, Codex, Claude, etc.) - CLI normalizes to unified ACP format. * * @param provider - The agent provider sending the message (e.g., 'gemini', 'codex', 'claude') * @param body - The message payload (type: 'message' | 'reasoning' | 'tool-call' | 'tool-result') */ sendAgentMessage(provider: 'gemini' | 'codex' | 'claude' | 'opencode', body: ACPMessageData): void; sendSessionEvent(event: { type: 'switch'; mode: 'local' | 'remote'; } | { type: 'message'; message: string; } | { type: 'permission-mode-changed'; mode: 'default' | 'acceptEdits' | 'bypassPermissions' | 'plan'; } | { type: 'ready'; }, id?: string): void; /** * Send a ping message to keep the connection alive */ keepAlive(thinking: boolean, mode: 'local' | 'remote'): void; /** * Send session death message */ sendSessionDeath(): void; /** * Send usage data to the server */ sendUsageData(usage: Usage, model?: string): void; /** * Update session metadata * @param handler - Handler function that returns the updated metadata */ updateMetadata(handler: (metadata: Metadata) => Metadata): void; /** * Update session agent state * @param handler - Handler function that returns the updated agent state */ updateAgentState(handler: (metadata: AgentState) => AgentState): void; /** * Wait for socket buffer to flush */ flush(): Promise; close(): Promise; } interface SpawnSessionOptions { machineId?: string; directory: string; sessionId?: string; approvedNewDirectoryCreation?: boolean; agent?: 'claude' | 'codex' | 'gemini'; token?: string; environmentVariables?: { ANTHROPIC_BASE_URL?: string; ANTHROPIC_AUTH_TOKEN?: string; ANTHROPIC_MODEL?: string; TMUX_SESSION_NAME?: string; TMUX_TMPDIR?: string; }; } type SpawnSessionResult = { type: 'success'; sessionId: string; } | { type: 'requestToApproveDirectoryCreation'; directory: string; } | { type: 'error'; errorMessage: string; }; /** * WebSocket client for machine/daemon communication with Consortium server * Similar to ApiSessionClient but for machine-scoped connections */ type MachineRpcHandlers = { spawnSession: (options: SpawnSessionOptions) => Promise; stopSession: (sessionId: string) => boolean; requestShutdown: () => void; }; declare class ApiMachineClient { private token; private machine; private socket; private keepAliveInterval; private rpcHandlerManager; constructor(token: string, machine: Machine); setRPCHandlers({ spawnSession, stopSession, requestShutdown }: MachineRpcHandlers): void; /** * Update machine metadata * Currently unused, changes from the mobile client are more likely * for example to set a custom name. */ updateMachineMetadata(handler: (metadata: MachineMetadata | null) => MachineMetadata): Promise; /** * Update daemon state (runtime info) - similar to session updateAgentState * Simplified without lock - relies on backoff for retry */ updateDaemonState(handler: (state: DaemonState | null) => DaemonState): Promise; connect(): void; private startKeepAlive; private stopKeepAlive; shutdown(): void; } interface PushToken { id: string; token: string; createdAt: number; updatedAt: number; } declare class PushNotificationClient { private readonly token; private readonly baseUrl; private readonly expo; constructor(token: string, baseUrl?: string); /** * Fetch all push tokens for the authenticated user */ fetchPushTokens(): Promise; /** * Send push notification via Expo Push API with retry * @param messages - Array of push messages to send */ sendPushNotifications(messages: ExpoPushMessage[]): Promise; /** * Send a push notification to all registered devices for the user * @param title - Notification title * @param body - Notification body * @param data - Additional data to send with the notification */ sendToAllDevices(title: string, body: string, data?: Record): void; } /** * Minimal persistence functions for consortium CLI * * Handles settings and private key storage in ~/.consortium/ or local .consortium/ */ type Credentials = { token: string; encryption: { type: 'legacy'; secret: Uint8Array; } | { type: 'dataKey'; publicKey: Uint8Array; machineKey: Uint8Array; }; }; declare class ApiClient { static create(credential: Credentials): Promise; private readonly credential; private readonly pushClient; private constructor(); /** * Create a new session or load existing one with the given tag */ getOrCreateSession(opts: { tag: string; metadata: Metadata; state: AgentState | null; }): Promise; /** * Register or update machine with the server * Returns the current machine state from the server with decrypted metadata and daemonState */ getOrCreateMachine(opts: { machineId: string; metadata: MachineMetadata; daemonState?: DaemonState; }): Promise; sessionSyncClient(session: Session): ApiSessionClient; machineSyncClient(machine: Machine): ApiMachineClient; push(): PushNotificationClient; /** * Register a vendor API token with the server * The token is sent as a JSON string - server handles encryption */ registerVendorToken(vendor: 'openai' | 'anthropic' | 'gemini', apiKey: any): Promise; /** * Get vendor API token from the server * Returns the token if it exists, null otherwise */ getVendorToken(vendor: 'openai' | 'anthropic' | 'gemini'): Promise; } /** * Design decisions: * - Logging should be done only through file for debugging, otherwise we might disturb the claude session when in interactive mode * - Use info for logs that are useful to the user - this is our UI * - File output location: ~/.consortium/logs/.log */ declare class Logger { readonly logFilePath: string; private dangerouslyUnencryptedServerLoggingUrl; constructor(logFilePath?: string); localTimezoneTimestamp(): string; debug(message: string, ...args: unknown[]): void; debugLargeJson(message: string, object: unknown, maxStringLength?: number, maxArrayLength?: number): void; info(message: string, ...args: unknown[]): void; infoDeveloper(message: string, ...args: unknown[]): void; warn(message: string, ...args: unknown[]): void; getLogPath(): string; private logToConsole; private sendToRemoteServer; private logToFile; } declare let logger: Logger; /** * Global configuration for consortium CLI * * Centralizes all configuration including environment variables and paths * Environment files should be loaded using Node's --env-file flag */ declare class Configuration { readonly serverUrl: string; readonly webappUrl: string; readonly isDaemonProcess: boolean; readonly consortiumHomeDir: string; readonly logsDir: string; readonly settingsFile: string; readonly privateKeyFile: string; readonly daemonStateFile: string; readonly daemonLockFile: string; readonly currentCliVersion: string; readonly isExperimentalEnabled: boolean; readonly disableCaffeinate: boolean; constructor(); } declare const configuration: Configuration; export { ApiClient, ApiSessionClient, RawJSONLinesSchema, configuration, logger }; export type { RawJSONLines };