Struct ApplicationReimportReceipt 

pub struct ApplicationReimportReceipt { /* private fields */ }

Canonical success receipt produced only after exact reconciliation.

Implementations

impl ApplicationReimportReceipt

pub fn reconcile( manifest: &ApplicationPortabilityManifest, export_manifest_hash: ApplicationExportManifestHash, target_database_id: DatabaseId, mappings: Vec<ReimportMappingResult>, observations: Vec<ReimportObservationResult>, ) -> Result<ApplicationReimportReceipt, ApplicationPortabilityError>

Seals a receipt only when all mappings and observations match the manifest.

Examples found in repository

examples/generate_portability_fixtures.rs (lines 221-254)

fn reimport_receipt(
    manifest: &ApplicationPortabilityManifest,
    domain: &Domain<'_>,
    outcome_hash: riffdb_types::GeneratedArtifactHash,
) -> ApplicationReimportReceipt {
    ApplicationReimportReceipt::reconcile(
        manifest,
        ApplicationExportManifestHash::from_bytes(
            *hash_generated_artifact(format!("{}-export-v1", domain.name).as_bytes()).as_bytes(),
        ),
        database_id(domain.seed),
        manifest
            .input()
            .mappings
            .iter()
            .map(|mapping| {
                ReimportMappingResult::new(
                    mapping.class(),
                    mapping.symbol().clone(),
                    2,
                    2,
                    0,
                    outcome_hash,
                )
                .expect("mapping result")
            })
            .collect(),
        manifest
            .input()
            .observations
            .iter()
            .map(|observation| {
                ReimportObservationResult::new(
                    observation.name().clone(),
                    observation.expected_hash(),
                )
            })
            .collect(),
    )
    .expect("reimport receipt")
}

pub fn decode_canonical( bytes: &[u8], manifest: &ApplicationPortabilityManifest, ) -> Result<ApplicationReimportReceipt, ApplicationPortabilityError>

Strictly decodes and revalidates one canonical receipt against its manifest.

pub const fn identity(&self) -> ApplicationReimportReceiptHash

Receipt identity.

pub const fn input(&self) -> &ApplicationReimportReceiptInput

Exact reconciled evidence.

pub fn canonical_bytes(&self) -> &[u8]

Exact canonical receipt bytes.

Examples found in repository

examples/generate_portability_fixtures.rs (line 205)

fn generate_domain(root: &Path, domain: &Domain<'_>, write: bool) {
    let bundle = ContractBundle::decode(
        &fs::read(
            root.join(domain.application_root)
                .join("generated/riffdb.contract.bundle"),
        )
        .expect("read adapter contract bundle"),
    )
    .expect("decode adapter contract bundle");
    let adapter = AdapterConformanceManifest::decode_canonical(
        &fs::read(
            root.join("fixtures/adapters/conformance")
                .join(domain.name)
                .join("adapter.conformance.json"),
        )
        .expect("read adapter manifest"),
    )
    .expect("decode adapter manifest");
    let observation_hash = empty_observation_hash(domain.empty_collection);
    let module_hash = adapter
        .input()
        .artifacts
        .iter()
        .find(|artifact| artifact.kind() == InstallationArtifactKind::QueryModule)
        .map(|artifact| QueryModuleHash::from_bytes(*artifact.content_hash().as_bytes()))
        .expect("adapter query module");
    let manifest = ApplicationPortabilityManifest::compile(ApplicationPortabilityManifestInput {
        adapter_manifest_hash: adapter.identity(),
        contract_lineage: bundle.lineage().clone(),
        contract_version: bundle.contract_version(),
        contract_bundle_hash: bundle.bundle_hash(),
        mappings: domain
            .mappings
            .iter()
            .map(|(entity, command)| {
                PortableRecordMapping::new(
                    PortableRecordClass::Entity,
                    symbol(entity),
                    PortableReimportStrategy::reimport_command(symbol(command)),
                )
            })
            .collect(),
        omissions: vec![
            PortableOmission::new(
                PortableOmissionClass::Provenance,
                None,
                PortableOmissionReason::HistoricalRecordsNotRegenerable,
            )
            .expect("provenance omission"),
            PortableOmission::new(
                PortableOmissionClass::PublicAudit,
                None,
                PortableOmissionReason::HistoricalRecordsNotRegenerable,
            )
            .expect("audit omission"),
        ],
        observations: vec![
            ReimportObservation::new_with_parameters(
                symbol("application_observation"),
                symbol(domain.query),
                module_hash,
                domain
                    .parameters
                    .iter()
                    .map(|(name, suffix)| {
                        ReimportObservationParameter::new(
                            symbol(name),
                            CanonicalValue::Uuid(application_uuid(*suffix)),
                        )
                        .expect("observation parameter")
                    })
                    .collect(),
                observation_hash,
                500,
            )
            .expect("observation"),
        ],
    })
    .expect("compile portability manifest");
    manifest
        .validate_compiled_contract(&bundle)
        .expect("compiled contract mapping");
    assert_eq!(manifest.input().adapter_manifest_hash, adapter.identity());
    assert_eq!(
        manifest.input().contract_lineage,
        adapter.input().contract_lineage
    );
    assert!(adapter.input().evolution.iter().any(|evolution| {
        evolution.successor().version() == manifest.input().contract_version
            && evolution.successor().bundle_hash() == manifest.input().contract_bundle_hash
    }));
    manifest
        .validate_adapter_conformance(&adapter)
        .unwrap_or_else(|error| panic!("{} adapter mapping: {error:?}", domain.name));

    let outcome_hash = hash_generated_artifact(format!("{}-outcomes-v1", domain.name).as_bytes());
    let destination = root.join("fixtures/export").join(domain.name);
    let receipt = reimport_receipt(&manifest, domain, outcome_hash);
    update(
        destination.join("portability-manifest-v3.json"),
        manifest.canonical_bytes(),
        write,
    );
    let legacy_manifest_path = destination.join("portability-manifest-v2.json");
    if legacy_manifest_path.is_file() {
        let legacy_manifest = ApplicationPortabilityManifest::decode_canonical(
            &fs::read(legacy_manifest_path).expect("read V2 portability manifest"),
        )
        .expect("decode V2 portability manifest");
        let legacy_receipt = reimport_receipt(&legacy_manifest, domain, outcome_hash);
        update(
            destination.join("reimport-receipt-v2.json"),
            legacy_receipt.canonical_bytes(),
            write,
        );
    }
    update(
        destination.join("reimport-receipt-v3.json"),
        receipt.canonical_bytes(),
        write,
    );
}

Trait Implementations

impl Clone for ApplicationReimportReceipt

fn clone(&self) -> ApplicationReimportReceipt

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ApplicationReimportReceipt

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Eq for ApplicationReimportReceipt

impl PartialEq for ApplicationReimportReceipt

fn eq(&self, other: &ApplicationReimportReceipt) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ApplicationReimportReceipt