Function openInteractiveUsageStoresForWrite

packages/storage/src/usage-stores.ts:263–283

(
  lease: StorageRootLease<'interactive', 'write'>,
)

}

export async function openInteractiveUsageStoresForWrite(
  lease: StorageRootLease<'interactive', 'write'>,
): Promise<InteractiveUsageStoresWriter> {
  const existing = writerByLease.get(lease);
  if (existing) return existing;
  const opening = writerOpeningByLease.get(lease);
  if (opening) return opening;
  const pending = runWithStorageRootLease(lease, 'interactive', 'write', async (root) => {
    const repos = await openRepos(root, true);
    const stores = createWriterFacade(lease, repos.telemetry, repos.modelCalls, repos.pricing);
    writers.add(stores);
    writerByLease.set(lease, stores);
    return stores;
  });
  writerOpeningByLease.set(lease, pending);
  try {
    return await pending;
  } finally {
    if (writerOpeningByLease.get(lease) === pending) writerOpeningByLease.delete(lease);
  }
}

async function openRepos(
  root: string,