Class SqliteRuntimeStore

packages/storage/src/sqlite-runtime-store.ts:231–2930

}

export class SqliteRuntimeStore
  implements
    RuntimeRecoveryBundleStore,
    RuntimeContinuationAuthorityStore,
    RuntimeWorkspaceVersionAuthorityStore
{
  readonly durability = 'canonical' as const;
  readonly toolBoundaryProtocol = 't1_after_preflight_v1' as const;
  readonly recoveryBundleCapability = TOOL_RECOVERY_BUNDLE_CAPABILITY_V1;
  readonly continuationAuthorityCapability = RUNTIME_CONTINUATION_AUTHORITY_V1;
  readonly workspaceVersionAuthorityCapability = WORKSPACE_VERSION_AUTHORITY_CAPABILITY_V1;
  private readonly db: DatabaseSync;
  private readonly databaseLease?: OperationalStateDatabaseLease;
  private toolLedgerHealth: ToolLedgerHealth | undefined;
  private closed = false;

  constructor(
    path: string,
    private readonly options: SqliteRuntimeStoreOptions = {},
  ) {
    if (options.readOnly && options.databaseLease) {
      throw new Error('Operational state database leases cannot be opened read-only');
    }
    if (path !== ':memory:' && !options.readOnly) mkdirSync(dirname(path), { recursive: true });
    if (options.databaseLease) {
      this.databaseLease = options.databaseLease;
      this.db = options.databaseLease.database;
      assertRecoveryAuthorityCapability(this.db);
      assertContinuationAuthorityCapability(this.db);
      assertWorkspaceVersionAuthorityCapability(this.db);
      if (!options.readOnly) {
        this.registerWorkspaceBaselineAuthorityWriter(options.databaseLease.databasePath);
        this.refreshToolLedgerHealth();
      }
      return;
    }
    const DatabaseSync = loadDatabaseSync();
    this.db = options.readOnly
      ? new DatabaseSync(path, { readOnly: true })
      : new DatabaseSync(path);
    try {
      if (options.readOnly) {
        configureSqliteRuntimeReadOnlyDatabase(this.db);
        const version = readUserVersion(this.db);
        if (version !== SQLITE_RUNTIME_SCHEMA_VERSION) {
          throw new Error(
            `SQLite runtime schema ${version} cannot be read without upgrading to ${SQLITE_RUNTIME_SCHEMA_VERSION}`,
          );
        }
      } else {
        configureSqliteRuntimeDatabase(this.db);
        migrateSqliteRuntimeDatabase(this.db);
      }
      assertRecoveryAuthorityCapability(this.db);
      assertContinuationAuthorityCapability(this.db);
      assertWorkspaceVersionAuthorityCapability(this.db);
      if (!options.readOnly) {
        this.registerWorkspaceBaselineAuthorityWriter(path);