Function openRepos

packages/storage/src/usage-stores.ts:285–306

(
  root: string,
  createIfMissing: boolean,
)

}

async function openRepos(
  root: string,
  createIfMissing: boolean,
): Promise<{ telemetry: TelemetryRepo; modelCalls: ModelCallLedger; pricing: PricingStore }> {
  const telemetry = createSqliteTelemetryRepo(root, { createIfMissing, managePricing: false });
  await telemetry.load();
  const modelCalls = createSqliteModelCallLedger(root);
  const pricing = createSqlitePricingStore(root, { createIfMissing });
  try {
    await pricing.load();
    return { telemetry, modelCalls, pricing };
  } catch (error) {
    const closed = await Promise.allSettled([
      telemetry.close(),
      modelCalls.close(),
      pricing.close(),
    ]);
    const failures = [error, ...rejectedReasons(closed)];
    throwDeduplicatedFailures('Unable to open interactive usage stores', failures);
    throw error;
  }
}

function createWriterFacade(
  lease: StorageRootLease<'interactive', 'write'>,