Function bindStateRootComposition

packages/storage/src/state-root-composition.ts:35–66

(
  lease: StorageRootLease<K, 'write'>,
  compositionId: string,
)

}

export async function bindStateRootComposition<K extends StorageRootKind>(
  lease: StorageRootLease<K, 'write'>,
  compositionId: string,
): Promise<void> {
  requireCompositionId(compositionId);
  const assertCurrentRoot = createStorageRootLeaseIdentityGuard(lease, lease.kind, 'write');
  await runWithStorageRootLease(lease, lease.kind, 'write', async (root) => {
    const existing = await readStateRootCompositionIfPresent(root);
    if (existing) {
      assertMatchingComposition(existing, compositionId);
      return;
    }
    const record: StateRootCompositionRecord = {
      schemaVersion: STATE_ROOT_COMPOSITION_SCHEMA_VERSION,
      compositionId,
    };
    const publication = await withCompositionIoFailure(() =>
      publishMarkerFile({
        root,
        markerFile: STATE_ROOT_COMPOSITION_FILE,
        contents: `${JSON.stringify(record)}\n`,
        maxBytes: MAX_STATE_ROOT_COMPOSITION_BYTES,
        publication: 'create',
        beforePublish: assertCurrentRoot,
        invalidFile,
      }),
    );
    if (publication === 'published') return;
    const winner = await readStateRootComposition(root);
    assertMatchingComposition(winner, compositionId);
  });
}

export async function readStateRootCompositionBinding(
  root: string,