Compare commits
1 Commits
rcc/cache-
...
rcc/ant-to
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
992681c4fd |
@@ -1,5 +1,4 @@
|
|||||||
use std::collections::VecDeque;
|
use std::collections::VecDeque;
|
||||||
use std::sync::{Arc, Mutex};
|
|
||||||
use std::time::{Duration, SystemTime, UNIX_EPOCH};
|
use std::time::{Duration, SystemTime, UNIX_EPOCH};
|
||||||
|
|
||||||
use runtime::{
|
use runtime::{
|
||||||
@@ -9,9 +8,8 @@ use runtime::{
|
|||||||
use serde::Deserialize;
|
use serde::Deserialize;
|
||||||
|
|
||||||
use crate::error::ApiError;
|
use crate::error::ApiError;
|
||||||
use crate::prompt_cache::{PromptCache, PromptCacheRecord, PromptCacheStats};
|
|
||||||
use crate::sse::SseParser;
|
use crate::sse::SseParser;
|
||||||
use crate::types::{MessageRequest, MessageResponse, StreamEvent, Usage};
|
use crate::types::{MessageRequest, MessageResponse, StreamEvent};
|
||||||
|
|
||||||
const DEFAULT_BASE_URL: &str = "https://api.anthropic.com";
|
const DEFAULT_BASE_URL: &str = "https://api.anthropic.com";
|
||||||
const ANTHROPIC_VERSION: &str = "2023-06-01";
|
const ANTHROPIC_VERSION: &str = "2023-06-01";
|
||||||
@@ -110,8 +108,6 @@ pub struct AnthropicClient {
|
|||||||
max_retries: u32,
|
max_retries: u32,
|
||||||
initial_backoff: Duration,
|
initial_backoff: Duration,
|
||||||
max_backoff: Duration,
|
max_backoff: Duration,
|
||||||
prompt_cache: Option<PromptCache>,
|
|
||||||
last_prompt_cache_record: Arc<Mutex<Option<PromptCacheRecord>>>,
|
|
||||||
}
|
}
|
||||||
|
|
||||||
impl AnthropicClient {
|
impl AnthropicClient {
|
||||||
@@ -124,8 +120,6 @@ impl AnthropicClient {
|
|||||||
max_retries: DEFAULT_MAX_RETRIES,
|
max_retries: DEFAULT_MAX_RETRIES,
|
||||||
initial_backoff: DEFAULT_INITIAL_BACKOFF,
|
initial_backoff: DEFAULT_INITIAL_BACKOFF,
|
||||||
max_backoff: DEFAULT_MAX_BACKOFF,
|
max_backoff: DEFAULT_MAX_BACKOFF,
|
||||||
prompt_cache: None,
|
|
||||||
last_prompt_cache_record: Arc::new(Mutex::new(None)),
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -138,8 +132,6 @@ impl AnthropicClient {
|
|||||||
max_retries: DEFAULT_MAX_RETRIES,
|
max_retries: DEFAULT_MAX_RETRIES,
|
||||||
initial_backoff: DEFAULT_INITIAL_BACKOFF,
|
initial_backoff: DEFAULT_INITIAL_BACKOFF,
|
||||||
max_backoff: DEFAULT_MAX_BACKOFF,
|
max_backoff: DEFAULT_MAX_BACKOFF,
|
||||||
prompt_cache: None,
|
|
||||||
last_prompt_cache_record: Arc::new(Mutex::new(None)),
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -197,30 +189,6 @@ impl AnthropicClient {
|
|||||||
self
|
self
|
||||||
}
|
}
|
||||||
|
|
||||||
#[must_use]
|
|
||||||
pub fn with_prompt_cache(mut self, prompt_cache: PromptCache) -> Self {
|
|
||||||
self.prompt_cache = Some(prompt_cache);
|
|
||||||
self
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
|
||||||
pub fn prompt_cache(&self) -> Option<&PromptCache> {
|
|
||||||
self.prompt_cache.as_ref()
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
|
||||||
pub fn prompt_cache_stats(&self) -> Option<PromptCacheStats> {
|
|
||||||
self.prompt_cache.as_ref().map(PromptCache::stats)
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
|
||||||
pub fn take_last_prompt_cache_record(&self) -> Option<PromptCacheRecord> {
|
|
||||||
self.last_prompt_cache_record()
|
|
||||||
.lock()
|
|
||||||
.unwrap_or_else(std::sync::PoisonError::into_inner)
|
|
||||||
.take()
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
#[must_use]
|
||||||
pub fn auth_source(&self) -> &AuthSource {
|
pub fn auth_source(&self) -> &AuthSource {
|
||||||
&self.auth
|
&self.auth
|
||||||
@@ -230,19 +198,10 @@ impl AnthropicClient {
|
|||||||
&self,
|
&self,
|
||||||
request: &MessageRequest,
|
request: &MessageRequest,
|
||||||
) -> Result<MessageResponse, ApiError> {
|
) -> Result<MessageResponse, ApiError> {
|
||||||
self.store_last_prompt_cache_record(None);
|
|
||||||
let request = MessageRequest {
|
let request = MessageRequest {
|
||||||
stream: false,
|
stream: false,
|
||||||
..request.clone()
|
..request.clone()
|
||||||
};
|
};
|
||||||
if let Some(prompt_cache) = &self.prompt_cache {
|
|
||||||
if let Some(response) = prompt_cache.lookup_completion(&request) {
|
|
||||||
self.store_last_prompt_cache_record(Some(prompt_cache_record_from_stats(
|
|
||||||
prompt_cache.stats(),
|
|
||||||
)));
|
|
||||||
return Ok(response);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
let response = self.send_with_retry(&request).await?;
|
let response = self.send_with_retry(&request).await?;
|
||||||
let request_id = request_id_from_headers(response.headers());
|
let request_id = request_id_from_headers(response.headers());
|
||||||
let mut response = response
|
let mut response = response
|
||||||
@@ -252,10 +211,6 @@ impl AnthropicClient {
|
|||||||
if response.request_id.is_none() {
|
if response.request_id.is_none() {
|
||||||
response.request_id = request_id;
|
response.request_id = request_id;
|
||||||
}
|
}
|
||||||
if let Some(prompt_cache) = &self.prompt_cache {
|
|
||||||
let record = prompt_cache.record_response(&request, &response);
|
|
||||||
self.store_last_prompt_cache_record(Some(record));
|
|
||||||
}
|
|
||||||
Ok(response)
|
Ok(response)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -263,7 +218,6 @@ impl AnthropicClient {
|
|||||||
&self,
|
&self,
|
||||||
request: &MessageRequest,
|
request: &MessageRequest,
|
||||||
) -> Result<MessageStream, ApiError> {
|
) -> Result<MessageStream, ApiError> {
|
||||||
self.store_last_prompt_cache_record(None);
|
|
||||||
let response = self
|
let response = self
|
||||||
.send_with_retry(&request.clone().with_streaming())
|
.send_with_retry(&request.clone().with_streaming())
|
||||||
.await?;
|
.await?;
|
||||||
@@ -273,30 +227,9 @@ impl AnthropicClient {
|
|||||||
parser: SseParser::new(),
|
parser: SseParser::new(),
|
||||||
pending: VecDeque::new(),
|
pending: VecDeque::new(),
|
||||||
done: false,
|
done: false,
|
||||||
cache_tracking: self
|
|
||||||
.prompt_cache
|
|
||||||
.as_ref()
|
|
||||||
.map(|prompt_cache| StreamCacheTracking {
|
|
||||||
prompt_cache: prompt_cache.clone(),
|
|
||||||
request: request.clone().with_streaming(),
|
|
||||||
last_usage: None,
|
|
||||||
finalized: false,
|
|
||||||
last_record: self.last_prompt_cache_record.clone(),
|
|
||||||
}),
|
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
fn store_last_prompt_cache_record(&self, record: Option<PromptCacheRecord>) {
|
|
||||||
*self
|
|
||||||
.last_prompt_cache_record()
|
|
||||||
.lock()
|
|
||||||
.unwrap_or_else(std::sync::PoisonError::into_inner) = record;
|
|
||||||
}
|
|
||||||
|
|
||||||
fn last_prompt_cache_record(&self) -> &Arc<Mutex<Option<PromptCacheRecord>>> {
|
|
||||||
&self.last_prompt_cache_record
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn exchange_oauth_code(
|
pub async fn exchange_oauth_code(
|
||||||
&self,
|
&self,
|
||||||
config: &OAuthConfig,
|
config: &OAuthConfig,
|
||||||
@@ -594,7 +527,6 @@ pub struct MessageStream {
|
|||||||
parser: SseParser,
|
parser: SseParser,
|
||||||
pending: VecDeque<StreamEvent>,
|
pending: VecDeque<StreamEvent>,
|
||||||
done: bool,
|
done: bool,
|
||||||
cache_tracking: Option<StreamCacheTracking>,
|
|
||||||
}
|
}
|
||||||
|
|
||||||
impl MessageStream {
|
impl MessageStream {
|
||||||
@@ -606,9 +538,6 @@ impl MessageStream {
|
|||||||
pub async fn next_event(&mut self) -> Result<Option<StreamEvent>, ApiError> {
|
pub async fn next_event(&mut self) -> Result<Option<StreamEvent>, ApiError> {
|
||||||
loop {
|
loop {
|
||||||
if let Some(event) = self.pending.pop_front() {
|
if let Some(event) = self.pending.pop_front() {
|
||||||
if let Some(cache_tracking) = &mut self.cache_tracking {
|
|
||||||
cache_tracking.observe(&event);
|
|
||||||
}
|
|
||||||
return Ok(Some(event));
|
return Ok(Some(event));
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -616,14 +545,8 @@ impl MessageStream {
|
|||||||
let remaining = self.parser.finish()?;
|
let remaining = self.parser.finish()?;
|
||||||
self.pending.extend(remaining);
|
self.pending.extend(remaining);
|
||||||
if let Some(event) = self.pending.pop_front() {
|
if let Some(event) = self.pending.pop_front() {
|
||||||
if let Some(cache_tracking) = &mut self.cache_tracking {
|
|
||||||
cache_tracking.observe(&event);
|
|
||||||
}
|
|
||||||
return Ok(Some(event));
|
return Ok(Some(event));
|
||||||
}
|
}
|
||||||
if let Some(cache_tracking) = &mut self.cache_tracking {
|
|
||||||
cache_tracking.finalize();
|
|
||||||
}
|
|
||||||
return Ok(None);
|
return Ok(None);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -639,53 +562,6 @@ impl MessageStream {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Clone)]
|
|
||||||
struct StreamCacheTracking {
|
|
||||||
prompt_cache: PromptCache,
|
|
||||||
request: MessageRequest,
|
|
||||||
last_usage: Option<Usage>,
|
|
||||||
finalized: bool,
|
|
||||||
last_record: Arc<Mutex<Option<PromptCacheRecord>>>,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl StreamCacheTracking {
|
|
||||||
fn observe(&mut self, event: &StreamEvent) {
|
|
||||||
match event {
|
|
||||||
StreamEvent::MessageStart(event) => {
|
|
||||||
self.last_usage = Some(event.message.usage.clone());
|
|
||||||
}
|
|
||||||
StreamEvent::MessageDelta(event) => {
|
|
||||||
self.last_usage = Some(event.usage.clone());
|
|
||||||
}
|
|
||||||
StreamEvent::ContentBlockStart(_)
|
|
||||||
| StreamEvent::ContentBlockDelta(_)
|
|
||||||
| StreamEvent::ContentBlockStop(_)
|
|
||||||
| StreamEvent::MessageStop(_) => {}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
fn finalize(&mut self) {
|
|
||||||
if self.finalized {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if let Some(usage) = &self.last_usage {
|
|
||||||
let record = self.prompt_cache.record_usage(&self.request, usage);
|
|
||||||
*self
|
|
||||||
.last_record
|
|
||||||
.lock()
|
|
||||||
.unwrap_or_else(std::sync::PoisonError::into_inner) = Some(record);
|
|
||||||
}
|
|
||||||
self.finalized = true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
fn prompt_cache_record_from_stats(stats: PromptCacheStats) -> PromptCacheRecord {
|
|
||||||
PromptCacheRecord {
|
|
||||||
cache_break: None,
|
|
||||||
stats,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
async fn expect_success(response: reqwest::Response) -> Result<reqwest::Response, ApiError> {
|
async fn expect_success(response: reqwest::Response) -> Result<reqwest::Response, ApiError> {
|
||||||
let status = response.status();
|
let status = response.status();
|
||||||
if status.is_success() {
|
if status.is_success() {
|
||||||
@@ -730,7 +606,7 @@ mod tests {
|
|||||||
use super::{ALT_REQUEST_ID_HEADER, REQUEST_ID_HEADER};
|
use super::{ALT_REQUEST_ID_HEADER, REQUEST_ID_HEADER};
|
||||||
use std::io::{Read, Write};
|
use std::io::{Read, Write};
|
||||||
use std::net::TcpListener;
|
use std::net::TcpListener;
|
||||||
use std::sync::atomic::{AtomicU64, Ordering};
|
use std::sync::{Mutex, OnceLock};
|
||||||
use std::thread;
|
use std::thread;
|
||||||
use std::time::{Duration, SystemTime, UNIX_EPOCH};
|
use std::time::{Duration, SystemTime, UNIX_EPOCH};
|
||||||
|
|
||||||
@@ -740,15 +616,19 @@ mod tests {
|
|||||||
now_unix_timestamp, oauth_token_is_expired, resolve_saved_oauth_token,
|
now_unix_timestamp, oauth_token_is_expired, resolve_saved_oauth_token,
|
||||||
resolve_startup_auth_source, AnthropicClient, AuthSource, OAuthTokenSet,
|
resolve_startup_auth_source, AnthropicClient, AuthSource, OAuthTokenSet,
|
||||||
};
|
};
|
||||||
use crate::test_env_lock;
|
|
||||||
use crate::types::{ContentBlockDelta, MessageRequest};
|
use crate::types::{ContentBlockDelta, MessageRequest};
|
||||||
|
|
||||||
|
fn env_lock() -> std::sync::MutexGuard<'static, ()> {
|
||||||
|
static LOCK: OnceLock<Mutex<()>> = OnceLock::new();
|
||||||
|
LOCK.get_or_init(|| Mutex::new(()))
|
||||||
|
.lock()
|
||||||
|
.expect("env lock")
|
||||||
|
}
|
||||||
|
|
||||||
fn temp_config_home() -> std::path::PathBuf {
|
fn temp_config_home() -> std::path::PathBuf {
|
||||||
static NEXT_ID: AtomicU64 = AtomicU64::new(0);
|
|
||||||
std::env::temp_dir().join(format!(
|
std::env::temp_dir().join(format!(
|
||||||
"api-oauth-test-{}-{}-{}",
|
"api-oauth-test-{}-{}",
|
||||||
std::process::id(),
|
std::process::id(),
|
||||||
NEXT_ID.fetch_add(1, Ordering::Relaxed),
|
|
||||||
SystemTime::now()
|
SystemTime::now()
|
||||||
.duration_since(UNIX_EPOCH)
|
.duration_since(UNIX_EPOCH)
|
||||||
.expect("time")
|
.expect("time")
|
||||||
@@ -788,7 +668,7 @@ mod tests {
|
|||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn read_api_key_requires_presence() {
|
fn read_api_key_requires_presence() {
|
||||||
let _guard = test_env_lock();
|
let _guard = env_lock();
|
||||||
std::env::remove_var("ANTHROPIC_AUTH_TOKEN");
|
std::env::remove_var("ANTHROPIC_AUTH_TOKEN");
|
||||||
std::env::remove_var("ANTHROPIC_API_KEY");
|
std::env::remove_var("ANTHROPIC_API_KEY");
|
||||||
std::env::remove_var("CLAUDE_CONFIG_HOME");
|
std::env::remove_var("CLAUDE_CONFIG_HOME");
|
||||||
@@ -798,7 +678,7 @@ mod tests {
|
|||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn read_api_key_requires_non_empty_value() {
|
fn read_api_key_requires_non_empty_value() {
|
||||||
let _guard = test_env_lock();
|
let _guard = env_lock();
|
||||||
std::env::set_var("ANTHROPIC_AUTH_TOKEN", "");
|
std::env::set_var("ANTHROPIC_AUTH_TOKEN", "");
|
||||||
std::env::remove_var("ANTHROPIC_API_KEY");
|
std::env::remove_var("ANTHROPIC_API_KEY");
|
||||||
let error = super::read_api_key().expect_err("empty key should error");
|
let error = super::read_api_key().expect_err("empty key should error");
|
||||||
@@ -808,7 +688,7 @@ mod tests {
|
|||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn read_api_key_prefers_api_key_env() {
|
fn read_api_key_prefers_api_key_env() {
|
||||||
let _guard = test_env_lock();
|
let _guard = env_lock();
|
||||||
std::env::set_var("ANTHROPIC_AUTH_TOKEN", "auth-token");
|
std::env::set_var("ANTHROPIC_AUTH_TOKEN", "auth-token");
|
||||||
std::env::set_var("ANTHROPIC_API_KEY", "legacy-key");
|
std::env::set_var("ANTHROPIC_API_KEY", "legacy-key");
|
||||||
assert_eq!(
|
assert_eq!(
|
||||||
@@ -821,7 +701,7 @@ mod tests {
|
|||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn read_auth_token_reads_auth_token_env() {
|
fn read_auth_token_reads_auth_token_env() {
|
||||||
let _guard = test_env_lock();
|
let _guard = env_lock();
|
||||||
std::env::set_var("ANTHROPIC_AUTH_TOKEN", "auth-token");
|
std::env::set_var("ANTHROPIC_AUTH_TOKEN", "auth-token");
|
||||||
assert_eq!(super::read_auth_token().as_deref(), Some("auth-token"));
|
assert_eq!(super::read_auth_token().as_deref(), Some("auth-token"));
|
||||||
std::env::remove_var("ANTHROPIC_AUTH_TOKEN");
|
std::env::remove_var("ANTHROPIC_AUTH_TOKEN");
|
||||||
@@ -841,7 +721,7 @@ mod tests {
|
|||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn auth_source_from_env_combines_api_key_and_bearer_token() {
|
fn auth_source_from_env_combines_api_key_and_bearer_token() {
|
||||||
let _guard = test_env_lock();
|
let _guard = env_lock();
|
||||||
std::env::set_var("ANTHROPIC_AUTH_TOKEN", "auth-token");
|
std::env::set_var("ANTHROPIC_AUTH_TOKEN", "auth-token");
|
||||||
std::env::set_var("ANTHROPIC_API_KEY", "legacy-key");
|
std::env::set_var("ANTHROPIC_API_KEY", "legacy-key");
|
||||||
let auth = AuthSource::from_env().expect("env auth");
|
let auth = AuthSource::from_env().expect("env auth");
|
||||||
@@ -853,7 +733,7 @@ mod tests {
|
|||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn auth_source_from_saved_oauth_when_env_absent() {
|
fn auth_source_from_saved_oauth_when_env_absent() {
|
||||||
let _guard = test_env_lock();
|
let _guard = env_lock();
|
||||||
let config_home = temp_config_home();
|
let config_home = temp_config_home();
|
||||||
std::env::set_var("CLAUDE_CONFIG_HOME", &config_home);
|
std::env::set_var("CLAUDE_CONFIG_HOME", &config_home);
|
||||||
std::env::remove_var("ANTHROPIC_AUTH_TOKEN");
|
std::env::remove_var("ANTHROPIC_AUTH_TOKEN");
|
||||||
@@ -892,7 +772,7 @@ mod tests {
|
|||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn resolve_saved_oauth_token_refreshes_expired_credentials() {
|
fn resolve_saved_oauth_token_refreshes_expired_credentials() {
|
||||||
let _guard = test_env_lock();
|
let _guard = env_lock();
|
||||||
let config_home = temp_config_home();
|
let config_home = temp_config_home();
|
||||||
std::env::set_var("CLAUDE_CONFIG_HOME", &config_home);
|
std::env::set_var("CLAUDE_CONFIG_HOME", &config_home);
|
||||||
std::env::remove_var("ANTHROPIC_AUTH_TOKEN");
|
std::env::remove_var("ANTHROPIC_AUTH_TOKEN");
|
||||||
@@ -924,7 +804,7 @@ mod tests {
|
|||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn resolve_startup_auth_source_uses_saved_oauth_without_loading_config() {
|
fn resolve_startup_auth_source_uses_saved_oauth_without_loading_config() {
|
||||||
let _guard = test_env_lock();
|
let _guard = env_lock();
|
||||||
let config_home = temp_config_home();
|
let config_home = temp_config_home();
|
||||||
std::env::set_var("CLAUDE_CONFIG_HOME", &config_home);
|
std::env::set_var("CLAUDE_CONFIG_HOME", &config_home);
|
||||||
std::env::remove_var("ANTHROPIC_AUTH_TOKEN");
|
std::env::remove_var("ANTHROPIC_AUTH_TOKEN");
|
||||||
@@ -948,7 +828,7 @@ mod tests {
|
|||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn resolve_startup_auth_source_errors_when_refreshable_token_lacks_config() {
|
fn resolve_startup_auth_source_errors_when_refreshable_token_lacks_config() {
|
||||||
let _guard = test_env_lock();
|
let _guard = env_lock();
|
||||||
let config_home = temp_config_home();
|
let config_home = temp_config_home();
|
||||||
std::env::set_var("CLAUDE_CONFIG_HOME", &config_home);
|
std::env::set_var("CLAUDE_CONFIG_HOME", &config_home);
|
||||||
std::env::remove_var("ANTHROPIC_AUTH_TOKEN");
|
std::env::remove_var("ANTHROPIC_AUTH_TOKEN");
|
||||||
@@ -980,7 +860,7 @@ mod tests {
|
|||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn resolve_saved_oauth_token_preserves_refresh_token_when_refresh_response_omits_it() {
|
fn resolve_saved_oauth_token_preserves_refresh_token_when_refresh_response_omits_it() {
|
||||||
let _guard = test_env_lock();
|
let _guard = env_lock();
|
||||||
let config_home = temp_config_home();
|
let config_home = temp_config_home();
|
||||||
std::env::set_var("CLAUDE_CONFIG_HOME", &config_home);
|
std::env::set_var("CLAUDE_CONFIG_HOME", &config_home);
|
||||||
std::env::remove_var("ANTHROPIC_AUTH_TOKEN");
|
std::env::remove_var("ANTHROPIC_AUTH_TOKEN");
|
||||||
|
|||||||
@@ -1,6 +1,5 @@
|
|||||||
mod client;
|
mod client;
|
||||||
mod error;
|
mod error;
|
||||||
mod prompt_cache;
|
|
||||||
mod sse;
|
mod sse;
|
||||||
mod types;
|
mod types;
|
||||||
|
|
||||||
@@ -9,10 +8,6 @@ pub use client::{
|
|||||||
AnthropicClient, AuthSource, MessageStream, OAuthTokenSet,
|
AnthropicClient, AuthSource, MessageStream, OAuthTokenSet,
|
||||||
};
|
};
|
||||||
pub use error::ApiError;
|
pub use error::ApiError;
|
||||||
pub use prompt_cache::{
|
|
||||||
CacheBreakEvent, PromptCache, PromptCacheConfig, PromptCachePaths, PromptCacheRecord,
|
|
||||||
PromptCacheStats,
|
|
||||||
};
|
|
||||||
pub use sse::{parse_frame, SseParser};
|
pub use sse::{parse_frame, SseParser};
|
||||||
pub use types::{
|
pub use types::{
|
||||||
ContentBlockDelta, ContentBlockDeltaEvent, ContentBlockStartEvent, ContentBlockStopEvent,
|
ContentBlockDelta, ContentBlockDeltaEvent, ContentBlockStartEvent, ContentBlockStopEvent,
|
||||||
@@ -20,11 +15,3 @@ pub use types::{
|
|||||||
MessageResponse, MessageStartEvent, MessageStopEvent, OutputContentBlock, StreamEvent,
|
MessageResponse, MessageStartEvent, MessageStopEvent, OutputContentBlock, StreamEvent,
|
||||||
ToolChoice, ToolDefinition, ToolResultContentBlock, Usage,
|
ToolChoice, ToolDefinition, ToolResultContentBlock, Usage,
|
||||||
};
|
};
|
||||||
|
|
||||||
#[cfg(test)]
|
|
||||||
pub(crate) fn test_env_lock() -> std::sync::MutexGuard<'static, ()> {
|
|
||||||
static LOCK: std::sync::OnceLock<std::sync::Mutex<()>> = std::sync::OnceLock::new();
|
|
||||||
LOCK.get_or_init(|| std::sync::Mutex::new(()))
|
|
||||||
.lock()
|
|
||||||
.unwrap_or_else(std::sync::PoisonError::into_inner)
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -1,727 +0,0 @@
|
|||||||
use std::fs;
|
|
||||||
use std::path::{Path, PathBuf};
|
|
||||||
use std::sync::{Arc, Mutex};
|
|
||||||
use std::time::{Duration, SystemTime, UNIX_EPOCH};
|
|
||||||
|
|
||||||
use serde::{Deserialize, Serialize};
|
|
||||||
|
|
||||||
use crate::types::{MessageRequest, MessageResponse, Usage};
|
|
||||||
|
|
||||||
const DEFAULT_COMPLETION_TTL_SECS: u64 = 30;
|
|
||||||
const DEFAULT_PROMPT_TTL_SECS: u64 = 5 * 60;
|
|
||||||
const DEFAULT_BREAK_MIN_DROP: u32 = 2_000;
|
|
||||||
const MAX_SANITIZED_LENGTH: usize = 80;
|
|
||||||
const REQUEST_FINGERPRINT_VERSION: u32 = 1;
|
|
||||||
const REQUEST_FINGERPRINT_PREFIX: &str = "v1";
|
|
||||||
const FNV_OFFSET_BASIS: u64 = 0xcbf2_9ce4_8422_2325;
|
|
||||||
const FNV_PRIME: u64 = 0x0000_0100_0000_01b3;
|
|
||||||
|
|
||||||
#[derive(Debug, Clone)]
|
|
||||||
pub struct PromptCacheConfig {
|
|
||||||
pub session_id: String,
|
|
||||||
pub completion_ttl: Duration,
|
|
||||||
pub prompt_ttl: Duration,
|
|
||||||
pub cache_break_min_drop: u32,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl PromptCacheConfig {
|
|
||||||
#[must_use]
|
|
||||||
pub fn new(session_id: impl Into<String>) -> Self {
|
|
||||||
Self {
|
|
||||||
session_id: session_id.into(),
|
|
||||||
completion_ttl: Duration::from_secs(DEFAULT_COMPLETION_TTL_SECS),
|
|
||||||
prompt_ttl: Duration::from_secs(DEFAULT_PROMPT_TTL_SECS),
|
|
||||||
cache_break_min_drop: DEFAULT_BREAK_MIN_DROP,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
impl Default for PromptCacheConfig {
|
|
||||||
fn default() -> Self {
|
|
||||||
Self::new("default")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
|
|
||||||
pub struct PromptCachePaths {
|
|
||||||
pub root: PathBuf,
|
|
||||||
pub session_dir: PathBuf,
|
|
||||||
pub completion_dir: PathBuf,
|
|
||||||
pub session_state_path: PathBuf,
|
|
||||||
pub stats_path: PathBuf,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl PromptCachePaths {
|
|
||||||
#[must_use]
|
|
||||||
pub fn for_session(session_id: &str) -> Self {
|
|
||||||
let root = base_cache_root();
|
|
||||||
let session_dir = root.join(sanitize_path_segment(session_id));
|
|
||||||
let completion_dir = session_dir.join("completions");
|
|
||||||
Self {
|
|
||||||
root,
|
|
||||||
session_state_path: session_dir.join("session-state.json"),
|
|
||||||
stats_path: session_dir.join("stats.json"),
|
|
||||||
session_dir,
|
|
||||||
completion_dir,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
|
||||||
pub fn completion_entry_path(&self, request_hash: &str) -> PathBuf {
|
|
||||||
self.completion_dir.join(format!("{request_hash}.json"))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug, Clone, Default, PartialEq, Eq, Serialize, Deserialize)]
|
|
||||||
pub struct PromptCacheStats {
|
|
||||||
pub tracked_requests: u64,
|
|
||||||
pub completion_cache_hits: u64,
|
|
||||||
pub completion_cache_misses: u64,
|
|
||||||
pub completion_cache_writes: u64,
|
|
||||||
pub expected_invalidations: u64,
|
|
||||||
pub unexpected_cache_breaks: u64,
|
|
||||||
pub total_cache_creation_input_tokens: u64,
|
|
||||||
pub total_cache_read_input_tokens: u64,
|
|
||||||
pub last_cache_creation_input_tokens: Option<u32>,
|
|
||||||
pub last_cache_read_input_tokens: Option<u32>,
|
|
||||||
pub last_request_hash: Option<String>,
|
|
||||||
pub last_completion_cache_key: Option<String>,
|
|
||||||
pub last_break_reason: Option<String>,
|
|
||||||
pub last_cache_source: Option<String>,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
|
|
||||||
pub struct CacheBreakEvent {
|
|
||||||
pub unexpected: bool,
|
|
||||||
pub reason: String,
|
|
||||||
pub previous_cache_read_input_tokens: u32,
|
|
||||||
pub current_cache_read_input_tokens: u32,
|
|
||||||
pub token_drop: u32,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug, Clone, PartialEq, Eq)]
|
|
||||||
pub struct PromptCacheRecord {
|
|
||||||
pub cache_break: Option<CacheBreakEvent>,
|
|
||||||
pub stats: PromptCacheStats,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug, Clone)]
|
|
||||||
pub struct PromptCache {
|
|
||||||
inner: Arc<Mutex<PromptCacheInner>>,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl PromptCache {
|
|
||||||
#[must_use]
|
|
||||||
pub fn new(session_id: impl Into<String>) -> Self {
|
|
||||||
Self::with_config(PromptCacheConfig::new(session_id))
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
|
||||||
pub fn with_config(config: PromptCacheConfig) -> Self {
|
|
||||||
let paths = PromptCachePaths::for_session(&config.session_id);
|
|
||||||
let stats = read_json::<PromptCacheStats>(&paths.stats_path).unwrap_or_default();
|
|
||||||
let previous = read_json::<TrackedPromptState>(&paths.session_state_path);
|
|
||||||
Self {
|
|
||||||
inner: Arc::new(Mutex::new(PromptCacheInner {
|
|
||||||
config,
|
|
||||||
paths,
|
|
||||||
stats,
|
|
||||||
previous,
|
|
||||||
})),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
|
||||||
pub fn paths(&self) -> PromptCachePaths {
|
|
||||||
self.lock().paths.clone()
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
|
||||||
pub fn stats(&self) -> PromptCacheStats {
|
|
||||||
self.lock().stats.clone()
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
|
||||||
pub fn lookup_completion(&self, request: &MessageRequest) -> Option<MessageResponse> {
|
|
||||||
let request_hash = request_hash_hex(request);
|
|
||||||
let (paths, ttl) = {
|
|
||||||
let inner = self.lock();
|
|
||||||
(inner.paths.clone(), inner.config.completion_ttl)
|
|
||||||
};
|
|
||||||
let entry_path = paths.completion_entry_path(&request_hash);
|
|
||||||
let entry = read_json::<CompletionCacheEntry>(&entry_path);
|
|
||||||
let Some(entry) = entry else {
|
|
||||||
let mut inner = self.lock();
|
|
||||||
inner.stats.completion_cache_misses += 1;
|
|
||||||
inner.stats.last_completion_cache_key = Some(request_hash);
|
|
||||||
persist_state(&inner);
|
|
||||||
return None;
|
|
||||||
};
|
|
||||||
|
|
||||||
if entry.fingerprint_version != current_fingerprint_version() {
|
|
||||||
let mut inner = self.lock();
|
|
||||||
inner.stats.completion_cache_misses += 1;
|
|
||||||
inner.stats.last_completion_cache_key = Some(request_hash.clone());
|
|
||||||
let _ = fs::remove_file(entry_path);
|
|
||||||
persist_state(&inner);
|
|
||||||
return None;
|
|
||||||
}
|
|
||||||
|
|
||||||
let expired = now_unix_secs().saturating_sub(entry.cached_at_unix_secs) >= ttl.as_secs();
|
|
||||||
let mut inner = self.lock();
|
|
||||||
inner.stats.last_completion_cache_key = Some(request_hash.clone());
|
|
||||||
if expired {
|
|
||||||
inner.stats.completion_cache_misses += 1;
|
|
||||||
let _ = fs::remove_file(entry_path);
|
|
||||||
persist_state(&inner);
|
|
||||||
return None;
|
|
||||||
}
|
|
||||||
|
|
||||||
inner.stats.completion_cache_hits += 1;
|
|
||||||
apply_usage_to_stats(
|
|
||||||
&mut inner.stats,
|
|
||||||
&entry.response.usage,
|
|
||||||
&request_hash,
|
|
||||||
"completion-cache",
|
|
||||||
);
|
|
||||||
inner.previous = Some(TrackedPromptState::from_usage(
|
|
||||||
request,
|
|
||||||
&entry.response.usage,
|
|
||||||
));
|
|
||||||
persist_state(&inner);
|
|
||||||
Some(entry.response)
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
|
||||||
pub fn record_response(
|
|
||||||
&self,
|
|
||||||
request: &MessageRequest,
|
|
||||||
response: &MessageResponse,
|
|
||||||
) -> PromptCacheRecord {
|
|
||||||
self.record_usage_internal(request, &response.usage, Some(response))
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
|
||||||
pub fn record_usage(&self, request: &MessageRequest, usage: &Usage) -> PromptCacheRecord {
|
|
||||||
self.record_usage_internal(request, usage, None)
|
|
||||||
}
|
|
||||||
|
|
||||||
fn record_usage_internal(
|
|
||||||
&self,
|
|
||||||
request: &MessageRequest,
|
|
||||||
usage: &Usage,
|
|
||||||
response: Option<&MessageResponse>,
|
|
||||||
) -> PromptCacheRecord {
|
|
||||||
let request_hash = request_hash_hex(request);
|
|
||||||
let mut inner = self.lock();
|
|
||||||
let previous = inner.previous.clone();
|
|
||||||
let current = TrackedPromptState::from_usage(request, usage);
|
|
||||||
let cache_break = detect_cache_break(&inner.config, previous.as_ref(), ¤t);
|
|
||||||
|
|
||||||
inner.stats.tracked_requests += 1;
|
|
||||||
apply_usage_to_stats(&mut inner.stats, usage, &request_hash, "api-response");
|
|
||||||
if let Some(event) = &cache_break {
|
|
||||||
if event.unexpected {
|
|
||||||
inner.stats.unexpected_cache_breaks += 1;
|
|
||||||
} else {
|
|
||||||
inner.stats.expected_invalidations += 1;
|
|
||||||
}
|
|
||||||
inner.stats.last_break_reason = Some(event.reason.clone());
|
|
||||||
}
|
|
||||||
|
|
||||||
inner.previous = Some(current);
|
|
||||||
if let Some(response) = response {
|
|
||||||
write_completion_entry(&inner.paths, &request_hash, response);
|
|
||||||
inner.stats.completion_cache_writes += 1;
|
|
||||||
}
|
|
||||||
persist_state(&inner);
|
|
||||||
|
|
||||||
PromptCacheRecord {
|
|
||||||
cache_break,
|
|
||||||
stats: inner.stats.clone(),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
fn lock(&self) -> std::sync::MutexGuard<'_, PromptCacheInner> {
|
|
||||||
self.inner
|
|
||||||
.lock()
|
|
||||||
.unwrap_or_else(std::sync::PoisonError::into_inner)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug)]
|
|
||||||
struct PromptCacheInner {
|
|
||||||
config: PromptCacheConfig,
|
|
||||||
paths: PromptCachePaths,
|
|
||||||
stats: PromptCacheStats,
|
|
||||||
previous: Option<TrackedPromptState>,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug, Clone, Serialize, Deserialize)]
|
|
||||||
struct CompletionCacheEntry {
|
|
||||||
cached_at_unix_secs: u64,
|
|
||||||
#[serde(default = "current_fingerprint_version")]
|
|
||||||
fingerprint_version: u32,
|
|
||||||
response: MessageResponse,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
|
|
||||||
struct TrackedPromptState {
|
|
||||||
observed_at_unix_secs: u64,
|
|
||||||
#[serde(default = "current_fingerprint_version")]
|
|
||||||
fingerprint_version: u32,
|
|
||||||
model_hash: u64,
|
|
||||||
system_hash: u64,
|
|
||||||
tools_hash: u64,
|
|
||||||
messages_hash: u64,
|
|
||||||
cache_read_input_tokens: u32,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl TrackedPromptState {
|
|
||||||
fn from_usage(request: &MessageRequest, usage: &Usage) -> Self {
|
|
||||||
let hashes = RequestFingerprints::from_request(request);
|
|
||||||
Self {
|
|
||||||
observed_at_unix_secs: now_unix_secs(),
|
|
||||||
fingerprint_version: current_fingerprint_version(),
|
|
||||||
model_hash: hashes.model,
|
|
||||||
system_hash: hashes.system,
|
|
||||||
tools_hash: hashes.tools,
|
|
||||||
messages_hash: hashes.messages,
|
|
||||||
cache_read_input_tokens: usage.cache_read_input_tokens,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug, Clone, Copy)]
|
|
||||||
struct RequestFingerprints {
|
|
||||||
model: u64,
|
|
||||||
system: u64,
|
|
||||||
tools: u64,
|
|
||||||
messages: u64,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl RequestFingerprints {
|
|
||||||
fn from_request(request: &MessageRequest) -> Self {
|
|
||||||
Self {
|
|
||||||
model: hash_serializable(&request.model),
|
|
||||||
system: hash_serializable(&request.system),
|
|
||||||
tools: hash_serializable(&request.tools),
|
|
||||||
messages: hash_serializable(&request.messages),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
fn detect_cache_break(
|
|
||||||
config: &PromptCacheConfig,
|
|
||||||
previous: Option<&TrackedPromptState>,
|
|
||||||
current: &TrackedPromptState,
|
|
||||||
) -> Option<CacheBreakEvent> {
|
|
||||||
let previous = previous?;
|
|
||||||
if previous.fingerprint_version != current.fingerprint_version {
|
|
||||||
return Some(CacheBreakEvent {
|
|
||||||
unexpected: false,
|
|
||||||
reason: format!(
|
|
||||||
"fingerprint version changed (v{} -> v{})",
|
|
||||||
previous.fingerprint_version, current.fingerprint_version
|
|
||||||
),
|
|
||||||
previous_cache_read_input_tokens: previous.cache_read_input_tokens,
|
|
||||||
current_cache_read_input_tokens: current.cache_read_input_tokens,
|
|
||||||
token_drop: previous
|
|
||||||
.cache_read_input_tokens
|
|
||||||
.saturating_sub(current.cache_read_input_tokens),
|
|
||||||
});
|
|
||||||
}
|
|
||||||
let token_drop = previous
|
|
||||||
.cache_read_input_tokens
|
|
||||||
.saturating_sub(current.cache_read_input_tokens);
|
|
||||||
if token_drop < config.cache_break_min_drop {
|
|
||||||
return None;
|
|
||||||
}
|
|
||||||
|
|
||||||
let mut reasons = Vec::new();
|
|
||||||
if previous.model_hash != current.model_hash {
|
|
||||||
reasons.push("model changed");
|
|
||||||
}
|
|
||||||
if previous.system_hash != current.system_hash {
|
|
||||||
reasons.push("system prompt changed");
|
|
||||||
}
|
|
||||||
if previous.tools_hash != current.tools_hash {
|
|
||||||
reasons.push("tool definitions changed");
|
|
||||||
}
|
|
||||||
if previous.messages_hash != current.messages_hash {
|
|
||||||
reasons.push("message payload changed");
|
|
||||||
}
|
|
||||||
|
|
||||||
let elapsed = current
|
|
||||||
.observed_at_unix_secs
|
|
||||||
.saturating_sub(previous.observed_at_unix_secs);
|
|
||||||
|
|
||||||
let (unexpected, reason) = if reasons.is_empty() {
|
|
||||||
if elapsed > config.prompt_ttl.as_secs() {
|
|
||||||
(
|
|
||||||
false,
|
|
||||||
format!("possible prompt cache TTL expiry after {elapsed}s"),
|
|
||||||
)
|
|
||||||
} else {
|
|
||||||
(
|
|
||||||
true,
|
|
||||||
"cache read tokens dropped while prompt fingerprint remained stable".to_string(),
|
|
||||||
)
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
(false, reasons.join(", "))
|
|
||||||
};
|
|
||||||
|
|
||||||
Some(CacheBreakEvent {
|
|
||||||
unexpected,
|
|
||||||
reason,
|
|
||||||
previous_cache_read_input_tokens: previous.cache_read_input_tokens,
|
|
||||||
current_cache_read_input_tokens: current.cache_read_input_tokens,
|
|
||||||
token_drop,
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn apply_usage_to_stats(
|
|
||||||
stats: &mut PromptCacheStats,
|
|
||||||
usage: &Usage,
|
|
||||||
request_hash: &str,
|
|
||||||
source: &str,
|
|
||||||
) {
|
|
||||||
stats.total_cache_creation_input_tokens += u64::from(usage.cache_creation_input_tokens);
|
|
||||||
stats.total_cache_read_input_tokens += u64::from(usage.cache_read_input_tokens);
|
|
||||||
stats.last_cache_creation_input_tokens = Some(usage.cache_creation_input_tokens);
|
|
||||||
stats.last_cache_read_input_tokens = Some(usage.cache_read_input_tokens);
|
|
||||||
stats.last_request_hash = Some(request_hash.to_string());
|
|
||||||
stats.last_cache_source = Some(source.to_string());
|
|
||||||
}
|
|
||||||
|
|
||||||
fn persist_state(inner: &PromptCacheInner) {
|
|
||||||
let _ = ensure_cache_dirs(&inner.paths);
|
|
||||||
let _ = write_json(&inner.paths.stats_path, &inner.stats);
|
|
||||||
if let Some(previous) = &inner.previous {
|
|
||||||
let _ = write_json(&inner.paths.session_state_path, previous);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
fn write_completion_entry(
|
|
||||||
paths: &PromptCachePaths,
|
|
||||||
request_hash: &str,
|
|
||||||
response: &MessageResponse,
|
|
||||||
) {
|
|
||||||
let _ = ensure_cache_dirs(paths);
|
|
||||||
let entry = CompletionCacheEntry {
|
|
||||||
cached_at_unix_secs: now_unix_secs(),
|
|
||||||
fingerprint_version: current_fingerprint_version(),
|
|
||||||
response: response.clone(),
|
|
||||||
};
|
|
||||||
let _ = write_json(&paths.completion_entry_path(request_hash), &entry);
|
|
||||||
}
|
|
||||||
|
|
||||||
fn ensure_cache_dirs(paths: &PromptCachePaths) -> std::io::Result<()> {
|
|
||||||
fs::create_dir_all(&paths.completion_dir)
|
|
||||||
}
|
|
||||||
|
|
||||||
fn write_json<T: Serialize>(path: &Path, value: &T) -> std::io::Result<()> {
|
|
||||||
let json = serde_json::to_vec_pretty(value)
|
|
||||||
.map_err(|error| std::io::Error::new(std::io::ErrorKind::InvalidData, error))?;
|
|
||||||
fs::write(path, json)
|
|
||||||
}
|
|
||||||
|
|
||||||
fn read_json<T: for<'de> Deserialize<'de>>(path: &Path) -> Option<T> {
|
|
||||||
let bytes = fs::read(path).ok()?;
|
|
||||||
serde_json::from_slice(&bytes).ok()
|
|
||||||
}
|
|
||||||
|
|
||||||
fn request_hash_hex(request: &MessageRequest) -> String {
|
|
||||||
format!(
|
|
||||||
"{REQUEST_FINGERPRINT_PREFIX}-{:016x}",
|
|
||||||
hash_serializable(request)
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
fn hash_serializable<T: Serialize>(value: &T) -> u64 {
|
|
||||||
let json = serde_json::to_vec(value).unwrap_or_default();
|
|
||||||
stable_hash_bytes(&json)
|
|
||||||
}
|
|
||||||
|
|
||||||
fn sanitize_path_segment(value: &str) -> String {
|
|
||||||
let sanitized: String = value
|
|
||||||
.chars()
|
|
||||||
.map(|ch| if ch.is_ascii_alphanumeric() { ch } else { '-' })
|
|
||||||
.collect();
|
|
||||||
if sanitized.len() <= MAX_SANITIZED_LENGTH {
|
|
||||||
return sanitized;
|
|
||||||
}
|
|
||||||
let suffix = format!("-{:x}", hash_string(value));
|
|
||||||
format!(
|
|
||||||
"{}{}",
|
|
||||||
&sanitized[..MAX_SANITIZED_LENGTH.saturating_sub(suffix.len())],
|
|
||||||
suffix
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
fn hash_string(value: &str) -> u64 {
|
|
||||||
stable_hash_bytes(value.as_bytes())
|
|
||||||
}
|
|
||||||
|
|
||||||
fn base_cache_root() -> PathBuf {
|
|
||||||
if let Some(config_home) = std::env::var_os("CLAUDE_CONFIG_HOME") {
|
|
||||||
return PathBuf::from(config_home)
|
|
||||||
.join("cache")
|
|
||||||
.join("prompt-cache");
|
|
||||||
}
|
|
||||||
if let Some(home) = std::env::var_os("HOME") {
|
|
||||||
return PathBuf::from(home)
|
|
||||||
.join(".claude")
|
|
||||||
.join("cache")
|
|
||||||
.join("prompt-cache");
|
|
||||||
}
|
|
||||||
std::env::temp_dir().join("claude-prompt-cache")
|
|
||||||
}
|
|
||||||
|
|
||||||
fn now_unix_secs() -> u64 {
|
|
||||||
SystemTime::now()
|
|
||||||
.duration_since(UNIX_EPOCH)
|
|
||||||
.map_or(0, |duration| duration.as_secs())
|
|
||||||
}
|
|
||||||
|
|
||||||
const fn current_fingerprint_version() -> u32 {
|
|
||||||
REQUEST_FINGERPRINT_VERSION
|
|
||||||
}
|
|
||||||
|
|
||||||
fn stable_hash_bytes(bytes: &[u8]) -> u64 {
|
|
||||||
let mut hash = FNV_OFFSET_BASIS;
|
|
||||||
for byte in bytes {
|
|
||||||
hash ^= u64::from(*byte);
|
|
||||||
hash = hash.wrapping_mul(FNV_PRIME);
|
|
||||||
}
|
|
||||||
hash
|
|
||||||
}
|
|
||||||
|
|
||||||
#[cfg(test)]
|
|
||||||
mod tests {
|
|
||||||
use std::time::{Duration, SystemTime, UNIX_EPOCH};
|
|
||||||
|
|
||||||
use super::{
|
|
||||||
detect_cache_break, read_json, request_hash_hex, sanitize_path_segment, PromptCache,
|
|
||||||
PromptCacheConfig, PromptCachePaths, TrackedPromptState, REQUEST_FINGERPRINT_PREFIX,
|
|
||||||
};
|
|
||||||
use crate::test_env_lock;
|
|
||||||
use crate::types::{InputMessage, MessageRequest, MessageResponse, OutputContentBlock, Usage};
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
fn path_builder_sanitizes_session_identifier() {
|
|
||||||
let paths = PromptCachePaths::for_session("session:/with spaces");
|
|
||||||
let session_dir = paths
|
|
||||||
.session_dir
|
|
||||||
.file_name()
|
|
||||||
.and_then(|value| value.to_str())
|
|
||||||
.expect("session dir name");
|
|
||||||
assert_eq!(session_dir, "session--with-spaces");
|
|
||||||
assert!(paths.completion_dir.ends_with("completions"));
|
|
||||||
assert!(paths.stats_path.ends_with("stats.json"));
|
|
||||||
assert!(paths.session_state_path.ends_with("session-state.json"));
|
|
||||||
}
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
fn request_fingerprint_drives_unexpected_break_detection() {
|
|
||||||
let request = sample_request("same");
|
|
||||||
let previous = TrackedPromptState::from_usage(
|
|
||||||
&request,
|
|
||||||
&Usage {
|
|
||||||
input_tokens: 0,
|
|
||||||
cache_creation_input_tokens: 0,
|
|
||||||
cache_read_input_tokens: 6_000,
|
|
||||||
output_tokens: 0,
|
|
||||||
},
|
|
||||||
);
|
|
||||||
let current = TrackedPromptState::from_usage(
|
|
||||||
&request,
|
|
||||||
&Usage {
|
|
||||||
input_tokens: 0,
|
|
||||||
cache_creation_input_tokens: 0,
|
|
||||||
cache_read_input_tokens: 1_000,
|
|
||||||
output_tokens: 0,
|
|
||||||
},
|
|
||||||
);
|
|
||||||
let event = detect_cache_break(&PromptCacheConfig::default(), Some(&previous), ¤t)
|
|
||||||
.expect("break should be detected");
|
|
||||||
assert!(event.unexpected);
|
|
||||||
assert!(event.reason.contains("stable"));
|
|
||||||
}
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
fn changed_prompt_marks_break_as_expected() {
|
|
||||||
let previous_request = sample_request("first");
|
|
||||||
let current_request = sample_request("second");
|
|
||||||
let previous = TrackedPromptState::from_usage(
|
|
||||||
&previous_request,
|
|
||||||
&Usage {
|
|
||||||
input_tokens: 0,
|
|
||||||
cache_creation_input_tokens: 0,
|
|
||||||
cache_read_input_tokens: 6_000,
|
|
||||||
output_tokens: 0,
|
|
||||||
},
|
|
||||||
);
|
|
||||||
let current = TrackedPromptState::from_usage(
|
|
||||||
¤t_request,
|
|
||||||
&Usage {
|
|
||||||
input_tokens: 0,
|
|
||||||
cache_creation_input_tokens: 0,
|
|
||||||
cache_read_input_tokens: 1_000,
|
|
||||||
output_tokens: 0,
|
|
||||||
},
|
|
||||||
);
|
|
||||||
let event = detect_cache_break(&PromptCacheConfig::default(), Some(&previous), ¤t)
|
|
||||||
.expect("break should be detected");
|
|
||||||
assert!(!event.unexpected);
|
|
||||||
assert!(event.reason.contains("message payload changed"));
|
|
||||||
}
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
fn completion_cache_round_trip_persists_recent_response() {
|
|
||||||
let _guard = test_env_lock();
|
|
||||||
let temp_root = std::env::temp_dir().join(format!(
|
|
||||||
"prompt-cache-test-{}-{}",
|
|
||||||
std::process::id(),
|
|
||||||
SystemTime::now()
|
|
||||||
.duration_since(UNIX_EPOCH)
|
|
||||||
.expect("time")
|
|
||||||
.as_nanos()
|
|
||||||
));
|
|
||||||
std::env::set_var("CLAUDE_CONFIG_HOME", &temp_root);
|
|
||||||
let cache = PromptCache::new("unit-test-session");
|
|
||||||
let request = sample_request("cache me");
|
|
||||||
let response = sample_response(42, 12, "cached");
|
|
||||||
|
|
||||||
assert!(cache.lookup_completion(&request).is_none());
|
|
||||||
let record = cache.record_response(&request, &response);
|
|
||||||
assert!(record.cache_break.is_none());
|
|
||||||
|
|
||||||
let cached = cache
|
|
||||||
.lookup_completion(&request)
|
|
||||||
.expect("cached response should load");
|
|
||||||
assert_eq!(cached.content, response.content);
|
|
||||||
|
|
||||||
let stats = cache.stats();
|
|
||||||
assert_eq!(stats.completion_cache_hits, 1);
|
|
||||||
assert_eq!(stats.completion_cache_misses, 1);
|
|
||||||
assert_eq!(stats.completion_cache_writes, 1);
|
|
||||||
|
|
||||||
let persisted = read_json::<super::PromptCacheStats>(&cache.paths().stats_path)
|
|
||||||
.expect("stats should persist");
|
|
||||||
assert_eq!(persisted.completion_cache_hits, 1);
|
|
||||||
|
|
||||||
std::fs::remove_dir_all(temp_root).expect("cleanup temp root");
|
|
||||||
std::env::remove_var("CLAUDE_CONFIG_HOME");
|
|
||||||
}
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
fn distinct_requests_do_not_collide_in_completion_cache() {
|
|
||||||
let _guard = test_env_lock();
|
|
||||||
let temp_root = std::env::temp_dir().join(format!(
|
|
||||||
"prompt-cache-distinct-{}-{}",
|
|
||||||
std::process::id(),
|
|
||||||
SystemTime::now()
|
|
||||||
.duration_since(UNIX_EPOCH)
|
|
||||||
.expect("time")
|
|
||||||
.as_nanos()
|
|
||||||
));
|
|
||||||
std::env::set_var("CLAUDE_CONFIG_HOME", &temp_root);
|
|
||||||
let cache = PromptCache::new("distinct-request-session");
|
|
||||||
let first_request = sample_request("first");
|
|
||||||
let second_request = sample_request("second");
|
|
||||||
|
|
||||||
let response = sample_response(42, 12, "cached");
|
|
||||||
let _ = cache.record_response(&first_request, &response);
|
|
||||||
|
|
||||||
assert!(cache.lookup_completion(&second_request).is_none());
|
|
||||||
|
|
||||||
std::fs::remove_dir_all(temp_root).expect("cleanup temp root");
|
|
||||||
std::env::remove_var("CLAUDE_CONFIG_HOME");
|
|
||||||
}
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
fn expired_completion_entries_are_not_reused() {
|
|
||||||
let _guard = test_env_lock();
|
|
||||||
let temp_root = std::env::temp_dir().join(format!(
|
|
||||||
"prompt-cache-expired-{}-{}",
|
|
||||||
std::process::id(),
|
|
||||||
SystemTime::now()
|
|
||||||
.duration_since(UNIX_EPOCH)
|
|
||||||
.expect("time")
|
|
||||||
.as_nanos()
|
|
||||||
));
|
|
||||||
std::env::set_var("CLAUDE_CONFIG_HOME", &temp_root);
|
|
||||||
let cache = PromptCache::with_config(PromptCacheConfig {
|
|
||||||
session_id: "expired-session".to_string(),
|
|
||||||
completion_ttl: Duration::ZERO,
|
|
||||||
..PromptCacheConfig::default()
|
|
||||||
});
|
|
||||||
let request = sample_request("expire me");
|
|
||||||
let response = sample_response(7, 3, "stale");
|
|
||||||
|
|
||||||
let _ = cache.record_response(&request, &response);
|
|
||||||
|
|
||||||
assert!(cache.lookup_completion(&request).is_none());
|
|
||||||
let stats = cache.stats();
|
|
||||||
assert_eq!(stats.completion_cache_hits, 0);
|
|
||||||
assert_eq!(stats.completion_cache_misses, 1);
|
|
||||||
|
|
||||||
std::fs::remove_dir_all(temp_root).expect("cleanup temp root");
|
|
||||||
std::env::remove_var("CLAUDE_CONFIG_HOME");
|
|
||||||
}
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
fn sanitize_path_caps_long_values() {
|
|
||||||
let long_value = "x".repeat(200);
|
|
||||||
let sanitized = sanitize_path_segment(&long_value);
|
|
||||||
assert!(sanitized.len() <= 80);
|
|
||||||
}
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
fn request_hashes_are_versioned_and_stable() {
|
|
||||||
let request = sample_request("stable");
|
|
||||||
let first = request_hash_hex(&request);
|
|
||||||
let second = request_hash_hex(&request);
|
|
||||||
assert_eq!(first, second);
|
|
||||||
assert!(first.starts_with(REQUEST_FINGERPRINT_PREFIX));
|
|
||||||
}
|
|
||||||
|
|
||||||
fn sample_request(text: &str) -> MessageRequest {
|
|
||||||
MessageRequest {
|
|
||||||
model: "claude-3-7-sonnet-latest".to_string(),
|
|
||||||
max_tokens: 64,
|
|
||||||
messages: vec![InputMessage::user_text(text)],
|
|
||||||
system: Some("system".to_string()),
|
|
||||||
tools: None,
|
|
||||||
tool_choice: None,
|
|
||||||
stream: false,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
fn sample_response(
|
|
||||||
cache_read_input_tokens: u32,
|
|
||||||
output_tokens: u32,
|
|
||||||
text: &str,
|
|
||||||
) -> MessageResponse {
|
|
||||||
MessageResponse {
|
|
||||||
id: "msg_test".to_string(),
|
|
||||||
kind: "message".to_string(),
|
|
||||||
role: "assistant".to_string(),
|
|
||||||
content: vec![OutputContentBlock::Text {
|
|
||||||
text: text.to_string(),
|
|
||||||
}],
|
|
||||||
model: "claude-3-7-sonnet-latest".to_string(),
|
|
||||||
stop_reason: Some("end_turn".to_string()),
|
|
||||||
stop_sequence: None,
|
|
||||||
usage: Usage {
|
|
||||||
input_tokens: 10,
|
|
||||||
cache_creation_input_tokens: 5,
|
|
||||||
cache_read_input_tokens,
|
|
||||||
output_tokens,
|
|
||||||
},
|
|
||||||
request_id: Some("req_test".to_string()),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -1,25 +1,17 @@
|
|||||||
use std::collections::HashMap;
|
use std::collections::HashMap;
|
||||||
use std::sync::Arc;
|
use std::sync::Arc;
|
||||||
use std::sync::{Mutex as StdMutex, OnceLock};
|
|
||||||
use std::time::Duration;
|
use std::time::Duration;
|
||||||
|
|
||||||
use api::{
|
use api::{
|
||||||
AnthropicClient, ApiError, ContentBlockDelta, ContentBlockDeltaEvent, ContentBlockStartEvent,
|
AnthropicClient, ApiError, ContentBlockDelta, ContentBlockDeltaEvent, ContentBlockStartEvent,
|
||||||
InputContentBlock, InputMessage, MessageDeltaEvent, MessageRequest, OutputContentBlock,
|
InputContentBlock, InputMessage, MessageDeltaEvent, MessageRequest, OutputContentBlock,
|
||||||
PromptCache, StreamEvent, ToolChoice, ToolDefinition,
|
StreamEvent, ToolChoice, ToolDefinition,
|
||||||
};
|
};
|
||||||
use serde_json::json;
|
use serde_json::json;
|
||||||
use tokio::io::{AsyncReadExt, AsyncWriteExt};
|
use tokio::io::{AsyncReadExt, AsyncWriteExt};
|
||||||
use tokio::net::TcpListener;
|
use tokio::net::TcpListener;
|
||||||
use tokio::sync::Mutex;
|
use tokio::sync::Mutex;
|
||||||
|
|
||||||
fn env_lock() -> std::sync::MutexGuard<'static, ()> {
|
|
||||||
static LOCK: OnceLock<StdMutex<()>> = OnceLock::new();
|
|
||||||
LOCK.get_or_init(|| StdMutex::new(()))
|
|
||||||
.lock()
|
|
||||||
.unwrap_or_else(std::sync::PoisonError::into_inner)
|
|
||||||
}
|
|
||||||
|
|
||||||
#[tokio::test]
|
#[tokio::test]
|
||||||
async fn send_message_posts_json_and_parses_response() {
|
async fn send_message_posts_json_and_parses_response() {
|
||||||
let state = Arc::new(Mutex::new(Vec::<CapturedRequest>::new()));
|
let state = Arc::new(Mutex::new(Vec::<CapturedRequest>::new()));
|
||||||
@@ -53,8 +45,6 @@ async fn send_message_posts_json_and_parses_response() {
|
|||||||
assert_eq!(response.id, "msg_test");
|
assert_eq!(response.id, "msg_test");
|
||||||
assert_eq!(response.total_tokens(), 16);
|
assert_eq!(response.total_tokens(), 16);
|
||||||
assert_eq!(response.request_id.as_deref(), Some("req_body_123"));
|
assert_eq!(response.request_id.as_deref(), Some("req_body_123"));
|
||||||
assert_eq!(response.usage.cache_creation_input_tokens, 0);
|
|
||||||
assert_eq!(response.usage.cache_read_input_tokens, 0);
|
|
||||||
assert_eq!(
|
assert_eq!(
|
||||||
response.content,
|
response.content,
|
||||||
vec![OutputContentBlock::Text {
|
vec![OutputContentBlock::Text {
|
||||||
@@ -86,55 +76,11 @@ async fn send_message_posts_json_and_parses_response() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
#[tokio::test]
|
#[tokio::test]
|
||||||
async fn send_message_parses_prompt_cache_token_usage_from_response() {
|
|
||||||
let state = Arc::new(Mutex::new(Vec::<CapturedRequest>::new()));
|
|
||||||
let body = concat!(
|
|
||||||
"{",
|
|
||||||
"\"id\":\"msg_cache_tokens\",",
|
|
||||||
"\"type\":\"message\",",
|
|
||||||
"\"role\":\"assistant\",",
|
|
||||||
"\"content\":[{\"type\":\"text\",\"text\":\"Cache tokens\"}],",
|
|
||||||
"\"model\":\"claude-3-7-sonnet-latest\",",
|
|
||||||
"\"stop_reason\":\"end_turn\",",
|
|
||||||
"\"stop_sequence\":null,",
|
|
||||||
"\"usage\":{\"input_tokens\":12,\"cache_creation_input_tokens\":321,\"cache_read_input_tokens\":654,\"output_tokens\":4}",
|
|
||||||
"}"
|
|
||||||
);
|
|
||||||
let server = spawn_server(
|
|
||||||
state,
|
|
||||||
vec![http_response("200 OK", "application/json", body)],
|
|
||||||
)
|
|
||||||
.await;
|
|
||||||
|
|
||||||
let client = AnthropicClient::new("test-key").with_base_url(server.base_url());
|
|
||||||
let response = client
|
|
||||||
.send_message(&sample_request(false))
|
|
||||||
.await
|
|
||||||
.expect("request should succeed");
|
|
||||||
|
|
||||||
assert_eq!(response.usage.input_tokens, 12);
|
|
||||||
assert_eq!(response.usage.cache_creation_input_tokens, 321);
|
|
||||||
assert_eq!(response.usage.cache_read_input_tokens, 654);
|
|
||||||
assert_eq!(response.usage.output_tokens, 4);
|
|
||||||
}
|
|
||||||
|
|
||||||
#[tokio::test]
|
|
||||||
#[allow(clippy::await_holding_lock)]
|
|
||||||
async fn stream_message_parses_sse_events_with_tool_use() {
|
async fn stream_message_parses_sse_events_with_tool_use() {
|
||||||
let _guard = env_lock();
|
|
||||||
let temp_root = std::env::temp_dir().join(format!(
|
|
||||||
"api-stream-cache-{}-{}",
|
|
||||||
std::process::id(),
|
|
||||||
std::time::SystemTime::now()
|
|
||||||
.duration_since(std::time::UNIX_EPOCH)
|
|
||||||
.expect("time")
|
|
||||||
.as_nanos()
|
|
||||||
));
|
|
||||||
std::env::set_var("CLAUDE_CONFIG_HOME", &temp_root);
|
|
||||||
let state = Arc::new(Mutex::new(Vec::<CapturedRequest>::new()));
|
let state = Arc::new(Mutex::new(Vec::<CapturedRequest>::new()));
|
||||||
let sse = concat!(
|
let sse = concat!(
|
||||||
"event: message_start\n",
|
"event: message_start\n",
|
||||||
"data: {\"type\":\"message_start\",\"message\":{\"id\":\"msg_stream\",\"type\":\"message\",\"role\":\"assistant\",\"content\":[],\"model\":\"claude-3-7-sonnet-latest\",\"stop_reason\":null,\"stop_sequence\":null,\"usage\":{\"input_tokens\":8,\"cache_creation_input_tokens\":13,\"cache_read_input_tokens\":21,\"output_tokens\":0}}}\n\n",
|
"data: {\"type\":\"message_start\",\"message\":{\"id\":\"msg_stream\",\"type\":\"message\",\"role\":\"assistant\",\"content\":[],\"model\":\"claude-3-7-sonnet-latest\",\"stop_reason\":null,\"stop_sequence\":null,\"usage\":{\"input_tokens\":8,\"output_tokens\":0}}}\n\n",
|
||||||
"event: content_block_start\n",
|
"event: content_block_start\n",
|
||||||
"data: {\"type\":\"content_block_start\",\"index\":0,\"content_block\":{\"type\":\"tool_use\",\"id\":\"toolu_123\",\"name\":\"get_weather\",\"input\":{}}}\n\n",
|
"data: {\"type\":\"content_block_start\",\"index\":0,\"content_block\":{\"type\":\"tool_use\",\"id\":\"toolu_123\",\"name\":\"get_weather\",\"input\":{}}}\n\n",
|
||||||
"event: content_block_delta\n",
|
"event: content_block_delta\n",
|
||||||
@@ -142,7 +88,7 @@ async fn stream_message_parses_sse_events_with_tool_use() {
|
|||||||
"event: content_block_stop\n",
|
"event: content_block_stop\n",
|
||||||
"data: {\"type\":\"content_block_stop\",\"index\":0}\n\n",
|
"data: {\"type\":\"content_block_stop\",\"index\":0}\n\n",
|
||||||
"event: message_delta\n",
|
"event: message_delta\n",
|
||||||
"data: {\"type\":\"message_delta\",\"delta\":{\"stop_reason\":\"tool_use\",\"stop_sequence\":null},\"usage\":{\"input_tokens\":8,\"cache_creation_input_tokens\":34,\"cache_read_input_tokens\":55,\"output_tokens\":1}}\n\n",
|
"data: {\"type\":\"message_delta\",\"delta\":{\"stop_reason\":\"tool_use\",\"stop_sequence\":null},\"usage\":{\"input_tokens\":8,\"output_tokens\":1}}\n\n",
|
||||||
"event: message_stop\n",
|
"event: message_stop\n",
|
||||||
"data: {\"type\":\"message_stop\"}\n\n",
|
"data: {\"type\":\"message_stop\"}\n\n",
|
||||||
"data: [DONE]\n\n"
|
"data: [DONE]\n\n"
|
||||||
@@ -160,8 +106,7 @@ async fn stream_message_parses_sse_events_with_tool_use() {
|
|||||||
|
|
||||||
let client = AnthropicClient::new("test-key")
|
let client = AnthropicClient::new("test-key")
|
||||||
.with_auth_token(Some("proxy-token".to_string()))
|
.with_auth_token(Some("proxy-token".to_string()))
|
||||||
.with_base_url(server.base_url())
|
.with_base_url(server.base_url());
|
||||||
.with_prompt_cache(PromptCache::new("stream-session"));
|
|
||||||
let mut stream = client
|
let mut stream = client
|
||||||
.stream_message(&sample_request(false))
|
.stream_message(&sample_request(false))
|
||||||
.await
|
.await
|
||||||
@@ -215,20 +160,6 @@ async fn stream_message_parses_sse_events_with_tool_use() {
|
|||||||
let captured = state.lock().await;
|
let captured = state.lock().await;
|
||||||
let request = captured.first().expect("server should capture request");
|
let request = captured.first().expect("server should capture request");
|
||||||
assert!(request.body.contains("\"stream\":true"));
|
assert!(request.body.contains("\"stream\":true"));
|
||||||
|
|
||||||
let cache_stats = client
|
|
||||||
.prompt_cache_stats()
|
|
||||||
.expect("prompt cache stats should exist");
|
|
||||||
assert_eq!(cache_stats.tracked_requests, 1);
|
|
||||||
assert_eq!(cache_stats.last_cache_creation_input_tokens, Some(34));
|
|
||||||
assert_eq!(cache_stats.last_cache_read_input_tokens, Some(55));
|
|
||||||
assert_eq!(
|
|
||||||
cache_stats.last_cache_source.as_deref(),
|
|
||||||
Some("api-response")
|
|
||||||
);
|
|
||||||
|
|
||||||
std::fs::remove_dir_all(temp_root).expect("cleanup temp root");
|
|
||||||
std::env::remove_var("CLAUDE_CONFIG_HOME");
|
|
||||||
}
|
}
|
||||||
|
|
||||||
#[tokio::test]
|
#[tokio::test]
|
||||||
@@ -312,121 +243,6 @@ async fn surfaces_retry_exhaustion_for_persistent_retryable_errors() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
#[tokio::test]
|
|
||||||
#[allow(clippy::await_holding_lock)]
|
|
||||||
async fn send_message_reuses_recent_completion_cache_entries() {
|
|
||||||
let _guard = env_lock();
|
|
||||||
let temp_root = std::env::temp_dir().join(format!(
|
|
||||||
"api-prompt-cache-{}-{}",
|
|
||||||
std::process::id(),
|
|
||||||
std::time::SystemTime::now()
|
|
||||||
.duration_since(std::time::UNIX_EPOCH)
|
|
||||||
.expect("time")
|
|
||||||
.as_nanos()
|
|
||||||
));
|
|
||||||
std::env::set_var("CLAUDE_CONFIG_HOME", &temp_root);
|
|
||||||
|
|
||||||
let state = Arc::new(Mutex::new(Vec::<CapturedRequest>::new()));
|
|
||||||
let server = spawn_server(
|
|
||||||
state.clone(),
|
|
||||||
vec![http_response(
|
|
||||||
"200 OK",
|
|
||||||
"application/json",
|
|
||||||
"{\"id\":\"msg_cached\",\"type\":\"message\",\"role\":\"assistant\",\"content\":[{\"type\":\"text\",\"text\":\"Cached once\"}],\"model\":\"claude-3-7-sonnet-latest\",\"stop_reason\":\"end_turn\",\"stop_sequence\":null,\"usage\":{\"input_tokens\":3,\"cache_creation_input_tokens\":5,\"cache_read_input_tokens\":4000,\"output_tokens\":2}}",
|
|
||||||
)],
|
|
||||||
)
|
|
||||||
.await;
|
|
||||||
|
|
||||||
let client = AnthropicClient::new("test-key")
|
|
||||||
.with_base_url(server.base_url())
|
|
||||||
.with_prompt_cache(PromptCache::new("integration-session"));
|
|
||||||
|
|
||||||
let first = client
|
|
||||||
.send_message(&sample_request(false))
|
|
||||||
.await
|
|
||||||
.expect("first request should succeed");
|
|
||||||
let second = client
|
|
||||||
.send_message(&sample_request(false))
|
|
||||||
.await
|
|
||||||
.expect("second request should reuse cache");
|
|
||||||
|
|
||||||
assert_eq!(first.content, second.content);
|
|
||||||
assert_eq!(state.lock().await.len(), 1);
|
|
||||||
|
|
||||||
let cache_stats = client
|
|
||||||
.prompt_cache_stats()
|
|
||||||
.expect("prompt cache stats should exist");
|
|
||||||
assert_eq!(cache_stats.completion_cache_hits, 1);
|
|
||||||
assert_eq!(cache_stats.completion_cache_misses, 1);
|
|
||||||
assert_eq!(cache_stats.completion_cache_writes, 1);
|
|
||||||
|
|
||||||
std::fs::remove_dir_all(temp_root).expect("cleanup temp root");
|
|
||||||
std::env::remove_var("CLAUDE_CONFIG_HOME");
|
|
||||||
}
|
|
||||||
|
|
||||||
#[tokio::test]
|
|
||||||
#[allow(clippy::await_holding_lock)]
|
|
||||||
async fn send_message_tracks_unexpected_prompt_cache_breaks() {
|
|
||||||
let _guard = env_lock();
|
|
||||||
let temp_root = std::env::temp_dir().join(format!(
|
|
||||||
"api-prompt-break-{}-{}",
|
|
||||||
std::process::id(),
|
|
||||||
std::time::SystemTime::now()
|
|
||||||
.duration_since(std::time::UNIX_EPOCH)
|
|
||||||
.expect("time")
|
|
||||||
.as_nanos()
|
|
||||||
));
|
|
||||||
std::env::set_var("CLAUDE_CONFIG_HOME", &temp_root);
|
|
||||||
|
|
||||||
let state = Arc::new(Mutex::new(Vec::<CapturedRequest>::new()));
|
|
||||||
let server = spawn_server(
|
|
||||||
state,
|
|
||||||
vec![
|
|
||||||
http_response(
|
|
||||||
"200 OK",
|
|
||||||
"application/json",
|
|
||||||
"{\"id\":\"msg_one\",\"type\":\"message\",\"role\":\"assistant\",\"content\":[{\"type\":\"text\",\"text\":\"One\"}],\"model\":\"claude-3-7-sonnet-latest\",\"stop_reason\":\"end_turn\",\"stop_sequence\":null,\"usage\":{\"input_tokens\":3,\"cache_creation_input_tokens\":5,\"cache_read_input_tokens\":6000,\"output_tokens\":2}}",
|
|
||||||
),
|
|
||||||
http_response(
|
|
||||||
"200 OK",
|
|
||||||
"application/json",
|
|
||||||
"{\"id\":\"msg_two\",\"type\":\"message\",\"role\":\"assistant\",\"content\":[{\"type\":\"text\",\"text\":\"Two\"}],\"model\":\"claude-3-7-sonnet-latest\",\"stop_reason\":\"end_turn\",\"stop_sequence\":null,\"usage\":{\"input_tokens\":3,\"cache_creation_input_tokens\":0,\"cache_read_input_tokens\":1000,\"output_tokens\":2}}",
|
|
||||||
),
|
|
||||||
],
|
|
||||||
)
|
|
||||||
.await;
|
|
||||||
|
|
||||||
let request = sample_request(false);
|
|
||||||
let client = AnthropicClient::new("test-key")
|
|
||||||
.with_base_url(server.base_url())
|
|
||||||
.with_prompt_cache(PromptCache::with_config(api::PromptCacheConfig {
|
|
||||||
session_id: "break-session".to_string(),
|
|
||||||
completion_ttl: Duration::from_secs(0),
|
|
||||||
..api::PromptCacheConfig::default()
|
|
||||||
}));
|
|
||||||
|
|
||||||
client
|
|
||||||
.send_message(&request)
|
|
||||||
.await
|
|
||||||
.expect("first response should succeed");
|
|
||||||
client
|
|
||||||
.send_message(&request)
|
|
||||||
.await
|
|
||||||
.expect("second response should succeed");
|
|
||||||
|
|
||||||
let cache_stats = client
|
|
||||||
.prompt_cache_stats()
|
|
||||||
.expect("prompt cache stats should exist");
|
|
||||||
assert_eq!(cache_stats.unexpected_cache_breaks, 1);
|
|
||||||
assert_eq!(
|
|
||||||
cache_stats.last_break_reason.as_deref(),
|
|
||||||
Some("cache read tokens dropped while prompt fingerprint remained stable")
|
|
||||||
);
|
|
||||||
|
|
||||||
std::fs::remove_dir_all(temp_root).expect("cleanup temp root");
|
|
||||||
std::env::remove_var("CLAUDE_CONFIG_HOME");
|
|
||||||
}
|
|
||||||
|
|
||||||
#[tokio::test]
|
#[tokio::test]
|
||||||
#[ignore = "requires ANTHROPIC_API_KEY and network access"]
|
#[ignore = "requires ANTHROPIC_API_KEY and network access"]
|
||||||
async fn live_stream_smoke_test() {
|
async fn live_stream_smoke_test() {
|
||||||
|
|||||||
@@ -117,6 +117,48 @@ const SLASH_COMMAND_SPECS: &[SlashCommandSpec] = &[
|
|||||||
argument_hint: None,
|
argument_hint: None,
|
||||||
resume_supported: true,
|
resume_supported: true,
|
||||||
},
|
},
|
||||||
|
SlashCommandSpec {
|
||||||
|
name: "bughunter",
|
||||||
|
summary: "Inspect the codebase for likely bugs",
|
||||||
|
argument_hint: Some("[scope]"),
|
||||||
|
resume_supported: false,
|
||||||
|
},
|
||||||
|
SlashCommandSpec {
|
||||||
|
name: "commit",
|
||||||
|
summary: "Generate a commit message and create a git commit",
|
||||||
|
argument_hint: None,
|
||||||
|
resume_supported: false,
|
||||||
|
},
|
||||||
|
SlashCommandSpec {
|
||||||
|
name: "pr",
|
||||||
|
summary: "Draft or create a pull request from the conversation",
|
||||||
|
argument_hint: Some("[context]"),
|
||||||
|
resume_supported: false,
|
||||||
|
},
|
||||||
|
SlashCommandSpec {
|
||||||
|
name: "issue",
|
||||||
|
summary: "Draft or create a GitHub issue from the conversation",
|
||||||
|
argument_hint: Some("[context]"),
|
||||||
|
resume_supported: false,
|
||||||
|
},
|
||||||
|
SlashCommandSpec {
|
||||||
|
name: "ultraplan",
|
||||||
|
summary: "Run a deep planning prompt with multi-step reasoning",
|
||||||
|
argument_hint: Some("[task]"),
|
||||||
|
resume_supported: false,
|
||||||
|
},
|
||||||
|
SlashCommandSpec {
|
||||||
|
name: "teleport",
|
||||||
|
summary: "Jump to a file or symbol by searching the workspace",
|
||||||
|
argument_hint: Some("<symbol-or-path>"),
|
||||||
|
resume_supported: false,
|
||||||
|
},
|
||||||
|
SlashCommandSpec {
|
||||||
|
name: "debug-tool-call",
|
||||||
|
summary: "Replay the last tool call with debug details",
|
||||||
|
argument_hint: None,
|
||||||
|
resume_supported: false,
|
||||||
|
},
|
||||||
SlashCommandSpec {
|
SlashCommandSpec {
|
||||||
name: "export",
|
name: "export",
|
||||||
summary: "Export the current conversation to a file",
|
summary: "Export the current conversation to a file",
|
||||||
@@ -136,6 +178,23 @@ pub enum SlashCommand {
|
|||||||
Help,
|
Help,
|
||||||
Status,
|
Status,
|
||||||
Compact,
|
Compact,
|
||||||
|
Bughunter {
|
||||||
|
scope: Option<String>,
|
||||||
|
},
|
||||||
|
Commit,
|
||||||
|
Pr {
|
||||||
|
context: Option<String>,
|
||||||
|
},
|
||||||
|
Issue {
|
||||||
|
context: Option<String>,
|
||||||
|
},
|
||||||
|
Ultraplan {
|
||||||
|
task: Option<String>,
|
||||||
|
},
|
||||||
|
Teleport {
|
||||||
|
target: Option<String>,
|
||||||
|
},
|
||||||
|
DebugToolCall,
|
||||||
Model {
|
Model {
|
||||||
model: Option<String>,
|
model: Option<String>,
|
||||||
},
|
},
|
||||||
@@ -180,6 +239,23 @@ impl SlashCommand {
|
|||||||
"help" => Self::Help,
|
"help" => Self::Help,
|
||||||
"status" => Self::Status,
|
"status" => Self::Status,
|
||||||
"compact" => Self::Compact,
|
"compact" => Self::Compact,
|
||||||
|
"bughunter" => Self::Bughunter {
|
||||||
|
scope: remainder_after_command(trimmed, command),
|
||||||
|
},
|
||||||
|
"commit" => Self::Commit,
|
||||||
|
"pr" => Self::Pr {
|
||||||
|
context: remainder_after_command(trimmed, command),
|
||||||
|
},
|
||||||
|
"issue" => Self::Issue {
|
||||||
|
context: remainder_after_command(trimmed, command),
|
||||||
|
},
|
||||||
|
"ultraplan" => Self::Ultraplan {
|
||||||
|
task: remainder_after_command(trimmed, command),
|
||||||
|
},
|
||||||
|
"teleport" => Self::Teleport {
|
||||||
|
target: remainder_after_command(trimmed, command),
|
||||||
|
},
|
||||||
|
"debug-tool-call" => Self::DebugToolCall,
|
||||||
"model" => Self::Model {
|
"model" => Self::Model {
|
||||||
model: parts.next().map(ToOwned::to_owned),
|
model: parts.next().map(ToOwned::to_owned),
|
||||||
},
|
},
|
||||||
@@ -212,6 +288,15 @@ impl SlashCommand {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fn remainder_after_command(input: &str, command: &str) -> Option<String> {
|
||||||
|
input
|
||||||
|
.trim()
|
||||||
|
.strip_prefix(&format!("/{command}"))
|
||||||
|
.map(str::trim)
|
||||||
|
.filter(|value| !value.is_empty())
|
||||||
|
.map(ToOwned::to_owned)
|
||||||
|
}
|
||||||
|
|
||||||
#[must_use]
|
#[must_use]
|
||||||
pub fn slash_command_specs() -> &'static [SlashCommandSpec] {
|
pub fn slash_command_specs() -> &'static [SlashCommandSpec] {
|
||||||
SLASH_COMMAND_SPECS
|
SLASH_COMMAND_SPECS
|
||||||
@@ -279,6 +364,13 @@ pub fn handle_slash_command(
|
|||||||
session: session.clone(),
|
session: session.clone(),
|
||||||
}),
|
}),
|
||||||
SlashCommand::Status
|
SlashCommand::Status
|
||||||
|
| SlashCommand::Bughunter { .. }
|
||||||
|
| SlashCommand::Commit
|
||||||
|
| SlashCommand::Pr { .. }
|
||||||
|
| SlashCommand::Issue { .. }
|
||||||
|
| SlashCommand::Ultraplan { .. }
|
||||||
|
| SlashCommand::Teleport { .. }
|
||||||
|
| SlashCommand::DebugToolCall
|
||||||
| SlashCommand::Model { .. }
|
| SlashCommand::Model { .. }
|
||||||
| SlashCommand::Permissions { .. }
|
| SlashCommand::Permissions { .. }
|
||||||
| SlashCommand::Clear { .. }
|
| SlashCommand::Clear { .. }
|
||||||
@@ -307,6 +399,41 @@ mod tests {
|
|||||||
fn parses_supported_slash_commands() {
|
fn parses_supported_slash_commands() {
|
||||||
assert_eq!(SlashCommand::parse("/help"), Some(SlashCommand::Help));
|
assert_eq!(SlashCommand::parse("/help"), Some(SlashCommand::Help));
|
||||||
assert_eq!(SlashCommand::parse(" /status "), Some(SlashCommand::Status));
|
assert_eq!(SlashCommand::parse(" /status "), Some(SlashCommand::Status));
|
||||||
|
assert_eq!(
|
||||||
|
SlashCommand::parse("/bughunter runtime"),
|
||||||
|
Some(SlashCommand::Bughunter {
|
||||||
|
scope: Some("runtime".to_string())
|
||||||
|
})
|
||||||
|
);
|
||||||
|
assert_eq!(SlashCommand::parse("/commit"), Some(SlashCommand::Commit));
|
||||||
|
assert_eq!(
|
||||||
|
SlashCommand::parse("/pr ready for review"),
|
||||||
|
Some(SlashCommand::Pr {
|
||||||
|
context: Some("ready for review".to_string())
|
||||||
|
})
|
||||||
|
);
|
||||||
|
assert_eq!(
|
||||||
|
SlashCommand::parse("/issue flaky test"),
|
||||||
|
Some(SlashCommand::Issue {
|
||||||
|
context: Some("flaky test".to_string())
|
||||||
|
})
|
||||||
|
);
|
||||||
|
assert_eq!(
|
||||||
|
SlashCommand::parse("/ultraplan ship both features"),
|
||||||
|
Some(SlashCommand::Ultraplan {
|
||||||
|
task: Some("ship both features".to_string())
|
||||||
|
})
|
||||||
|
);
|
||||||
|
assert_eq!(
|
||||||
|
SlashCommand::parse("/teleport conversation.rs"),
|
||||||
|
Some(SlashCommand::Teleport {
|
||||||
|
target: Some("conversation.rs".to_string())
|
||||||
|
})
|
||||||
|
);
|
||||||
|
assert_eq!(
|
||||||
|
SlashCommand::parse("/debug-tool-call"),
|
||||||
|
Some(SlashCommand::DebugToolCall)
|
||||||
|
);
|
||||||
assert_eq!(
|
assert_eq!(
|
||||||
SlashCommand::parse("/model claude-opus"),
|
SlashCommand::parse("/model claude-opus"),
|
||||||
Some(SlashCommand::Model {
|
Some(SlashCommand::Model {
|
||||||
@@ -374,6 +501,13 @@ mod tests {
|
|||||||
assert!(help.contains("/help"));
|
assert!(help.contains("/help"));
|
||||||
assert!(help.contains("/status"));
|
assert!(help.contains("/status"));
|
||||||
assert!(help.contains("/compact"));
|
assert!(help.contains("/compact"));
|
||||||
|
assert!(help.contains("/bughunter [scope]"));
|
||||||
|
assert!(help.contains("/commit"));
|
||||||
|
assert!(help.contains("/pr [context]"));
|
||||||
|
assert!(help.contains("/issue [context]"));
|
||||||
|
assert!(help.contains("/ultraplan [task]"));
|
||||||
|
assert!(help.contains("/teleport <symbol-or-path>"));
|
||||||
|
assert!(help.contains("/debug-tool-call"));
|
||||||
assert!(help.contains("/model [model]"));
|
assert!(help.contains("/model [model]"));
|
||||||
assert!(help.contains("/permissions [read-only|workspace-write|danger-full-access]"));
|
assert!(help.contains("/permissions [read-only|workspace-write|danger-full-access]"));
|
||||||
assert!(help.contains("/clear [--confirm]"));
|
assert!(help.contains("/clear [--confirm]"));
|
||||||
@@ -386,7 +520,7 @@ mod tests {
|
|||||||
assert!(help.contains("/version"));
|
assert!(help.contains("/version"));
|
||||||
assert!(help.contains("/export [file]"));
|
assert!(help.contains("/export [file]"));
|
||||||
assert!(help.contains("/session [list|switch <session-id>]"));
|
assert!(help.contains("/session [list|switch <session-id>]"));
|
||||||
assert_eq!(slash_command_specs().len(), 15);
|
assert_eq!(slash_command_specs().len(), 22);
|
||||||
assert_eq!(resume_supported_slash_commands().len(), 11);
|
assert_eq!(resume_supported_slash_commands().len(), 11);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -434,6 +568,22 @@ mod tests {
|
|||||||
let session = Session::new();
|
let session = Session::new();
|
||||||
assert!(handle_slash_command("/unknown", &session, CompactionConfig::default()).is_none());
|
assert!(handle_slash_command("/unknown", &session, CompactionConfig::default()).is_none());
|
||||||
assert!(handle_slash_command("/status", &session, CompactionConfig::default()).is_none());
|
assert!(handle_slash_command("/status", &session, CompactionConfig::default()).is_none());
|
||||||
|
assert!(
|
||||||
|
handle_slash_command("/bughunter", &session, CompactionConfig::default()).is_none()
|
||||||
|
);
|
||||||
|
assert!(handle_slash_command("/commit", &session, CompactionConfig::default()).is_none());
|
||||||
|
assert!(handle_slash_command("/pr", &session, CompactionConfig::default()).is_none());
|
||||||
|
assert!(handle_slash_command("/issue", &session, CompactionConfig::default()).is_none());
|
||||||
|
assert!(
|
||||||
|
handle_slash_command("/ultraplan", &session, CompactionConfig::default()).is_none()
|
||||||
|
);
|
||||||
|
assert!(
|
||||||
|
handle_slash_command("/teleport foo", &session, CompactionConfig::default()).is_none()
|
||||||
|
);
|
||||||
|
assert!(
|
||||||
|
handle_slash_command("/debug-tool-call", &session, CompactionConfig::default())
|
||||||
|
.is_none()
|
||||||
|
);
|
||||||
assert!(
|
assert!(
|
||||||
handle_slash_command("/model claude", &session, CompactionConfig::default()).is_none()
|
handle_slash_command("/model claude", &session, CompactionConfig::default()).is_none()
|
||||||
);
|
);
|
||||||
|
|||||||
@@ -37,7 +37,6 @@ pub struct RuntimeConfig {
|
|||||||
|
|
||||||
#[derive(Debug, Clone, PartialEq, Eq, Default)]
|
#[derive(Debug, Clone, PartialEq, Eq, Default)]
|
||||||
pub struct RuntimeFeatureConfig {
|
pub struct RuntimeFeatureConfig {
|
||||||
hooks: RuntimeHookConfig,
|
|
||||||
mcp: McpConfigCollection,
|
mcp: McpConfigCollection,
|
||||||
oauth: Option<OAuthConfig>,
|
oauth: Option<OAuthConfig>,
|
||||||
model: Option<String>,
|
model: Option<String>,
|
||||||
@@ -45,12 +44,6 @@ pub struct RuntimeFeatureConfig {
|
|||||||
sandbox: SandboxConfig,
|
sandbox: SandboxConfig,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Clone, PartialEq, Eq, Default)]
|
|
||||||
pub struct RuntimeHookConfig {
|
|
||||||
pre_tool_use: Vec<String>,
|
|
||||||
post_tool_use: Vec<String>,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug, Clone, PartialEq, Eq, Default)]
|
#[derive(Debug, Clone, PartialEq, Eq, Default)]
|
||||||
pub struct McpConfigCollection {
|
pub struct McpConfigCollection {
|
||||||
servers: BTreeMap<String, ScopedMcpServerConfig>,
|
servers: BTreeMap<String, ScopedMcpServerConfig>,
|
||||||
@@ -228,7 +221,6 @@ impl ConfigLoader {
|
|||||||
let merged_value = JsonValue::Object(merged.clone());
|
let merged_value = JsonValue::Object(merged.clone());
|
||||||
|
|
||||||
let feature_config = RuntimeFeatureConfig {
|
let feature_config = RuntimeFeatureConfig {
|
||||||
hooks: parse_optional_hooks_config(&merged_value)?,
|
|
||||||
mcp: McpConfigCollection {
|
mcp: McpConfigCollection {
|
||||||
servers: mcp_servers,
|
servers: mcp_servers,
|
||||||
},
|
},
|
||||||
@@ -286,11 +278,6 @@ impl RuntimeConfig {
|
|||||||
&self.feature_config.mcp
|
&self.feature_config.mcp
|
||||||
}
|
}
|
||||||
|
|
||||||
#[must_use]
|
|
||||||
pub fn hooks(&self) -> &RuntimeHookConfig {
|
|
||||||
&self.feature_config.hooks
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
#[must_use]
|
||||||
pub fn oauth(&self) -> Option<&OAuthConfig> {
|
pub fn oauth(&self) -> Option<&OAuthConfig> {
|
||||||
self.feature_config.oauth.as_ref()
|
self.feature_config.oauth.as_ref()
|
||||||
@@ -313,17 +300,6 @@ impl RuntimeConfig {
|
|||||||
}
|
}
|
||||||
|
|
||||||
impl RuntimeFeatureConfig {
|
impl RuntimeFeatureConfig {
|
||||||
#[must_use]
|
|
||||||
pub fn with_hooks(mut self, hooks: RuntimeHookConfig) -> Self {
|
|
||||||
self.hooks = hooks;
|
|
||||||
self
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
|
||||||
pub fn hooks(&self) -> &RuntimeHookConfig {
|
|
||||||
&self.hooks
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
#[must_use]
|
||||||
pub fn mcp(&self) -> &McpConfigCollection {
|
pub fn mcp(&self) -> &McpConfigCollection {
|
||||||
&self.mcp
|
&self.mcp
|
||||||
@@ -350,26 +326,6 @@ impl RuntimeFeatureConfig {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
impl RuntimeHookConfig {
|
|
||||||
#[must_use]
|
|
||||||
pub fn new(pre_tool_use: Vec<String>, post_tool_use: Vec<String>) -> Self {
|
|
||||||
Self {
|
|
||||||
pre_tool_use,
|
|
||||||
post_tool_use,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
|
||||||
pub fn pre_tool_use(&self) -> &[String] {
|
|
||||||
&self.pre_tool_use
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
|
||||||
pub fn post_tool_use(&self) -> &[String] {
|
|
||||||
&self.post_tool_use
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
impl McpConfigCollection {
|
impl McpConfigCollection {
|
||||||
#[must_use]
|
#[must_use]
|
||||||
pub fn servers(&self) -> &BTreeMap<String, ScopedMcpServerConfig> {
|
pub fn servers(&self) -> &BTreeMap<String, ScopedMcpServerConfig> {
|
||||||
@@ -468,22 +424,6 @@ fn parse_optional_model(root: &JsonValue) -> Option<String> {
|
|||||||
.map(ToOwned::to_owned)
|
.map(ToOwned::to_owned)
|
||||||
}
|
}
|
||||||
|
|
||||||
fn parse_optional_hooks_config(root: &JsonValue) -> Result<RuntimeHookConfig, ConfigError> {
|
|
||||||
let Some(object) = root.as_object() else {
|
|
||||||
return Ok(RuntimeHookConfig::default());
|
|
||||||
};
|
|
||||||
let Some(hooks_value) = object.get("hooks") else {
|
|
||||||
return Ok(RuntimeHookConfig::default());
|
|
||||||
};
|
|
||||||
let hooks = expect_object(hooks_value, "merged settings.hooks")?;
|
|
||||||
Ok(RuntimeHookConfig {
|
|
||||||
pre_tool_use: optional_string_array(hooks, "PreToolUse", "merged settings.hooks")?
|
|
||||||
.unwrap_or_default(),
|
|
||||||
post_tool_use: optional_string_array(hooks, "PostToolUse", "merged settings.hooks")?
|
|
||||||
.unwrap_or_default(),
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn parse_optional_permission_mode(
|
fn parse_optional_permission_mode(
|
||||||
root: &JsonValue,
|
root: &JsonValue,
|
||||||
) -> Result<Option<ResolvedPermissionMode>, ConfigError> {
|
) -> Result<Option<ResolvedPermissionMode>, ConfigError> {
|
||||||
@@ -896,8 +836,6 @@ mod tests {
|
|||||||
.and_then(JsonValue::as_object)
|
.and_then(JsonValue::as_object)
|
||||||
.expect("hooks object")
|
.expect("hooks object")
|
||||||
.contains_key("PostToolUse"));
|
.contains_key("PostToolUse"));
|
||||||
assert_eq!(loaded.hooks().pre_tool_use(), &["base".to_string()]);
|
|
||||||
assert_eq!(loaded.hooks().post_tool_use(), &["project".to_string()]);
|
|
||||||
assert!(loaded.mcp().get("home").is_some());
|
assert!(loaded.mcp().get("home").is_some());
|
||||||
assert!(loaded.mcp().get("project").is_some());
|
assert!(loaded.mcp().get("project").is_some());
|
||||||
|
|
||||||
|
|||||||
@@ -4,12 +4,13 @@ use std::fmt::{Display, Formatter};
|
|||||||
use crate::compact::{
|
use crate::compact::{
|
||||||
compact_session, estimate_session_tokens, CompactionConfig, CompactionResult,
|
compact_session, estimate_session_tokens, CompactionConfig, CompactionResult,
|
||||||
};
|
};
|
||||||
use crate::config::RuntimeFeatureConfig;
|
|
||||||
use crate::hooks::{HookRunResult, HookRunner};
|
|
||||||
use crate::permissions::{PermissionOutcome, PermissionPolicy, PermissionPrompter};
|
use crate::permissions::{PermissionOutcome, PermissionPolicy, PermissionPrompter};
|
||||||
use crate::session::{ContentBlock, ConversationMessage, Session};
|
use crate::session::{ContentBlock, ConversationMessage, Session};
|
||||||
use crate::usage::{TokenUsage, UsageTracker};
|
use crate::usage::{TokenUsage, UsageTracker};
|
||||||
|
|
||||||
|
const DEFAULT_AUTO_COMPACTION_INPUT_TOKENS_THRESHOLD: u32 = 100_000;
|
||||||
|
const AUTO_COMPACTION_THRESHOLD_ENV_VAR: &str = "CLAUDE_CODE_AUTO_COMPACT_INPUT_TOKENS";
|
||||||
|
|
||||||
#[derive(Debug, Clone, PartialEq, Eq)]
|
#[derive(Debug, Clone, PartialEq, Eq)]
|
||||||
pub struct ApiRequest {
|
pub struct ApiRequest {
|
||||||
pub system_prompt: Vec<String>,
|
pub system_prompt: Vec<String>,
|
||||||
@@ -25,19 +26,9 @@ pub enum AssistantEvent {
|
|||||||
input: String,
|
input: String,
|
||||||
},
|
},
|
||||||
Usage(TokenUsage),
|
Usage(TokenUsage),
|
||||||
PromptCache(PromptCacheEvent),
|
|
||||||
MessageStop,
|
MessageStop,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Clone, PartialEq, Eq)]
|
|
||||||
pub struct PromptCacheEvent {
|
|
||||||
pub unexpected: bool,
|
|
||||||
pub reason: String,
|
|
||||||
pub previous_cache_read_input_tokens: u32,
|
|
||||||
pub current_cache_read_input_tokens: u32,
|
|
||||||
pub token_drop: u32,
|
|
||||||
}
|
|
||||||
|
|
||||||
pub trait ApiClient {
|
pub trait ApiClient {
|
||||||
fn stream(&mut self, request: ApiRequest) -> Result<Vec<AssistantEvent>, RuntimeError>;
|
fn stream(&mut self, request: ApiRequest) -> Result<Vec<AssistantEvent>, RuntimeError>;
|
||||||
}
|
}
|
||||||
@@ -94,9 +85,14 @@ impl std::error::Error for RuntimeError {}
|
|||||||
pub struct TurnSummary {
|
pub struct TurnSummary {
|
||||||
pub assistant_messages: Vec<ConversationMessage>,
|
pub assistant_messages: Vec<ConversationMessage>,
|
||||||
pub tool_results: Vec<ConversationMessage>,
|
pub tool_results: Vec<ConversationMessage>,
|
||||||
pub prompt_cache_events: Vec<PromptCacheEvent>,
|
|
||||||
pub iterations: usize,
|
pub iterations: usize,
|
||||||
pub usage: TokenUsage,
|
pub usage: TokenUsage,
|
||||||
|
pub auto_compaction: Option<AutoCompactionEvent>,
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
|
||||||
|
pub struct AutoCompactionEvent {
|
||||||
|
pub removed_message_count: usize,
|
||||||
}
|
}
|
||||||
|
|
||||||
pub struct ConversationRuntime<C, T> {
|
pub struct ConversationRuntime<C, T> {
|
||||||
@@ -107,7 +103,7 @@ pub struct ConversationRuntime<C, T> {
|
|||||||
system_prompt: Vec<String>,
|
system_prompt: Vec<String>,
|
||||||
max_iterations: usize,
|
max_iterations: usize,
|
||||||
usage_tracker: UsageTracker,
|
usage_tracker: UsageTracker,
|
||||||
hook_runner: HookRunner,
|
auto_compaction_input_tokens_threshold: u32,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl<C, T> ConversationRuntime<C, T>
|
impl<C, T> ConversationRuntime<C, T>
|
||||||
@@ -122,25 +118,6 @@ where
|
|||||||
tool_executor: T,
|
tool_executor: T,
|
||||||
permission_policy: PermissionPolicy,
|
permission_policy: PermissionPolicy,
|
||||||
system_prompt: Vec<String>,
|
system_prompt: Vec<String>,
|
||||||
) -> Self {
|
|
||||||
Self::new_with_features(
|
|
||||||
session,
|
|
||||||
api_client,
|
|
||||||
tool_executor,
|
|
||||||
permission_policy,
|
|
||||||
system_prompt,
|
|
||||||
&RuntimeFeatureConfig::default(),
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
|
||||||
pub fn new_with_features(
|
|
||||||
session: Session,
|
|
||||||
api_client: C,
|
|
||||||
tool_executor: T,
|
|
||||||
permission_policy: PermissionPolicy,
|
|
||||||
system_prompt: Vec<String>,
|
|
||||||
feature_config: &RuntimeFeatureConfig,
|
|
||||||
) -> Self {
|
) -> Self {
|
||||||
let usage_tracker = UsageTracker::from_session(&session);
|
let usage_tracker = UsageTracker::from_session(&session);
|
||||||
Self {
|
Self {
|
||||||
@@ -151,7 +128,7 @@ where
|
|||||||
system_prompt,
|
system_prompt,
|
||||||
max_iterations: usize::MAX,
|
max_iterations: usize::MAX,
|
||||||
usage_tracker,
|
usage_tracker,
|
||||||
hook_runner: HookRunner::from_feature_config(feature_config),
|
auto_compaction_input_tokens_threshold: auto_compaction_threshold_from_env(),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -161,6 +138,12 @@ where
|
|||||||
self
|
self
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[must_use]
|
||||||
|
pub fn with_auto_compaction_input_tokens_threshold(mut self, threshold: u32) -> Self {
|
||||||
|
self.auto_compaction_input_tokens_threshold = threshold;
|
||||||
|
self
|
||||||
|
}
|
||||||
|
|
||||||
pub fn run_turn(
|
pub fn run_turn(
|
||||||
&mut self,
|
&mut self,
|
||||||
user_input: impl Into<String>,
|
user_input: impl Into<String>,
|
||||||
@@ -172,7 +155,6 @@ where
|
|||||||
|
|
||||||
let mut assistant_messages = Vec::new();
|
let mut assistant_messages = Vec::new();
|
||||||
let mut tool_results = Vec::new();
|
let mut tool_results = Vec::new();
|
||||||
let mut prompt_cache_events = Vec::new();
|
|
||||||
let mut iterations = 0;
|
let mut iterations = 0;
|
||||||
|
|
||||||
loop {
|
loop {
|
||||||
@@ -188,12 +170,10 @@ where
|
|||||||
messages: self.session.messages.clone(),
|
messages: self.session.messages.clone(),
|
||||||
};
|
};
|
||||||
let events = self.api_client.stream(request)?;
|
let events = self.api_client.stream(request)?;
|
||||||
let (assistant_message, usage, turn_prompt_cache_events) =
|
let (assistant_message, usage) = build_assistant_message(events)?;
|
||||||
build_assistant_message(events)?;
|
|
||||||
if let Some(usage) = usage {
|
if let Some(usage) = usage {
|
||||||
self.usage_tracker.record(usage);
|
self.usage_tracker.record(usage);
|
||||||
}
|
}
|
||||||
prompt_cache_events.extend(turn_prompt_cache_events);
|
|
||||||
let pending_tool_uses = assistant_message
|
let pending_tool_uses = assistant_message
|
||||||
.blocks
|
.blocks
|
||||||
.iter()
|
.iter()
|
||||||
@@ -222,41 +202,19 @@ where
|
|||||||
|
|
||||||
let result_message = match permission_outcome {
|
let result_message = match permission_outcome {
|
||||||
PermissionOutcome::Allow => {
|
PermissionOutcome::Allow => {
|
||||||
let pre_hook_result = self.hook_runner.run_pre_tool_use(&tool_name, &input);
|
match self.tool_executor.execute(&tool_name, &input) {
|
||||||
if pre_hook_result.is_denied() {
|
Ok(output) => ConversationMessage::tool_result(
|
||||||
let deny_message = format!("PreToolUse hook denied tool `{tool_name}`");
|
|
||||||
ConversationMessage::tool_result(
|
|
||||||
tool_use_id,
|
tool_use_id,
|
||||||
tool_name,
|
tool_name,
|
||||||
format_hook_message(&pre_hook_result, &deny_message),
|
output,
|
||||||
|
false,
|
||||||
|
),
|
||||||
|
Err(error) => ConversationMessage::tool_result(
|
||||||
|
tool_use_id,
|
||||||
|
tool_name,
|
||||||
|
error.to_string(),
|
||||||
true,
|
true,
|
||||||
)
|
),
|
||||||
} else {
|
|
||||||
let (mut output, mut is_error) =
|
|
||||||
match self.tool_executor.execute(&tool_name, &input) {
|
|
||||||
Ok(output) => (output, false),
|
|
||||||
Err(error) => (error.to_string(), true),
|
|
||||||
};
|
|
||||||
output = merge_hook_feedback(pre_hook_result.messages(), output, false);
|
|
||||||
|
|
||||||
let post_hook_result = self
|
|
||||||
.hook_runner
|
|
||||||
.run_post_tool_use(&tool_name, &input, &output, is_error);
|
|
||||||
if post_hook_result.is_denied() {
|
|
||||||
is_error = true;
|
|
||||||
}
|
|
||||||
output = merge_hook_feedback(
|
|
||||||
post_hook_result.messages(),
|
|
||||||
output,
|
|
||||||
post_hook_result.is_denied(),
|
|
||||||
);
|
|
||||||
|
|
||||||
ConversationMessage::tool_result(
|
|
||||||
tool_use_id,
|
|
||||||
tool_name,
|
|
||||||
output,
|
|
||||||
is_error,
|
|
||||||
)
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
PermissionOutcome::Deny { reason } => {
|
PermissionOutcome::Deny { reason } => {
|
||||||
@@ -268,12 +226,14 @@ where
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
let auto_compaction = self.maybe_auto_compact();
|
||||||
|
|
||||||
Ok(TurnSummary {
|
Ok(TurnSummary {
|
||||||
assistant_messages,
|
assistant_messages,
|
||||||
tool_results,
|
tool_results,
|
||||||
prompt_cache_events,
|
|
||||||
iterations,
|
iterations,
|
||||||
usage: self.usage_tracker.cumulative_usage(),
|
usage: self.usage_tracker.cumulative_usage(),
|
||||||
|
auto_compaction,
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -301,21 +261,55 @@ where
|
|||||||
pub fn into_session(self) -> Session {
|
pub fn into_session(self) -> Session {
|
||||||
self.session
|
self.session
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fn maybe_auto_compact(&mut self) -> Option<AutoCompactionEvent> {
|
||||||
|
if self.usage_tracker.cumulative_usage().input_tokens
|
||||||
|
< self.auto_compaction_input_tokens_threshold
|
||||||
|
{
|
||||||
|
return None;
|
||||||
|
}
|
||||||
|
|
||||||
|
let result = compact_session(
|
||||||
|
&self.session,
|
||||||
|
CompactionConfig {
|
||||||
|
max_estimated_tokens: 0,
|
||||||
|
..CompactionConfig::default()
|
||||||
|
},
|
||||||
|
);
|
||||||
|
|
||||||
|
if result.removed_message_count == 0 {
|
||||||
|
return None;
|
||||||
|
}
|
||||||
|
|
||||||
|
self.session = result.compacted_session;
|
||||||
|
Some(AutoCompactionEvent {
|
||||||
|
removed_message_count: result.removed_message_count,
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#[must_use]
|
||||||
|
pub fn auto_compaction_threshold_from_env() -> u32 {
|
||||||
|
parse_auto_compaction_threshold(
|
||||||
|
std::env::var(AUTO_COMPACTION_THRESHOLD_ENV_VAR)
|
||||||
|
.ok()
|
||||||
|
.as_deref(),
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
#[must_use]
|
||||||
|
fn parse_auto_compaction_threshold(value: Option<&str>) -> u32 {
|
||||||
|
value
|
||||||
|
.and_then(|raw| raw.trim().parse::<u32>().ok())
|
||||||
|
.filter(|threshold| *threshold > 0)
|
||||||
|
.unwrap_or(DEFAULT_AUTO_COMPACTION_INPUT_TOKENS_THRESHOLD)
|
||||||
}
|
}
|
||||||
|
|
||||||
fn build_assistant_message(
|
fn build_assistant_message(
|
||||||
events: Vec<AssistantEvent>,
|
events: Vec<AssistantEvent>,
|
||||||
) -> Result<
|
) -> Result<(ConversationMessage, Option<TokenUsage>), RuntimeError> {
|
||||||
(
|
|
||||||
ConversationMessage,
|
|
||||||
Option<TokenUsage>,
|
|
||||||
Vec<PromptCacheEvent>,
|
|
||||||
),
|
|
||||||
RuntimeError,
|
|
||||||
> {
|
|
||||||
let mut text = String::new();
|
let mut text = String::new();
|
||||||
let mut blocks = Vec::new();
|
let mut blocks = Vec::new();
|
||||||
let mut prompt_cache_events = Vec::new();
|
|
||||||
let mut finished = false;
|
let mut finished = false;
|
||||||
let mut usage = None;
|
let mut usage = None;
|
||||||
|
|
||||||
@@ -327,7 +321,6 @@ fn build_assistant_message(
|
|||||||
blocks.push(ContentBlock::ToolUse { id, name, input });
|
blocks.push(ContentBlock::ToolUse { id, name, input });
|
||||||
}
|
}
|
||||||
AssistantEvent::Usage(value) => usage = Some(value),
|
AssistantEvent::Usage(value) => usage = Some(value),
|
||||||
AssistantEvent::PromptCache(event) => prompt_cache_events.push(event),
|
|
||||||
AssistantEvent::MessageStop => {
|
AssistantEvent::MessageStop => {
|
||||||
finished = true;
|
finished = true;
|
||||||
}
|
}
|
||||||
@@ -348,7 +341,6 @@ fn build_assistant_message(
|
|||||||
Ok((
|
Ok((
|
||||||
ConversationMessage::assistant_with_usage(blocks, usage),
|
ConversationMessage::assistant_with_usage(blocks, usage),
|
||||||
usage,
|
usage,
|
||||||
prompt_cache_events,
|
|
||||||
))
|
))
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -360,32 +352,6 @@ fn flush_text_block(text: &mut String, blocks: &mut Vec<ContentBlock>) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
fn format_hook_message(result: &HookRunResult, fallback: &str) -> String {
|
|
||||||
if result.messages().is_empty() {
|
|
||||||
fallback.to_string()
|
|
||||||
} else {
|
|
||||||
result.messages().join("\n")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
fn merge_hook_feedback(messages: &[String], output: String, denied: bool) -> String {
|
|
||||||
if messages.is_empty() {
|
|
||||||
return output;
|
|
||||||
}
|
|
||||||
|
|
||||||
let mut sections = Vec::new();
|
|
||||||
if !output.trim().is_empty() {
|
|
||||||
sections.push(output);
|
|
||||||
}
|
|
||||||
let label = if denied {
|
|
||||||
"Hook feedback (denied)"
|
|
||||||
} else {
|
|
||||||
"Hook feedback"
|
|
||||||
};
|
|
||||||
sections.push(format!("{label}:\n{}", messages.join("\n")));
|
|
||||||
sections.join("\n\n")
|
|
||||||
}
|
|
||||||
|
|
||||||
type ToolHandler = Box<dyn FnMut(&str) -> Result<String, ToolError>>;
|
type ToolHandler = Box<dyn FnMut(&str) -> Result<String, ToolError>>;
|
||||||
|
|
||||||
#[derive(Default)]
|
#[derive(Default)]
|
||||||
@@ -421,11 +387,11 @@ impl ToolExecutor for StaticToolExecutor {
|
|||||||
#[cfg(test)]
|
#[cfg(test)]
|
||||||
mod tests {
|
mod tests {
|
||||||
use super::{
|
use super::{
|
||||||
ApiClient, ApiRequest, AssistantEvent, ConversationRuntime, PromptCacheEvent, RuntimeError,
|
parse_auto_compaction_threshold, ApiClient, ApiRequest, AssistantEvent,
|
||||||
StaticToolExecutor,
|
AutoCompactionEvent, ConversationRuntime, RuntimeError, StaticToolExecutor,
|
||||||
|
DEFAULT_AUTO_COMPACTION_INPUT_TOKENS_THRESHOLD,
|
||||||
};
|
};
|
||||||
use crate::compact::CompactionConfig;
|
use crate::compact::CompactionConfig;
|
||||||
use crate::config::{RuntimeFeatureConfig, RuntimeHookConfig};
|
|
||||||
use crate::permissions::{
|
use crate::permissions::{
|
||||||
PermissionMode, PermissionPolicy, PermissionPromptDecision, PermissionPrompter,
|
PermissionMode, PermissionPolicy, PermissionPromptDecision, PermissionPrompter,
|
||||||
PermissionRequest,
|
PermissionRequest,
|
||||||
@@ -478,15 +444,6 @@ mod tests {
|
|||||||
cache_creation_input_tokens: 1,
|
cache_creation_input_tokens: 1,
|
||||||
cache_read_input_tokens: 3,
|
cache_read_input_tokens: 3,
|
||||||
}),
|
}),
|
||||||
AssistantEvent::PromptCache(PromptCacheEvent {
|
|
||||||
unexpected: true,
|
|
||||||
reason:
|
|
||||||
"cache read tokens dropped while prompt fingerprint remained stable"
|
|
||||||
.to_string(),
|
|
||||||
previous_cache_read_input_tokens: 6_000,
|
|
||||||
current_cache_read_input_tokens: 1_000,
|
|
||||||
token_drop: 5_000,
|
|
||||||
}),
|
|
||||||
AssistantEvent::MessageStop,
|
AssistantEvent::MessageStop,
|
||||||
])
|
])
|
||||||
}
|
}
|
||||||
@@ -540,10 +497,9 @@ mod tests {
|
|||||||
assert_eq!(summary.iterations, 2);
|
assert_eq!(summary.iterations, 2);
|
||||||
assert_eq!(summary.assistant_messages.len(), 2);
|
assert_eq!(summary.assistant_messages.len(), 2);
|
||||||
assert_eq!(summary.tool_results.len(), 1);
|
assert_eq!(summary.tool_results.len(), 1);
|
||||||
assert_eq!(summary.prompt_cache_events.len(), 1);
|
|
||||||
assert_eq!(runtime.session().messages.len(), 4);
|
assert_eq!(runtime.session().messages.len(), 4);
|
||||||
assert_eq!(summary.usage.output_tokens, 10);
|
assert_eq!(summary.usage.output_tokens, 10);
|
||||||
assert!(summary.prompt_cache_events[0].unexpected);
|
assert_eq!(summary.auto_compaction, None);
|
||||||
assert!(matches!(
|
assert!(matches!(
|
||||||
runtime.session().messages[1].blocks[1],
|
runtime.session().messages[1].blocks[1],
|
||||||
ContentBlock::ToolUse { .. }
|
ContentBlock::ToolUse { .. }
|
||||||
@@ -611,141 +567,6 @@ mod tests {
|
|||||||
));
|
));
|
||||||
}
|
}
|
||||||
|
|
||||||
#[test]
|
|
||||||
fn denies_tool_use_when_pre_tool_hook_blocks() {
|
|
||||||
struct SingleCallApiClient;
|
|
||||||
impl ApiClient for SingleCallApiClient {
|
|
||||||
fn stream(&mut self, request: ApiRequest) -> Result<Vec<AssistantEvent>, RuntimeError> {
|
|
||||||
if request
|
|
||||||
.messages
|
|
||||||
.iter()
|
|
||||||
.any(|message| message.role == MessageRole::Tool)
|
|
||||||
{
|
|
||||||
return Ok(vec![
|
|
||||||
AssistantEvent::TextDelta("blocked".to_string()),
|
|
||||||
AssistantEvent::MessageStop,
|
|
||||||
]);
|
|
||||||
}
|
|
||||||
Ok(vec![
|
|
||||||
AssistantEvent::ToolUse {
|
|
||||||
id: "tool-1".to_string(),
|
|
||||||
name: "blocked".to_string(),
|
|
||||||
input: r#"{"path":"secret.txt"}"#.to_string(),
|
|
||||||
},
|
|
||||||
AssistantEvent::MessageStop,
|
|
||||||
])
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
let mut runtime = ConversationRuntime::new_with_features(
|
|
||||||
Session::new(),
|
|
||||||
SingleCallApiClient,
|
|
||||||
StaticToolExecutor::new().register("blocked", |_input| {
|
|
||||||
panic!("tool should not execute when hook denies")
|
|
||||||
}),
|
|
||||||
PermissionPolicy::new(PermissionMode::DangerFullAccess),
|
|
||||||
vec!["system".to_string()],
|
|
||||||
&RuntimeFeatureConfig::default().with_hooks(RuntimeHookConfig::new(
|
|
||||||
vec![shell_snippet("printf 'blocked by hook'; exit 2")],
|
|
||||||
Vec::new(),
|
|
||||||
)),
|
|
||||||
);
|
|
||||||
|
|
||||||
let summary = runtime
|
|
||||||
.run_turn("use the tool", None)
|
|
||||||
.expect("conversation should continue after hook denial");
|
|
||||||
|
|
||||||
assert_eq!(summary.tool_results.len(), 1);
|
|
||||||
let ContentBlock::ToolResult {
|
|
||||||
is_error, output, ..
|
|
||||||
} = &summary.tool_results[0].blocks[0]
|
|
||||||
else {
|
|
||||||
panic!("expected tool result block");
|
|
||||||
};
|
|
||||||
assert!(
|
|
||||||
*is_error,
|
|
||||||
"hook denial should produce an error result: {output}"
|
|
||||||
);
|
|
||||||
assert!(
|
|
||||||
output.contains("denied tool") || output.contains("blocked by hook"),
|
|
||||||
"unexpected hook denial output: {output:?}"
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
fn appends_post_tool_hook_feedback_to_tool_result() {
|
|
||||||
struct TwoCallApiClient {
|
|
||||||
calls: usize,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl ApiClient for TwoCallApiClient {
|
|
||||||
fn stream(&mut self, request: ApiRequest) -> Result<Vec<AssistantEvent>, RuntimeError> {
|
|
||||||
self.calls += 1;
|
|
||||||
match self.calls {
|
|
||||||
1 => Ok(vec![
|
|
||||||
AssistantEvent::ToolUse {
|
|
||||||
id: "tool-1".to_string(),
|
|
||||||
name: "add".to_string(),
|
|
||||||
input: r#"{"lhs":2,"rhs":2}"#.to_string(),
|
|
||||||
},
|
|
||||||
AssistantEvent::MessageStop,
|
|
||||||
]),
|
|
||||||
2 => {
|
|
||||||
assert!(request
|
|
||||||
.messages
|
|
||||||
.iter()
|
|
||||||
.any(|message| message.role == MessageRole::Tool));
|
|
||||||
Ok(vec![
|
|
||||||
AssistantEvent::TextDelta("done".to_string()),
|
|
||||||
AssistantEvent::MessageStop,
|
|
||||||
])
|
|
||||||
}
|
|
||||||
_ => Err(RuntimeError::new("unexpected extra API call")),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
let mut runtime = ConversationRuntime::new_with_features(
|
|
||||||
Session::new(),
|
|
||||||
TwoCallApiClient { calls: 0 },
|
|
||||||
StaticToolExecutor::new().register("add", |_input| Ok("4".to_string())),
|
|
||||||
PermissionPolicy::new(PermissionMode::DangerFullAccess),
|
|
||||||
vec!["system".to_string()],
|
|
||||||
&RuntimeFeatureConfig::default().with_hooks(RuntimeHookConfig::new(
|
|
||||||
vec![shell_snippet("printf 'pre hook ran'")],
|
|
||||||
vec![shell_snippet("printf 'post hook ran'")],
|
|
||||||
)),
|
|
||||||
);
|
|
||||||
|
|
||||||
let summary = runtime
|
|
||||||
.run_turn("use add", None)
|
|
||||||
.expect("tool loop succeeds");
|
|
||||||
|
|
||||||
assert_eq!(summary.tool_results.len(), 1);
|
|
||||||
let ContentBlock::ToolResult {
|
|
||||||
is_error, output, ..
|
|
||||||
} = &summary.tool_results[0].blocks[0]
|
|
||||||
else {
|
|
||||||
panic!("expected tool result block");
|
|
||||||
};
|
|
||||||
assert!(
|
|
||||||
!*is_error,
|
|
||||||
"post hook should preserve non-error result: {output:?}"
|
|
||||||
);
|
|
||||||
assert!(
|
|
||||||
output.contains('4'),
|
|
||||||
"tool output missing value: {output:?}"
|
|
||||||
);
|
|
||||||
assert!(
|
|
||||||
output.contains("pre hook ran"),
|
|
||||||
"tool output missing pre hook feedback: {output:?}"
|
|
||||||
);
|
|
||||||
assert!(
|
|
||||||
output.contains("post hook ran"),
|
|
||||||
"tool output missing post hook feedback: {output:?}"
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn reconstructs_usage_tracker_from_restored_session() {
|
fn reconstructs_usage_tracker_from_restored_session() {
|
||||||
struct SimpleApi;
|
struct SimpleApi;
|
||||||
@@ -825,13 +646,110 @@ mod tests {
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
#[cfg(windows)]
|
#[test]
|
||||||
fn shell_snippet(script: &str) -> String {
|
fn auto_compacts_when_cumulative_input_threshold_is_crossed() {
|
||||||
script.replace('\'', "\"")
|
struct SimpleApi;
|
||||||
|
impl ApiClient for SimpleApi {
|
||||||
|
fn stream(
|
||||||
|
&mut self,
|
||||||
|
_request: ApiRequest,
|
||||||
|
) -> Result<Vec<AssistantEvent>, RuntimeError> {
|
||||||
|
Ok(vec![
|
||||||
|
AssistantEvent::TextDelta("done".to_string()),
|
||||||
|
AssistantEvent::Usage(TokenUsage {
|
||||||
|
input_tokens: 120_000,
|
||||||
|
output_tokens: 4,
|
||||||
|
cache_creation_input_tokens: 0,
|
||||||
|
cache_read_input_tokens: 0,
|
||||||
|
}),
|
||||||
|
AssistantEvent::MessageStop,
|
||||||
|
])
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
let session = Session {
|
||||||
|
version: 1,
|
||||||
|
messages: vec![
|
||||||
|
crate::session::ConversationMessage::user_text("one"),
|
||||||
|
crate::session::ConversationMessage::assistant(vec![ContentBlock::Text {
|
||||||
|
text: "two".to_string(),
|
||||||
|
}]),
|
||||||
|
crate::session::ConversationMessage::user_text("three"),
|
||||||
|
crate::session::ConversationMessage::assistant(vec![ContentBlock::Text {
|
||||||
|
text: "four".to_string(),
|
||||||
|
}]),
|
||||||
|
],
|
||||||
|
};
|
||||||
|
|
||||||
|
let mut runtime = ConversationRuntime::new(
|
||||||
|
session,
|
||||||
|
SimpleApi,
|
||||||
|
StaticToolExecutor::new(),
|
||||||
|
PermissionPolicy::new(PermissionMode::DangerFullAccess),
|
||||||
|
vec!["system".to_string()],
|
||||||
|
)
|
||||||
|
.with_auto_compaction_input_tokens_threshold(100_000);
|
||||||
|
|
||||||
|
let summary = runtime
|
||||||
|
.run_turn("trigger", None)
|
||||||
|
.expect("turn should succeed");
|
||||||
|
|
||||||
|
assert_eq!(
|
||||||
|
summary.auto_compaction,
|
||||||
|
Some(AutoCompactionEvent {
|
||||||
|
removed_message_count: 2,
|
||||||
|
})
|
||||||
|
);
|
||||||
|
assert_eq!(runtime.session().messages[0].role, MessageRole::System);
|
||||||
}
|
}
|
||||||
|
|
||||||
#[cfg(not(windows))]
|
#[test]
|
||||||
fn shell_snippet(script: &str) -> String {
|
fn skips_auto_compaction_below_threshold() {
|
||||||
script.to_string()
|
struct SimpleApi;
|
||||||
|
impl ApiClient for SimpleApi {
|
||||||
|
fn stream(
|
||||||
|
&mut self,
|
||||||
|
_request: ApiRequest,
|
||||||
|
) -> Result<Vec<AssistantEvent>, RuntimeError> {
|
||||||
|
Ok(vec![
|
||||||
|
AssistantEvent::TextDelta("done".to_string()),
|
||||||
|
AssistantEvent::Usage(TokenUsage {
|
||||||
|
input_tokens: 99_999,
|
||||||
|
output_tokens: 4,
|
||||||
|
cache_creation_input_tokens: 0,
|
||||||
|
cache_read_input_tokens: 0,
|
||||||
|
}),
|
||||||
|
AssistantEvent::MessageStop,
|
||||||
|
])
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
let mut runtime = ConversationRuntime::new(
|
||||||
|
Session::new(),
|
||||||
|
SimpleApi,
|
||||||
|
StaticToolExecutor::new(),
|
||||||
|
PermissionPolicy::new(PermissionMode::DangerFullAccess),
|
||||||
|
vec!["system".to_string()],
|
||||||
|
)
|
||||||
|
.with_auto_compaction_input_tokens_threshold(100_000);
|
||||||
|
|
||||||
|
let summary = runtime
|
||||||
|
.run_turn("trigger", None)
|
||||||
|
.expect("turn should succeed");
|
||||||
|
assert_eq!(summary.auto_compaction, None);
|
||||||
|
assert_eq!(runtime.session().messages.len(), 2);
|
||||||
|
}
|
||||||
|
|
||||||
|
#[test]
|
||||||
|
fn auto_compaction_threshold_defaults_and_parses_values() {
|
||||||
|
assert_eq!(
|
||||||
|
parse_auto_compaction_threshold(None),
|
||||||
|
DEFAULT_AUTO_COMPACTION_INPUT_TOKENS_THRESHOLD
|
||||||
|
);
|
||||||
|
assert_eq!(parse_auto_compaction_threshold(Some("4321")), 4321);
|
||||||
|
assert_eq!(
|
||||||
|
parse_auto_compaction_threshold(Some("not-a-number")),
|
||||||
|
DEFAULT_AUTO_COMPACTION_INPUT_TOKENS_THRESHOLD
|
||||||
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,347 +0,0 @@
|
|||||||
use std::ffi::OsStr;
|
|
||||||
use std::process::Command;
|
|
||||||
|
|
||||||
use serde_json::json;
|
|
||||||
|
|
||||||
use crate::config::{RuntimeFeatureConfig, RuntimeHookConfig};
|
|
||||||
|
|
||||||
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
|
|
||||||
pub enum HookEvent {
|
|
||||||
PreToolUse,
|
|
||||||
PostToolUse,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl HookEvent {
|
|
||||||
fn as_str(self) -> &'static str {
|
|
||||||
match self {
|
|
||||||
Self::PreToolUse => "PreToolUse",
|
|
||||||
Self::PostToolUse => "PostToolUse",
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug, Clone, PartialEq, Eq)]
|
|
||||||
pub struct HookRunResult {
|
|
||||||
denied: bool,
|
|
||||||
messages: Vec<String>,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl HookRunResult {
|
|
||||||
#[must_use]
|
|
||||||
pub fn allow(messages: Vec<String>) -> Self {
|
|
||||||
Self {
|
|
||||||
denied: false,
|
|
||||||
messages,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
|
||||||
pub fn is_denied(&self) -> bool {
|
|
||||||
self.denied
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
|
||||||
pub fn messages(&self) -> &[String] {
|
|
||||||
&self.messages
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug, Clone, PartialEq, Eq, Default)]
|
|
||||||
pub struct HookRunner {
|
|
||||||
config: RuntimeHookConfig,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl HookRunner {
|
|
||||||
#[must_use]
|
|
||||||
pub fn new(config: RuntimeHookConfig) -> Self {
|
|
||||||
Self { config }
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
|
||||||
pub fn from_feature_config(feature_config: &RuntimeFeatureConfig) -> Self {
|
|
||||||
Self::new(feature_config.hooks().clone())
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
|
||||||
pub fn run_pre_tool_use(&self, tool_name: &str, tool_input: &str) -> HookRunResult {
|
|
||||||
Self::run_commands(
|
|
||||||
HookEvent::PreToolUse,
|
|
||||||
self.config.pre_tool_use(),
|
|
||||||
tool_name,
|
|
||||||
tool_input,
|
|
||||||
None,
|
|
||||||
false,
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
#[must_use]
|
|
||||||
pub fn run_post_tool_use(
|
|
||||||
&self,
|
|
||||||
tool_name: &str,
|
|
||||||
tool_input: &str,
|
|
||||||
tool_output: &str,
|
|
||||||
is_error: bool,
|
|
||||||
) -> HookRunResult {
|
|
||||||
Self::run_commands(
|
|
||||||
HookEvent::PostToolUse,
|
|
||||||
self.config.post_tool_use(),
|
|
||||||
tool_name,
|
|
||||||
tool_input,
|
|
||||||
Some(tool_output),
|
|
||||||
is_error,
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
fn run_commands(
|
|
||||||
event: HookEvent,
|
|
||||||
commands: &[String],
|
|
||||||
tool_name: &str,
|
|
||||||
tool_input: &str,
|
|
||||||
tool_output: Option<&str>,
|
|
||||||
is_error: bool,
|
|
||||||
) -> HookRunResult {
|
|
||||||
if commands.is_empty() {
|
|
||||||
return HookRunResult::allow(Vec::new());
|
|
||||||
}
|
|
||||||
|
|
||||||
let payload = json!({
|
|
||||||
"hook_event_name": event.as_str(),
|
|
||||||
"tool_name": tool_name,
|
|
||||||
"tool_input": parse_tool_input(tool_input),
|
|
||||||
"tool_input_json": tool_input,
|
|
||||||
"tool_output": tool_output,
|
|
||||||
"tool_result_is_error": is_error,
|
|
||||||
})
|
|
||||||
.to_string();
|
|
||||||
|
|
||||||
let mut messages = Vec::new();
|
|
||||||
|
|
||||||
for command in commands {
|
|
||||||
match Self::run_command(
|
|
||||||
command,
|
|
||||||
event,
|
|
||||||
tool_name,
|
|
||||||
tool_input,
|
|
||||||
tool_output,
|
|
||||||
is_error,
|
|
||||||
&payload,
|
|
||||||
) {
|
|
||||||
HookCommandOutcome::Allow { message } => {
|
|
||||||
if let Some(message) = message {
|
|
||||||
messages.push(message);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
HookCommandOutcome::Deny { message } => {
|
|
||||||
let message = message.unwrap_or_else(|| {
|
|
||||||
format!("{} hook denied tool `{tool_name}`", event.as_str())
|
|
||||||
});
|
|
||||||
messages.push(message);
|
|
||||||
return HookRunResult {
|
|
||||||
denied: true,
|
|
||||||
messages,
|
|
||||||
};
|
|
||||||
}
|
|
||||||
HookCommandOutcome::Warn { message } => messages.push(message),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
HookRunResult::allow(messages)
|
|
||||||
}
|
|
||||||
|
|
||||||
fn run_command(
|
|
||||||
command: &str,
|
|
||||||
event: HookEvent,
|
|
||||||
tool_name: &str,
|
|
||||||
tool_input: &str,
|
|
||||||
tool_output: Option<&str>,
|
|
||||||
is_error: bool,
|
|
||||||
payload: &str,
|
|
||||||
) -> HookCommandOutcome {
|
|
||||||
let mut child = shell_command(command);
|
|
||||||
child.stdin(std::process::Stdio::piped());
|
|
||||||
child.stdout(std::process::Stdio::piped());
|
|
||||||
child.stderr(std::process::Stdio::piped());
|
|
||||||
child.env("HOOK_EVENT", event.as_str());
|
|
||||||
child.env("HOOK_TOOL_NAME", tool_name);
|
|
||||||
child.env("HOOK_TOOL_INPUT", tool_input);
|
|
||||||
child.env("HOOK_TOOL_IS_ERROR", if is_error { "1" } else { "0" });
|
|
||||||
if let Some(tool_output) = tool_output {
|
|
||||||
child.env("HOOK_TOOL_OUTPUT", tool_output);
|
|
||||||
}
|
|
||||||
|
|
||||||
match child.output_with_stdin(payload.as_bytes()) {
|
|
||||||
Ok(output) => {
|
|
||||||
let stdout = String::from_utf8_lossy(&output.stdout).trim().to_string();
|
|
||||||
let stderr = String::from_utf8_lossy(&output.stderr).trim().to_string();
|
|
||||||
let message = (!stdout.is_empty()).then_some(stdout);
|
|
||||||
match output.status.code() {
|
|
||||||
Some(0) => HookCommandOutcome::Allow { message },
|
|
||||||
Some(2) => HookCommandOutcome::Deny { message },
|
|
||||||
Some(code) => HookCommandOutcome::Warn {
|
|
||||||
message: format_hook_warning(
|
|
||||||
command,
|
|
||||||
code,
|
|
||||||
message.as_deref(),
|
|
||||||
stderr.as_str(),
|
|
||||||
),
|
|
||||||
},
|
|
||||||
None => HookCommandOutcome::Warn {
|
|
||||||
message: format!(
|
|
||||||
"{} hook `{command}` terminated by signal while handling `{tool_name}`",
|
|
||||||
event.as_str()
|
|
||||||
),
|
|
||||||
},
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Err(error) => HookCommandOutcome::Warn {
|
|
||||||
message: format!(
|
|
||||||
"{} hook `{command}` failed to start for `{tool_name}`: {error}",
|
|
||||||
event.as_str()
|
|
||||||
),
|
|
||||||
},
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
enum HookCommandOutcome {
|
|
||||||
Allow { message: Option<String> },
|
|
||||||
Deny { message: Option<String> },
|
|
||||||
Warn { message: String },
|
|
||||||
}
|
|
||||||
|
|
||||||
fn parse_tool_input(tool_input: &str) -> serde_json::Value {
|
|
||||||
serde_json::from_str(tool_input).unwrap_or_else(|_| json!({ "raw": tool_input }))
|
|
||||||
}
|
|
||||||
|
|
||||||
fn format_hook_warning(command: &str, code: i32, stdout: Option<&str>, stderr: &str) -> String {
|
|
||||||
let mut message =
|
|
||||||
format!("Hook `{command}` exited with status {code}; allowing tool execution to continue");
|
|
||||||
if let Some(stdout) = stdout.filter(|stdout| !stdout.is_empty()) {
|
|
||||||
message.push_str(": ");
|
|
||||||
message.push_str(stdout);
|
|
||||||
} else if !stderr.is_empty() {
|
|
||||||
message.push_str(": ");
|
|
||||||
message.push_str(stderr);
|
|
||||||
}
|
|
||||||
message
|
|
||||||
}
|
|
||||||
|
|
||||||
fn shell_command(command: &str) -> CommandWithStdin {
|
|
||||||
#[cfg(windows)]
|
|
||||||
let mut command_builder = {
|
|
||||||
let mut command_builder = Command::new("cmd");
|
|
||||||
command_builder.arg("/C").arg(command);
|
|
||||||
CommandWithStdin::new(command_builder)
|
|
||||||
};
|
|
||||||
|
|
||||||
#[cfg(not(windows))]
|
|
||||||
let command_builder = {
|
|
||||||
let mut command_builder = Command::new("sh");
|
|
||||||
command_builder.arg("-lc").arg(command);
|
|
||||||
CommandWithStdin::new(command_builder)
|
|
||||||
};
|
|
||||||
|
|
||||||
command_builder
|
|
||||||
}
|
|
||||||
|
|
||||||
struct CommandWithStdin {
|
|
||||||
command: Command,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl CommandWithStdin {
|
|
||||||
fn new(command: Command) -> Self {
|
|
||||||
Self { command }
|
|
||||||
}
|
|
||||||
|
|
||||||
fn stdin(&mut self, cfg: std::process::Stdio) -> &mut Self {
|
|
||||||
self.command.stdin(cfg);
|
|
||||||
self
|
|
||||||
}
|
|
||||||
|
|
||||||
fn stdout(&mut self, cfg: std::process::Stdio) -> &mut Self {
|
|
||||||
self.command.stdout(cfg);
|
|
||||||
self
|
|
||||||
}
|
|
||||||
|
|
||||||
fn stderr(&mut self, cfg: std::process::Stdio) -> &mut Self {
|
|
||||||
self.command.stderr(cfg);
|
|
||||||
self
|
|
||||||
}
|
|
||||||
|
|
||||||
fn env<K, V>(&mut self, key: K, value: V) -> &mut Self
|
|
||||||
where
|
|
||||||
K: AsRef<OsStr>,
|
|
||||||
V: AsRef<OsStr>,
|
|
||||||
{
|
|
||||||
self.command.env(key, value);
|
|
||||||
self
|
|
||||||
}
|
|
||||||
|
|
||||||
fn output_with_stdin(&mut self, stdin: &[u8]) -> std::io::Result<std::process::Output> {
|
|
||||||
let mut child = self.command.spawn()?;
|
|
||||||
if let Some(mut child_stdin) = child.stdin.take() {
|
|
||||||
use std::io::Write;
|
|
||||||
child_stdin.write_all(stdin)?;
|
|
||||||
}
|
|
||||||
child.wait_with_output()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[cfg(test)]
|
|
||||||
mod tests {
|
|
||||||
use super::{HookRunResult, HookRunner};
|
|
||||||
use crate::config::{RuntimeFeatureConfig, RuntimeHookConfig};
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
fn allows_exit_code_zero_and_captures_stdout() {
|
|
||||||
let runner = HookRunner::new(RuntimeHookConfig::new(
|
|
||||||
vec![shell_snippet("printf 'pre ok'")],
|
|
||||||
Vec::new(),
|
|
||||||
));
|
|
||||||
|
|
||||||
let result = runner.run_pre_tool_use("Read", r#"{"path":"README.md"}"#);
|
|
||||||
|
|
||||||
assert_eq!(result, HookRunResult::allow(vec!["pre ok".to_string()]));
|
|
||||||
}
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
fn denies_exit_code_two() {
|
|
||||||
let runner = HookRunner::new(RuntimeHookConfig::new(
|
|
||||||
vec![shell_snippet("printf 'blocked by hook'; exit 2")],
|
|
||||||
Vec::new(),
|
|
||||||
));
|
|
||||||
|
|
||||||
let result = runner.run_pre_tool_use("Bash", r#"{"command":"pwd"}"#);
|
|
||||||
|
|
||||||
assert!(result.is_denied());
|
|
||||||
assert_eq!(result.messages(), &["blocked by hook".to_string()]);
|
|
||||||
}
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
fn warns_for_other_non_zero_statuses() {
|
|
||||||
let runner = HookRunner::from_feature_config(&RuntimeFeatureConfig::default().with_hooks(
|
|
||||||
RuntimeHookConfig::new(
|
|
||||||
vec![shell_snippet("printf 'warning hook'; exit 1")],
|
|
||||||
Vec::new(),
|
|
||||||
),
|
|
||||||
));
|
|
||||||
|
|
||||||
let result = runner.run_pre_tool_use("Edit", r#"{"file":"src/lib.rs"}"#);
|
|
||||||
|
|
||||||
assert!(!result.is_denied());
|
|
||||||
assert!(result
|
|
||||||
.messages()
|
|
||||||
.iter()
|
|
||||||
.any(|message| message.contains("allowing tool execution to continue")));
|
|
||||||
}
|
|
||||||
|
|
||||||
#[cfg(windows)]
|
|
||||||
fn shell_snippet(script: &str) -> String {
|
|
||||||
script.replace('\'', "\"")
|
|
||||||
}
|
|
||||||
|
|
||||||
#[cfg(not(windows))]
|
|
||||||
fn shell_snippet(script: &str) -> String {
|
|
||||||
script.to_string()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -4,7 +4,6 @@ mod compact;
|
|||||||
mod config;
|
mod config;
|
||||||
mod conversation;
|
mod conversation;
|
||||||
mod file_ops;
|
mod file_ops;
|
||||||
mod hooks;
|
|
||||||
mod json;
|
mod json;
|
||||||
mod mcp;
|
mod mcp;
|
||||||
mod mcp_client;
|
mod mcp_client;
|
||||||
@@ -27,19 +26,18 @@ pub use config::{
|
|||||||
ConfigEntry, ConfigError, ConfigLoader, ConfigSource, McpClaudeAiProxyServerConfig,
|
ConfigEntry, ConfigError, ConfigLoader, ConfigSource, McpClaudeAiProxyServerConfig,
|
||||||
McpConfigCollection, McpOAuthConfig, McpRemoteServerConfig, McpSdkServerConfig,
|
McpConfigCollection, McpOAuthConfig, McpRemoteServerConfig, McpSdkServerConfig,
|
||||||
McpServerConfig, McpStdioServerConfig, McpTransport, McpWebSocketServerConfig, OAuthConfig,
|
McpServerConfig, McpStdioServerConfig, McpTransport, McpWebSocketServerConfig, OAuthConfig,
|
||||||
ResolvedPermissionMode, RuntimeConfig, RuntimeFeatureConfig, RuntimeHookConfig,
|
ResolvedPermissionMode, RuntimeConfig, RuntimeFeatureConfig, ScopedMcpServerConfig,
|
||||||
ScopedMcpServerConfig, CLAUDE_CODE_SETTINGS_SCHEMA_NAME,
|
CLAUDE_CODE_SETTINGS_SCHEMA_NAME,
|
||||||
};
|
};
|
||||||
pub use conversation::{
|
pub use conversation::{
|
||||||
ApiClient, ApiRequest, AssistantEvent, ConversationRuntime, PromptCacheEvent, RuntimeError,
|
auto_compaction_threshold_from_env, ApiClient, ApiRequest, AssistantEvent, AutoCompactionEvent,
|
||||||
StaticToolExecutor, ToolError, ToolExecutor, TurnSummary,
|
ConversationRuntime, RuntimeError, StaticToolExecutor, ToolError, ToolExecutor, TurnSummary,
|
||||||
};
|
};
|
||||||
pub use file_ops::{
|
pub use file_ops::{
|
||||||
edit_file, glob_search, grep_search, read_file, write_file, EditFileOutput, GlobSearchOutput,
|
edit_file, glob_search, grep_search, read_file, write_file, EditFileOutput, GlobSearchOutput,
|
||||||
GrepSearchInput, GrepSearchOutput, ReadFileOutput, StructuredPatchHunk, TextFilePayload,
|
GrepSearchInput, GrepSearchOutput, ReadFileOutput, StructuredPatchHunk, TextFilePayload,
|
||||||
WriteFileOutput,
|
WriteFileOutput,
|
||||||
};
|
};
|
||||||
pub use hooks::{HookEvent, HookRunResult, HookRunner};
|
|
||||||
pub use mcp::{
|
pub use mcp::{
|
||||||
mcp_server_signature, mcp_tool_name, mcp_tool_prefix, normalize_name_for_mcp,
|
mcp_server_signature, mcp_tool_name, mcp_tool_prefix, normalize_name_for_mcp,
|
||||||
scoped_mcp_config_hash, unwrap_ccr_proxy_url,
|
scoped_mcp_config_hash, unwrap_ccr_proxy_url,
|
||||||
|
|||||||
@@ -13,9 +13,8 @@ use std::time::{SystemTime, UNIX_EPOCH};
|
|||||||
|
|
||||||
use api::{
|
use api::{
|
||||||
resolve_startup_auth_source, AnthropicClient, AuthSource, ContentBlockDelta, InputContentBlock,
|
resolve_startup_auth_source, AnthropicClient, AuthSource, ContentBlockDelta, InputContentBlock,
|
||||||
InputMessage, MessageRequest, MessageResponse, OutputContentBlock, PromptCache,
|
InputMessage, MessageRequest, MessageResponse, OutputContentBlock,
|
||||||
PromptCacheRecord, StreamEvent as ApiStreamEvent, ToolChoice, ToolDefinition,
|
StreamEvent as ApiStreamEvent, ToolChoice, ToolDefinition, ToolResultContentBlock,
|
||||||
ToolResultContentBlock,
|
|
||||||
};
|
};
|
||||||
|
|
||||||
use commands::{
|
use commands::{
|
||||||
@@ -29,8 +28,8 @@ use runtime::{
|
|||||||
parse_oauth_callback_request_target, save_oauth_credentials, ApiClient, ApiRequest,
|
parse_oauth_callback_request_target, save_oauth_credentials, ApiClient, ApiRequest,
|
||||||
AssistantEvent, CompactionConfig, ConfigLoader, ConfigSource, ContentBlock,
|
AssistantEvent, CompactionConfig, ConfigLoader, ConfigSource, ContentBlock,
|
||||||
ConversationMessage, ConversationRuntime, MessageRole, OAuthAuthorizationRequest, OAuthConfig,
|
ConversationMessage, ConversationRuntime, MessageRole, OAuthAuthorizationRequest, OAuthConfig,
|
||||||
OAuthTokenExchangeRequest, PermissionMode, PermissionPolicy, ProjectContext, PromptCacheEvent,
|
OAuthTokenExchangeRequest, PermissionMode, PermissionPolicy, ProjectContext, RuntimeError,
|
||||||
RuntimeError, Session, TokenUsage, ToolError, ToolExecutor, UsageTracker,
|
Session, TokenUsage, ToolError, ToolExecutor, UsageTracker,
|
||||||
};
|
};
|
||||||
use serde_json::json;
|
use serde_json::json;
|
||||||
use tools::{execute_tool, mvp_tool_specs, ToolSpec};
|
use tools::{execute_tool, mvp_tool_specs, ToolSpec};
|
||||||
@@ -776,6 +775,10 @@ fn format_compact_report(removed: usize, resulting_messages: usize, skipped: boo
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fn format_auto_compaction_notice(removed: usize) -> String {
|
||||||
|
format!("[auto-compacted: removed {removed} messages]")
|
||||||
|
}
|
||||||
|
|
||||||
fn parse_git_status_metadata(status: Option<&str>) -> (Option<PathBuf>, Option<String>) {
|
fn parse_git_status_metadata(status: Option<&str>) -> (Option<PathBuf>, Option<String>) {
|
||||||
let Some(status) = status else {
|
let Some(status) = status else {
|
||||||
return (None, None);
|
return (None, None);
|
||||||
@@ -914,7 +917,14 @@ fn run_resume_command(
|
|||||||
)),
|
)),
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
SlashCommand::Resume { .. }
|
SlashCommand::Bughunter { .. }
|
||||||
|
| SlashCommand::Commit
|
||||||
|
| SlashCommand::Pr { .. }
|
||||||
|
| SlashCommand::Issue { .. }
|
||||||
|
| SlashCommand::Ultraplan { .. }
|
||||||
|
| SlashCommand::Teleport { .. }
|
||||||
|
| SlashCommand::DebugToolCall
|
||||||
|
| SlashCommand::Resume { .. }
|
||||||
| SlashCommand::Model { .. }
|
| SlashCommand::Model { .. }
|
||||||
| SlashCommand::Permissions { .. }
|
| SlashCommand::Permissions { .. }
|
||||||
| SlashCommand::Session { .. }
|
| SlashCommand::Session { .. }
|
||||||
@@ -996,7 +1006,6 @@ impl LiveCli {
|
|||||||
let session = create_managed_session_handle()?;
|
let session = create_managed_session_handle()?;
|
||||||
let runtime = build_runtime(
|
let runtime = build_runtime(
|
||||||
Session::new(),
|
Session::new(),
|
||||||
session.id.clone(),
|
|
||||||
model.clone(),
|
model.clone(),
|
||||||
system_prompt.clone(),
|
system_prompt.clone(),
|
||||||
enable_tools,
|
enable_tools,
|
||||||
@@ -1059,7 +1068,12 @@ impl LiveCli {
|
|||||||
&mut stdout,
|
&mut stdout,
|
||||||
)?;
|
)?;
|
||||||
println!();
|
println!();
|
||||||
print_prompt_cache_events(&summary);
|
if let Some(event) = summary.auto_compaction {
|
||||||
|
println!(
|
||||||
|
"{}",
|
||||||
|
format_auto_compaction_notice(event.removed_message_count)
|
||||||
|
);
|
||||||
|
}
|
||||||
self.persist_session()?;
|
self.persist_session()?;
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
@@ -1089,7 +1103,6 @@ impl LiveCli {
|
|||||||
let session = self.runtime.session().clone();
|
let session = self.runtime.session().clone();
|
||||||
let mut runtime = build_runtime(
|
let mut runtime = build_runtime(
|
||||||
session,
|
session,
|
||||||
self.session.id.clone(),
|
|
||||||
self.model.clone(),
|
self.model.clone(),
|
||||||
self.system_prompt.clone(),
|
self.system_prompt.clone(),
|
||||||
true,
|
true,
|
||||||
@@ -1107,9 +1120,12 @@ impl LiveCli {
|
|||||||
"message": final_assistant_text(&summary),
|
"message": final_assistant_text(&summary),
|
||||||
"model": self.model,
|
"model": self.model,
|
||||||
"iterations": summary.iterations,
|
"iterations": summary.iterations,
|
||||||
|
"auto_compaction": summary.auto_compaction.map(|event| json!({
|
||||||
|
"removed_messages": event.removed_message_count,
|
||||||
|
"notice": format_auto_compaction_notice(event.removed_message_count),
|
||||||
|
})),
|
||||||
"tool_uses": collect_tool_uses(&summary),
|
"tool_uses": collect_tool_uses(&summary),
|
||||||
"tool_results": collect_tool_results(&summary),
|
"tool_results": collect_tool_results(&summary),
|
||||||
"prompt_cache_events": collect_prompt_cache_events(&summary),
|
|
||||||
"usage": {
|
"usage": {
|
||||||
"input_tokens": summary.usage.input_tokens,
|
"input_tokens": summary.usage.input_tokens,
|
||||||
"output_tokens": summary.usage.output_tokens,
|
"output_tokens": summary.usage.output_tokens,
|
||||||
@@ -1134,6 +1150,34 @@ impl LiveCli {
|
|||||||
self.print_status();
|
self.print_status();
|
||||||
false
|
false
|
||||||
}
|
}
|
||||||
|
SlashCommand::Bughunter { scope } => {
|
||||||
|
self.run_bughunter(scope.as_deref())?;
|
||||||
|
false
|
||||||
|
}
|
||||||
|
SlashCommand::Commit => {
|
||||||
|
self.run_commit()?;
|
||||||
|
true
|
||||||
|
}
|
||||||
|
SlashCommand::Pr { context } => {
|
||||||
|
self.run_pr(context.as_deref())?;
|
||||||
|
false
|
||||||
|
}
|
||||||
|
SlashCommand::Issue { context } => {
|
||||||
|
self.run_issue(context.as_deref())?;
|
||||||
|
false
|
||||||
|
}
|
||||||
|
SlashCommand::Ultraplan { task } => {
|
||||||
|
self.run_ultraplan(task.as_deref())?;
|
||||||
|
false
|
||||||
|
}
|
||||||
|
SlashCommand::Teleport { target } => {
|
||||||
|
self.run_teleport(target.as_deref())?;
|
||||||
|
false
|
||||||
|
}
|
||||||
|
SlashCommand::DebugToolCall => {
|
||||||
|
self.run_debug_tool_call()?;
|
||||||
|
false
|
||||||
|
}
|
||||||
SlashCommand::Compact => {
|
SlashCommand::Compact => {
|
||||||
self.compact()?;
|
self.compact()?;
|
||||||
false
|
false
|
||||||
@@ -1237,7 +1281,6 @@ impl LiveCli {
|
|||||||
let message_count = session.messages.len();
|
let message_count = session.messages.len();
|
||||||
self.runtime = build_runtime(
|
self.runtime = build_runtime(
|
||||||
session,
|
session,
|
||||||
self.session.id.clone(),
|
|
||||||
model.clone(),
|
model.clone(),
|
||||||
self.system_prompt.clone(),
|
self.system_prompt.clone(),
|
||||||
true,
|
true,
|
||||||
@@ -1281,7 +1324,6 @@ impl LiveCli {
|
|||||||
self.permission_mode = permission_mode_from_label(normalized);
|
self.permission_mode = permission_mode_from_label(normalized);
|
||||||
self.runtime = build_runtime(
|
self.runtime = build_runtime(
|
||||||
session,
|
session,
|
||||||
self.session.id.clone(),
|
|
||||||
self.model.clone(),
|
self.model.clone(),
|
||||||
self.system_prompt.clone(),
|
self.system_prompt.clone(),
|
||||||
true,
|
true,
|
||||||
@@ -1307,7 +1349,6 @@ impl LiveCli {
|
|||||||
self.session = create_managed_session_handle()?;
|
self.session = create_managed_session_handle()?;
|
||||||
self.runtime = build_runtime(
|
self.runtime = build_runtime(
|
||||||
Session::new(),
|
Session::new(),
|
||||||
self.session.id.clone(),
|
|
||||||
self.model.clone(),
|
self.model.clone(),
|
||||||
self.system_prompt.clone(),
|
self.system_prompt.clone(),
|
||||||
true,
|
true,
|
||||||
@@ -1343,7 +1384,6 @@ impl LiveCli {
|
|||||||
let message_count = session.messages.len();
|
let message_count = session.messages.len();
|
||||||
self.runtime = build_runtime(
|
self.runtime = build_runtime(
|
||||||
session,
|
session,
|
||||||
handle.id.clone(),
|
|
||||||
self.model.clone(),
|
self.model.clone(),
|
||||||
self.system_prompt.clone(),
|
self.system_prompt.clone(),
|
||||||
true,
|
true,
|
||||||
@@ -1416,7 +1456,6 @@ impl LiveCli {
|
|||||||
let message_count = session.messages.len();
|
let message_count = session.messages.len();
|
||||||
self.runtime = build_runtime(
|
self.runtime = build_runtime(
|
||||||
session,
|
session,
|
||||||
handle.id.clone(),
|
|
||||||
self.model.clone(),
|
self.model.clone(),
|
||||||
self.system_prompt.clone(),
|
self.system_prompt.clone(),
|
||||||
true,
|
true,
|
||||||
@@ -1447,7 +1486,6 @@ impl LiveCli {
|
|||||||
let skipped = removed == 0;
|
let skipped = removed == 0;
|
||||||
self.runtime = build_runtime(
|
self.runtime = build_runtime(
|
||||||
result.compacted_session,
|
result.compacted_session,
|
||||||
self.session.id.clone(),
|
|
||||||
self.model.clone(),
|
self.model.clone(),
|
||||||
self.system_prompt.clone(),
|
self.system_prompt.clone(),
|
||||||
true,
|
true,
|
||||||
@@ -1459,6 +1497,160 @@ impl LiveCli {
|
|||||||
println!("{}", format_compact_report(removed, kept, skipped));
|
println!("{}", format_compact_report(removed, kept, skipped));
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fn run_internal_prompt_text(
|
||||||
|
&self,
|
||||||
|
prompt: &str,
|
||||||
|
enable_tools: bool,
|
||||||
|
) -> Result<String, Box<dyn std::error::Error>> {
|
||||||
|
let session = self.runtime.session().clone();
|
||||||
|
let mut runtime = build_runtime(
|
||||||
|
session,
|
||||||
|
self.model.clone(),
|
||||||
|
self.system_prompt.clone(),
|
||||||
|
enable_tools,
|
||||||
|
false,
|
||||||
|
self.allowed_tools.clone(),
|
||||||
|
self.permission_mode,
|
||||||
|
)?;
|
||||||
|
let mut permission_prompter = CliPermissionPrompter::new(self.permission_mode);
|
||||||
|
let summary = runtime.run_turn(prompt, Some(&mut permission_prompter))?;
|
||||||
|
Ok(final_assistant_text(&summary).trim().to_string())
|
||||||
|
}
|
||||||
|
|
||||||
|
fn run_bughunter(&self, scope: Option<&str>) -> Result<(), Box<dyn std::error::Error>> {
|
||||||
|
let scope = scope.unwrap_or("the current repository");
|
||||||
|
let prompt = format!(
|
||||||
|
"You are /bughunter. Inspect {scope} and identify the most likely bugs or correctness issues. Prioritize concrete findings with file paths, severity, and suggested fixes. Use tools if needed."
|
||||||
|
);
|
||||||
|
println!("{}", self.run_internal_prompt_text(&prompt, true)?);
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
fn run_ultraplan(&self, task: Option<&str>) -> Result<(), Box<dyn std::error::Error>> {
|
||||||
|
let task = task.unwrap_or("the current repo work");
|
||||||
|
let prompt = format!(
|
||||||
|
"You are /ultraplan. Produce a deep multi-step execution plan for {task}. Include goals, risks, implementation sequence, verification steps, and rollback considerations. Use tools if needed."
|
||||||
|
);
|
||||||
|
println!("{}", self.run_internal_prompt_text(&prompt, true)?);
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
fn run_teleport(&self, target: Option<&str>) -> Result<(), Box<dyn std::error::Error>> {
|
||||||
|
let Some(target) = target.map(str::trim).filter(|value| !value.is_empty()) else {
|
||||||
|
println!("Usage: /teleport <symbol-or-path>");
|
||||||
|
return Ok(());
|
||||||
|
};
|
||||||
|
|
||||||
|
println!("{}", render_teleport_report(target)?);
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
fn run_debug_tool_call(&self) -> Result<(), Box<dyn std::error::Error>> {
|
||||||
|
println!("{}", render_last_tool_debug_report(self.runtime.session())?);
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
fn run_commit(&mut self) -> Result<(), Box<dyn std::error::Error>> {
|
||||||
|
let status = git_output(&["status", "--short"])?;
|
||||||
|
if status.trim().is_empty() {
|
||||||
|
println!("Commit\n Result skipped\n Reason no workspace changes");
|
||||||
|
return Ok(());
|
||||||
|
}
|
||||||
|
|
||||||
|
git_status_ok(&["add", "-A"])?;
|
||||||
|
let staged_stat = git_output(&["diff", "--cached", "--stat"])?;
|
||||||
|
let prompt = format!(
|
||||||
|
"Generate a git commit message in plain text Lore format only. Base it on this staged diff summary:\n\n{}\n\nRecent conversation context:\n{}",
|
||||||
|
truncate_for_prompt(&staged_stat, 8_000),
|
||||||
|
recent_user_context(self.runtime.session(), 6)
|
||||||
|
);
|
||||||
|
let message = sanitize_generated_message(&self.run_internal_prompt_text(&prompt, false)?);
|
||||||
|
if message.trim().is_empty() {
|
||||||
|
return Err("generated commit message was empty".into());
|
||||||
|
}
|
||||||
|
|
||||||
|
let path = write_temp_text_file("claw-commit-message.txt", &message)?;
|
||||||
|
let output = Command::new("git")
|
||||||
|
.args(["commit", "--file"])
|
||||||
|
.arg(&path)
|
||||||
|
.current_dir(env::current_dir()?)
|
||||||
|
.output()?;
|
||||||
|
if !output.status.success() {
|
||||||
|
let stderr = String::from_utf8_lossy(&output.stderr).trim().to_string();
|
||||||
|
return Err(format!("git commit failed: {stderr}").into());
|
||||||
|
}
|
||||||
|
|
||||||
|
println!(
|
||||||
|
"Commit\n Result created\n Message file {}\n\n{}",
|
||||||
|
path.display(),
|
||||||
|
message.trim()
|
||||||
|
);
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
fn run_pr(&self, context: Option<&str>) -> Result<(), Box<dyn std::error::Error>> {
|
||||||
|
let staged = git_output(&["diff", "--stat"])?;
|
||||||
|
let prompt = format!(
|
||||||
|
"Generate a pull request title and body from this conversation and diff summary. Output plain text in this format exactly:\nTITLE: <title>\nBODY:\n<body markdown>\n\nContext hint: {}\n\nDiff summary:\n{}",
|
||||||
|
context.unwrap_or("none"),
|
||||||
|
truncate_for_prompt(&staged, 10_000)
|
||||||
|
);
|
||||||
|
let draft = sanitize_generated_message(&self.run_internal_prompt_text(&prompt, false)?);
|
||||||
|
let (title, body) = parse_titled_body(&draft)
|
||||||
|
.ok_or_else(|| "failed to parse generated PR title/body".to_string())?;
|
||||||
|
|
||||||
|
if command_exists("gh") {
|
||||||
|
let body_path = write_temp_text_file("claw-pr-body.md", &body)?;
|
||||||
|
let output = Command::new("gh")
|
||||||
|
.args(["pr", "create", "--title", &title, "--body-file"])
|
||||||
|
.arg(&body_path)
|
||||||
|
.current_dir(env::current_dir()?)
|
||||||
|
.output()?;
|
||||||
|
if output.status.success() {
|
||||||
|
let stdout = String::from_utf8_lossy(&output.stdout).trim().to_string();
|
||||||
|
println!(
|
||||||
|
"PR\n Result created\n Title {title}\n URL {}",
|
||||||
|
if stdout.is_empty() { "<unknown>" } else { &stdout }
|
||||||
|
);
|
||||||
|
return Ok(());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
println!("PR draft\n Title {title}\n\n{body}");
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
fn run_issue(&self, context: Option<&str>) -> Result<(), Box<dyn std::error::Error>> {
|
||||||
|
let prompt = format!(
|
||||||
|
"Generate a GitHub issue title and body from this conversation. Output plain text in this format exactly:\nTITLE: <title>\nBODY:\n<body markdown>\n\nContext hint: {}\n\nConversation context:\n{}",
|
||||||
|
context.unwrap_or("none"),
|
||||||
|
truncate_for_prompt(&recent_user_context(self.runtime.session(), 10), 10_000)
|
||||||
|
);
|
||||||
|
let draft = sanitize_generated_message(&self.run_internal_prompt_text(&prompt, false)?);
|
||||||
|
let (title, body) = parse_titled_body(&draft)
|
||||||
|
.ok_or_else(|| "failed to parse generated issue title/body".to_string())?;
|
||||||
|
|
||||||
|
if command_exists("gh") {
|
||||||
|
let body_path = write_temp_text_file("claw-issue-body.md", &body)?;
|
||||||
|
let output = Command::new("gh")
|
||||||
|
.args(["issue", "create", "--title", &title, "--body-file"])
|
||||||
|
.arg(&body_path)
|
||||||
|
.current_dir(env::current_dir()?)
|
||||||
|
.output()?;
|
||||||
|
if output.status.success() {
|
||||||
|
let stdout = String::from_utf8_lossy(&output.stdout).trim().to_string();
|
||||||
|
println!(
|
||||||
|
"Issue\n Result created\n Title {title}\n URL {}",
|
||||||
|
if stdout.is_empty() { "<unknown>" } else { &stdout }
|
||||||
|
);
|
||||||
|
return Ok(());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
println!("Issue draft\n Title {title}\n\n{body}");
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
fn sessions_dir() -> Result<PathBuf, Box<dyn std::error::Error>> {
|
fn sessions_dir() -> Result<PathBuf, Box<dyn std::error::Error>> {
|
||||||
@@ -1810,6 +2002,206 @@ fn render_diff_report() -> Result<String, Box<dyn std::error::Error>> {
|
|||||||
Ok(format!("Diff\n\n{}", diff.trim_end()))
|
Ok(format!("Diff\n\n{}", diff.trim_end()))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fn render_teleport_report(target: &str) -> Result<String, Box<dyn std::error::Error>> {
|
||||||
|
let cwd = env::current_dir()?;
|
||||||
|
|
||||||
|
let file_list = Command::new("rg")
|
||||||
|
.args(["--files"])
|
||||||
|
.current_dir(&cwd)
|
||||||
|
.output()?;
|
||||||
|
let file_matches = if file_list.status.success() {
|
||||||
|
String::from_utf8(file_list.stdout)?
|
||||||
|
.lines()
|
||||||
|
.filter(|line| line.contains(target))
|
||||||
|
.take(10)
|
||||||
|
.map(ToOwned::to_owned)
|
||||||
|
.collect::<Vec<_>>()
|
||||||
|
} else {
|
||||||
|
Vec::new()
|
||||||
|
};
|
||||||
|
|
||||||
|
let content_output = Command::new("rg")
|
||||||
|
.args(["-n", "-S", "--color", "never", target, "."])
|
||||||
|
.current_dir(&cwd)
|
||||||
|
.output()?;
|
||||||
|
|
||||||
|
let mut lines = vec![format!("Teleport\n Target {target}")];
|
||||||
|
if !file_matches.is_empty() {
|
||||||
|
lines.push(String::new());
|
||||||
|
lines.push("File matches".to_string());
|
||||||
|
lines.extend(file_matches.into_iter().map(|path| format!(" {path}")));
|
||||||
|
}
|
||||||
|
|
||||||
|
if content_output.status.success() {
|
||||||
|
let matches = String::from_utf8(content_output.stdout)?;
|
||||||
|
if !matches.trim().is_empty() {
|
||||||
|
lines.push(String::new());
|
||||||
|
lines.push("Content matches".to_string());
|
||||||
|
lines.push(truncate_for_prompt(&matches, 4_000));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if lines.len() == 1 {
|
||||||
|
lines.push(" Result no matches found".to_string());
|
||||||
|
}
|
||||||
|
|
||||||
|
Ok(lines.join("\n"))
|
||||||
|
}
|
||||||
|
|
||||||
|
fn render_last_tool_debug_report(session: &Session) -> Result<String, Box<dyn std::error::Error>> {
|
||||||
|
let last_tool_use = session
|
||||||
|
.messages
|
||||||
|
.iter()
|
||||||
|
.rev()
|
||||||
|
.find_map(|message| {
|
||||||
|
message.blocks.iter().rev().find_map(|block| match block {
|
||||||
|
ContentBlock::ToolUse { id, name, input } => {
|
||||||
|
Some((id.clone(), name.clone(), input.clone()))
|
||||||
|
}
|
||||||
|
_ => None,
|
||||||
|
})
|
||||||
|
})
|
||||||
|
.ok_or_else(|| "no prior tool call found in session".to_string())?;
|
||||||
|
|
||||||
|
let tool_result = session.messages.iter().rev().find_map(|message| {
|
||||||
|
message.blocks.iter().rev().find_map(|block| match block {
|
||||||
|
ContentBlock::ToolResult {
|
||||||
|
tool_use_id,
|
||||||
|
tool_name,
|
||||||
|
output,
|
||||||
|
is_error,
|
||||||
|
} if tool_use_id == &last_tool_use.0 => {
|
||||||
|
Some((tool_name.clone(), output.clone(), *is_error))
|
||||||
|
}
|
||||||
|
_ => None,
|
||||||
|
})
|
||||||
|
});
|
||||||
|
|
||||||
|
let mut lines = vec![
|
||||||
|
"Debug tool call".to_string(),
|
||||||
|
format!(" Tool id {}", last_tool_use.0),
|
||||||
|
format!(" Tool name {}", last_tool_use.1),
|
||||||
|
" Input".to_string(),
|
||||||
|
indent_block(&last_tool_use.2, 4),
|
||||||
|
];
|
||||||
|
|
||||||
|
match tool_result {
|
||||||
|
Some((tool_name, output, is_error)) => {
|
||||||
|
lines.push(" Result".to_string());
|
||||||
|
lines.push(format!(" name {tool_name}"));
|
||||||
|
lines.push(format!(
|
||||||
|
" status {}",
|
||||||
|
if is_error { "error" } else { "ok" }
|
||||||
|
));
|
||||||
|
lines.push(indent_block(&output, 4));
|
||||||
|
}
|
||||||
|
None => lines.push(" Result missing tool result".to_string()),
|
||||||
|
}
|
||||||
|
|
||||||
|
Ok(lines.join("\n"))
|
||||||
|
}
|
||||||
|
|
||||||
|
fn indent_block(value: &str, spaces: usize) -> String {
|
||||||
|
let indent = " ".repeat(spaces);
|
||||||
|
value
|
||||||
|
.lines()
|
||||||
|
.map(|line| format!("{indent}{line}"))
|
||||||
|
.collect::<Vec<_>>()
|
||||||
|
.join("\n")
|
||||||
|
}
|
||||||
|
|
||||||
|
fn git_output(args: &[&str]) -> Result<String, Box<dyn std::error::Error>> {
|
||||||
|
let output = Command::new("git")
|
||||||
|
.args(args)
|
||||||
|
.current_dir(env::current_dir()?)
|
||||||
|
.output()?;
|
||||||
|
if !output.status.success() {
|
||||||
|
let stderr = String::from_utf8_lossy(&output.stderr).trim().to_string();
|
||||||
|
return Err(format!("git {} failed: {stderr}", args.join(" ")).into());
|
||||||
|
}
|
||||||
|
Ok(String::from_utf8(output.stdout)?)
|
||||||
|
}
|
||||||
|
|
||||||
|
fn git_status_ok(args: &[&str]) -> Result<(), Box<dyn std::error::Error>> {
|
||||||
|
let output = Command::new("git")
|
||||||
|
.args(args)
|
||||||
|
.current_dir(env::current_dir()?)
|
||||||
|
.output()?;
|
||||||
|
if !output.status.success() {
|
||||||
|
let stderr = String::from_utf8_lossy(&output.stderr).trim().to_string();
|
||||||
|
return Err(format!("git {} failed: {stderr}", args.join(" ")).into());
|
||||||
|
}
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
fn command_exists(name: &str) -> bool {
|
||||||
|
Command::new("which")
|
||||||
|
.arg(name)
|
||||||
|
.output()
|
||||||
|
.map(|output| output.status.success())
|
||||||
|
.unwrap_or(false)
|
||||||
|
}
|
||||||
|
|
||||||
|
fn write_temp_text_file(
|
||||||
|
filename: &str,
|
||||||
|
contents: &str,
|
||||||
|
) -> Result<PathBuf, Box<dyn std::error::Error>> {
|
||||||
|
let path = env::temp_dir().join(filename);
|
||||||
|
fs::write(&path, contents)?;
|
||||||
|
Ok(path)
|
||||||
|
}
|
||||||
|
|
||||||
|
fn recent_user_context(session: &Session, limit: usize) -> String {
|
||||||
|
let requests = session
|
||||||
|
.messages
|
||||||
|
.iter()
|
||||||
|
.filter(|message| message.role == MessageRole::User)
|
||||||
|
.filter_map(|message| {
|
||||||
|
message.blocks.iter().find_map(|block| match block {
|
||||||
|
ContentBlock::Text { text } => Some(text.trim().to_string()),
|
||||||
|
_ => None,
|
||||||
|
})
|
||||||
|
})
|
||||||
|
.rev()
|
||||||
|
.take(limit)
|
||||||
|
.collect::<Vec<_>>();
|
||||||
|
|
||||||
|
if requests.is_empty() {
|
||||||
|
"<no prior user messages>".to_string()
|
||||||
|
} else {
|
||||||
|
requests
|
||||||
|
.into_iter()
|
||||||
|
.rev()
|
||||||
|
.enumerate()
|
||||||
|
.map(|(index, text)| format!("{}. {}", index + 1, text))
|
||||||
|
.collect::<Vec<_>>()
|
||||||
|
.join("\n")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn truncate_for_prompt(value: &str, limit: usize) -> String {
|
||||||
|
if value.chars().count() <= limit {
|
||||||
|
value.trim().to_string()
|
||||||
|
} else {
|
||||||
|
let truncated = value.chars().take(limit).collect::<String>();
|
||||||
|
format!("{}\n…[truncated]", truncated.trim_end())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn sanitize_generated_message(value: &str) -> String {
|
||||||
|
value.trim().trim_matches('`').trim().replace("\r\n", "\n")
|
||||||
|
}
|
||||||
|
|
||||||
|
fn parse_titled_body(value: &str) -> Option<(String, String)> {
|
||||||
|
let normalized = sanitize_generated_message(value);
|
||||||
|
let title = normalized
|
||||||
|
.lines()
|
||||||
|
.find_map(|line| line.strip_prefix("TITLE:").map(str::trim))?;
|
||||||
|
let body_start = normalized.find("BODY:")?;
|
||||||
|
let body = normalized[body_start + "BODY:".len()..].trim();
|
||||||
|
Some((title.to_string(), body.to_string()))
|
||||||
|
}
|
||||||
|
|
||||||
fn render_version_report() -> String {
|
fn render_version_report() -> String {
|
||||||
let git_sha = GIT_SHA.unwrap_or("unknown");
|
let git_sha = GIT_SHA.unwrap_or("unknown");
|
||||||
let target = BUILD_TARGET.unwrap_or("unknown");
|
let target = BUILD_TARGET.unwrap_or("unknown");
|
||||||
@@ -1914,19 +2306,8 @@ fn build_system_prompt() -> Result<Vec<String>, Box<dyn std::error::Error>> {
|
|||||||
)?)
|
)?)
|
||||||
}
|
}
|
||||||
|
|
||||||
fn build_runtime_feature_config(
|
|
||||||
) -> Result<runtime::RuntimeFeatureConfig, Box<dyn std::error::Error>> {
|
|
||||||
let cwd = env::current_dir()?;
|
|
||||||
Ok(ConfigLoader::default_for(cwd)
|
|
||||||
.load()?
|
|
||||||
.feature_config()
|
|
||||||
.clone())
|
|
||||||
}
|
|
||||||
|
|
||||||
#[allow(clippy::too_many_arguments)]
|
|
||||||
fn build_runtime(
|
fn build_runtime(
|
||||||
session: Session,
|
session: Session,
|
||||||
session_id: String,
|
|
||||||
model: String,
|
model: String,
|
||||||
system_prompt: Vec<String>,
|
system_prompt: Vec<String>,
|
||||||
enable_tools: bool,
|
enable_tools: bool,
|
||||||
@@ -1935,19 +2316,12 @@ fn build_runtime(
|
|||||||
permission_mode: PermissionMode,
|
permission_mode: PermissionMode,
|
||||||
) -> Result<ConversationRuntime<AnthropicRuntimeClient, CliToolExecutor>, Box<dyn std::error::Error>>
|
) -> Result<ConversationRuntime<AnthropicRuntimeClient, CliToolExecutor>, Box<dyn std::error::Error>>
|
||||||
{
|
{
|
||||||
Ok(ConversationRuntime::new_with_features(
|
Ok(ConversationRuntime::new(
|
||||||
session,
|
session,
|
||||||
AnthropicRuntimeClient::new(
|
AnthropicRuntimeClient::new(model, enable_tools, emit_output, allowed_tools.clone())?,
|
||||||
model,
|
|
||||||
enable_tools,
|
|
||||||
emit_output,
|
|
||||||
allowed_tools.clone(),
|
|
||||||
session_id,
|
|
||||||
)?,
|
|
||||||
CliToolExecutor::new(allowed_tools, emit_output),
|
CliToolExecutor::new(allowed_tools, emit_output),
|
||||||
permission_policy(permission_mode),
|
permission_policy(permission_mode),
|
||||||
system_prompt,
|
system_prompt,
|
||||||
&build_runtime_feature_config()?,
|
|
||||||
))
|
))
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -2012,13 +2386,11 @@ impl AnthropicRuntimeClient {
|
|||||||
enable_tools: bool,
|
enable_tools: bool,
|
||||||
emit_output: bool,
|
emit_output: bool,
|
||||||
allowed_tools: Option<AllowedToolSet>,
|
allowed_tools: Option<AllowedToolSet>,
|
||||||
session_id: impl Into<String>,
|
|
||||||
) -> Result<Self, Box<dyn std::error::Error>> {
|
) -> Result<Self, Box<dyn std::error::Error>> {
|
||||||
Ok(Self {
|
Ok(Self {
|
||||||
runtime: tokio::runtime::Runtime::new()?,
|
runtime: tokio::runtime::Runtime::new()?,
|
||||||
client: AnthropicClient::from_auth(resolve_cli_auth_source()?)
|
client: AnthropicClient::from_auth(resolve_cli_auth_source()?)
|
||||||
.with_base_url(api::read_base_url())
|
.with_base_url(api::read_base_url()),
|
||||||
.with_prompt_cache(PromptCache::new(session_id)),
|
|
||||||
model,
|
model,
|
||||||
enable_tools,
|
enable_tools,
|
||||||
emit_output,
|
emit_output,
|
||||||
@@ -2133,8 +2505,8 @@ impl ApiClient for AnthropicRuntimeClient {
|
|||||||
events.push(AssistantEvent::Usage(TokenUsage {
|
events.push(AssistantEvent::Usage(TokenUsage {
|
||||||
input_tokens: delta.usage.input_tokens,
|
input_tokens: delta.usage.input_tokens,
|
||||||
output_tokens: delta.usage.output_tokens,
|
output_tokens: delta.usage.output_tokens,
|
||||||
cache_creation_input_tokens: delta.usage.cache_creation_input_tokens,
|
cache_creation_input_tokens: 0,
|
||||||
cache_read_input_tokens: delta.usage.cache_read_input_tokens,
|
cache_read_input_tokens: 0,
|
||||||
}));
|
}));
|
||||||
}
|
}
|
||||||
ApiStreamEvent::MessageStop(_) => {
|
ApiStreamEvent::MessageStop(_) => {
|
||||||
@@ -2149,8 +2521,6 @@ impl ApiClient for AnthropicRuntimeClient {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
push_prompt_cache_record(&self.client, &mut events);
|
|
||||||
|
|
||||||
if !saw_stop
|
if !saw_stop
|
||||||
&& events.iter().any(|event| {
|
&& events.iter().any(|event| {
|
||||||
matches!(event, AssistantEvent::TextDelta(text) if !text.is_empty())
|
matches!(event, AssistantEvent::TextDelta(text) if !text.is_empty())
|
||||||
@@ -2175,9 +2545,7 @@ impl ApiClient for AnthropicRuntimeClient {
|
|||||||
})
|
})
|
||||||
.await
|
.await
|
||||||
.map_err(|error| RuntimeError::new(error.to_string()))?;
|
.map_err(|error| RuntimeError::new(error.to_string()))?;
|
||||||
let mut events = response_to_events(response, out)?;
|
response_to_events(response, out)
|
||||||
push_prompt_cache_record(&self.client, &mut events);
|
|
||||||
Ok(events)
|
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -2238,39 +2606,6 @@ fn collect_tool_results(summary: &runtime::TurnSummary) -> Vec<serde_json::Value
|
|||||||
.collect()
|
.collect()
|
||||||
}
|
}
|
||||||
|
|
||||||
fn collect_prompt_cache_events(summary: &runtime::TurnSummary) -> Vec<serde_json::Value> {
|
|
||||||
summary
|
|
||||||
.prompt_cache_events
|
|
||||||
.iter()
|
|
||||||
.map(|event| {
|
|
||||||
json!({
|
|
||||||
"unexpected": event.unexpected,
|
|
||||||
"reason": event.reason,
|
|
||||||
"previous_cache_read_input_tokens": event.previous_cache_read_input_tokens,
|
|
||||||
"current_cache_read_input_tokens": event.current_cache_read_input_tokens,
|
|
||||||
"token_drop": event.token_drop,
|
|
||||||
})
|
|
||||||
})
|
|
||||||
.collect()
|
|
||||||
}
|
|
||||||
|
|
||||||
fn print_prompt_cache_events(summary: &runtime::TurnSummary) {
|
|
||||||
for event in &summary.prompt_cache_events {
|
|
||||||
let label = if event.unexpected {
|
|
||||||
"Prompt cache break"
|
|
||||||
} else {
|
|
||||||
"Prompt cache invalidation"
|
|
||||||
};
|
|
||||||
println!(
|
|
||||||
"{label}: {} (cache read {} -> {}, drop {})",
|
|
||||||
event.reason,
|
|
||||||
event.previous_cache_read_input_tokens,
|
|
||||||
event.current_cache_read_input_tokens,
|
|
||||||
event.token_drop,
|
|
||||||
);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
fn slash_command_completion_candidates() -> Vec<String> {
|
fn slash_command_completion_candidates() -> Vec<String> {
|
||||||
slash_command_specs()
|
slash_command_specs()
|
||||||
.iter()
|
.iter()
|
||||||
@@ -2417,20 +2752,18 @@ fn first_visible_line(text: &str) -> &str {
|
|||||||
}
|
}
|
||||||
|
|
||||||
fn format_bash_result(icon: &str, parsed: &serde_json::Value) -> String {
|
fn format_bash_result(icon: &str, parsed: &serde_json::Value) -> String {
|
||||||
use std::fmt::Write as _;
|
|
||||||
|
|
||||||
let mut lines = vec![format!("{icon} \x1b[38;5;245mbash\x1b[0m")];
|
let mut lines = vec![format!("{icon} \x1b[38;5;245mbash\x1b[0m")];
|
||||||
if let Some(task_id) = parsed
|
if let Some(task_id) = parsed
|
||||||
.get("backgroundTaskId")
|
.get("backgroundTaskId")
|
||||||
.and_then(|value| value.as_str())
|
.and_then(|value| value.as_str())
|
||||||
{
|
{
|
||||||
let _ = write!(lines[0], " backgrounded ({task_id})");
|
lines[0].push_str(&format!(" backgrounded ({task_id})"));
|
||||||
} else if let Some(status) = parsed
|
} else if let Some(status) = parsed
|
||||||
.get("returnCodeInterpretation")
|
.get("returnCodeInterpretation")
|
||||||
.and_then(|value| value.as_str())
|
.and_then(|value| value.as_str())
|
||||||
.filter(|status| !status.is_empty())
|
.filter(|status| !status.is_empty())
|
||||||
{
|
{
|
||||||
let _ = write!(lines[0], " {status}");
|
lines[0].push_str(&format!(" {status}"));
|
||||||
}
|
}
|
||||||
|
|
||||||
if let Some(stdout) = parsed.get("stdout").and_then(|value| value.as_str()) {
|
if let Some(stdout) = parsed.get("stdout").and_then(|value| value.as_str()) {
|
||||||
@@ -2452,15 +2785,15 @@ fn format_read_result(icon: &str, parsed: &serde_json::Value) -> String {
|
|||||||
let path = extract_tool_path(file);
|
let path = extract_tool_path(file);
|
||||||
let start_line = file
|
let start_line = file
|
||||||
.get("startLine")
|
.get("startLine")
|
||||||
.and_then(serde_json::Value::as_u64)
|
.and_then(|value| value.as_u64())
|
||||||
.unwrap_or(1);
|
.unwrap_or(1);
|
||||||
let num_lines = file
|
let num_lines = file
|
||||||
.get("numLines")
|
.get("numLines")
|
||||||
.and_then(serde_json::Value::as_u64)
|
.and_then(|value| value.as_u64())
|
||||||
.unwrap_or(0);
|
.unwrap_or(0);
|
||||||
let total_lines = file
|
let total_lines = file
|
||||||
.get("totalLines")
|
.get("totalLines")
|
||||||
.and_then(serde_json::Value::as_u64)
|
.and_then(|value| value.as_u64())
|
||||||
.unwrap_or(num_lines);
|
.unwrap_or(num_lines);
|
||||||
let content = file
|
let content = file
|
||||||
.get("content")
|
.get("content")
|
||||||
@@ -2486,7 +2819,8 @@ fn format_write_result(icon: &str, parsed: &serde_json::Value) -> String {
|
|||||||
let line_count = parsed
|
let line_count = parsed
|
||||||
.get("content")
|
.get("content")
|
||||||
.and_then(|value| value.as_str())
|
.and_then(|value| value.as_str())
|
||||||
.map_or(0, |content| content.lines().count());
|
.map(|content| content.lines().count())
|
||||||
|
.unwrap_or(0);
|
||||||
format!(
|
format!(
|
||||||
"{icon} \x1b[1;32m✏️ {} {path}\x1b[0m \x1b[2m({line_count} lines)\x1b[0m",
|
"{icon} \x1b[1;32m✏️ {} {path}\x1b[0m \x1b[2m({line_count} lines)\x1b[0m",
|
||||||
if kind == "create" { "Wrote" } else { "Updated" },
|
if kind == "create" { "Wrote" } else { "Updated" },
|
||||||
@@ -2517,7 +2851,7 @@ fn format_edit_result(icon: &str, parsed: &serde_json::Value) -> String {
|
|||||||
let path = extract_tool_path(parsed);
|
let path = extract_tool_path(parsed);
|
||||||
let suffix = if parsed
|
let suffix = if parsed
|
||||||
.get("replaceAll")
|
.get("replaceAll")
|
||||||
.and_then(serde_json::Value::as_bool)
|
.and_then(|value| value.as_bool())
|
||||||
.unwrap_or(false)
|
.unwrap_or(false)
|
||||||
{
|
{
|
||||||
" (replace all)"
|
" (replace all)"
|
||||||
@@ -2545,7 +2879,7 @@ fn format_edit_result(icon: &str, parsed: &serde_json::Value) -> String {
|
|||||||
fn format_glob_result(icon: &str, parsed: &serde_json::Value) -> String {
|
fn format_glob_result(icon: &str, parsed: &serde_json::Value) -> String {
|
||||||
let num_files = parsed
|
let num_files = parsed
|
||||||
.get("numFiles")
|
.get("numFiles")
|
||||||
.and_then(serde_json::Value::as_u64)
|
.and_then(|value| value.as_u64())
|
||||||
.unwrap_or(0);
|
.unwrap_or(0);
|
||||||
let filenames = parsed
|
let filenames = parsed
|
||||||
.get("filenames")
|
.get("filenames")
|
||||||
@@ -2569,11 +2903,11 @@ fn format_glob_result(icon: &str, parsed: &serde_json::Value) -> String {
|
|||||||
fn format_grep_result(icon: &str, parsed: &serde_json::Value) -> String {
|
fn format_grep_result(icon: &str, parsed: &serde_json::Value) -> String {
|
||||||
let num_matches = parsed
|
let num_matches = parsed
|
||||||
.get("numMatches")
|
.get("numMatches")
|
||||||
.and_then(serde_json::Value::as_u64)
|
.and_then(|value| value.as_u64())
|
||||||
.unwrap_or(0);
|
.unwrap_or(0);
|
||||||
let num_files = parsed
|
let num_files = parsed
|
||||||
.get("numFiles")
|
.get("numFiles")
|
||||||
.and_then(serde_json::Value::as_u64)
|
.and_then(|value| value.as_u64())
|
||||||
.unwrap_or(0);
|
.unwrap_or(0);
|
||||||
let content = parsed
|
let content = parsed
|
||||||
.get("content")
|
.get("content")
|
||||||
@@ -2680,26 +3014,6 @@ fn response_to_events(
|
|||||||
Ok(events)
|
Ok(events)
|
||||||
}
|
}
|
||||||
|
|
||||||
fn push_prompt_cache_record(client: &AnthropicClient, events: &mut Vec<AssistantEvent>) {
|
|
||||||
if let Some(event) = client
|
|
||||||
.take_last_prompt_cache_record()
|
|
||||||
.and_then(prompt_cache_record_to_runtime_event)
|
|
||||||
{
|
|
||||||
events.push(AssistantEvent::PromptCache(event));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
fn prompt_cache_record_to_runtime_event(record: PromptCacheRecord) -> Option<PromptCacheEvent> {
|
|
||||||
let cache_break = record.cache_break?;
|
|
||||||
Some(PromptCacheEvent {
|
|
||||||
unexpected: cache_break.unexpected,
|
|
||||||
reason: cache_break.reason,
|
|
||||||
previous_cache_read_input_tokens: cache_break.previous_cache_read_input_tokens,
|
|
||||||
current_cache_read_input_tokens: cache_break.current_cache_read_input_tokens,
|
|
||||||
token_drop: cache_break.token_drop,
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
struct CliToolExecutor {
|
struct CliToolExecutor {
|
||||||
renderer: TerminalRenderer,
|
renderer: TerminalRenderer,
|
||||||
emit_output: bool,
|
emit_output: bool,
|
||||||
|
|||||||
@@ -286,7 +286,7 @@ impl TerminalRenderer {
|
|||||||
) {
|
) {
|
||||||
match event {
|
match event {
|
||||||
Event::Start(Tag::Heading { level, .. }) => {
|
Event::Start(Tag::Heading { level, .. }) => {
|
||||||
Self::start_heading(state, level as u8, output);
|
self.start_heading(state, level as u8, output)
|
||||||
}
|
}
|
||||||
Event::End(TagEnd::Paragraph) => output.push_str("\n\n"),
|
Event::End(TagEnd::Paragraph) => output.push_str("\n\n"),
|
||||||
Event::Start(Tag::BlockQuote(..)) => self.start_quote(state, output),
|
Event::Start(Tag::BlockQuote(..)) => self.start_quote(state, output),
|
||||||
@@ -426,7 +426,7 @@ impl TerminalRenderer {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
fn start_heading(state: &mut RenderState, level: u8, output: &mut String) {
|
fn start_heading(&self, state: &mut RenderState, level: u8, output: &mut String) {
|
||||||
state.heading_level = Some(level);
|
state.heading_level = Some(level);
|
||||||
if !output.is_empty() {
|
if !output.is_empty() {
|
||||||
output.push('\n');
|
output.push('\n');
|
||||||
|
|||||||
@@ -5,15 +5,15 @@ use std::time::{Duration, Instant};
|
|||||||
|
|
||||||
use api::{
|
use api::{
|
||||||
read_base_url, AnthropicClient, ContentBlockDelta, InputContentBlock, InputMessage,
|
read_base_url, AnthropicClient, ContentBlockDelta, InputContentBlock, InputMessage,
|
||||||
MessageRequest, MessageResponse, OutputContentBlock, PromptCache, PromptCacheRecord,
|
MessageRequest, MessageResponse, OutputContentBlock, StreamEvent as ApiStreamEvent, ToolChoice,
|
||||||
StreamEvent as ApiStreamEvent, ToolChoice, ToolDefinition, ToolResultContentBlock,
|
ToolDefinition, ToolResultContentBlock,
|
||||||
};
|
};
|
||||||
use reqwest::blocking::Client;
|
use reqwest::blocking::Client;
|
||||||
use runtime::{
|
use runtime::{
|
||||||
edit_file, execute_bash, glob_search, grep_search, load_system_prompt, read_file, write_file,
|
edit_file, execute_bash, glob_search, grep_search, load_system_prompt, read_file, write_file,
|
||||||
ApiClient, ApiRequest, AssistantEvent, BashCommandInput, ContentBlock, ConversationMessage,
|
ApiClient, ApiRequest, AssistantEvent, BashCommandInput, ContentBlock, ConversationMessage,
|
||||||
ConversationRuntime, GrepSearchInput, MessageRole, PermissionMode, PermissionPolicy,
|
ConversationRuntime, GrepSearchInput, MessageRole, PermissionMode, PermissionPolicy,
|
||||||
PromptCacheEvent, RuntimeError, Session, TokenUsage, ToolError, ToolExecutor,
|
RuntimeError, Session, TokenUsage, ToolError, ToolExecutor,
|
||||||
};
|
};
|
||||||
use serde::{Deserialize, Serialize};
|
use serde::{Deserialize, Serialize};
|
||||||
use serde_json::{json, Value};
|
use serde_json::{json, Value};
|
||||||
@@ -1466,8 +1466,7 @@ fn build_agent_runtime(
|
|||||||
.clone()
|
.clone()
|
||||||
.unwrap_or_else(|| DEFAULT_AGENT_MODEL.to_string());
|
.unwrap_or_else(|| DEFAULT_AGENT_MODEL.to_string());
|
||||||
let allowed_tools = job.allowed_tools.clone();
|
let allowed_tools = job.allowed_tools.clone();
|
||||||
let api_client =
|
let api_client = AnthropicRuntimeClient::new(model, allowed_tools.clone())?;
|
||||||
AnthropicRuntimeClient::new(model, allowed_tools.clone(), job.manifest.agent_id.clone())?;
|
|
||||||
let tool_executor = SubagentToolExecutor::new(allowed_tools);
|
let tool_executor = SubagentToolExecutor::new(allowed_tools);
|
||||||
Ok(ConversationRuntime::new(
|
Ok(ConversationRuntime::new(
|
||||||
Session::new(),
|
Session::new(),
|
||||||
@@ -1644,15 +1643,10 @@ struct AnthropicRuntimeClient {
|
|||||||
}
|
}
|
||||||
|
|
||||||
impl AnthropicRuntimeClient {
|
impl AnthropicRuntimeClient {
|
||||||
fn new(
|
fn new(model: String, allowed_tools: BTreeSet<String>) -> Result<Self, String> {
|
||||||
model: String,
|
|
||||||
allowed_tools: BTreeSet<String>,
|
|
||||||
session_id: impl Into<String>,
|
|
||||||
) -> Result<Self, String> {
|
|
||||||
let client = AnthropicClient::from_env()
|
let client = AnthropicClient::from_env()
|
||||||
.map_err(|error| error.to_string())?
|
.map_err(|error| error.to_string())?
|
||||||
.with_base_url(read_base_url())
|
.with_base_url(read_base_url());
|
||||||
.with_prompt_cache(PromptCache::new(session_id));
|
|
||||||
Ok(Self {
|
Ok(Self {
|
||||||
runtime: tokio::runtime::Runtime::new().map_err(|error| error.to_string())?,
|
runtime: tokio::runtime::Runtime::new().map_err(|error| error.to_string())?,
|
||||||
client,
|
client,
|
||||||
@@ -1663,7 +1657,6 @@ impl AnthropicRuntimeClient {
|
|||||||
}
|
}
|
||||||
|
|
||||||
impl ApiClient for AnthropicRuntimeClient {
|
impl ApiClient for AnthropicRuntimeClient {
|
||||||
#[allow(clippy::too_many_lines)]
|
|
||||||
fn stream(&mut self, request: ApiRequest) -> Result<Vec<AssistantEvent>, RuntimeError> {
|
fn stream(&mut self, request: ApiRequest) -> Result<Vec<AssistantEvent>, RuntimeError> {
|
||||||
let tools = tool_specs_for_allowed_tools(Some(&self.allowed_tools))
|
let tools = tool_specs_for_allowed_tools(Some(&self.allowed_tools))
|
||||||
.into_iter()
|
.into_iter()
|
||||||
@@ -1733,8 +1726,8 @@ impl ApiClient for AnthropicRuntimeClient {
|
|||||||
events.push(AssistantEvent::Usage(TokenUsage {
|
events.push(AssistantEvent::Usage(TokenUsage {
|
||||||
input_tokens: delta.usage.input_tokens,
|
input_tokens: delta.usage.input_tokens,
|
||||||
output_tokens: delta.usage.output_tokens,
|
output_tokens: delta.usage.output_tokens,
|
||||||
cache_creation_input_tokens: delta.usage.cache_creation_input_tokens,
|
cache_creation_input_tokens: 0,
|
||||||
cache_read_input_tokens: delta.usage.cache_read_input_tokens,
|
cache_read_input_tokens: 0,
|
||||||
}));
|
}));
|
||||||
}
|
}
|
||||||
ApiStreamEvent::MessageStop(_) => {
|
ApiStreamEvent::MessageStop(_) => {
|
||||||
@@ -1744,8 +1737,6 @@ impl ApiClient for AnthropicRuntimeClient {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
push_prompt_cache_record(&self.client, &mut events);
|
|
||||||
|
|
||||||
if !saw_stop
|
if !saw_stop
|
||||||
&& events.iter().any(|event| {
|
&& events.iter().any(|event| {
|
||||||
matches!(event, AssistantEvent::TextDelta(text) if !text.is_empty())
|
matches!(event, AssistantEvent::TextDelta(text) if !text.is_empty())
|
||||||
@@ -1770,9 +1761,7 @@ impl ApiClient for AnthropicRuntimeClient {
|
|||||||
})
|
})
|
||||||
.await
|
.await
|
||||||
.map_err(|error| RuntimeError::new(error.to_string()))?;
|
.map_err(|error| RuntimeError::new(error.to_string()))?;
|
||||||
let mut events = response_to_events(response);
|
Ok(response_to_events(response))
|
||||||
push_prompt_cache_record(&self.client, &mut events);
|
|
||||||
Ok(events)
|
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -1895,26 +1884,6 @@ fn response_to_events(response: MessageResponse) -> Vec<AssistantEvent> {
|
|||||||
events
|
events
|
||||||
}
|
}
|
||||||
|
|
||||||
fn push_prompt_cache_record(client: &AnthropicClient, events: &mut Vec<AssistantEvent>) {
|
|
||||||
if let Some(event) = client
|
|
||||||
.take_last_prompt_cache_record()
|
|
||||||
.and_then(prompt_cache_record_to_runtime_event)
|
|
||||||
{
|
|
||||||
events.push(AssistantEvent::PromptCache(event));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
fn prompt_cache_record_to_runtime_event(record: PromptCacheRecord) -> Option<PromptCacheEvent> {
|
|
||||||
let cache_break = record.cache_break?;
|
|
||||||
Some(PromptCacheEvent {
|
|
||||||
unexpected: cache_break.unexpected,
|
|
||||||
reason: cache_break.reason,
|
|
||||||
previous_cache_read_input_tokens: cache_break.previous_cache_read_input_tokens,
|
|
||||||
current_cache_read_input_tokens: cache_break.current_cache_read_input_tokens,
|
|
||||||
token_drop: cache_break.token_drop,
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn final_assistant_text(summary: &runtime::TurnSummary) -> String {
|
fn final_assistant_text(summary: &runtime::TurnSummary) -> String {
|
||||||
summary
|
summary
|
||||||
.assistant_messages
|
.assistant_messages
|
||||||
|
|||||||
Reference in New Issue
Block a user