import type { AgentHistoryRecord } from "@/types"; import { AgentsRepository } from "./agentsRepository.js"; import { ChannelMessagesRepository } from "./channelMessagesRepository.js"; import { ChannelsRepository } from "./channelsRepository.js"; import { ConnectionsRepository } from "./connectionsRepository.js"; import { CronTasksRepository } from "./cronTasksRepository.js"; import { databaseOpen } from "./databaseOpen.js"; import type { CreateAgentInput, CreateUserInput, UserWithConnectorKeysDbRecord } from "./databaseTypes.js"; import { DelayedSignalsRepository } from "./delayedSignalsRepository.js"; import { ExposeEndpointsRepository } from "./exposeEndpointsRepository.js"; import { HeartbeatTasksRepository } from "./heartbeatTasksRepository.js"; import { HistoryRepository } from "./historyRepository.js"; import { InboxRepository } from "./inboxRepository.js"; import { ProcessesRepository } from "./processesRepository.js"; import { SessionsRepository } from "./sessionsRepository.js"; import { SignalEventsRepository } from "./signalEventsRepository.js"; import { SignalSubscriptionsRepository } from "./signalSubscriptionsRepository.js"; import { UsersRepository } from "./usersRepository.js"; /** * Facade for all SQLite access. Owns one connection and repository instances. * Expects: dbPath points to a writable sqlite file or ":memory:". */ export declare class Storage { readonly users: UsersRepository; readonly agents: AgentsRepository; readonly sessions: SessionsRepository; readonly history: HistoryRepository; readonly inbox: InboxRepository; readonly cronTasks: CronTasksRepository; readonly heartbeatTasks: HeartbeatTasksRepository; readonly signalEvents: SignalEventsRepository; readonly signalSubscriptions: SignalSubscriptionsRepository; readonly delayedSignals: DelayedSignalsRepository; readonly channels: ChannelsRepository; readonly channelMessages: ChannelMessagesRepository; readonly connections: ConnectionsRepository; readonly exposeEndpoints: ExposeEndpointsRepository; readonly processes: ProcessesRepository; private readonly connection; private readonly connectorKeyLocks; private constructor(); static open(dbPath: string): Storage; get db(): ReturnType; close(): void; createUser(input: CreateUserInput): Promise; resolveUserByConnectorKey(connectorKey: string): Promise; createAgentWithSession(input: CreateAgentInput): Promise<{ agent: CreateAgentInput["record"]; sessionId: string; }>; appendHistory(agentId: string, record: AgentHistoryRecord): Promise; private connectorKeyLockFor; private userCreateWithGeneratedNametag; } //# sourceMappingURL=storage.d.ts.map