harn-vm 0.10.125

Async bytecode virtual machine for the Harn programming language
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

//! Execution identity attachment for newly constructed run records.

use crate::orchestration::{
    normalize_run_record, validate_execution_evidence, RunRecord, EXECUTION_EVIDENCE_SCHEMA_VERSION,
};
use crate::stdlib::macros::harn_builtin;
use crate::value::{VmError, VmValue};

use super::to_vm;

#[harn_builtin(
    exposure = "harness.obs.run_record",
    effects = ["state.read@const=execution-scope"],
    sig = "run_record(payload: dict) -> dict", category = "records"
)]
pub(super) fn run_record_impl(args: &[VmValue], _out: &mut String) -> Result<VmValue, VmError> {
    let mut run = normalize_run_record(
        args.first()
            .ok_or_else(|| VmError::Runtime("run_record: missing payload".to_string()))?,
    )?;
    let execution_id = crate::current_execution_scope().ok_or_else(|| {
        VmError::Runtime("run_record: active execution scope unavailable".to_string())
    })?;
    attach_execution_identity(&mut run, &execution_id);
    validate_execution_evidence(&run.evidence).map_err(|error| {
        VmError::Runtime(format!("run_record: invalid execution evidence: {error}"))
    })?;
    to_vm(&run)
}

fn attach_execution_identity(run: &mut RunRecord, execution_id: &crate::ExecutionId) {
    run.evidence.schema_version = EXECUTION_EVIDENCE_SCHEMA_VERSION;
    run.evidence.execution_id = Some(execution_id.to_string());
    run.evidence
        .gaps
        .retain(|gap| gap.component != "execution_identity");
}