rustchain 0.1.0

Workflow transpilation and execution framework - import LangChain, Airflow, GitHub Actions, and more
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

use crate::core::Result;
use serde::{Deserialize, Serialize};
use std::path::Path;

#[derive(Debug, Clone, Deserialize, Serialize)]
pub struct Mission {
    pub name: String,
    pub description: Option<String>,
    pub steps: Vec<MissionStep>,
}

#[derive(Debug, Clone, Deserialize, Serialize)]
pub struct MissionStep {
    pub id: String,
    pub step_type: String,
    pub parameters: Option<serde_json::Value>,
    // Legacy fields for backward compatibility
    pub file_path: Option<String>,
    pub content: Option<String>,
    pub command: Option<String>,
    pub language: Option<String>,
    pub description: Option<String>,
}

pub fn load_mission(path: &Path) -> Result<Mission> {
    let content = std::fs::read_to_string(path)?;
    let data: serde_yaml::Value = serde_yaml::from_str(&content).map_err(|e| {
        crate::core::RustChainError::Io(std::io::Error::new(std::io::ErrorKind::InvalidData, e))
    })?;

    let mission_data = data.get("mission").unwrap_or(&data);
    let mission: Mission = serde_yaml::from_value(mission_data.clone()).map_err(|e| {
        crate::core::RustChainError::Io(std::io::Error::new(std::io::ErrorKind::InvalidData, e))
    })?;

    Ok(mission)
}