greentic 0.1.0

The fastest, most secure and extendable agentic platform
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

use crate::node::{NodeContext, NodeType};
use crate::{message::Message, node::NodeError};
use schemars::{schema_for, JsonSchema};
use serde::{Deserialize, Serialize};
use schemars::schema::RootSchema;
use serde_json::{json, Value};   // assume you have some Executor‐like trait for agents

#[derive(Debug, Clone, Serialize, Deserialize, JsonSchema)]
#[serde(rename = "process")]
pub struct ProcessNode {
    pub name: String,
    /// which arguments are needed for the process
    pub args: Value,

}

impl ProcessNode {
    /// Create a new `AgentNode`
    pub fn new<N: Into<String>,A: Into<Value>>(name: N, args: A, ) -> Self {
        ProcessNode {
            name: name.into(),
            args: args.into(),
        }
    }
}

#[typetag::serde]
impl NodeType for ProcessNode {
    fn type_name(&self) -> String {
        self.name.clone()
    }

    fn schema(&self) -> RootSchema {
        // delegates to schemars
        schema_for!(ProcessNode)
    }


    fn process(&self, input: Message, _context: &mut NodeContext) -> Result<Message, NodeError> {
        // TODO
        let payload = json!({});
        Ok(Message::new(&input.id(), payload, input.session_id()))
    }

    fn clone_box(&self) -> Box<dyn NodeType> {
        Box::new(self.clone())
    }
}