Merge 808e7cea13 into sapling-pr-archive-bolinfest

This commit is contained in:
Michael Bolin
2026-02-25 00:46:03 -08:00
committed by GitHub
3 changed files with 31 additions and 3 deletions
+1
View File
@@ -1348,6 +1348,7 @@ impl Session {
otel_manager,
models_manager: Arc::clone(&models_manager),
tool_approvals: Mutex::new(ApprovalStore::default()),
execve_session_approvals: RwLock::new(HashSet::new()),
skills_manager,
file_watcher,
agent_control,
+3
View File
@@ -1,3 +1,4 @@
use std::collections::HashSet;
use std::sync::Arc;
use crate::AuthManager;
@@ -17,6 +18,7 @@ use crate::tools::sandboxing::ApprovalStore;
use crate::unified_exec::UnifiedExecProcessManager;
use codex_hooks::Hooks;
use codex_otel::OtelManager;
use codex_utils_absolute_path::AbsolutePathBuf;
use std::path::PathBuf;
use tokio::sync::Mutex;
use tokio::sync::RwLock;
@@ -42,6 +44,7 @@ pub(crate) struct SessionServices {
pub(crate) models_manager: Arc<ModelsManager>,
pub(crate) otel_manager: OtelManager,
pub(crate) tool_approvals: Mutex<ApprovalStore>,
pub(crate) execve_session_approvals: RwLock<HashSet<AbsolutePathBuf>>,
pub(crate) skills_manager: Arc<SkillsManager>,
pub(crate) file_watcher: Arc<FileWatcher>,
pub(crate) agent_control: AgentControl,
@@ -255,8 +255,20 @@ impl CoreShellActionProvider {
} else {
match self.prompt(program, argv, workdir, &self.stopwatch).await? {
ReviewDecision::Approved
| ReviewDecision::ApprovedExecpolicyAmendment { .. }
| ReviewDecision::ApprovedForSession => {
| ReviewDecision::ApprovedExecpolicyAmendment { .. } => {
if needs_escalation {
EscalateAction::Escalate
} else {
EscalateAction::Run
}
}
ReviewDecision::ApprovedForSession => {
self.session
.services
.execve_session_approvals
.write()
.await
.insert(program.clone());
if needs_escalation {
EscalateAction::Escalate
} else {
@@ -325,8 +337,20 @@ impl EscalationPolicy for CoreShellActionProvider {
// EscalateAction::Run case, rather than always escalating when a
// skill matches.
let needs_escalation = true;
let is_approved_for_session = self
.session
.services
.execve_session_approvals
.read()
.await
.contains(program);
let decision = if is_approved_for_session {
Decision::Allow
} else {
Decision::Prompt
};
return self
.process_decision(Decision::Prompt, needs_escalation, program, argv, workdir)
.process_decision(decision, needs_escalation, program, argv, workdir)
.await;
}