yao 0.1.4

a fast, tiny, extensiable workflow engine
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

use crate::{
    sch::{Proc, Scheduler},
    utils, Workflow,
};
use std::sync::Arc;

#[tokio::test]
async fn proc_messages() {
    let mut workflow = create_workflow();
    let id = utils::longid();
    let (proc, scher) = create_proc(&mut workflow, &id);
    scher.sched_proc(&proc);
    let tid = utils::shortid();
    let msg = proc.make_message(&tid, "u1");

    assert!(scher.message(&msg.id).is_some())
}

fn create_proc(workflow: &mut Workflow, id: &str) -> (Proc, Arc<Scheduler>) {
    let scher = Scheduler::new();

    workflow.set_biz_id(id);
    let proc = scher.create_raw_proc(workflow);

    scher.cache().push(&proc);
    (proc.clone(), Arc::new(scher))
}

fn create_workflow() -> Workflow {
    let text = include_str!("./simple.yml");
    let workflow = Workflow::from_str(text).unwrap();
    workflow
}