zebflow 0.7.9

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
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130

//! Pattern matching: maps a DSL command string to a navigation URL.

/// Match a DSL string against known patterns and return a navigation URL if matched.
/// Only inspects the first command when chained with `&&`.
pub fn match_patterns(dsl: &str, owner: &str, project: &str) -> Option<String> {
    // For multi-command DSL (&&), only match against the first command.
    let first_cmd = dsl.split("&&").next().unwrap_or(dsl).trim();
    let lower = first_cmd.to_lowercase();
    let tokens: Vec<&str> = first_cmd.split_whitespace().collect();

    // register <name> ...
    if lower.starts_with("register ") {
        let name = tokens.get(1).copied().unwrap_or("");
        if !name.is_empty() {
            return Some(format!(
                "/projects/{owner}/{project}/pipelines/editor?name={name}"
            ));
        }
    }

    // activate pipeline <name>
    if lower.starts_with("activate pipeline ") {
        let name = tokens.get(2).copied().unwrap_or("");
        if !name.is_empty() {
            return Some(format!(
                "/projects/{owner}/{project}/pipelines/editor?name={name}&tab=status"
            ));
        }
    }

    // describe pipeline <name>
    if lower.starts_with("describe pipeline ") {
        let name = tokens.get(2).copied().unwrap_or("");
        if !name.is_empty() {
            return Some(format!(
                "/projects/{owner}/{project}/pipelines/editor?name={name}"
            ));
        }
    }

    // patch pipeline <name>
    if lower.starts_with("patch pipeline ") {
        let name = tokens.get(2).copied().unwrap_or("");
        if !name.is_empty() {
            return Some(format!(
                "/projects/{owner}/{project}/pipelines/editor?name={name}"
            ));
        }
    }

    // get templates
    if lower.starts_with("get templates") {
        return Some(format!("/projects/{owner}/{project}/build/templates"));
    }

    // get pipelines
    if lower.starts_with("get pipelines") {
        return Some(format!("/projects/{owner}/{project}/pipelines/registry"));
    }

    // describe connection <slug>
    if lower.starts_with("describe connection ") {
        let slug = tokens.get(2).copied().unwrap_or("");
        if !slug.is_empty() {
            return Some(format!("/projects/{owner}/{project}/db?slug={slug}"));
        }
    }

    // contains pg.query
    if lower.contains("pg.query") {
        return Some(format!("/projects/{owner}/{project}/db"));
    }

    // get connections
    if lower.starts_with("get connections") {
        return Some(format!("/projects/{owner}/{project}/db/connections"));
    }

    // get credentials
    if lower.starts_with("get credentials") {
        return Some(format!("/projects/{owner}/{project}/credentials"));
    }

    // get docs
    if lower.starts_with("get docs") {
        return Some(format!("/projects/{owner}/{project}/build/docs"));
    }

    // get nodes
    if lower.starts_with("get nodes") {
        return Some(format!("/projects/{owner}/{project}/build/nodes"));
    }

    // get tables
    if lower.starts_with("get tables") {
        return Some(format!("/projects/{owner}/{project}/db"));
    }

    // describe node <kind>
    if lower.starts_with("describe node ") {
        return Some(format!("/projects/{owner}/{project}/build/nodes"));
    }

    // execute pipeline <name>
    if lower.starts_with("execute pipeline ") {
        let name = tokens.get(2).copied().unwrap_or("");
        if !name.is_empty() {
            return Some(format!(
                "/projects/{owner}/{project}/pipelines/editor?name={name}&tab=logs"
            ));
        }
    }

    // deactivate pipeline <name>
    if lower.starts_with("deactivate pipeline ") {
        let name = tokens.get(2).copied().unwrap_or("");
        if !name.is_empty() {
            return Some(format!(
                "/projects/{owner}/{project}/pipelines/editor?name={name}&tab=status"
            ));
        }
    }

    // git <subcommand>
    if lower.starts_with("git ") {
        return Some(format!("/projects/{owner}/{project}/files"));
    }

    None
}