Function openOwnedLocalDatabase

apps/local/src/db/owned-database.ts:34–92

(
  input: OpenOwnedLocalDatabaseOptions<TTables>,
)

}

export const openOwnedLocalDatabase = async <const TTables extends FumaTables>(
  input: OpenOwnedLocalDatabaseOptions<TTables>,
): Promise<OwnedLocalDatabase<TTables>> => {
  const ownership = await acquireDataDirOwnership(input.dataDir);
  let db: SqliteFumaDb<TTables> | null = null;

  try {
    // Use the real directory captured by the ownership primitive so a symlinked
    // input path cannot be repointed between lock acquisition and data.db open.
    const dataDir = dirname(ownership.lockPath);
    const sqlitePath = join(dataDir, "data.db");

    const migration = await migrateLocalV1ToV2IfNeeded({
      sqlitePath,
      tables: input.tables,
      namespace: input.namespace,
      tenantId: input.tenantId,
      ...(input.oauthMetadataFetch !== undefined
        ? { oauthMetadataFetch: input.oauthMetadataFetch }
        : {}),
      ...(input.oauthMetadataTimeoutMs !== undefined
        ? { oauthMetadataTimeoutMs: input.oauthMetadataTimeoutMs }
        : {}),
    });

    const openedDb = await createSqliteFumaDb({
      tables: input.tables,
      namespace: input.namespace,
      path: sqlitePath,
      ...(input.version !== undefined ? { version: input.version } : {}),
    });
    db = openedDb;

    let closed = false;
    return {
      dataDir,
      sqlitePath,
      lockPath: ownership.lockPath,
      db: openedDb,
      migration,
      close: async () => {
        if (closed) return;
        closed = true;
        try {
          await openedDb.close();
        } finally {
          await ownership.release();
        }
      },
    };
  } catch (cause) {
    try {
      if (db) await db.close();
    } finally {
      await ownership.release();
    }
    throw cause;
  }