use std::path::Path;
use crate::config::AuditConfig;
#[derive(Debug)]
pub struct AuditLogger {
destination: AuditDestination,
}
#[derive(Debug)]
enum AuditDestination {
Stdout,
File(tokio::sync::Mutex<tokio::fs::File>),
}
#[derive(serde::Serialize)]
#[allow(clippy::struct_excessive_bools)]
pub struct AuditEntry {
pub timestamp: String,
pub tool: String,
pub command: String,
pub result: AuditResult,
pub duration_ms: u64,
#[serde(skip_serializing_if = "Option::is_none")]
pub error_category: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub error_domain: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub error_phase: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub claim_source: Option<crate::executor::ClaimSource>,
#[serde(skip_serializing_if = "Option::is_none")]
pub mcp_server_id: Option<String>,
#[serde(default, skip_serializing_if = "std::ops::Not::not")]
pub injection_flagged: bool,
#[serde(default, skip_serializing_if = "std::ops::Not::not")]
pub embedding_anomalous: bool,
#[serde(default, skip_serializing_if = "std::ops::Not::not")]
pub cross_boundary_mcp_to_acp: bool,
#[serde(skip_serializing_if = "Option::is_none")]
pub adversarial_policy_decision: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub exit_code: Option<i32>,
#[serde(default, skip_serializing_if = "std::ops::Not::not")]
pub truncated: bool,
}
#[derive(serde::Serialize)]
#[serde(tag = "type")]
pub enum AuditResult {
#[serde(rename = "success")]
Success,
#[serde(rename = "blocked")]
Blocked { reason: String },
#[serde(rename = "error")]
Error { message: String },
#[serde(rename = "timeout")]
Timeout,
#[serde(rename = "rollback")]
Rollback { restored: usize, deleted: usize },
}
impl AuditLogger {
pub async fn from_config(config: &AuditConfig) -> Result<Self, std::io::Error> {
let destination = if config.destination == "stdout" {
AuditDestination::Stdout
} else {
let file = tokio::fs::OpenOptions::new()
.create(true)
.append(true)
.open(Path::new(&config.destination))
.await?;
AuditDestination::File(tokio::sync::Mutex::new(file))
};
Ok(Self { destination })
}
pub async fn log(&self, entry: &AuditEntry) {
let json = match serde_json::to_string(entry) {
Ok(j) => j,
Err(err) => {
tracing::error!("audit entry serialization failed: {err}");
return;
}
};
match &self.destination {
AuditDestination::Stdout => {
tracing::info!(target: "audit", "{json}");
}
AuditDestination::File(file) => {
use tokio::io::AsyncWriteExt;
let mut f = file.lock().await;
let line = format!("{json}\n");
if let Err(e) = f.write_all(line.as_bytes()).await {
tracing::error!("failed to write audit log: {e}");
} else if let Err(e) = f.flush().await {
tracing::error!("failed to flush audit log: {e}");
}
}
}
}
}
#[must_use]
pub fn chrono_now() -> String {
use std::time::{SystemTime, UNIX_EPOCH};
let secs = SystemTime::now()
.duration_since(UNIX_EPOCH)
.unwrap_or_default()
.as_secs();
format!("{secs}")
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn audit_entry_serialization() {
let entry = AuditEntry {
timestamp: "1234567890".into(),
tool: "shell".into(),
command: "echo hello".into(),
result: AuditResult::Success,
duration_ms: 42,
error_category: None,
error_domain: None,
error_phase: None,
claim_source: None,
mcp_server_id: None,
injection_flagged: false,
embedding_anomalous: false,
cross_boundary_mcp_to_acp: false,
adversarial_policy_decision: None,
exit_code: None,
truncated: false,
};
let json = serde_json::to_string(&entry).unwrap();
assert!(json.contains("\"type\":\"success\""));
assert!(json.contains("\"tool\":\"shell\""));
assert!(json.contains("\"duration_ms\":42"));
}
#[test]
fn audit_result_blocked_serialization() {
let entry = AuditEntry {
timestamp: "0".into(),
tool: "shell".into(),
command: "sudo rm".into(),
result: AuditResult::Blocked {
reason: "blocked command: sudo".into(),
},
duration_ms: 0,
error_category: Some("policy_blocked".to_owned()),
error_domain: Some("action".to_owned()),
error_phase: None,
claim_source: None,
mcp_server_id: None,
injection_flagged: false,
embedding_anomalous: false,
cross_boundary_mcp_to_acp: false,
adversarial_policy_decision: None,
exit_code: None,
truncated: false,
};
let json = serde_json::to_string(&entry).unwrap();
assert!(json.contains("\"type\":\"blocked\""));
assert!(json.contains("\"reason\""));
}
#[test]
fn audit_result_error_serialization() {
let entry = AuditEntry {
timestamp: "0".into(),
tool: "shell".into(),
command: "bad".into(),
result: AuditResult::Error {
message: "exec failed".into(),
},
duration_ms: 0,
error_category: None,
error_domain: None,
error_phase: None,
claim_source: None,
mcp_server_id: None,
injection_flagged: false,
embedding_anomalous: false,
cross_boundary_mcp_to_acp: false,
adversarial_policy_decision: None,
exit_code: None,
truncated: false,
};
let json = serde_json::to_string(&entry).unwrap();
assert!(json.contains("\"type\":\"error\""));
}
#[test]
fn audit_result_timeout_serialization() {
let entry = AuditEntry {
timestamp: "0".into(),
tool: "shell".into(),
command: "sleep 999".into(),
result: AuditResult::Timeout,
duration_ms: 30000,
error_category: Some("timeout".to_owned()),
error_domain: Some("system".to_owned()),
error_phase: None,
claim_source: None,
mcp_server_id: None,
injection_flagged: false,
embedding_anomalous: false,
cross_boundary_mcp_to_acp: false,
adversarial_policy_decision: None,
exit_code: None,
truncated: false,
};
let json = serde_json::to_string(&entry).unwrap();
assert!(json.contains("\"type\":\"timeout\""));
}
#[tokio::test]
async fn audit_logger_stdout() {
let config = AuditConfig {
enabled: true,
destination: "stdout".into(),
};
let logger = AuditLogger::from_config(&config).await.unwrap();
let entry = AuditEntry {
timestamp: "0".into(),
tool: "shell".into(),
command: "echo test".into(),
result: AuditResult::Success,
duration_ms: 1,
error_category: None,
error_domain: None,
error_phase: None,
claim_source: None,
mcp_server_id: None,
injection_flagged: false,
embedding_anomalous: false,
cross_boundary_mcp_to_acp: false,
adversarial_policy_decision: None,
exit_code: None,
truncated: false,
};
logger.log(&entry).await;
}
#[tokio::test]
async fn audit_logger_file() {
let dir = tempfile::tempdir().unwrap();
let path = dir.path().join("audit.log");
let config = AuditConfig {
enabled: true,
destination: path.display().to_string(),
};
let logger = AuditLogger::from_config(&config).await.unwrap();
let entry = AuditEntry {
timestamp: "0".into(),
tool: "shell".into(),
command: "echo test".into(),
result: AuditResult::Success,
duration_ms: 1,
error_category: None,
error_domain: None,
error_phase: None,
claim_source: None,
mcp_server_id: None,
injection_flagged: false,
embedding_anomalous: false,
cross_boundary_mcp_to_acp: false,
adversarial_policy_decision: None,
exit_code: None,
truncated: false,
};
logger.log(&entry).await;
let content = tokio::fs::read_to_string(&path).await.unwrap();
assert!(content.contains("\"tool\":\"shell\""));
}
#[tokio::test]
async fn audit_logger_file_write_error_logged() {
let config = AuditConfig {
enabled: true,
destination: "/nonexistent/dir/audit.log".into(),
};
let result = AuditLogger::from_config(&config).await;
assert!(result.is_err());
}
#[test]
fn claim_source_serde_roundtrip() {
use crate::executor::ClaimSource;
let cases = [
(ClaimSource::Shell, "\"shell\""),
(ClaimSource::FileSystem, "\"file_system\""),
(ClaimSource::WebScrape, "\"web_scrape\""),
(ClaimSource::Mcp, "\"mcp\""),
(ClaimSource::A2a, "\"a2a\""),
(ClaimSource::CodeSearch, "\"code_search\""),
(ClaimSource::Diagnostics, "\"diagnostics\""),
(ClaimSource::Memory, "\"memory\""),
];
for (variant, expected_json) in cases {
let serialized = serde_json::to_string(&variant).unwrap();
assert_eq!(serialized, expected_json, "serialize {variant:?}");
let deserialized: ClaimSource = serde_json::from_str(&serialized).unwrap();
assert_eq!(deserialized, variant, "deserialize {variant:?}");
}
}
#[test]
fn audit_entry_claim_source_none_omitted() {
let entry = AuditEntry {
timestamp: "0".into(),
tool: "shell".into(),
command: "echo".into(),
result: AuditResult::Success,
duration_ms: 1,
error_category: None,
error_domain: None,
error_phase: None,
claim_source: None,
mcp_server_id: None,
injection_flagged: false,
embedding_anomalous: false,
cross_boundary_mcp_to_acp: false,
adversarial_policy_decision: None,
exit_code: None,
truncated: false,
};
let json = serde_json::to_string(&entry).unwrap();
assert!(
!json.contains("claim_source"),
"claim_source must be omitted when None: {json}"
);
}
#[test]
fn audit_entry_claim_source_some_present() {
use crate::executor::ClaimSource;
let entry = AuditEntry {
timestamp: "0".into(),
tool: "shell".into(),
command: "echo".into(),
result: AuditResult::Success,
duration_ms: 1,
error_category: None,
error_domain: None,
error_phase: None,
claim_source: Some(ClaimSource::Shell),
mcp_server_id: None,
injection_flagged: false,
embedding_anomalous: false,
cross_boundary_mcp_to_acp: false,
adversarial_policy_decision: None,
exit_code: None,
truncated: false,
};
let json = serde_json::to_string(&entry).unwrap();
assert!(
json.contains("\"claim_source\":\"shell\""),
"expected claim_source=shell in JSON: {json}"
);
}
#[tokio::test]
async fn audit_logger_multiple_entries() {
let dir = tempfile::tempdir().unwrap();
let path = dir.path().join("audit.log");
let config = AuditConfig {
enabled: true,
destination: path.display().to_string(),
};
let logger = AuditLogger::from_config(&config).await.unwrap();
for i in 0..5 {
let entry = AuditEntry {
timestamp: i.to_string(),
tool: "shell".into(),
command: format!("cmd{i}"),
result: AuditResult::Success,
duration_ms: i,
error_category: None,
error_domain: None,
error_phase: None,
claim_source: None,
mcp_server_id: None,
injection_flagged: false,
embedding_anomalous: false,
cross_boundary_mcp_to_acp: false,
adversarial_policy_decision: None,
exit_code: None,
truncated: false,
};
logger.log(&entry).await;
}
let content = tokio::fs::read_to_string(&path).await.unwrap();
assert_eq!(content.lines().count(), 5);
}
#[test]
fn audit_entry_exit_code_serialized() {
let entry = AuditEntry {
timestamp: "0".into(),
tool: "shell".into(),
command: "echo hi".into(),
result: AuditResult::Success,
duration_ms: 5,
error_category: None,
error_domain: None,
error_phase: None,
claim_source: None,
mcp_server_id: None,
injection_flagged: false,
embedding_anomalous: false,
cross_boundary_mcp_to_acp: false,
adversarial_policy_decision: None,
exit_code: Some(0),
truncated: false,
};
let json = serde_json::to_string(&entry).unwrap();
assert!(
json.contains("\"exit_code\":0"),
"exit_code must be serialized: {json}"
);
}
#[test]
fn audit_entry_exit_code_none_omitted() {
let entry = AuditEntry {
timestamp: "0".into(),
tool: "file".into(),
command: "read /tmp/x".into(),
result: AuditResult::Success,
duration_ms: 1,
error_category: None,
error_domain: None,
error_phase: None,
claim_source: None,
mcp_server_id: None,
injection_flagged: false,
embedding_anomalous: false,
cross_boundary_mcp_to_acp: false,
adversarial_policy_decision: None,
exit_code: None,
truncated: false,
};
let json = serde_json::to_string(&entry).unwrap();
assert!(
!json.contains("exit_code"),
"exit_code None must be omitted: {json}"
);
}
}