lash-core 0.1.0-alpha.52

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

use crate::{PluginError, TriggerEmitReport, TriggerOccurrenceRequest};

use super::ToolContext;

#[derive(Clone)]
pub struct ToolTriggerClient<'run> {
    pub(super) context: ToolContext<'run>,
}

impl<'run> ToolTriggerClient<'run> {
    pub async fn emit(
        &self,
        request: TriggerOccurrenceRequest,
    ) -> Result<TriggerEmitReport, PluginError> {
        let Some(dispatch) = self.context.runtime_dispatch.clone() else {
            return Err(PluginError::Session(
                "trigger emission is unavailable outside runtime tool execution".to_string(),
            ));
        };
        let router = dispatch.trigger_router.as_ref().ok_or_else(|| {
            PluginError::Session("trigger store is unavailable in this runtime".to_string())
        })?;
        let outcome = request.clone();
        let report = router
            .emit(request, dispatch.effect_controller.controller())
            .await?;
        dispatch
            .trigger_outcomes
            .enqueue(crate::tool_dispatch::ToolTriggerEffectOutcome {
                source_type: outcome.source_type,
                source_key: outcome.source_key,
                occurrence_id: report.occurrence_id.clone(),
                payload: outcome.payload,
                idempotency_key: outcome.idempotency_key,
                source: outcome.source,
                started_process_ids: report.started_process_ids.clone(),
            })
            .map_err(PluginError::Session)?;
        Ok(report)
    }
}