tandem-server 0.5.5

HTTP server for Tandem engine APIs
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

async fn sync_bug_monitor_automation_node_artifact(
    state: &AppState,
    context_run_id: &str,
    automation: &crate::AutomationV2Spec,
    run: &crate::AutomationV2RunRecord,
    node: &crate::AutomationFlowNode,
    output: Option<&Value>,
) -> Result<(), StatusCode> {
    let is_bug_monitor_triage = automation
        .metadata
        .as_ref()
        .and_then(|metadata| metadata.get("source"))
        .and_then(Value::as_str)
        == Some("bug_monitor");
    if !is_bug_monitor_triage {
        return Ok(());
    }
    let Some(output) = output else {
        return Ok(());
    };
    let status = output
        .get("status")
        .and_then(Value::as_str)
        .unwrap_or_default();
    if !status.eq_ignore_ascii_case("completed") {
        return Ok(());
    }
    let Some(artifact_type) = node
        .metadata
        .as_ref()
        .and_then(|metadata| metadata.get("bug_monitor"))
        .and_then(|metadata| metadata.get("artifact_type"))
        .and_then(Value::as_str)
        .map(str::trim)
        .filter(|value| !value.is_empty())
    else {
        return Ok(());
    };
    let artifact_id = format!("bug-monitor-v2-{}-{}", run.run_id, node.node_id);
    let blackboard = load_context_blackboard(state, context_run_id);
    if blackboard.artifacts.iter().any(|row| row.id == artifact_id) {
        return Ok(());
    }
    let payload = output
        .get("content")
        .and_then(|content| content.get("structured_handoff"))
        .cloned()
        .or_else(|| output.get("content").cloned())
        .filter(|value| !value.is_null())
        .unwrap_or_else(|| output.clone());
    let relative_path = node
        .metadata
        .as_ref()
        .and_then(|metadata| metadata.get("bug_monitor"))
        .and_then(|metadata| metadata.get("context_artifact_path"))
        .and_then(Value::as_str)
        .map(str::trim)
        .filter(|value| !value.is_empty())
        .map(str::to_string)
        .or_else(|| {
            match artifact_type {
                "bug_monitor_inspection" => Some("artifacts/bug_monitor.inspection.json"),
                "bug_monitor_research" => Some("artifacts/bug_monitor.research.json"),
                "bug_monitor_validation" => Some("artifacts/bug_monitor.validation.json"),
                "bug_monitor_fix_proposal" => Some("artifacts/bug_monitor.fix_proposal.json"),
                _ => None,
            }
            .map(str::to_string)
        });
    let Some(relative_path) = relative_path else {
        return Ok(());
    };
    append_json_artifact_to_context_run(
        state,
        context_run_id,
        &artifact_id,
        artifact_type,
        &relative_path,
        &payload,
    )
    .await
    .map_err(|_| StatusCode::INTERNAL_SERVER_ERROR)?;
    if artifact_type == "bug_monitor_fix_proposal" {
        if let Some(draft_id) = automation
            .metadata
            .as_ref()
            .and_then(|metadata| metadata.get("draft_id"))
            .and_then(Value::as_str)
            .filter(|value| !value.trim().is_empty())
        {
            if let Err(error) =
                crate::http::bug_monitor::finalize_completed_bug_monitor_triage(state, draft_id)
                    .await
            {
                tracing::warn!(
                    draft_id = %draft_id,
                    run_id = %run.run_id,
                    error = %error,
                    "failed to finalize completed Bug Monitor triage after artifact sync",
                );
            }
        }
    }
    Ok(())
}