Class D1ResourceOwnershipStore

Implements

RecoverableResourceOwnershipStore

Index

Constructors

Methods

claim owner release reserveAll settleReservation

Constructors

constructor

new D1ResourceOwnershipStore(
db: ResourceOwnershipDatabase,
options?: { ready?: () => Promise<void> },
): D1ResourceOwnershipStore
Parameters
- db: ResourceOwnershipDatabase
- options: { ready?: () => Promise<void> } = {}
Returns D1ResourceOwnershipStore
- Defined in packages/flowsafe/src/approval-api/resource-ownership.ts:189

Methods

claim

claim(
    kind: "run" | "thread" | "resource" | "schedule",
    resourceId: string,
    owner: ResourceOwner,
): Promise<boolean>
Claim an available id; returns false for pending or foreign-owned ids.
Parameters
- kind: "run" | "thread" | "resource" | "schedule"
- resourceId: string
- owner: ResourceOwner
Returns Promise<boolean>
Implementation of RecoverableResourceOwnershipStore.claim
- Defined in packages/flowsafe/src/approval-api/resource-ownership.ts:208

owner

owner(
kind: "run" | "thread" | "resource" | "schedule",
resourceId: string,
): Promise<ResourceOwner | undefined>
Parameters
- kind: "run" | "thread" | "resource" | "schedule"
- resourceId: string
Returns Promise<ResourceOwner | undefined>
Implementation of RecoverableResourceOwnershipStore.owner
- Defined in packages/flowsafe/src/approval-api/resource-ownership.ts:324

release

release(
    kind: "run" | "thread" | "resource" | "schedule",
    resourceId: string,
    owner: ResourceOwner,
): Promise<boolean>
Release a committed id only when it is still owned by the expected principal.
Parameters
- kind: "run" | "thread" | "resource" | "schedule"
- resourceId: string
- owner: ResourceOwner
Returns Promise<boolean>
Implementation of RecoverableResourceOwnershipStore.release
- Defined in packages/flowsafe/src/approval-api/resource-ownership.ts:342

reserveAll

reserveAll(
    claims: readonly ResourceClaim[],
    owner: ResourceOwner,
    token: string,
): Promise<boolean>
Reserve every id under one recoverable target-side attempt token.
Parameters
- claims: readonly ResourceClaim[]
- owner: ResourceOwner
- token: string
Returns Promise<boolean>
Implementation of RecoverableResourceOwnershipStore.reserveAll
- Defined in packages/flowsafe/src/approval-api/resource-ownership.ts:229

settleReservation

settleReservation(
token: string,
release: readonly ResourceClaim[],
): Promise<void>
Delete selected token-created claims and commit every retained claim.
Parameters
- token: string
- release: readonly ResourceClaim[]
Returns Promise<void>
Implementation of RecoverableResourceOwnershipStore.settleReservation
- Defined in packages/flowsafe/src/approval-api/resource-ownership.ts:287