reflow_network 0.2.1

Network executor for Reflow — routes messages between actors, manages subgraphs, and emits runtime events.
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

use super::types::{PortDefinition, ScriptActorMetadata};
use anyhow::Result;
use async_trait::async_trait;
use reflow_actor::message::Message;
use serde_json::Value;
use std::collections::HashMap;

/// Trait for simple script-based actors that need bridging to the full Actor trait
/// This is a simpler interface for scripts that:
/// - Process messages synchronously (return outputs)
/// - Don't need direct access to outports for async sending
/// - Are typically embedded or simple scripts
///
/// For full async capabilities, implement Actor directly (like WebSocketScriptActor does)
#[async_trait]
pub trait ScriptActor: Send + Sync + 'static {
    /// Process a message and return outputs
    /// Simple synchronous processing - input to output
    async fn process(
        &mut self,
        inputs: HashMap<String, Message>,
    ) -> Result<HashMap<String, Message>>;

    /// Get input port definitions
    fn get_inports(&self) -> Vec<PortDefinition>;

    /// Get output port definitions
    fn get_outports(&self) -> Vec<PortDefinition>;

    /// Get actor metadata
    fn get_metadata(&self) -> ScriptActorMetadata;

    /// Initialize the actor (called once before first message)
    async fn initialize(&mut self) -> Result<()> {
        Ok(())
    }

    /// Cleanup the actor (called when shutting down)
    async fn cleanup(&mut self) -> Result<()> {
        Ok(())
    }

    /// Get current state (for debugging/inspection)
    async fn get_state(&self) -> Result<Value> {
        Ok(Value::Null)
    }

    /// Set state (for restoration)
    async fn set_state(&mut self, _state: Value) -> Result<()> {
        Ok(())
    }
}