Class SqliteSessionStore

packages/storage/src/session-store.ts:366–926

}

class SqliteSessionStore implements SessionAuthorityStore {
  private readonly metadata: SqliteSessionMetadataStore;
  private readonly workspaceRoot: string;
  private readonly transcriptChangeListeners = new Set<(sessionId: string) => void>();
  private closePromise: Promise<void> | null = null;

  constructor(workspaceRoot: string) {
    this.workspaceRoot = workspaceRoot;
    const databaseLease = acquireOperationalStateDatabase(workspaceRoot);
    this.metadata = createSqliteSessionMetadataStore(
      join(workspaceRoot, OPERATIONAL_STATE_DATABASE_NAME),
      { databaseLease },
    );
  }

  private ensureReady(): Promise<void> {
    return Promise.resolve();
  }

  ready(): Promise<void> {
    return this.ensureReady();
  }

  async create(
    input: CreateSessionInput,
    initialBoundary?: ExecutionBoundary,
  ): Promise<SessionHeader> {
    await this.ensureReady();
    assertNoConversationCopyMetadata(input);
    if (input.subagentSpawn) {
      throw new Error('Subagent spawn metadata requires createSubagent()');
    }
    return (
      await this.metadata.create(buildSessionHeader(this.workspaceRoot, input), initialBoundary)
    ).header;
  }

  async createImportedSession(
    input: CreateSessionInput,
    messages: readonly StoredMessage[],
  ): Promise<SessionHeader> {
    await this.ensureReady();
    assertNoConversationCopyMetadata(input);
    if (input.subagentSpawn) {
      throw new Error('Subagent spawn metadata requires createSubagent()');
    }
    const canonicalMessages = messages.map((message) =>
      decodeStoredMessage(JSON.parse(JSON.stringify(message)) as unknown),
    );
    const header: SessionHeader = {
      ...buildSessionHeader(this.workspaceRoot, input),
      transcriptLedgerVersion: 0,
    };
    const outcome = await this.metadata.importSession(
      header,
      canonicalMessages,
      projectSessionCatalogMessages(canonicalMessages),
    );