ironflow-orchestrator 0.1.0

A lightning-fast, zero-dependency workflow orchestrator written in Rust
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

use super::Operator;
use async_trait::async_trait;
use serde_json::Value;
use anyhow::Result;

pub struct SqlOperator;

#[async_trait]
impl Operator for SqlOperator {
    async fn execute(&self, config: &Value) -> Result<String> {
        let _query = config
            .get("query")
            .and_then(|v| v.as_str())
            .ok_or_else(|| anyhow::anyhow!("Missing 'query' field in SQL operator config"))?;

        let _connection_string = config
            .get("connection_string")
            .and_then(|v| v.as_str())
            .ok_or_else(|| anyhow::anyhow!("Missing 'connection_string' field in SQL operator config"))?;

        // For Phase 1, this is a placeholder
        // In a real implementation, we would execute the query against a database
        Ok("SQL execution result".to_string())
    }

    fn name(&self) -> &'static str {
        "sql"
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[tokio::test]
    async fn test_sql_operator_missing_query() {
        let config = serde_json::json!({
            "connection_string": "sqlite::memory:"
        });

        let operator = SqlOperator;
        let result = operator.execute(&config).await;
        assert!(result.is_err());
    }
}