1use std::path::PathBuf;
2use std::sync::atomic::{AtomicUsize, Ordering};
3use std::sync::Arc;
4use std::time::Instant;
5use tokio::sync::RwLock;
6
7use crate::core::cache::SessionCache;
8use crate::core::session::SessionState;
9
10pub mod autonomy;
11pub mod ctx_agent;
12pub mod ctx_analyze;
13pub mod ctx_architecture;
14pub mod ctx_benchmark;
15pub mod ctx_callees;
16pub mod ctx_callers;
17pub mod ctx_compress;
18pub mod ctx_compress_memory;
19pub mod ctx_context;
20pub mod ctx_cost;
21pub mod ctx_dedup;
22pub mod ctx_delta;
23pub mod ctx_discover;
24pub mod ctx_edit;
25pub mod ctx_execute;
26pub mod ctx_expand;
27pub mod ctx_feedback;
28pub mod ctx_fill;
29pub mod ctx_gain;
30pub mod ctx_graph;
31pub mod ctx_graph_diagram;
32pub mod ctx_handoff;
33pub mod ctx_heatmap;
34pub mod ctx_impact;
35pub mod ctx_intent;
36pub mod ctx_knowledge;
37pub mod ctx_metrics;
38pub mod ctx_multi_read;
39pub mod ctx_outline;
40pub mod ctx_overview;
41pub mod ctx_prefetch;
42pub mod ctx_preload;
43pub mod ctx_read;
44pub mod ctx_response;
45pub mod ctx_search;
46pub mod ctx_semantic_search;
47pub mod ctx_session;
48pub mod ctx_share;
49pub mod ctx_shell;
50pub mod ctx_smart_read;
51pub mod ctx_symbol;
52pub mod ctx_task;
53pub mod ctx_tree;
54pub mod ctx_workflow;
55pub mod ctx_wrapped;
56
57const DEFAULT_CACHE_TTL_SECS: u64 = 300;
58
59struct CepComputedStats {
60 cep_score: u32,
61 cache_util: u32,
62 mode_diversity: u32,
63 compression_rate: u32,
64 total_original: u64,
65 total_compressed: u64,
66 total_saved: u64,
67 mode_counts: std::collections::HashMap<String, u64>,
68 complexity: String,
69 cache_hits: u64,
70 total_reads: u64,
71 tool_call_count: u64,
72}
73
74#[derive(Clone, Copy, Debug, PartialEq, Eq)]
75pub enum CrpMode {
76 Off,
77 Compact,
78 Tdd,
79}
80
81impl CrpMode {
82 pub fn from_env() -> Self {
83 match std::env::var("NEBU_CTX_CRP_MODE")
84 .unwrap_or_default()
85 .to_lowercase()
86 .as_str()
87 {
88 "off" => Self::Off,
89 "compact" => Self::Compact,
90 _ => Self::Tdd,
91 }
92 }
93
94 pub fn is_tdd(&self) -> bool {
95 *self == Self::Tdd
96 }
97}
98
99pub type SharedCache = Arc<RwLock<SessionCache>>;
100
101#[derive(Clone)]
102pub struct NebuCtxServer {
103 pub cache: SharedCache,
104 pub session: Arc<RwLock<SessionState>>,
105 pub tool_calls: Arc<RwLock<Vec<ToolCallRecord>>>,
106 pub call_count: Arc<AtomicUsize>,
107 pub checkpoint_interval: usize,
108 pub cache_ttl_secs: u64,
109 pub last_call: Arc<RwLock<Instant>>,
110 pub crp_mode: CrpMode,
111 pub agent_id: Arc<RwLock<Option<String>>>,
112 pub client_name: Arc<RwLock<String>>,
113 pub autonomy: Arc<autonomy::AutonomyState>,
114 pub loop_detector: Arc<RwLock<crate::core::loop_detection::LoopDetector>>,
115 pub workflow: Arc<RwLock<Option<crate::core::workflow::WorkflowRun>>>,
116 pub ledger: Arc<RwLock<crate::core::context_ledger::ContextLedger>>,
117 pub pipeline_stats: Arc<RwLock<crate::core::pipeline::PipelineStats>>,
118 startup_project_root: Option<String>,
119 startup_shell_cwd: Option<String>,
120}
121
122#[derive(Clone, Debug)]
123pub struct ToolCallRecord {
124 pub tool: String,
125 pub original_tokens: usize,
126 pub saved_tokens: usize,
127 pub mode: Option<String>,
128 pub duration_ms: u64,
129 pub timestamp: String,
130}
131
132impl Default for NebuCtxServer {
133 fn default() -> Self {
134 Self::new()
135 }
136}
137
138impl NebuCtxServer {
139 pub fn new() -> Self {
140 Self::new_with_project_root(None)
141 }
142
143 pub fn new_with_project_root(project_root: Option<String>) -> Self {
144 Self::new_with_startup(project_root, std::env::current_dir().ok())
145 }
146
147 fn new_with_startup(project_root: Option<String>, startup_cwd: Option<PathBuf>) -> Self {
148 let config = crate::core::config::Config::load();
149
150 let interval = std::env::var("NEBU_CTX_CHECKPOINT_INTERVAL")
151 .ok()
152 .and_then(|v| v.parse().ok())
153 .unwrap_or(config.checkpoint_interval as usize);
154
155 let ttl = std::env::var("NEBU_CTX_CACHE_TTL")
156 .ok()
157 .and_then(|v| v.parse().ok())
158 .unwrap_or(DEFAULT_CACHE_TTL_SECS);
159
160 let crp_mode = CrpMode::from_env();
161
162 let startup = detect_startup_context(project_root.as_deref(), startup_cwd.as_deref());
163 let mut session = if let Some(ref root) = startup.project_root {
164 SessionState::load_latest_for_project_root(root).unwrap_or_default()
165 } else {
166 SessionState::load_latest().unwrap_or_default()
167 };
168
169 if let Some(ref root) = startup.project_root {
170 session.project_root = Some(root.clone());
171 }
172 if let Some(ref cwd) = startup.shell_cwd {
173 session.shell_cwd = Some(cwd.clone());
174 }
175
176 Self {
177 cache: Arc::new(RwLock::new(SessionCache::new())),
178 session: Arc::new(RwLock::new(session)),
179 tool_calls: Arc::new(RwLock::new(Vec::new())),
180 call_count: Arc::new(AtomicUsize::new(0)),
181 checkpoint_interval: interval,
182 cache_ttl_secs: ttl,
183 last_call: Arc::new(RwLock::new(Instant::now())),
184 crp_mode,
185 agent_id: Arc::new(RwLock::new(None)),
186 client_name: Arc::new(RwLock::new(String::new())),
187 autonomy: Arc::new(autonomy::AutonomyState::new()),
188 loop_detector: Arc::new(RwLock::new(
189 crate::core::loop_detection::LoopDetector::with_config(
190 &crate::core::config::Config::load().loop_detection,
191 ),
192 )),
193 workflow: Arc::new(RwLock::new(
194 crate::core::workflow::load_active().ok().flatten(),
195 )),
196 ledger: Arc::new(RwLock::new(
197 crate::core::context_ledger::ContextLedger::new(),
198 )),
199 pipeline_stats: Arc::new(RwLock::new(crate::core::pipeline::PipelineStats::new())),
200 startup_project_root: startup.project_root,
201 startup_shell_cwd: startup.shell_cwd,
202 }
203 }
204
205 async fn resolve_path_candidate(
206 &self,
207 path: &str,
208 ) -> Result<(String, std::path::PathBuf, String, bool), String> {
209 let normalized = crate::hooks::normalize_tool_path(path);
210 if normalized.is_empty() || normalized == "." {
211 return Ok((normalized, std::path::PathBuf::from("."), ".".to_string(), false));
212 }
213 let p = std::path::Path::new(&normalized);
214 let input_is_absolute = p.is_absolute() || looks_like_windows_absolute_path(&normalized);
215
216 let (resolved, jail_root) = {
217 let session = self.session.read().await;
218 let jail_root = session
219 .project_root
220 .as_deref()
221 .or(session.shell_cwd.as_deref())
222 .unwrap_or(".")
223 .to_string();
224
225 let resolved =
226 if input_is_absolute || p.exists() {
227 std::path::PathBuf::from(&normalized)
228 } else if let Some(ref root) = session.project_root {
229 let joined = std::path::Path::new(root).join(&normalized);
230 if joined.exists() {
231 joined
232 } else if let Some(ref cwd) = session.shell_cwd {
233 std::path::Path::new(cwd).join(&normalized)
234 } else {
235 std::path::Path::new(&jail_root).join(&normalized)
236 }
237 } else if let Some(ref cwd) = session.shell_cwd {
238 std::path::Path::new(cwd).join(&normalized)
239 } else {
240 std::path::Path::new(&jail_root).join(&normalized)
241 };
242
243 (resolved, jail_root)
244 };
245
246 Ok((normalized, resolved, jail_root, input_is_absolute))
247 }
248
249 async fn jail_resolved_candidate(
250 &self,
251 resolved: &std::path::Path,
252 jail_root: &str,
253 input_is_absolute: bool,
254 ) -> Result<std::path::PathBuf, String> {
255 let jail_root_path = std::path::Path::new(jail_root);
256 match crate::core::pathjail::jail_path(resolved, jail_root_path) {
257 Ok(path) => Ok(path),
258 Err(e) => {
259 if input_is_absolute {
260 if let Some(new_root) = maybe_derive_project_root_from_absolute(resolved) {
261 let current_root_is_weak = !has_project_marker(jail_root_path)
262 || is_suspicious_root(jail_root_path);
263 let allow_reroot = self
264 .startup_project_root
265 .as_ref()
266 .map(|trusted_root| {
267 std::path::Path::new(trusted_root) == new_root.as_path()
268 })
269 .unwrap_or(current_root_is_weak);
270
271 if allow_reroot {
272 let mut session = self.session.write().await;
273 let new_root_str = new_root.to_string_lossy().to_string();
274 session.project_root = Some(new_root_str.clone());
275 session.shell_cwd = self
276 .startup_shell_cwd
277 .as_ref()
278 .filter(|cwd| std::path::Path::new(cwd).starts_with(&new_root))
279 .cloned()
280 .or_else(|| Some(new_root_str.clone()));
281 let _ = session.save();
282
283 crate::core::pathjail::jail_path(resolved, &new_root)
284 } else {
285 Err(e)
286 }
287 } else {
288 Err(e)
289 }
290 } else {
291 Err(e)
292 }
293 }
294 }
295 }
296
297 pub async fn resolve_path(&self, path: &str) -> Result<String, String> {
301 let (normalized, resolved, jail_root, input_is_absolute) =
302 self.resolve_path_candidate(path).await?;
303 if normalized.is_empty() || normalized == "." {
304 return Ok(normalized);
305 }
306
307 let jailed = self
308 .jail_resolved_candidate(&resolved, &jail_root, input_is_absolute)
309 .await?;
310
311 Ok(crate::hooks::normalize_tool_path(
312 &jailed.to_string_lossy().replace('\\', "/"),
313 ))
314 }
315
316 pub async fn resolve_path_or_warn(
317 &self,
318 path: &str,
319 ) -> Result<(String, Option<String>), String> {
320 let (normalized, resolved, jail_root, input_is_absolute) =
321 self.resolve_path_candidate(path).await?;
322 if normalized.is_empty() || normalized == "." {
323 return Ok((normalized, None));
324 }
325
326 match self
327 .jail_resolved_candidate(&resolved, &jail_root, input_is_absolute)
328 .await
329 {
330 Ok(jailed) => Ok((
331 crate::hooks::normalize_tool_path(&jailed.to_string_lossy().replace('\\', "/")),
332 None,
333 )),
334 Err(e) if e.contains("path escapes project root") => Ok((
335 crate::hooks::normalize_tool_path(&resolved.to_string_lossy().replace('\\', "/")),
336 Some(format!(
337 "[warning: path outside project root; using explicit path: {normalized}]"
338 )),
339 )),
340 Err(e) => Err(e),
341 }
342 }
343
344 pub async fn resolve_path_or_passthrough(&self, path: &str) -> String {
345 self.resolve_path_or_warn(path)
346 .await
347 .map(|(resolved, _)| resolved)
348 .unwrap_or_else(|_| path.to_string())
349 }
350
351 pub async fn check_idle_expiry(&self) {
352 if self.cache_ttl_secs == 0 {
353 return;
354 }
355 let last = *self.last_call.read().await;
356 if last.elapsed().as_secs() >= self.cache_ttl_secs {
357 {
358 let mut session = self.session.write().await;
359 let _ = session.save();
360 }
361 let mut cache = self.cache.write().await;
362 let count = cache.clear();
363 if count > 0 {
364 tracing::info!(
365 "Cache auto-cleared after {}s idle ({count} file(s))",
366 self.cache_ttl_secs
367 );
368 }
369 }
370 *self.last_call.write().await = Instant::now();
371 }
372
373 pub async fn record_call(
374 &self,
375 tool: &str,
376 original: usize,
377 saved: usize,
378 mode: Option<String>,
379 ) {
380 self.record_call_with_timing(tool, original, saved, mode, 0)
381 .await;
382 }
383
384 pub async fn record_call_with_timing(
385 &self,
386 tool: &str,
387 original: usize,
388 saved: usize,
389 mode: Option<String>,
390 duration_ms: u64,
391 ) {
392 let ts = chrono::Local::now().format("%Y-%m-%d %H:%M:%S").to_string();
393 let mut calls = self.tool_calls.write().await;
394 calls.push(ToolCallRecord {
395 tool: tool.to_string(),
396 original_tokens: original,
397 saved_tokens: saved,
398 mode: mode.clone(),
399 duration_ms,
400 timestamp: ts.clone(),
401 });
402
403 if duration_ms > 0 {
404 Self::append_tool_call_log(tool, duration_ms, original, saved, mode.as_deref(), &ts);
405 }
406
407 crate::core::events::emit_tool_call(
408 tool,
409 original as u64,
410 saved as u64,
411 mode.clone(),
412 duration_ms,
413 None,
414 );
415
416 let output_tokens = original.saturating_sub(saved);
417 crate::core::stats::record(tool, original, output_tokens);
418
419 let mut session = self.session.write().await;
420 session.record_tool_call(saved as u64, original as u64);
421 if tool == "ctx_shell" {
422 session.record_command();
423 }
424 if session.should_save() {
425 let _ = session.save();
426 }
427 drop(calls);
428 drop(session);
429
430 self.write_mcp_live_stats().await;
431
432 let session_slug = {
435 let session = self.session.read().await;
436 session.project_root.clone().unwrap_or_default()
437 };
438 let project_context = std::env::current_dir()
439 .ok()
440 .map(|d| crate::git_context::discover_project_context(&d));
441 let request = crate::models::TelemetryIngestRequest {
442 tool_name: tool.to_string(),
443 tokens_original: original as i64,
444 tokens_saved: saved as i64,
445 duration_ms: duration_ms as i64,
446 mode,
447 repository_fingerprint: project_context.as_ref().and_then(|c| {
448 c.fingerprint
449 .has_safe_identity()
450 .then(|| c.fingerprint.clone())
451 }),
452 checkout_binding: project_context.as_ref().map(|c| c.checkout_binding.clone()),
453 project_slug: project_context
454 .as_ref()
455 .map(|c| c.project_slug.clone())
456 .filter(|s| !s.is_empty())
457 .or_else(|| {
458 let slug = std::path::Path::new(&session_slug)
459 .file_name()
460 .and_then(|n| n.to_str())
461 .unwrap_or("unknown")
462 .to_string();
463 Some(slug)
464 }),
465 command_preview: None,
466 };
467 crate::core::telemetry_queue::enqueue(request);
468 }
469
470 pub async fn is_prompt_cache_stale(&self) -> bool {
471 let last = *self.last_call.read().await;
472 last.elapsed().as_secs() > 3600
473 }
474
475 pub fn upgrade_mode_if_stale(mode: &str, stale: bool) -> &str {
476 if !stale {
477 return mode;
478 }
479 match mode {
480 "full" => "full",
481 "map" => "signatures",
482 m => m,
483 }
484 }
485
486 pub fn increment_and_check(&self) -> bool {
487 let count = self.call_count.fetch_add(1, Ordering::Relaxed) + 1;
488 self.checkpoint_interval > 0 && count.is_multiple_of(self.checkpoint_interval)
489 }
490
491 pub async fn auto_checkpoint(&self) -> Option<String> {
492 let cache = self.cache.read().await;
493 if cache.get_all_entries().is_empty() {
494 return None;
495 }
496 let complexity = crate::core::adaptive::classify_from_context(&cache);
497 let checkpoint = ctx_compress::handle(&cache, true, self.crp_mode);
498 drop(cache);
499
500 let mut session = self.session.write().await;
501 let _ = session.save();
502 let session_summary = session.format_compact();
503 let has_insights = !session.findings.is_empty() || !session.decisions.is_empty();
504 let project_root = session.project_root.clone();
505 drop(session);
506
507 if has_insights {
508 if let Some(ref root) = project_root {
509 let root = root.clone();
510 std::thread::spawn(move || {
511 auto_consolidate_knowledge(&root);
512 });
513 }
514 }
515
516 let multi_agent_block = self.auto_multi_agent_checkpoint(&project_root).await;
517
518 self.record_call("ctx_compress", 0, 0, Some("auto".to_string()))
519 .await;
520
521 self.record_cep_snapshot().await;
522
523 Some(format!(
524 "{checkpoint}\n\n--- SESSION STATE ---\n{session_summary}\n\n{}{multi_agent_block}",
525 complexity.instruction_suffix()
526 ))
527 }
528
529 async fn auto_multi_agent_checkpoint(&self, project_root: &Option<String>) -> String {
530 let root = match project_root {
531 Some(r) => r,
532 None => return String::new(),
533 };
534
535 let registry = crate::core::agents::AgentRegistry::load_or_create();
536 let active = registry.list_active(Some(root));
537 if active.len() <= 1 {
538 return String::new();
539 }
540
541 let agent_id = self.agent_id.read().await;
542 let my_id = match agent_id.as_deref() {
543 Some(id) => id.to_string(),
544 None => return String::new(),
545 };
546 drop(agent_id);
547
548 let cache = self.cache.read().await;
549 let entries = cache.get_all_entries();
550 if !entries.is_empty() {
551 let mut by_access: Vec<_> = entries.iter().collect();
552 by_access.sort_by_key(|x| std::cmp::Reverse(x.1.read_count));
553 let top_paths: Vec<&str> = by_access
554 .iter()
555 .take(5)
556 .map(|(key, _)| key.as_str())
557 .collect();
558 let paths_csv = top_paths.join(",");
559
560 let _ = ctx_share::handle("push", Some(&my_id), None, Some(&paths_csv), None, &cache);
561 }
562 drop(cache);
563
564 let pending_count = registry
565 .scratchpad
566 .iter()
567 .filter(|e| !e.read_by.contains(&my_id) && e.from_agent != my_id)
568 .count();
569
570 let shared_dir = crate::core::data_dir::nebu_ctx_data_dir()
571 .unwrap_or_default()
572 .join("agents")
573 .join("shared");
574 let shared_count = if shared_dir.exists() {
575 std::fs::read_dir(&shared_dir)
576 .map(|rd| rd.count())
577 .unwrap_or(0)
578 } else {
579 0
580 };
581
582 let agent_names: Vec<String> = active
583 .iter()
584 .map(|a| {
585 let role = a.role.as_deref().unwrap_or(&a.agent_type);
586 format!("{role}({})", &a.agent_id[..8.min(a.agent_id.len())])
587 })
588 .collect();
589
590 format!(
591 "\n\n--- MULTI-AGENT SYNC ---\nAgents: {} | Pending msgs: {} | Shared contexts: {}\nAuto-shared top-5 cached files.\n--- END SYNC ---",
592 agent_names.join(", "),
593 pending_count,
594 shared_count,
595 )
596 }
597
598 pub fn append_tool_call_log(
599 tool: &str,
600 duration_ms: u64,
601 original: usize,
602 saved: usize,
603 mode: Option<&str>,
604 timestamp: &str,
605 ) {
606 const MAX_LOG_LINES: usize = 50;
607 if let Ok(dir) = crate::core::data_dir::nebu_ctx_data_dir() {
608 let log_path = dir.join("tool-calls.log");
609 let mode_str = mode.unwrap_or("-");
610 let slow = if duration_ms > 5000 { " **SLOW**" } else { "" };
611 let line = format!(
612 "{timestamp}\t{tool}\t{duration_ms}ms\torig={original}\tsaved={saved}\tmode={mode_str}{slow}\n"
613 );
614
615 let mut lines: Vec<String> = std::fs::read_to_string(&log_path)
616 .unwrap_or_default()
617 .lines()
618 .map(|l| l.to_string())
619 .collect();
620
621 lines.push(line.trim_end().to_string());
622 if lines.len() > MAX_LOG_LINES {
623 lines.drain(0..lines.len() - MAX_LOG_LINES);
624 }
625
626 let _ = std::fs::write(&log_path, lines.join("\n") + "\n");
627 }
628 }
629
630 fn compute_cep_stats(
631 calls: &[ToolCallRecord],
632 stats: &crate::core::cache::CacheStats,
633 complexity: &crate::core::adaptive::TaskComplexity,
634 ) -> CepComputedStats {
635 let total_original: u64 = calls.iter().map(|c| c.original_tokens as u64).sum();
636 let total_saved: u64 = calls.iter().map(|c| c.saved_tokens as u64).sum();
637 let total_compressed = total_original.saturating_sub(total_saved);
638 let compression_rate = if total_original > 0 {
639 total_saved as f64 / total_original as f64
640 } else {
641 0.0
642 };
643
644 let modes_used: std::collections::HashSet<&str> =
645 calls.iter().filter_map(|c| c.mode.as_deref()).collect();
646 let mode_diversity = (modes_used.len() as f64 / 10.0).min(1.0);
647 let cache_util = stats.hit_rate() / 100.0;
648 let cep_score = cache_util * 0.3 + mode_diversity * 0.2 + compression_rate * 0.5;
649
650 let mut mode_counts: std::collections::HashMap<String, u64> =
651 std::collections::HashMap::new();
652 for call in calls {
653 if let Some(ref mode) = call.mode {
654 *mode_counts.entry(mode.clone()).or_insert(0) += 1;
655 }
656 }
657
658 CepComputedStats {
659 cep_score: (cep_score * 100.0).round() as u32,
660 cache_util: (cache_util * 100.0).round() as u32,
661 mode_diversity: (mode_diversity * 100.0).round() as u32,
662 compression_rate: (compression_rate * 100.0).round() as u32,
663 total_original,
664 total_compressed,
665 total_saved,
666 mode_counts,
667 complexity: format!("{:?}", complexity),
668 cache_hits: stats.cache_hits,
669 total_reads: stats.total_reads,
670 tool_call_count: calls.len() as u64,
671 }
672 }
673
674 async fn write_mcp_live_stats(&self) {
675 let cache = self.cache.read().await;
676 let calls = self.tool_calls.read().await;
677 let stats = cache.get_stats();
678 let complexity = crate::core::adaptive::classify_from_context(&cache);
679
680 let cs = Self::compute_cep_stats(&calls, stats, &complexity);
681 let started_at = calls
682 .first()
683 .map(|c| c.timestamp.clone())
684 .unwrap_or_default();
685
686 drop(cache);
687 drop(calls);
688 let live = serde_json::json!({
689 "cep_score": cs.cep_score,
690 "cache_utilization": cs.cache_util,
691 "mode_diversity": cs.mode_diversity,
692 "compression_rate": cs.compression_rate,
693 "task_complexity": cs.complexity,
694 "files_cached": cs.total_reads,
695 "total_reads": cs.total_reads,
696 "cache_hits": cs.cache_hits,
697 "tokens_saved": cs.total_saved,
698 "tokens_original": cs.total_original,
699 "tool_calls": cs.tool_call_count,
700 "started_at": started_at,
701 "updated_at": chrono::Local::now().to_rfc3339(),
702 });
703
704 if let Ok(dir) = crate::core::data_dir::nebu_ctx_data_dir() {
705 let _ = std::fs::write(dir.join("mcp-live.json"), live.to_string());
706 }
707 }
708
709 pub async fn record_cep_snapshot(&self) {
710 let cache = self.cache.read().await;
711 let calls = self.tool_calls.read().await;
712 let stats = cache.get_stats();
713 let complexity = crate::core::adaptive::classify_from_context(&cache);
714
715 let cs = Self::compute_cep_stats(&calls, stats, &complexity);
716
717 drop(cache);
718 drop(calls);
719
720 crate::core::stats::record_cep_session(
721 cs.cep_score,
722 cs.cache_hits,
723 cs.total_reads,
724 cs.total_original,
725 cs.total_compressed,
726 &cs.mode_counts,
727 cs.tool_call_count,
728 &cs.complexity,
729 );
730 }
731}
732
733#[derive(Clone, Debug, Default)]
734struct StartupContext {
735 project_root: Option<String>,
736 shell_cwd: Option<String>,
737}
738
739pub fn create_server() -> NebuCtxServer {
740 NebuCtxServer::new()
741}
742
743const PROJECT_ROOT_MARKERS: &[&str] = &[
744 ".git",
745 ".lean-ctx.toml",
746 "Cargo.toml",
747 "package.json",
748 "go.mod",
749 "pyproject.toml",
750 "pom.xml",
751 "build.gradle",
752 "Makefile",
753 ".planning",
754];
755
756fn has_project_marker(dir: &std::path::Path) -> bool {
757 PROJECT_ROOT_MARKERS.iter().any(|m| dir.join(m).exists())
758}
759
760fn is_suspicious_root(dir: &std::path::Path) -> bool {
761 let s = dir.to_string_lossy();
762 s.contains("/.claude")
763 || s.contains("/.codex")
764 || s.contains("\\.claude")
765 || s.contains("\\.codex")
766}
767
768fn canonicalize_path(path: &std::path::Path) -> String {
769 crate::core::pathutil::safe_canonicalize_or_self(path)
770 .to_string_lossy()
771 .to_string()
772}
773
774fn detect_startup_context(
775 explicit_project_root: Option<&str>,
776 startup_cwd: Option<&std::path::Path>,
777) -> StartupContext {
778 let shell_cwd = startup_cwd.map(canonicalize_path);
779 let project_root = explicit_project_root
780 .map(|root| canonicalize_path(std::path::Path::new(root)))
781 .or_else(|| {
782 startup_cwd
783 .and_then(maybe_derive_project_root_from_absolute)
784 .map(|p| canonicalize_path(&p))
785 });
786
787 let shell_cwd = match (shell_cwd, project_root.as_ref()) {
788 (Some(cwd), Some(root))
789 if std::path::Path::new(&cwd).starts_with(std::path::Path::new(root)) =>
790 {
791 Some(cwd)
792 }
793 (Some(_), Some(root)) => Some(root.clone()),
794 (Some(cwd), None) => Some(cwd),
795 (None, Some(root)) => Some(root.clone()),
796 (None, None) => None,
797 };
798
799 StartupContext {
800 project_root,
801 shell_cwd,
802 }
803}
804
805fn maybe_derive_project_root_from_absolute(abs: &std::path::Path) -> Option<std::path::PathBuf> {
806 let mut cur = if abs.is_dir() {
807 abs.to_path_buf()
808 } else {
809 abs.parent()?.to_path_buf()
810 };
811 loop {
812 if has_project_marker(&cur) {
813 return Some(crate::core::pathutil::safe_canonicalize_or_self(&cur));
814 }
815 if !cur.pop() {
816 break;
817 }
818 }
819 None
820}
821
822fn auto_consolidate_knowledge(project_root: &str) {
823 use crate::core::knowledge::ProjectKnowledge;
824 use crate::core::session::SessionState;
825
826 let session = match SessionState::load_latest_for_project_root(project_root) {
827 Some(s) => s,
828 None => return,
829 };
830
831 if session.findings.is_empty() && session.decisions.is_empty() {
832 return;
833 }
834
835 let mut knowledge = ProjectKnowledge::load_or_create(project_root);
836
837 for finding in &session.findings {
838 let key = if let Some(ref file) = finding.file {
839 if let Some(line) = finding.line {
840 format!("{file}:{line}")
841 } else {
842 file.clone()
843 }
844 } else {
845 "finding-auto".to_string()
846 };
847 knowledge.remember("finding", &key, &finding.summary, &session.id, 0.7);
848 }
849
850 for decision in &session.decisions {
851 let key = decision
852 .summary
853 .chars()
854 .take(50)
855 .collect::<String>()
856 .replace(' ', "-")
857 .to_lowercase();
858 knowledge.remember("decision", &key, &decision.summary, &session.id, 0.85);
859 }
860
861 let task_desc = session
862 .task
863 .as_ref()
864 .map(|t| t.description.clone())
865 .unwrap_or_default();
866
867 let summary = format!(
868 "Auto-consolidate session {}: {} — {} findings, {} decisions",
869 session.id,
870 task_desc,
871 session.findings.len(),
872 session.decisions.len()
873 );
874 knowledge.consolidate(&summary, vec![session.id.clone()]);
875 let _ = knowledge.save();
876}
877
878fn looks_like_windows_absolute_path(path: &str) -> bool {
879 path.len() >= 3
880 && path.as_bytes()[0].is_ascii_alphabetic()
881 && path.as_bytes()[1] == b':'
882 && path.as_bytes()[2] == b'/'
883}
884
885#[cfg(test)]
886mod resolve_path_tests {
887 use super::*;
888
889 fn create_git_root(path: &std::path::Path) -> String {
890 std::fs::create_dir_all(path.join(".git")).unwrap();
891 canonicalize_path(path)
892 }
893
894 #[tokio::test]
895 async fn resolve_path_can_reroot_to_trusted_startup_root_when_session_root_is_stale() {
896 let tmp = tempfile::tempdir().unwrap();
897 let stale = tmp.path().join("stale");
898 let real = tmp.path().join("real");
899 std::fs::create_dir_all(&stale).unwrap();
900 let real_root = create_git_root(&real);
901 std::fs::write(real.join("a.txt"), "ok").unwrap();
902
903 let server = NebuCtxServer::new_with_startup(None, Some(real.clone()));
904 {
905 let mut session = server.session.write().await;
906 session.project_root = Some(stale.to_string_lossy().to_string());
907 session.shell_cwd = Some(stale.to_string_lossy().to_string());
908 }
909
910 let out = server
911 .resolve_path(&real.join("a.txt").to_string_lossy())
912 .await
913 .unwrap();
914
915 assert!(out.ends_with("/a.txt"));
916
917 let session = server.session.read().await;
918 assert_eq!(session.project_root.as_deref(), Some(real_root.as_str()));
919 assert_eq!(session.shell_cwd.as_deref(), Some(real_root.as_str()));
920 }
921
922 #[tokio::test]
923 async fn resolve_path_rejects_absolute_path_outside_trusted_startup_root() {
924 let tmp = tempfile::tempdir().unwrap();
925 let stale = tmp.path().join("stale");
926 let root = tmp.path().join("root");
927 let other = tmp.path().join("other");
928 std::fs::create_dir_all(&stale).unwrap();
929 create_git_root(&root);
930 let _other_value = create_git_root(&other);
931 std::fs::write(other.join("b.txt"), "no").unwrap();
932
933 let server = NebuCtxServer::new_with_startup(None, Some(root.clone()));
934 {
935 let mut session = server.session.write().await;
936 session.project_root = Some(stale.to_string_lossy().to_string());
937 session.shell_cwd = Some(stale.to_string_lossy().to_string());
938 }
939
940 let err = server
941 .resolve_path(&other.join("b.txt").to_string_lossy())
942 .await
943 .unwrap_err();
944 assert!(err.contains("path escapes project root"));
945
946 let session = server.session.read().await;
947 assert_eq!(
948 session.project_root.as_deref(),
949 Some(stale.to_string_lossy().as_ref())
950 );
951 }
952
953 #[tokio::test]
954 async fn startup_prefers_workspace_scoped_session_over_global_latest() {
955 let _data = tempfile::tempdir().unwrap();
956 let _tmp = tempfile::tempdir().unwrap();
957
958 let (server, root_b) = {
959 let _lock = crate::core::data_dir::test_env_lock();
960 std::env::set_var("NEBU_CTX_DATA_DIR", _data.path());
961
962 let repo_a = _tmp.path().join("repo-a");
963 let repo_b = _tmp.path().join("repo-b");
964 let root_a = create_git_root(&repo_a);
965 let root_b = create_git_root(&repo_b);
966
967 let mut session_b = SessionState::new();
968 session_b.project_root = Some(root_b.clone());
969 session_b.shell_cwd = Some(root_b.clone());
970 session_b.set_task("repo-b task", None);
971 session_b.save().unwrap();
972
973 let mut session_a = SessionState::new();
974 session_a.project_root = Some(root_a.clone());
975 session_a.shell_cwd = Some(root_a.clone());
976 session_a.set_task("repo-a latest task", None);
977 session_a.save().unwrap();
978
979 let server = NebuCtxServer::new_with_startup(None, Some(repo_b.clone()));
980 std::env::remove_var("NEBU_CTX_DATA_DIR");
981 (server, root_b)
982 };
983
984 let session = server.session.read().await;
985 assert_eq!(session.project_root.as_deref(), Some(root_b.as_str()));
986 assert_eq!(session.shell_cwd.as_deref(), Some(root_b.as_str()));
987 assert_eq!(
988 session.task.as_ref().map(|t| t.description.as_str()),
989 Some("repo-b task")
990 );
991 }
992
993 #[tokio::test]
994 async fn startup_creates_fresh_session_for_new_workspace_and_preserves_subdir_cwd() {
995 let _data = tempfile::tempdir().unwrap();
996 let _tmp = tempfile::tempdir().unwrap();
997
998 let (server, root_b, repo_b_src_value, old_id) = {
999 let _lock = crate::core::data_dir::test_env_lock();
1000 std::env::set_var("NEBU_CTX_DATA_DIR", _data.path());
1001
1002 let repo_a = _tmp.path().join("repo-a");
1003 let repo_b = _tmp.path().join("repo-b");
1004 let repo_b_src = repo_b.join("src");
1005 let root_a = create_git_root(&repo_a);
1006 let root_b = create_git_root(&repo_b);
1007 std::fs::create_dir_all(&repo_b_src).unwrap();
1008 let repo_b_src_value = canonicalize_path(&repo_b_src);
1009
1010 let mut session_a = SessionState::new();
1011 session_a.project_root = Some(root_a.clone());
1012 session_a.shell_cwd = Some(root_a.clone());
1013 session_a.set_task("repo-a latest task", None);
1014 let old_id = session_a.id.clone();
1015 session_a.save().unwrap();
1016
1017 let server = NebuCtxServer::new_with_startup(None, Some(repo_b_src.clone()));
1018 std::env::remove_var("NEBU_CTX_DATA_DIR");
1019 (server, root_b, repo_b_src_value, old_id)
1020 };
1021
1022 let session = server.session.read().await;
1023 assert_eq!(session.project_root.as_deref(), Some(root_b.as_str()));
1024 assert_eq!(
1025 session.shell_cwd.as_deref(),
1026 Some(repo_b_src_value.as_str())
1027 );
1028 assert!(session.task.is_none());
1029 assert_ne!(session.id, old_id);
1030 }
1031
1032 #[tokio::test]
1033 async fn resolve_path_does_not_auto_update_when_current_root_is_real_project() {
1034 let tmp = tempfile::tempdir().unwrap();
1035 let root = tmp.path().join("root");
1036 let other = tmp.path().join("other");
1037 let root_value = create_git_root(&root);
1038 create_git_root(&other);
1039 std::fs::write(other.join("b.txt"), "no").unwrap();
1040
1041 let server = NebuCtxServer::new_with_project_root(Some(root.to_string_lossy().to_string()));
1042
1043 let err = server
1044 .resolve_path(&other.join("b.txt").to_string_lossy())
1045 .await
1046 .unwrap_err();
1047 assert!(err.contains("path escapes project root"));
1048
1049 let session = server.session.read().await;
1050 assert_eq!(session.project_root.as_deref(), Some(root_value.as_str()));
1051 }
1052
1053 #[tokio::test]
1054 async fn resolve_path_or_warn_allows_absolute_path_outside_root() {
1055 let tmp = tempfile::tempdir().unwrap();
1056 let root = tmp.path().join("root");
1057 let other = tmp.path().join("other");
1058 let root_value = create_git_root(&root);
1059 create_git_root(&other);
1060 std::fs::write(other.join("b.txt"), "no").unwrap();
1061
1062 let server = NebuCtxServer::new_with_project_root(Some(root.to_string_lossy().to_string()));
1063
1064 let (resolved, warning) = server
1065 .resolve_path_or_warn(&other.join("b.txt").to_string_lossy())
1066 .await
1067 .unwrap();
1068
1069 assert!(resolved.ends_with("/b.txt") || resolved.ends_with("\\b.txt"));
1070 assert!(warning.is_some());
1071
1072 let session = server.session.read().await;
1073 assert_eq!(session.project_root.as_deref(), Some(root_value.as_str()));
1074 }
1075
1076 #[cfg(unix)]
1077 #[tokio::test]
1078 async fn resolve_path_reroots_symlinked_workspace_path_when_shell_root_is_not_a_project() {
1079 use std::os::unix::fs::symlink;
1080
1081 let data = tempfile::tempdir().unwrap();
1082 let tmp = tempfile::tempdir().unwrap();
1083 let home = tmp.path().join("home");
1084 let mnt = tmp.path().join("mnt");
1085 let real_repo = mnt.join("work").join("repo");
1086 let symlink_root = home.join("Work");
1087
1088 let _lock = crate::core::data_dir::test_env_lock();
1089 std::env::set_var("NEBU_CTX_DATA_DIR", data.path());
1090
1091 std::fs::create_dir_all(&home).unwrap();
1092 std::fs::create_dir_all(real_repo.join(".git")).unwrap();
1093 std::fs::write(real_repo.join("a.txt"), "ok").unwrap();
1094 symlink(real_repo.parent().unwrap(), &symlink_root).unwrap();
1095
1096 let aliased_file = symlink_root.join("repo").join("a.txt");
1097 let server = NebuCtxServer::new_with_startup(None, Some(home.clone()));
1098 std::env::remove_var("NEBU_CTX_DATA_DIR");
1099
1100 let out = server
1101 .resolve_path(&aliased_file.to_string_lossy())
1102 .await
1103 .unwrap();
1104
1105 assert_eq!(out, real_repo.join("a.txt").to_string_lossy());
1106
1107 let session = server.session.read().await;
1108 assert_eq!(
1109 session.project_root.as_deref(),
1110 Some(real_repo.to_string_lossy().as_ref())
1111 );
1112 assert_eq!(
1113 session.shell_cwd.as_deref(),
1114 Some(real_repo.to_string_lossy().as_ref())
1115 );
1116 }
1117
1118 #[test]
1119 fn auto_consolidate_uses_workspace_scoped_session() {
1120 let _lock = crate::core::data_dir::test_env_lock();
1121 let data = tempfile::tempdir().unwrap();
1122 let tmp = tempfile::tempdir().unwrap();
1123 std::env::set_var("NEBU_CTX_DATA_DIR", data.path());
1124
1125 let repo_a = tmp.path().join("repo-a");
1126 let repo_b = tmp.path().join("repo-b");
1127 let root_a = create_git_root(&repo_a);
1128 let root_b = create_git_root(&repo_b);
1129
1130 let mut session_a = SessionState::new();
1131 session_a.project_root = Some(root_a.clone());
1132 session_a.add_decision("decision from repo-a", None);
1133 session_a.save().unwrap();
1134
1135 let mut session_b = SessionState::new();
1136 session_b.project_root = Some(root_b.clone());
1137 session_b.add_decision("decision from repo-b", None);
1138 session_b.save().unwrap();
1139
1140 auto_consolidate_knowledge(&root_a);
1141
1142 let knowledge = crate::core::knowledge::ProjectKnowledge::load(&root_a)
1143 .expect("knowledge should exist for repo-a");
1144 assert!(knowledge
1145 .facts
1146 .iter()
1147 .any(|fact| fact.category == "decision" && fact.value == "decision from repo-a"));
1148 assert!(!knowledge
1149 .facts
1150 .iter()
1151 .any(|fact| fact.category == "decision" && fact.value == "decision from repo-b"));
1152
1153 std::env::remove_var("NEBU_CTX_DATA_DIR");
1154 }
1155
1156 #[test]
1157 fn recognizes_windows_absolute_paths_even_off_windows() {
1158 assert!(looks_like_windows_absolute_path(
1159 "C:/Users/markb/Projects/Spotify/package.json"
1160 ));
1161 assert!(looks_like_windows_absolute_path(
1162 "c:/Users/markb/Projects/Spotify/package.json"
1163 ));
1164 assert!(!looks_like_windows_absolute_path(
1165 "/mnt/work/Projects/Spotify/package.json"
1166 ));
1167 assert!(!looks_like_windows_absolute_path("src/package.json"));
1168 }
1169}