Enum PortableReimportStrategy 

pub enum PortableReimportStrategy {
    ReimportCommand {
        command: InstallationSymbol,
    },
    Migration {
        migration_hash: MigrationBundleHash,
    },
    // some variants omitted
}

Closed reimport implementation. There is no callback, method path, or transaction escape.

Variants

ReimportCommand

Invoke one operator-only, compiler-owned reimport command.

Fields

command: InstallationSymbol

Symbolic compiled reimport-command name.

Migration

Delegate this class to one exact accepted application migration.

Fields

migration_hash: MigrationBundleHash

Exact reviewed migration identity.

Implementations

impl PortableReimportStrategy

pub const fn reimport_command( command: InstallationSymbol, ) -> PortableReimportStrategy

Constructs an exact compiler-owned reimport-command mapping.

Examples found in repository

examples/generate_portability_fixtures.rs (line 131)

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,
    );
}

pub const fn migration( migration_hash: MigrationBundleHash, ) -> PortableReimportStrategy

Selects one exact accepted migration with no record callback.

Trait Implementations

impl Clone for PortableReimportStrategy

fn clone(&self) -> PortableReimportStrategy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PortableReimportStrategy

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

Formats the value using the given formatter.

impl Eq for PortableReimportStrategy

impl Ord for PortableReimportStrategy

fn cmp(&self, other: &PortableReimportStrategy) -> Ordering

This method returns an Ordering between self and other.

fn max(self, other: Self) -> Self

where Self: Sized,

Compares and returns the maximum of two values.

fn min(self, other: Self) -> Self

where Self: Sized,

Compares and returns the minimum of two values.

fn clamp(self, min: Self, max: Self) -> Self

where Self: Sized,

Restrict a value to a certain interval.

fn clamp_to<R>(self, range: R) -> Self

where Self: Sized, R: ClampBounds<Self>,

🔬This is a nightly-only experimental API. (clamp_to)

Restrict a value to a certain range.

impl PartialEq for PortableReimportStrategy

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

Equality operator ==.

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

Inequality operator !=.

impl PartialOrd for PortableReimportStrategy

fn partial_cmp(&self, other: &PortableReimportStrategy) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

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

Tests less than (for self and other) and is used by the < operator.

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

Tests less than or equal to (for self and other) and is used by the <= operator.

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

Tests greater than (for self and other) and is used by the > operator.

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

Tests greater than or equal to (for self and other) and is used by the >= operator.

impl StructuralPartialEq for PortableReimportStrategy