hm-dsl-engine 0.0.3

DSL engine: evaluate Python/TypeScript pipeline definitions via system runtimes.
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

use std::path::Path;

use async_trait::async_trait;
use serde::Deserialize;

pub mod detect;
pub mod python_engine;
pub mod ts_engine;

mod bundled_sources;

#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]
pub enum DslLanguage {
    Python,
    TypeScript,
}

#[derive(Debug, Clone, Deserialize)]
pub struct PipelineMeta {
    pub slug: String,
    pub name: String,
}

#[async_trait]
pub trait DslEngine: Send + Sync {
    async fn list_pipelines(&self, project_dir: &Path) -> anyhow::Result<Vec<PipelineMeta>>;
    async fn render_pipeline_json(&self, project_dir: &Path, slug: &str) -> anyhow::Result<String>;
}

/// Return an appropriate [`DslEngine`] for the given language.
///
/// # Errors
///
/// Returns an error if the required system runtime (`python3`, `node`/`bun`)
/// is not found on PATH.
pub fn engine_for(lang: DslLanguage) -> anyhow::Result<Box<dyn DslEngine>> {
    match lang {
        DslLanguage::Python => {
            let engine = python_engine::SubprocessPythonEngine::new()?;
            Ok(Box::new(engine))
        }
        DslLanguage::TypeScript => {
            let engine = ts_engine::SubprocessTsEngine::new()?;
            Ok(Box::new(engine))
        }
    }
}