cadrumo.application.operations._projection_read module¶

Read-only operation projection resolution stages.

async load_refresh_context(reader, request)¶

Read and validate the exact successful terminal snapshot requested.

Return type:

_RefreshContext | OperationWorkspaceRefreshTargetRefusalV1

Parameters:

reader (OperationObservationReader)
request (OperationWorkspaceRefreshTargetRequestV1)

async load_result_context(reader, request)¶

Read and validate the exact terminal snapshot named by the request.

Return type:

_ResultContext | OperationResultProjectionRefusalV1

Parameters:

reader (OperationObservationReader)
request (OperationResultProjectionRequestV1)

async load_review_context(reader, reference, clock)¶

Read and validate the exact live REVIEW checkpoint for a reference.

Return type:

_ReviewContext | OperationReviewProjectionRefusalV1

Parameters:

reader (OperationObservationReader)
reference (OperationReviewProjectionReferenceV1)
clock (Callable[[], datetime])

lookup_refresh_registration(registry, context)¶

Bind terminal facts to the exact refresh adapter and schema contract.

Return type:

_RefreshRegistration | OperationWorkspaceRefreshTargetRefusalV1

Parameters:

registry (OperationRegistry)
context (_RefreshContext)

lookup_result_registration(registry, context)¶

Bind terminal facts to the exact projector and public schema contract.

Return type:

_ResultRegistration | OperationResultProjectionRefusalV1

Parameters:

registry (OperationRegistry)
context (_ResultContext)

lookup_review_registration(registry, context)¶

Bind the checkpoint to the exact public contract and schema identities.

Return type:

_ReviewRegistration | OperationReviewProjectionRefusalV1

Parameters:

registry (OperationRegistry)
context (_ReviewContext)

refresh_request_or_refusal(request)¶

Validate the refresh-target request envelope before reading state.

Return type:: OperationWorkspaceRefreshTargetRequestV1 | OperationWorkspaceRefreshTargetRefusalV1
Parameters:: request (OperationWorkspaceRefreshTargetVersionHeader | OperationWorkspaceRefreshTargetRequestV1)

async resolve_refresh_target(registry, bound)¶

Resolve, adapt, and strictly validate one registered refresh target.

Return type:

GenericAlias[TypeVar(RefreshTargetT, bound= BaseModel)]

Parameters:

registry (OperationRegistry)
bound (_RefreshRegistration)

async resolve_result_projection(registry, operands, bound, digest)¶

Resolve, project, and strictly validate one registered result model.

Return type:

GenericAlias[TypeVar(ResultProjectionT, bound= BaseModel)]

Parameters:

registry (OperationRegistry)
operands (OperationSecureReferenceStore)
bound (_ResultRegistration)
digest (ContentDigest)

async resolve_review_projection(registry, operands, bound)¶

Resolve, project, and strictly validate one registered REVIEW model.

Return type:

GenericAlias[TypeVar(ReviewProjectionT, bound= BaseModel)]

Parameters:

registry (OperationRegistry)
operands (OperationSecureReferenceStore)
bound (_ReviewRegistration)

result_digest_or_refusal(context)¶

Validate the persisted result reference as the canonical digest type.

Return type:: TypeAliasType | OperationResultProjectionRefusalV1
Parameters:: context (_ResultContext)

result_request_or_refusal(request)¶

Validate the result-projection request envelope before reading state.

Return type:: OperationResultProjectionRequestV1 | OperationResultProjectionRefusalV1
Parameters:: request (OperationResultProjectionVersionHeader | OperationResultProjectionRequestV1)

review_request_or_refusal(request)¶

Validate the versioned request envelope before reading durable state.

Return type:: OperationReviewProjectionReferenceV1 | OperationReviewProjectionRefusalV1
Parameters:: request (OperationReviewProjectionVersionHeader | OperationReviewProjectionRequestV1)