tandem-plan-compiler 0.6.3

Mission and plan compiler boundary for Tandem
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

pub fn workflow_step_expects_connector_source_capture(
    step_id: &str,
    kind: &str,
    objective: &str,
) -> bool {
    let text = format!("{step_id} {kind} {objective}").to_ascii_lowercase();
    if !workflow_plan_mentions_connector_backed_sources(&text) {
        return false;
    }
    let collection_intent = [
        "collect",
        "extract",
        "search",
        "query",
        "fetch",
        "retrieve",
        "scan",
        "gather",
        "harvest",
        "find",
        "list",
        "source",
        "research",
        "lead",
        "signal",
        "candidate",
        "thread",
        "post",
        "issue",
        "ticket",
        "record",
        "dataset",
        "results",
    ]
    .iter()
    .any(|needle| text.contains(needle));
    let writer_intent = workflow_step_text_has_writer_intent(&text);
    collection_intent && !writer_intent
}

fn workflow_step_text_has_writer_intent(text: &str) -> bool {
    let phrase_intent = [
        "write to",
        "save to",
        "create page",
        "send ",
        "post to",
        "draft email",
    ]
    .iter()
    .any(|needle| text.contains(needle));
    if phrase_intent {
        return true;
    }

    let tokens = text
        .split(|ch: char| !ch.is_ascii_alphanumeric())
        .filter(|token| !token.is_empty())
        .collect::<std::collections::BTreeSet<_>>();
    ["insert", "upsert", "update", "publish", "outreach"]
        .iter()
        .any(|needle| tokens.contains(needle))
}