vtcode 0.99.1

A Rust-based terminal coding agent with modular architecture supporting multiple LLM providers
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

use anyhow::Result;
use serde_json::Value;

use crate::agent::runloop::unified::turn::context::{
    TurnHandlerOutcome, TurnLoopResult, TurnProcessingContext,
};

use super::super::helpers::push_tool_response;
use super::ValidationResult;
use super::fallbacks::build_validation_error_content_with_fallback;

fn circuit_breaker_default_blocked(
    ctx: &mut TurnProcessingContext<'_>,
    tool_call_id: &str,
    canonical_tool_name: &str,
    fallback_tool: Option<String>,
    fallback_tool_args: Option<Value>,
) -> ValidationResult {
    push_tool_response(
        ctx.working_history,
        tool_call_id,
        build_validation_error_content_with_fallback(
            format!(
                "Tool '{}' is temporarily disabled due to high failure rate (Circuit Breaker OPEN).",
                canonical_tool_name
            ),
            "circuit_breaker",
            fallback_tool,
            fallback_tool_args,
        ),
    );
    ValidationResult::Blocked
}

pub(super) async fn apply_recovery_action(
    ctx: &mut TurnProcessingContext<'_>,
    tool_call_id: &str,
    action: crate::agent::runloop::unified::turn::recovery_flow::RecoveryAction,
) -> Result<Option<ValidationResult>> {
    use crate::agent::runloop::unified::turn::recovery_flow::RecoveryAction;

    match action {
        RecoveryAction::ResetAllCircuits => {
            ctx.circuit_breaker.reset_all();
            ctx.error_recovery.write().await.clear_circuit_events();
            tracing::info!("Recovery: user chose Reset All & Retry");
            Ok(None)
        }
        RecoveryAction::Continue => {
            tracing::info!(action = ?action, "Recovery: user chose to continue");
            Ok(None)
        }
        RecoveryAction::SkipStep => {
            tracing::info!("Recovery: user chose Skip This Step");
            ctx.push_tool_response(
                tool_call_id,
                serde_json::json!({
                    "skipped": true,
                    "reason": "Skipped by user via recovery wizard. Try a different approach."
                })
                .to_string(),
            );
            Ok(Some(ValidationResult::Handled))
        }
        RecoveryAction::SaveAndExit => {
            tracing::info!("Recovery: user chose Save & Exit");
            Ok(Some(ValidationResult::Outcome(TurnHandlerOutcome::Break(
                TurnLoopResult::Exit,
            ))))
        }
    }
}

/// Attempt interactive recovery when a circuit breaker blocks a tool.
pub(crate) async fn try_interactive_circuit_recovery(
    ctx: &mut TurnProcessingContext<'_>,
    tool_call_id: &str,
    canonical_tool_name: &str,
    fallback_tool: Option<String>,
    fallback_tool_args: Option<Value>,
) -> Result<Option<ValidationResult>> {
    use crate::agent::runloop::unified::turn::recovery_flow;

    if ctx.full_auto || !ctx.error_recovery.read().await.can_prompt_user() {
        return Ok(Some(circuit_breaker_default_blocked(
            ctx,
            tool_call_id,
            canonical_tool_name,
            fallback_tool,
            fallback_tool_args,
        )));
    }

    let prompt_args = {
        let open_circuits = ctx.circuit_breaker.get_open_circuits();
        let diagnostics = ctx
            .error_recovery
            .read()
            .await
            .get_diagnostics(&open_circuits, 10);
        recovery_flow::build_recovery_prompt_from_diagnostics(&diagnostics).build()
    };
    ctx.error_recovery.write().await.mark_prompt_shown();

    let action = recovery_flow::execute_recovery_prompt(
        ctx.handle,
        ctx.session,
        &prompt_args,
        ctx.ctrl_c_state,
        ctx.ctrl_c_notify,
    )
    .await
    .ok()
    .and_then(|r| recovery_flow::parse_recovery_response(&r));

    let Some(action) = action else {
        return Ok(Some(circuit_breaker_default_blocked(
            ctx,
            tool_call_id,
            canonical_tool_name,
            fallback_tool,
            fallback_tool_args,
        )));
    };

    apply_recovery_action(ctx, tool_call_id, action).await
}