ic-backup 0.24.6

Host-side snapshot backup and same-release recovery for Internet Computer canisters
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

//! Exact original Applied receipt recording after independent reply qualification.

use crate::{
    model::attempt_journal::{MutationOutcomeRecord, MutationReceiptRequest},
    ops::persistence::{
        AttemptJournalError, AttemptJournalGuard, ExecutionStageGuard,
        ExecutionWorkflowPersistenceError,
    },
};

pub(super) struct AppliedReceiptRecorder<'stage, 'journal, 'layout, 'request> {
    pub(super) stage: &'stage ExecutionStageGuard<'layout>,
    pub(super) journal: &'journal mut AttemptJournalGuard<'layout>,
    pub(super) expected_attempt: u32,
    pub(super) expected_request: &'request str,
}

impl AppliedReceiptRecorder<'_, '_, '_, '_> {
    pub(super) async fn record_applied<R, A, E, Q, T>(
        &mut self,
        request: &R,
        reply: &A,
        qualify: impl AsyncFnOnce(&R, &A) -> Result<MutationReceiptRequest, E>,
        qualification_error: fn(E) -> Q,
        receipt_error: fn() -> Q,
        before_record: impl FnOnce() -> Result<T, Q>,
    ) -> Result<T, Q>
    where
        Q: From<ExecutionWorkflowPersistenceError> + From<AttemptJournalError>,
    {
        let receipt = qualify(request, reply).await.map_err(qualification_error)?;
        if receipt.outcome != MutationOutcomeRecord::Applied
            || receipt.attempt != self.expected_attempt
            || receipt.request != self.expected_request
        {
            return Err(receipt_error());
        }
        let result = before_record()?;
        self.stage.layout()?;
        self.journal.record_mutation(receipt)?;
        Ok(result)
    }
}