lash-core 0.1.0-alpha.37

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

use super::*;
use crate::PluginError;

impl<'run> RuntimeTurnDriver<'run> {
    pub(super) fn effect_controller_handle(&self) -> RuntimeEffectControllerHandle<'run> {
        RuntimeEffectControllerHandle::borrowed(self.scoped_effect_controller.clone())
    }

    pub(super) fn execution_context(
        &self,
        event_tx: mpsc::Sender<SessionEvent>,
        chronological_projection: Arc<crate::ChronologicalProjection>,
    ) -> Result<crate::RuntimeExecutionContext<'run>, PluginError> {
        let manager = self.session_services.clone();
        let effect_controller = self.effect_controller_handle();
        let direct_completions = manager
            .direct_completion_client(effect_controller.clone_scoped(), Some(self.turn_id.clone()));
        self.session.code_execution_context(
            &self.session_id,
            &self.turn_pipeline.state().current_agent_frame_id,
            manager.state_service(),
            manager.lifecycle_service(),
            manager.graph_service(),
            manager.process_service(),
            manager.process_cancel_ability(),
            effect_controller,
            direct_completions,
            manager.host_event_router(),
            event_tx,
            chronological_projection,
            self.protocol_extension.clone(),
            self.turn_context.clone(),
            self.checkpoint_messages.clone(),
        )
    }
}