lash-core 0.1.0-alpha.36

Sans-IO turn machine and runtime kernel for the lash agent runtime.
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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63

use std::sync::Arc;

use super::{PluginError, PluginFactory, PluginRegistrar, PluginSessionContext, SessionPlugin};

pub(crate) const TRIGGER_RESOURCE_PLUGIN_ID: &str = "lash.triggers";

pub(crate) struct TriggerResourcePluginFactory;

impl PluginFactory for TriggerResourcePluginFactory {
    fn id(&self) -> &'static str {
        TRIGGER_RESOURCE_PLUGIN_ID
    }

    fn lashlang_resources(&self) -> lashlang::ResourceCatalog {
        let mut resources = lashlang::ResourceCatalog::new();
        lashlang::add_trigger_resource_operations(&mut resources);
        resources
    }

    fn build(&self, _ctx: &PluginSessionContext) -> Result<Arc<dyn SessionPlugin>, PluginError> {
        Ok(Arc::new(TriggerResourcePlugin))
    }
}

struct TriggerResourcePlugin;

impl SessionPlugin for TriggerResourcePlugin {
    fn id(&self) -> &'static str {
        TRIGGER_RESOURCE_PLUGIN_ID
    }

    fn register(&self, _reg: &mut PluginRegistrar) -> Result<(), PluginError> {
        Ok(())
    }
}

pub(crate) fn trigger_handle_json(handle: &str) -> serde_json::Value {
    serde_json::json!({
        "type": "trigger_handle",
        "id": handle,
    })
}

pub(crate) async fn validate_target_process(
    target: &lashlang::TriggerTargetIdentity,
    event_ty: &lashlang::NamedDataType,
    inputs: &lashlang::TriggerInputTemplate,
    artifact_store: &dyn lashlang::LashlangArtifactStore,
) -> Result<lashlang::TriggerTargetValidation, PluginError> {
    let artifact = artifact_store
        .get_module_artifact(&target.module_ref)
        .await
        .map_err(|err| PluginError::Session(format!("load trigger target artifact: {err}")))?
        .ok_or_else(|| {
            PluginError::Session(format!(
                "missing trigger target artifact `{}`",
                target.module_ref
            ))
        })?;
    let validation = lashlang::validate_trigger_target(target, event_ty, inputs, &artifact)
        .map_err(|err| PluginError::Session(err.to_string()))?;
    Ok(validation)
}