#![warn(missing_docs)]
#![warn(clippy::unwrap_used)]
#![allow(unknown_lints)]
pub mod bootstrap;
pub mod cli;
pub mod main_dispatch;
pub mod print_mode;
pub mod services;
pub mod setup_wizard;
pub mod store;
pub(crate) mod app;
pub(crate) mod context;
pub mod extensions; pub(crate) mod infra;
pub(crate) mod media;
pub(crate) mod prompt;
pub(crate) mod rpc_mode;
pub(crate) mod skills;
pub mod storage; pub use storage::packages::PackageManager;
pub use storage::packages::ResourceKind;
pub mod tui; pub(crate) mod ui;
pub(crate) mod util;
pub fn build_oxi_engine() -> anyhow::Result<oxi_sdk::Oxi> {
let paths = services::OxiPaths::default_paths()?;
services::build_oxi(&paths)
}
pub async fn run_port_check() -> anyhow::Result<()> {
let oxi = build_oxi_engine()?;
let ports = oxi.ports();
let entries = ports.state.list("").await?;
println!("[state] entries: {}", entries.len());
let providers = ports.auth.list_providers().await?;
println!("[auth] providers with credentials: {:?}", providers);
let keys = ports.config.list()?;
println!("[config] keys: {}", keys.len());
let skills = ports.skills.list().await?;
println!("[skills] {} skill(s) discovered", skills.len());
for s in &skills {
println!(" - {}: {}", s.name, s.description);
}
let _ = ports
.event_bus
.publish(&"port-check".to_string(), serde_json::json!({"ok": true}))
.await;
println!("[event-bus] publish ok (noop bus if not registered)");
println!("\nport check: ok");
Ok(())
}
#[derive(Debug, Clone)]
pub struct CompactionContext {
pub messages_count: usize,
pub tokens_before: usize,
pub target_tokens: usize,
pub strategy: String,
}
impl CompactionContext {
pub fn new(
messages_count: usize,
tokens_before: usize,
target_tokens: usize,
strategy: impl Into<String>,
) -> Self {
Self {
messages_count,
tokens_before,
target_tokens,
strategy: strategy.into(),
}
}
pub fn compression_ratio(&self) -> f32 {
if self.tokens_before == 0 {
return 1.0;
}
self.target_tokens as f32 / self.tokens_before as f32
}
}
use crate::store::settings::Settings;
use anyhow::{Error, Result};
use oxi_agent::{Agent, AgentConfig, AgentEvent};
use parking_lot::RwLock;
use skills::SkillManager;
use std::sync::Arc;
pub struct App {
oxi: oxi_sdk::Oxi,
agent: Arc<Agent>,
settings: Settings,
skills: RwLock<SkillManager>,
active_skills: RwLock<Vec<String>>,
wasm_ext: Option<std::sync::Arc<crate::extensions::WasmExtensionManager>>,
questionnaire_bridge:
Option<std::sync::Arc<oxi_agent::tools::questionnaire::QuestionnaireBridge>>,
}
fn build_system_prompt(
thinking_level: crate::store::settings::ThinkingLevel,
skill_contents: &[String],
) -> String {
let skills: Vec<prompt::system_prompt::Skill> = skill_contents
.iter()
.enumerate()
.map(|(i, content)| prompt::system_prompt::Skill {
name: format!("skill-{}", i),
content: content.clone(),
})
.collect();
let options = prompt::system_prompt::BuildSystemPromptOptions {
custom_prompt: prompt::system_prompt::thinking_level_prompt(thinking_level),
skills,
cwd: std::env::current_dir()
.map(|p| p.to_string_lossy().to_string())
.unwrap_or_default(),
..Default::default()
};
prompt::system_prompt::build_system_prompt(&options)
}
impl App {
pub async fn from_oxi(oxi: oxi_sdk::Oxi, settings: Settings) -> Result<Self> {
let model_id = settings.effective_model(None).unwrap_or_default();
let provider_name = settings
.effective_provider(None)
.unwrap_or_else(|| model_id.split('/').next().unwrap_or("").to_string());
let api_key = oxi.ports().auth.get_api_key(&provider_name).await?;
let skills_dir = SkillManager::skills_dir().unwrap_or_else(|_| {
dirs::home_dir()
.unwrap_or_default()
.join(".oxi")
.join("skills")
});
let skills = SkillManager::load_from_dir(&skills_dir).unwrap_or_else(|e| {
tracing::debug!("Skills not loaded: {}", e);
SkillManager::new()
});
let system_prompt = build_system_prompt(settings.thinking_level, &[]);
let compaction_strategy = if settings.auto_compaction {
oxi_sdk::CompactionStrategy::Threshold(0.8)
} else {
oxi_sdk::CompactionStrategy::Disabled
};
let config = AgentConfig {
name: "oxi".to_string(),
description: Some("oxi CLI agent".to_string()),
model_id: model_id.clone(),
system_prompt: Some(system_prompt),
max_iterations: 10,
timeout_seconds: settings.tool_timeout_seconds,
temperature: settings.effective_temperature(),
max_tokens: settings.effective_max_tokens(),
compaction_strategy,
compaction_instruction: None,
context_window: 128_000,
api_key,
workspace_dir: Some(
std::env::current_dir().unwrap_or_else(|_| std::path::PathBuf::from(".")),
),
output_mode: None,
provider_options: None,
};
let cwd = std::env::current_dir().unwrap_or_else(|_| std::path::PathBuf::from("."));
let agent = oxi
.agent(config)
.workspace(cwd)
.build()
.map_err(|e| Error::msg(format!("agent build failed: {e}")))?;
let agent = Arc::new(agent);
let bridge =
std::sync::Arc::new(oxi_agent::tools::questionnaire::QuestionnaireBridge::new());
let questionnaire_tool =
oxi_agent::tools::questionnaire::QuestionnaireTool::new(bridge.clone());
agent
.tools()
.register_arc(std::sync::Arc::new(questionnaire_tool));
Ok(Self {
oxi,
agent,
settings,
skills: RwLock::new(skills),
active_skills: RwLock::new(Vec::new()),
wasm_ext: None,
questionnaire_bridge: Some(bridge),
})
}
pub fn settings(&self) -> &Settings {
&self.settings
}
pub fn set_wasm_ext(
&mut self,
ext: Option<std::sync::Arc<crate::extensions::WasmExtensionManager>>,
) {
self.wasm_ext = ext;
}
pub fn wasm_ext(&self) -> Option<&std::sync::Arc<crate::extensions::WasmExtensionManager>> {
self.wasm_ext.as_ref()
}
pub fn agent(&self) -> Arc<Agent> {
Arc::clone(&self.agent)
}
pub fn agent_tools(&self) -> Arc<oxi_agent::ToolRegistry> {
self.agent.tools()
}
pub fn questionnaire_bridge(
&self,
) -> Option<&std::sync::Arc<oxi_agent::tools::questionnaire::QuestionnaireBridge>> {
self.questionnaire_bridge.as_ref()
}
pub fn skills(&self) -> parking_lot::RwLockReadGuard<'_, SkillManager> {
self.skills.read()
}
pub fn activate_skill(&self, name: &str) -> Result<(), String> {
{
let skills = self.skills.read();
if skills.get(name).is_none() {
return Err(format!("Skill '{}' not found", name));
}
}
let name_lower = name.to_lowercase();
{
let mut active = self.active_skills.write();
if !active.contains(&name_lower) {
active.push(name_lower);
}
}
self.rebuild_system_prompt();
Ok(())
}
pub fn deactivate_skill(&self, name: &str) {
let name_lower = name.to_lowercase();
{
let mut active = self.active_skills.write();
active.retain(|n| n != &name_lower);
}
self.rebuild_system_prompt();
}
pub fn active_skills(&self) -> Vec<String> {
self.active_skills.read().clone()
}
fn rebuild_system_prompt(&self) {
let active = self.active_skills.read();
let skills = self.skills.read();
let contents: Vec<String> = active
.iter()
.filter_map(|name| skills.get(name).map(|s| s.content.clone()))
.collect();
let prompt = build_system_prompt(self.settings.thinking_level, &contents);
self.agent.set_system_prompt(prompt);
}
pub fn agent_state(&self) -> oxi_agent::AgentState {
self.agent.state()
}
pub async fn run_prompt(&self, prompt: String) -> Result<String> {
let (response, _events) = self.agent.run(prompt).await?;
Ok(response.content)
}
pub async fn run_prompt_with_events<F>(&self, prompt: String, on_event: F) -> Result<String>
where
F: FnMut(AgentEvent) + Send + 'static,
{
self.agent.run_streaming(prompt, on_event).await?;
let state = self.agent_state();
for msg in state.messages.iter().rev() {
if let oxi_sdk::Message::Assistant(a) = msg {
return Ok(a.text_content());
}
}
Ok(String::new())
}
pub fn reset(&self) {
self.agent.reset();
}
pub async fn switch_model(&self, model_id: &str) -> anyhow::Result<()> {
let parts: Vec<&str> = model_id.split('/').collect();
let provider = parts
.first()
.map(|s| s.to_string())
.unwrap_or_else(|| "anthropic".to_string());
let api_key = self.oxi.ports().auth.get_api_key(&provider).await?;
let _ = self.agent.switch_model(model_id, api_key);
Ok(())
}
pub fn model_id(&self) -> String {
self.agent.model_id()
}
}