Class SqliteTaskLedgerStoreImpl

packages/storage/src/task-ledger-store.ts:65–647

}

class SqliteTaskLedgerStoreImpl implements SqliteTaskLedgerStore {
  readonly #lease: OperationalStateDatabaseLease;
  private readonly writeQueues = new Map<string, Promise<void>>();
  private readonly listeners = new Set<(event: TaskLedgerChangedEvent) => void>();

  constructor(workspaceRoot: string) {
    this.#lease = acquireOperationalStateDatabase(resolve(workspaceRoot));
    registerTaskLedgerCanonicalReader(this, {
      list: (sessionId, options) => this.#listCanonical(sessionId, options),
      get: (sessionId, id, options) => this.#getCanonical(sessionId, id, options),
    });
  }

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

  close(): void {
    this.#lease.close();
  }

  async list(sessionId: string, options: TaskLedgerListOptions = {}): Promise<Task[]> {
    assertSafeSessionId(sessionId);
    return this.applyListOptions(await this.readForRender(sessionId), options);
  }

  async get(
    sessionId: string,
    id: string,
    options: TaskLedgerListOptions = {},
  ): Promise<Task | undefined> {
    assertSafeSessionId(sessionId);
    if (!isSafeTaskId(id))
      throw new Error('Task id must be a stable token (alphanumeric plus . _ : -, max 64 chars)');
    const tasks = await this.list(sessionId, options);
    return findTaskByRef(tasks, id);
  }

  async #listCanonical(sessionId: string, options: TaskLedgerListOptions = {}): Promise<Task[]> {
    assertSafeSessionId(sessionId);
    const { tasks } = await this.readForMutateWithSource(sessionId);
    return this.applyListOptions(tasks, options);
  }

  async #getCanonical(
    sessionId: string,
    id: string,
    options: TaskLedgerListOptions = {},
  ): Promise<Task | undefined> {
    assertSafeSessionId(sessionId);
    if (!isSafeTaskId(id))
      throw new Error('Task id must be a stable token (alphanumeric plus . _ : -, max 64 chars)');
    return findTaskByRef(await this.#listCanonical(sessionId, options), id);
  }

  subscribe(listener: (event: TaskLedgerChangedEvent) => void): () => void {
    this.listeners.add(listener);
    return () => this.listeners.delete(listener);