Struct UncertainRecovery 

struct UncertainRecovery {
    recoveries: Vec<Recovery>,
}

Looks for the attainment a submission we lost track of would have produced. The row stays submission_uncertain unless it is found: never failed, never re-imported.

Fields

recoveries: Vec<Recovery>

Trait Implementations

impl SuotarBatchPhase for UncertainRecovery

async fn prepare( &mut self, _ctx: &PhaseContext<'_>, conn: &mut PgConnection, _scope: &PhaseScope, ) -> Result<Prepared<Self::Row, Self::Item>>

A row with nothing to ask about is left where it is: it is uncertain, which no answer of ours may turn into a failure, and it is already scheduled for the next check.

async fn apply_request_rejection( &self, conn: &mut PgConnection, recovery: &Self::Row, request: &Value, error: &UtilError, ) -> Result<bool>

Not the shared request-level outcome either: these rows must stay uncertain whatever the call did.

const ALL_TRANSIENT_ERROR: &'static str = "Every recovery lookup came back transiently unavailable."

The iteration’s error when every item came back transiently unavailable.

type Row = Recovery

A row to send for, with whatever its preflight read alongside it.

type Item = ResolveEnrolmentRequestItem

The request item, which is also what the audit log records as sent.

type Result = EnrolmentResolutionResult

The endpoint’s per-item result body.

fn registration(recovery: &Self::Row) -> &CreditRegistration

fn request_item_id(recovery: &Self::Row) -> String

What the row was addressed as, and so how its answer is found again.

async fn send( &self, ctx: &PhaseContext<'_>, rows: &[Self::Row], items: Vec<Self::Item>, ) -> Result<SuotarBatchResponse<Self::Result>, UtilError>

async fn apply( &self, conn: &mut PgConnection, recovery: &Self::Row, item: Option<&SuotarResponseItem<Self::Result>>, event: OutcomeEvent<'_>, ) -> Result<bool>

Applies one answer, or the absence of one, to its row. Returns whether the row ended up in a failure state; errors with PreconditionFailed if another writer moved the row meanwhile.

fn sent_student_number(_row: &Self::Row) -> Option<&str>

The student number this row’s request carried, where it carried one: a number the registry rejects may only cost the link it was sent under.