1#![allow(
4 missing_docs,
5 dead_code,
6 clippy::field_reassign_with_default,
7 clippy::unwrap_used,
8 clippy::let_and_return,
9 clippy::borrow_interior_mutable_const,
10 clippy::derivable_impls,
11 clippy::new_without_default,
12 unknown_lints
13)]
14pub mod bootstrap;
21pub mod cli;
22pub mod internal_urls;
23pub mod lsp;
24pub mod main_dispatch;
25pub mod mcp_credentials;
26pub mod oauth_listener;
27pub mod oauth_refresh;
28pub mod print_mode;
29pub mod provider_oauth;
30pub mod services;
31pub mod setup_wizard;
32pub mod store;
33
34pub(crate) mod app;
36pub(crate) mod context;
37pub mod discovery;
38pub mod extensions; pub(crate) mod infra;
40pub(crate) mod media;
41pub(crate) mod prompt;
42pub mod rpc_mode;
43pub(crate) mod skills;
44pub mod storage; pub use storage::packages::PackageManager;
47pub use storage::packages::ResourceKind;
48pub mod tools;
49pub(crate) mod ui;
50pub(crate) mod util;
51
52pub async fn build_oxicode_engine(
67 embedding_provider: Option<std::sync::Arc<dyn oxicode_sdk::ports::EmbeddingProvider>>,
68 hook_runner: Option<std::sync::Arc<dyn oxicode_sdk::ports::HookRunner>>,
69) -> anyhow::Result<oxicode_sdk::Oxicode> {
70 let paths = services::OxicodePaths::default_paths()?;
71 services::build_oxicode(&paths, embedding_provider, hook_runner).await
72}
73
74pub async fn run_port_check() -> anyhow::Result<()> {
81 let oxicode = build_oxicode_engine(None, None).await?;
82 let ports = oxicode.ports();
83
84 let entries = ports.state.list("").await?;
85 println!("[state] entries: {}", entries.len());
86
87 let providers = ports.auth.list_providers().await?;
89 println!("[auth] providers with credentials: {:?}", providers);
90
91 let keys = ports.config.list()?;
93 println!("[config] keys: {}", keys.len());
94
95 let skills = ports.skills.list().await?;
97 println!("[skills] {} skill(s) discovered", skills.len());
98 for s in &skills {
99 println!(" - {}: {}", s.name, s.description);
100 }
101
102 let _ = ports
104 .event_bus
105 .publish(&"port-check".to_string(), serde_json::json!({"ok": true}))
106 .await;
107 println!("[event-bus] publish ok (noop bus if not registered)");
108
109 println!("\nport check: ok");
110 Ok(())
111}
112
113#[derive(Debug, Clone)]
115pub struct CompactionContext {
116 pub messages_count: usize,
118 pub tokens_before: usize,
120 pub target_tokens: usize,
122 pub strategy: String,
124}
125
126impl CompactionContext {
127 pub fn new(
129 messages_count: usize,
130 tokens_before: usize,
131 target_tokens: usize,
132 strategy: impl Into<String>,
133 ) -> Self {
134 Self {
135 messages_count,
136 tokens_before,
137 target_tokens,
138 strategy: strategy.into(),
139 }
140 }
141
142 pub fn compression_ratio(&self) -> f32 {
144 if self.tokens_before == 0 {
145 return 1.0;
146 }
147 self.target_tokens as f32 / self.tokens_before as f32
148 }
149}
150
151use crate::store::settings::Settings;
153use anyhow::{Error, Result};
154use oxicode_agent::{Agent, AgentConfig, AgentEvent};
155use parking_lot::RwLock;
156use skills::SkillManager;
157use std::collections::VecDeque;
158use std::sync::Arc;
159
160#[derive(Clone)]
171pub struct SessionState {
172 pub should_stop: Arc<std::sync::atomic::AtomicBool>,
176 pub steering: Arc<RwLock<VecDeque<oxicode_sdk::Message>>>,
178 pub follow_up: Arc<RwLock<VecDeque<oxicode_sdk::Message>>>,
180}
181
182impl Default for SessionState {
183 fn default() -> Self {
184 Self {
185 should_stop: Arc::new(std::sync::atomic::AtomicBool::new(false)),
186 steering: Arc::new(RwLock::new(VecDeque::new())),
187 follow_up: Arc::new(RwLock::new(VecDeque::new())),
188 }
189 }
190}
191
192pub struct App {
199 oxicode: oxicode_sdk::Oxicode,
200 agent: Arc<Agent>,
201 settings: Settings,
202 skills: RwLock<SkillManager>,
203 active_skills: RwLock<Vec<String>>,
204 wasm_ext: Option<std::sync::Arc<crate::extensions::WasmExtensionManager>>,
205 ask_bridge: Option<std::sync::Arc<oxicode_agent::tools::ask::AskBridge>>,
206 issue_store: Option<crate::store::issues::FileIssueStore>,
210 ownership_session_id: String,
215 #[allow(dead_code)]
220 liveness_guard: Option<crate::store::issues::liveness::AliveGuard>,
221 persona_body: RwLock<Option<String>>,
224 session_state: SessionState,
228}
229fn build_system_prompt(
231 thinking_level: crate::store::settings::ThinkingLevel,
232 skill_contents: &[String],
233 persona_body: Option<&str>,
234) -> String {
235 let skills: Vec<prompt::system_prompt::Skill> = skill_contents
236 .iter()
237 .enumerate()
238 .map(|(i, content)| prompt::system_prompt::Skill {
239 name: format!("skill-{}", i),
240 content: content.clone(),
241 })
242 .collect();
243
244 let options = prompt::system_prompt::BuildSystemPromptOptions {
245 custom_prompt: prompt::system_prompt::thinking_level_prompt(thinking_level),
246 skills,
247 cwd: std::env::current_dir()
248 .map(|p| p.to_string_lossy().to_string())
249 .unwrap_or_default(),
250 persona_prompt: persona_body.map(|s| s.to_string()),
251 ..Default::default()
252 };
253
254 prompt::system_prompt::build_system_prompt(&options)
255}
256
257impl App {
260 pub async fn from_oxicode(
280 oxicode: oxicode_sdk::Oxicode,
281 settings: Settings,
282 ownership_session_id: String,
283 session_state: Option<SessionState>,
284 ) -> Result<Self> {
285 let session_state = session_state.unwrap_or_default();
286 let persona = match oxicode.ports().personas.get("default").await {
291 Ok(Some(p)) if !p.system_prompt.trim().is_empty() => Some(p),
292 Ok(_) => None,
293 Err(e) => {
294 tracing::warn!(error = %e, "default persona lookup failed");
295 None
296 }
297 };
298
299 let model_id = persona
300 .as_ref()
301 .and_then(|p| p.preferred_model.clone())
302 .or_else(|| settings.effective_model(None))
303 .unwrap_or_default();
304 let skills_dir = SkillManager::skills_dir().unwrap_or_else(|_| {
308 dirs::home_dir()
309 .unwrap_or_default()
310 .join(".oxicode")
311 .join("skills")
312 });
313 let skills = SkillManager::load_from_dir(&skills_dir).unwrap_or_else(|e| {
314 tracing::debug!("Skills not loaded: {}", e);
315 SkillManager::new()
316 });
317
318 let body_str = persona.as_ref().map(|p| p.system_prompt.clone());
319 let system_prompt = build_system_prompt(settings.thinking_level, &[], body_str.as_deref());
320 let compaction_strategy = if settings.auto_compaction {
321 oxicode_sdk::CompactionStrategy::Threshold(0.8)
322 } else {
323 oxicode_sdk::CompactionStrategy::Disabled
324 };
325
326 let config = AgentConfig {
327 name: "oxicode".to_string(),
328 description: Some("oxicode CLI agent".to_string()),
329 model_id: model_id.clone(),
330 system_prompt: Some(system_prompt),
331 timeout_seconds: settings.tool_timeout_seconds,
332 temperature: settings.effective_temperature(),
333 max_tokens: settings.effective_max_tokens(),
334 compaction_strategy,
335 compaction_instruction: None,
336 context_window: 128_000,
337 workspace_dir: Some(
338 std::env::current_dir().unwrap_or_else(|_| std::path::PathBuf::from(".")),
339 ),
340 output_mode: None,
341 provider_options: None,
342 session_id: Some(ownership_session_id.clone()),
343 ttsr_engine: None,
344 memory: None,
345 todo: None,
346 agent_pool: None,
347 url_resolver: Some(Arc::new(oxicode_sdk::SdkUrlResolver::new(
348 oxicode.ports().url_router.clone(),
349 ))),
350 lsp: if crate::lsp::manager::default_servers().is_empty() {
356 None
357 } else {
358 Some(Arc::new(crate::lsp::CliLspProvider::with_defaults(
359 std::env::current_dir().unwrap_or_else(|_| std::path::PathBuf::from(".")),
360 )))
361 },
362 ..Default::default()
363 };
364
365 let cwd = std::env::current_dir().unwrap_or_else(|_| std::path::PathBuf::from("."));
374
375 let ask_timeout = if settings.ask_timeout_secs > 0 {
384 Some(std::time::Duration::from_secs(settings.ask_timeout_secs))
385 } else {
386 None
387 };
388 let bridge = std::sync::Arc::new(oxicode_agent::tools::ask::AskBridge::with_timeout(
389 ask_timeout,
390 ));
391 let mode_handle = bridge.mode_handle();
392
393 let stop_flag = Arc::clone(&session_state.should_stop);
394 let steering = Arc::clone(&session_state.steering);
395 let follow_up = Arc::clone(&session_state.follow_up);
396 let session_hooks = oxicode_sdk::agent_builder::SessionHookClosures {
397 should_stop_after_turn: Arc::new(move |_| {
398 stop_flag.load(std::sync::atomic::Ordering::SeqCst)
399 }),
400 get_steering_messages: Arc::new(move || {
401 let mut msgs: Vec<oxicode_sdk::Message> = steering.write().drain(..).collect();
402 if oxicode_agent::config::Mode::load(&mode_handle).is_auto() {
405 msgs.push(oxicode_sdk::Message::User(oxicode_sdk::UserMessage::new(
406 "Autonomy mode (auto) is active: proceed autonomously to \
407 completion without asking the user questions. Make \
408 reasonable decisions on your own and keep working.",
409 )));
410 }
411 msgs
412 }),
413 get_follow_up_messages: Arc::new(move || follow_up.write().drain(..).collect()),
414 tool_execution: oxicode_agent::config::ToolExecutionMode::Sequential,
415 };
416
417 let agent = oxicode
418 .agent(config)
419 .workspace(cwd)
420 .with_port_hooks()
421 .with_session_hooks(session_hooks)
422 .build()
423 .map_err(|e| Error::msg(format!("agent build failed: {e}")))?;
424 let agent = Arc::new(agent);
425
426 let ask_tool = oxicode_agent::tools::ask::AskTool::new(bridge.clone());
427 agent.tools().register_arc(std::sync::Arc::new(ask_tool));
428 let issue_store = std::env::current_dir()
433 .ok()
434 .map(|cwd| crate::store::issues::FileIssueStore::open_from_cwd(&cwd))
435 .and_then(|r| {
436 r.map_err(|e| tracing::warn!("issue store unavailable: {e}"))
437 .ok()
438 });
439
440 if let Some(store) = issue_store.clone() {
442 let tool = std::sync::Arc::new(crate::tools::IssueTool::new(store));
443 agent.tools().register_arc(tool);
444 }
445
446 Ok(Self {
447 oxicode,
448 agent,
449 settings,
450 skills: RwLock::new(skills),
451 active_skills: RwLock::new(Vec::new()),
452 wasm_ext: None,
453 ask_bridge: Some(bridge),
454 issue_store,
455 ownership_session_id,
456 liveness_guard: None, persona_body: RwLock::new(persona.as_ref().map(|p| p.system_prompt.clone())),
458 session_state,
459 })
460 .map(|mut app| {
461 app.liveness_guard =
465 acquire_ownership_guard(app.issue_store.as_ref(), &app.ownership_session_id);
466 app
467 })
468 }
469
470 pub fn ownership_session_id(&self) -> &str {
473 &self.ownership_session_id
474 }
475
476 pub fn has_liveness_lock(&self) -> bool {
481 self.liveness_guard.is_some()
482 }
483
484 pub fn settings(&self) -> &Settings {
486 &self.settings
487 }
488
489 pub fn set_wasm_ext(
491 &mut self,
492 ext: Option<std::sync::Arc<crate::extensions::WasmExtensionManager>>,
493 ) {
494 self.wasm_ext = ext;
495 }
496
497 pub fn wasm_ext(&self) -> Option<&std::sync::Arc<crate::extensions::WasmExtensionManager>> {
499 self.wasm_ext.as_ref()
500 }
501
502 pub fn issue_store(&self) -> Option<crate::store::issues::FileIssueStore> {
504 self.issue_store.clone()
505 }
506
507 pub fn oxicode(&self) -> &oxicode_sdk::Oxicode {
510 &self.oxicode
511 }
512
513 pub fn catalog(&self) -> std::sync::Arc<dyn oxicode_sdk::ports::catalog::ModelCatalog> {
516 std::sync::Arc::clone(self.oxicode.catalog())
517 }
518
519 pub fn agent(&self) -> Arc<Agent> {
521 Arc::clone(&self.agent)
522 }
523
524 pub fn agent_tools(&self) -> Arc<oxicode_agent::ToolRegistry> {
526 self.agent.tools()
527 }
528
529 pub fn ask_bridge(&self) -> Option<&std::sync::Arc<oxicode_agent::tools::ask::AskBridge>> {
531 self.ask_bridge.as_ref()
532 }
533
534 pub fn skills(&self) -> parking_lot::RwLockReadGuard<'_, SkillManager> {
536 self.skills.read()
537 }
538
539 pub fn activate_skill(&self, name: &str) -> Result<(), String> {
541 {
542 let skills = self.skills.read();
543 if skills.get(name).is_none() {
544 return Err(format!("Skill '{}' not found", name));
545 }
546 }
547 let name_lower = name.to_lowercase();
548 {
549 let mut active = self.active_skills.write();
550 if !active.contains(&name_lower) {
551 active.push(name_lower);
552 }
553 }
554 self.rebuild_system_prompt();
555 Ok(())
556 }
557
558 pub fn deactivate_skill(&self, name: &str) {
560 let name_lower = name.to_lowercase();
561 {
562 let mut active = self.active_skills.write();
563 active.retain(|n| n != &name_lower);
564 }
565 self.rebuild_system_prompt();
566 }
567
568 pub fn active_skills(&self) -> Vec<String> {
570 self.active_skills.read().clone()
571 }
572
573 fn rebuild_system_prompt(&self) {
575 let active = self.active_skills.read();
576 let skills = self.skills.read();
577 let contents: Vec<String> = active
578 .iter()
579 .filter_map(|name| skills.get(name).map(|s| s.content.clone()))
580 .collect();
581 let persona = self.persona_body.read().clone();
585 let prompt =
586 build_system_prompt(self.settings.thinking_level, &contents, persona.as_deref());
587 self.agent.set_system_prompt(prompt);
588 }
589
590 pub fn agent_state(&self) -> oxicode_agent::AgentState {
592 self.agent.state()
593 }
594
595 pub async fn run_prompt(&self, prompt: String) -> Result<String> {
597 let (response, _events) = self.agent.run(prompt).await?;
598 Ok(response.content)
599 }
600
601 pub async fn run_prompt_with_events<F>(&self, prompt: String, on_event: F) -> Result<String>
603 where
604 F: FnMut(AgentEvent) + Send + 'static,
605 {
606 self.agent.run_streaming(prompt, on_event).await?;
607 let state = self.agent_state();
608 for msg in state.messages.iter().rev() {
609 if let oxicode_sdk::Message::Assistant(a) = msg {
610 return Ok(a.text_content());
611 }
612 }
613 Ok(String::new())
614 }
615
616 pub fn reset(&self) {
618 self.agent.reset();
619 }
620
621 pub async fn switch_model(&self, model_id: &str) -> anyhow::Result<()> {
627 let _ = self.agent.switch_model(model_id);
628 Ok(())
629 }
630
631 pub fn model_id(&self) -> String {
633 self.agent.model_id()
634 }
635
636 pub fn session_state(&self) -> &SessionState {
641 &self.session_state
642 }
643
644 pub fn should_stop_flag(&self) -> Arc<std::sync::atomic::AtomicBool> {
646 Arc::clone(&self.session_state.should_stop)
647 }
648
649 pub fn steering_queue(&self) -> Arc<RwLock<VecDeque<oxicode_sdk::Message>>> {
651 Arc::clone(&self.session_state.steering)
652 }
653
654 pub fn follow_up_queue(&self) -> Arc<RwLock<VecDeque<oxicode_sdk::Message>>> {
656 Arc::clone(&self.session_state.follow_up)
657 }
658}
659
660pub(crate) fn acquire_ownership_guard(
671 issue_store: Option<&crate::store::issues::FileIssueStore>,
672 ownership_id: &str,
673) -> Option<crate::store::issues::liveness::AliveGuard> {
674 let store = issue_store?;
675 if ownership_id.is_empty() {
676 return None;
679 }
680 crate::store::issues::liveness::acquire(&store.issues_dir(), ownership_id).ok()
681}
682
683#[cfg(test)]
684mod tests {
685 use super::*;
690 use crate::store::issues::FileIssueStore;
691 use crate::store::issues::liveness;
692
693 fn tmp_store() -> (tempfile::TempDir, FileIssueStore) {
694 let tmp = tempfile::tempdir().unwrap();
695 let dir = tmp.path().join(".oxicode").join("issues");
696 std::fs::create_dir_all(&dir).unwrap();
697 (tmp, FileIssueStore::open(dir).unwrap())
698 }
699
700 #[test]
701 fn app_holds_single_liveness_lock() {
702 let (_tmp, store) = tmp_store();
706 let dir = store.issues_dir();
707 let id = "proc-test-app";
708
709 let guard = acquire_ownership_guard(Some(&store), id);
710 assert!(
711 guard.is_some(),
712 "App must acquire the liveness lock for its ownership id"
713 );
714 assert!(
715 liveness::is_session_alive(&dir, id),
716 "after acquire, the session must be live"
717 );
718
719 let second = liveness::acquire(&dir, id);
721 assert!(second.is_err(), "second acquire under same id must fail");
722
723 drop(guard);
724 assert!(
725 !liveness::is_session_alive(&dir, id),
726 "dropping App's guard releases the lock"
727 );
728 }
729
730 #[test]
731 fn acquire_returns_none_without_store() {
732 let dir = tempfile::tempdir().unwrap();
734 let id = "proc-x";
735 assert!(acquire_ownership_guard(None, id).is_none());
736 let _ = dir; }
738
739 #[test]
740 fn acquire_rejects_empty_ownership_id() {
741 let (_tmp, store) = tmp_store();
744 assert!(
745 acquire_ownership_guard(Some(&store), "").is_none(),
746 "empty ownership id must never acquire a lock (#13 guard)"
747 );
748 }
749}
750pub mod symbols;
751pub mod tui_vt;