use std::collections::{HashMap, VecDeque};
use std::path::PathBuf;
use std::sync::Arc;
use std::time::Instant;
use tokio::sync::{Notify, mpsc, watch};
use tokio_util::sync::CancellationToken;
use zeph_llm::any::AnyProvider;
use zeph_llm::provider::Message;
use zeph_llm::stt::SpeechToText;
use crate::config::{SecurityConfig, SkillPromptMode, TimeoutConfig};
use crate::config_watcher::ConfigEvent;
use crate::context::EnvironmentContext;
use crate::cost::CostTracker;
use crate::instructions::{InstructionBlock, InstructionEvent, InstructionReloadState};
use crate::metrics::MetricsSnapshot;
use crate::vault::Secret;
use zeph_memory::TokenCounter;
use zeph_memory::semantic::SemanticMemory;
use zeph_sanitizer::ContentSanitizer;
use zeph_sanitizer::quarantine::QuarantinedSummarizer;
use zeph_skills::matcher::SkillMatcherBackend;
use zeph_skills::registry::SkillRegistry;
use zeph_skills::watcher::SkillEvent;
use super::message_queue::QueuedMessage;
pub(crate) struct MemoryState {
pub(crate) memory: Option<Arc<SemanticMemory>>,
pub(crate) conversation_id: Option<zeph_memory::ConversationId>,
pub(crate) history_limit: u32,
pub(crate) recall_limit: usize,
pub(crate) summarization_threshold: usize,
pub(crate) cross_session_score_threshold: f32,
pub(crate) autosave_assistant: bool,
pub(crate) autosave_min_length: usize,
pub(crate) tool_call_cutoff: usize,
pub(crate) unsummarized_count: usize,
pub(crate) document_config: crate::config::DocumentConfig,
pub(crate) graph_config: crate::config::GraphConfig,
pub(crate) compression_guidelines_config: zeph_memory::CompressionGuidelinesConfig,
pub(crate) shutdown_summary: bool,
pub(crate) shutdown_summary_min_messages: usize,
pub(crate) shutdown_summary_max_messages: usize,
pub(crate) shutdown_summary_timeout_secs: u64,
}
pub(crate) struct SkillState {
pub(crate) registry: std::sync::Arc<std::sync::RwLock<SkillRegistry>>,
pub(crate) skill_paths: Vec<PathBuf>,
pub(crate) managed_dir: Option<PathBuf>,
pub(crate) trust_config: crate::config::TrustConfig,
pub(crate) matcher: Option<SkillMatcherBackend>,
pub(crate) max_active_skills: usize,
pub(crate) disambiguation_threshold: f32,
pub(crate) embedding_model: String,
pub(crate) skill_reload_rx: Option<mpsc::Receiver<SkillEvent>>,
pub(crate) active_skill_names: Vec<String>,
pub(crate) last_skills_prompt: String,
pub(crate) prompt_mode: SkillPromptMode,
pub(crate) available_custom_secrets: HashMap<String, Secret>,
pub(crate) cosine_weight: f32,
pub(crate) hybrid_search: bool,
pub(crate) bm25_index: Option<zeph_skills::bm25::Bm25Index>,
}
pub(crate) struct McpState {
pub(crate) tools: Vec<zeph_mcp::McpTool>,
pub(crate) registry: Option<zeph_mcp::McpToolRegistry>,
pub(crate) manager: Option<std::sync::Arc<zeph_mcp::McpManager>>,
pub(crate) allowed_commands: Vec<String>,
pub(crate) max_dynamic: usize,
pub(crate) shared_tools: Option<std::sync::Arc<std::sync::RwLock<Vec<zeph_mcp::McpTool>>>>,
pub(crate) tool_rx: Option<tokio::sync::watch::Receiver<Vec<zeph_mcp::McpTool>>>,
}
pub(crate) struct IndexState {
pub(crate) retriever: Option<std::sync::Arc<zeph_index::retriever::CodeRetriever>>,
pub(crate) repo_map_tokens: usize,
pub(crate) cached_repo_map: Option<(String, std::time::Instant)>,
pub(crate) repo_map_ttl: std::time::Duration,
}
pub(crate) struct RuntimeConfig {
pub(crate) security: SecurityConfig,
pub(crate) timeouts: TimeoutConfig,
pub(crate) model_name: String,
pub(crate) permission_policy: zeph_tools::PermissionPolicy,
pub(crate) redact_credentials: bool,
pub(crate) rate_limiter: super::rate_limiter::ToolRateLimiter,
}
pub(crate) struct FeedbackState {
pub(crate) detector: super::feedback_detector::FeedbackDetector,
pub(crate) judge: Option<super::feedback_detector::JudgeDetector>,
}
pub(crate) struct SecurityState {
pub(crate) sanitizer: ContentSanitizer,
pub(crate) quarantine_summarizer: Option<QuarantinedSummarizer>,
pub(crate) exfiltration_guard: zeph_sanitizer::exfiltration::ExfiltrationGuard,
pub(crate) flagged_urls: std::collections::HashSet<String>,
pub(crate) pii_filter: zeph_sanitizer::pii::PiiFilter,
pub(crate) memory_validator: zeph_sanitizer::memory_validation::MemoryWriteValidator,
#[cfg(feature = "guardrail")]
pub(crate) guardrail: Option<zeph_sanitizer::guardrail::GuardrailFilter>,
}
pub(crate) struct DebugState {
pub(crate) debug_dumper: Option<crate::debug_dump::DebugDumper>,
pub(crate) dump_format: crate::debug_dump::DumpFormat,
pub(crate) trace_collector: Option<crate::debug_dump::trace::TracingCollector>,
pub(crate) iteration_counter: usize,
pub(crate) anomaly_detector: Option<zeph_tools::AnomalyDetector>,
pub(crate) logging_config: crate::config::LoggingConfig,
pub(crate) dump_dir: Option<PathBuf>,
pub(crate) trace_service_name: String,
pub(crate) trace_redact: bool,
pub(crate) current_iteration_span_id: Option<[u8; 8]>,
}
pub(crate) struct LifecycleState {
pub(crate) shutdown: watch::Receiver<bool>,
pub(crate) start_time: Instant,
pub(crate) cancel_signal: Arc<Notify>,
pub(crate) cancel_token: CancellationToken,
pub(crate) config_path: Option<PathBuf>,
pub(crate) config_reload_rx: Option<mpsc::Receiver<ConfigEvent>>,
pub(crate) warmup_ready: Option<watch::Receiver<bool>>,
pub(crate) update_notify_rx: Option<mpsc::Receiver<String>>,
pub(crate) custom_task_rx: Option<mpsc::Receiver<String>>,
}
pub(crate) struct ProviderState {
pub(crate) summary_provider: Option<AnyProvider>,
pub(crate) provider_override: Option<Arc<std::sync::RwLock<Option<AnyProvider>>>>,
pub(crate) judge_provider: Option<AnyProvider>,
pub(crate) cached_prompt_tokens: u64,
pub(crate) server_compaction_active: bool,
pub(crate) stt: Option<Box<dyn SpeechToText>>,
}
pub(crate) struct MetricsState {
pub(crate) metrics_tx: Option<watch::Sender<MetricsSnapshot>>,
pub(crate) cost_tracker: Option<CostTracker>,
pub(crate) token_counter: Arc<TokenCounter>,
pub(crate) extended_context: bool,
}
pub(crate) struct OrchestrationState {
pub(crate) pending_graph: Option<crate::orchestration::TaskGraph>,
pub(crate) plan_cancel_token: Option<CancellationToken>,
pub(crate) subagent_manager: Option<crate::subagent::SubAgentManager>,
pub(crate) subagent_config: crate::config::SubAgentConfig,
pub(crate) orchestration_config: crate::config::OrchestrationConfig,
}
pub(crate) struct InstructionState {
pub(crate) blocks: Vec<InstructionBlock>,
pub(crate) reload_rx: Option<mpsc::Receiver<InstructionEvent>>,
pub(crate) reload_state: Option<InstructionReloadState>,
}
pub(crate) struct ExperimentState {
#[cfg(feature = "experiments")]
pub(crate) config: crate::config::ExperimentConfig,
#[cfg(feature = "experiments")]
pub(crate) cancel: Option<tokio_util::sync::CancellationToken>,
#[cfg(feature = "experiments")]
pub(crate) baseline: crate::experiments::ConfigSnapshot,
pub(crate) notify_rx: Option<tokio::sync::mpsc::Receiver<String>>,
#[cfg(feature = "experiments")]
pub(crate) notify_tx: tokio::sync::mpsc::Sender<String>,
}
#[cfg(feature = "context-compression")]
pub(crate) struct CompressionState {
pub(crate) current_task_goal: Option<String>,
pub(crate) task_goal_user_msg_hash: Option<u64>,
pub(crate) pending_task_goal: Option<tokio::task::JoinHandle<Option<String>>>,
pub(crate) pending_sidequest_result: Option<tokio::task::JoinHandle<Option<Vec<usize>>>>,
}
pub(crate) struct SessionState {
pub(crate) env_context: EnvironmentContext,
pub(crate) response_cache: Option<std::sync::Arc<zeph_memory::ResponseCache>>,
pub(crate) parent_tool_use_id: Option<String>,
pub(crate) status_tx: Option<tokio::sync::mpsc::UnboundedSender<String>>,
#[cfg(feature = "lsp-context")]
pub(crate) lsp_hooks: Option<crate::lsp_hooks::LspHookRunner>,
#[cfg(feature = "policy-enforcer")]
pub(crate) policy_config: Option<zeph_tools::PolicyConfig>,
}
pub(crate) struct MessageState {
pub(crate) messages: Vec<Message>,
#[allow(private_interfaces)]
pub(crate) message_queue: VecDeque<QueuedMessage>,
pub(crate) pending_image_parts: Vec<zeph_llm::provider::MessagePart>,
}
#[cfg(test)]
mod tests;