zebflow 0.6.1

Reactive web automation platform — pipelines, templates, and real-time collaboration in a single binary.
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

//! Minimal automaton engine used for testing and scaffolding.

use serde_json::json;

use crate::automaton::infra::interface::AutomatonEngine;
use crate::automaton::infra::model::{
    AutomatonContext, AutomatonError, AutomatonExecutionOutput, AutomatonObjective, AutomatonPlan,
    AutomatonResult,
};

/// Reference automaton engine that returns deterministic plan/execute outputs.
#[derive(Default)]
pub struct NoopAutomatonEngine;

impl AutomatonEngine for NoopAutomatonEngine {
    fn id(&self) -> &'static str {
        "automaton.noop"
    }

    fn plan(
        &self,
        objective: &AutomatonObjective,
        _ctx: &AutomatonContext,
    ) -> Result<AutomatonPlan, AutomatonError> {
        if objective.goal.trim().is_empty() {
            return Err(AutomatonError::new(
                "AUTOMATON_EMPTY_GOAL",
                "objective goal is required",
            ));
        }

        Ok(AutomatonPlan {
            objective_id: objective.objective_id.clone(),
            steps: vec![format!("interpret objective: {}", objective.goal)],
            metadata: json!({
                "engine": self.id(),
            }),
        })
    }

    fn execute(
        &self,
        plan: &AutomatonPlan,
        ctx: &AutomatonContext,
    ) -> Result<AutomatonExecutionOutput, AutomatonError> {
        if plan.steps.is_empty() {
            return Err(AutomatonError::new(
                "AUTOMATON_EMPTY_PLAN",
                "plan has no steps to execute",
            ));
        }

        Ok(AutomatonExecutionOutput {
            result: AutomatonResult::Succeeded,
            output: json!({
                "objective_id": plan.objective_id,
                "executed_steps": plan.steps.len(),
            }),
            trace: vec![
                format!("engine={}", self.id()),
                format!("owner={}", ctx.owner),
                format!("project={}", ctx.project),
                format!("run_id={}", ctx.run_id),
                format!("step_budget={}", ctx.step_budget),
            ],
        })
    }
}