nika 0.35.4

Semantic YAML workflow engine for AI tasks - DAG execution, MCP integration, multi-provider LLM support
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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69

//! Extract init workflows to disk for testing
//!
//! Usage: cargo run --example extract_init_workflows

use std::fs;
use std::path::Path;

fn main() {
    let base = Path::new("/tmp/nika-test-workflows");

    // Clean and recreate
    if base.exists() {
        fs::remove_dir_all(base).unwrap();
    }

    let workflows = nika::init::get_all_workflows();
    let context_files = nika::init::get_all_context_files();
    let schemas = nika::init::get_all_schemas();
    let partials = nika::init::get_all_partials();

    // Write workflows
    for w in &workflows {
        let dir = base.join("workflows").join(w.tier_dir);
        fs::create_dir_all(&dir).unwrap();
        let path = dir.join(w.filename);
        fs::write(&path, w.content).unwrap();
        println!("✓ {}", path.display());
    }

    // Write context files
    for f in &context_files {
        let dir = base.join("workflows").join(f.dir);
        fs::create_dir_all(&dir).unwrap();
        let path = dir.join(f.filename);
        fs::write(&path, f.content).unwrap();
        println!("✓ {}", path.display());
    }

    // Write schemas
    for f in &schemas {
        let dir = base.join("workflows").join(f.dir);
        fs::create_dir_all(&dir).unwrap();
        let path = dir.join(f.filename);
        fs::write(&path, f.content).unwrap();
        println!("✓ {}", path.display());
    }

    // Write partials
    for f in &partials {
        let dir = base.join("workflows").join(f.dir);
        fs::create_dir_all(&dir).unwrap();
        let path = dir.join(f.filename);
        fs::write(&path, f.content).unwrap();
        println!("✓ {}", path.display());
    }

    // Write README
    let readme_path = base.join("workflows/README.md");
    fs::write(&readme_path, nika::init::WORKFLOWS_README).unwrap();
    println!("✓ {}", readme_path.display());

    println!(
        "\n✅ Extracted {} workflows, {} context, {} schemas, {} partials",
        workflows.len(),
        context_files.len(),
        schemas.len(),
        partials.len()
    );
}