Enhance command-based content type inference and distillation logic (#56)

<!-- AI-PR-DESCRIPTION-START -->
## PR Auto Describe
## Summary
This PR overhauls Omni's core pipeline and CLI stack, replacing the
legacy content-type classification model with command-aware routing,
cleaning up deprecated code, and streamlining user-facing reporting and
performance.

---

## Key Changes
1. Replaced legacy content-based pipeline routing with command-first
profile resolution
2. Rewrote `omni stats` CLI: removed `--by-type` flag, added `--project`
per-project analytics
3.  Deleted unused distillers and deprecated classifier/composer modules
4.  Updated hook logic with auto-sibling command detection for pipe mode

---

## Detailed Breakdown
### Core Pipeline Overhaul
- Removed entire `src/pipeline/classifier.rs` legacy content classifier
- Rewrote distiller system: removed `content_type()` from `Distiller`
trait, replaced `get_distiller()` with command-based
`distill_with_command()` in `src/distillers/mod.rs`
- Deleted unused distillers: `infra.rs`, `log.rs`, `tabular.rs`
- Updated all distiller tests to use command strings instead of
ContentType, updated snapshot outputs for docker/kubectl/nginx workflows
- Rewrote `collapse.rs` to use `CollapseMode` enum instead of
ContentType for content-aware collapsing
- Removed `src/pipeline/composer.rs`, moving rewind/learning logic
directly into hook code

### CLI & Stats Updates
- **`src/cli/stats.rs`**: Removed `--by-type` mode, added `--project`
flag for per-project stats, reworked default view to show top commands,
updated JSON output to return command stats instead of content-type data
- Replaced hardcoded $3/1M token cost calculation with config-driven
pricing via new `src/guard/config.rs`
- Renamed all Indonesian-named test functions in `init.rs`,
`session.rs`, `stats.rs` to English
- Deleted old `truncate_commands()` function and associated tests
- Updated bench targets in `benches/pipeline.rs` from `bench_classify`
to `bench_registry_resolve` testing `scorer::score_with_command`

### Hook & Runtime Changes
- Rewrote `src/hooks/pipe.rs` and `src/hooks/post_tool.rs`: removed
classifier calls, added auto-sibling command detection for pipe mode,
updated rewind/route logic and auto-learn triggers
- Added `src/guard/config.rs` for loading user pricing/config settings
- Updated `src/main.rs` to detect pipe commands via env vars, added
background DB cleanup thread
- Added new MCP `omni_search` tool in `src/mcp/server.rs`
- Removed Intelligence Consistency check from `src/cli/doctor.rs`

---

## Notes
- Distiller snapshot outputs have been updated for docker, kubectl, and
nginx workflows to match new command-based distillation logic

---

## Breaking Changes
1. **Public API Break**: Removed `pipeline::classifier::classify`,
`distillers::get_distiller()`, and deprecated `ContentType` enum usage
across core code
2. **CLI Break**: Removed `--by-type` flag from `omni stats`; JSON
output now returns `commands` instead of `content_types`
3. **Distiller Trait Break**: `Distiller` trait no longer includes the
`content_type()` method
4. **Hook Logic Break**: Pipe mode now requires command context, and
pipeline results no longer include ContentType fields

_Last updated: 2026-04-12 04:30:58_
<!-- AI-PR-DESCRIPTION-END -->

Author: fajarhide

benches/pipeline.rs

@@ -1,31 +1,18 @@
 use criterion::{BenchmarkId, Criterion, criterion_group, criterion_main};
 use omni::distillers;
-use omni::pipeline::{classifier, scorer};
+use omni::pipeline::scorer;
 use std::time::Duration;
 
-fn bench_classify(c: &mut Criterion) {
-    let fixtures = [
-        (
-            "git_diff",
-            include_str!("../tests/fixtures/git_diff_multi_file.txt"),
-        ),
-        (
-            "cargo_build",
-            include_str!("../tests/fixtures/cargo_build_errors.txt"),
-        ),
-        (
-            "kubectl",
-            include_str!("../tests/fixtures/kubectl_pods_mixed.txt"),
-        ),
-        (
-            "nginx_log",
-            include_str!("../tests/fixtures/nginx_access_log.txt"),
-        ),
+fn bench_registry_resolve(c: &mut Criterion) {
+    let commands = [
+        ("git_diff", "git diff HEAD~1"),
+        ("cargo_build", "cargo build"),
+        ("kubectl", "kubectl get pods"),
     ];
 
-    for (name, input) in &fixtures {
-        c.bench_with_input(BenchmarkId::new("classify", name), input, |b, i| {
-            b.iter(|| classifier::classify(i, None))
+    for (name, cmd) in &commands {
+        c.bench_with_input(BenchmarkId::new("registry_resolve", name), cmd, |b, &i| {
+            b.iter(|| scorer::score_with_command("", i, None))
         });
     }
 }
@@ -35,10 +22,8 @@ fn bench_full_pipeline(c: &mut Criterion) {
 
     c.bench_function("full_pipeline_cargo_build", |b| {
         b.iter(|| {
-            let ctype = classifier::classify(input, None);
-            let segments = scorer::score_segments(input, &ctype, None);
-            let distiller = distillers::get_distiller(&ctype);
-            distiller.distill(&segments, input, None)
+            let segments = scorer::score_with_command(input, "cargo build", None);
+            distillers::distill_with_command(&segments, input, "cargo build", None)
         })
     });
 }
@@ -49,10 +34,8 @@ fn bench_hook_roundtrip(c: &mut Criterion) {
 
     c.bench_function("hook_roundtrip_50kb", |b| {
         b.iter(|| {
-            let ctype = classifier::classify(&large_input, None);
-            let segments = scorer::score_segments(&large_input, &ctype, None);
-            let distiller = distillers::get_distiller(&ctype);
-            distiller.distill(&segments, &large_input, None)
+            let segments = scorer::score_with_command(&large_input, "git diff", None);
+            distillers::distill_with_command(&segments, &large_input, "git diff", None)
         })
     });
 }
@@ -62,6 +45,6 @@ criterion_group! {
     config = Criterion::default()
         .measurement_time(Duration::from_secs(5))
         .warm_up_time(Duration::from_secs(2));
-    targets = bench_classify, bench_full_pipeline, bench_hook_roundtrip
+    targets = bench_registry_resolve, bench_full_pipeline, bench_hook_roundtrip
 }
 criterion_main!(benches);

src/cli/doctor.rs

@@ -463,47 +463,6 @@ pub fn run(args: &[String]) -> anyhow::Result<()> {
         println!("   {:<15} none", "Project:".bright_black());
     }
 
-    // 10. Intelligence Consistency
-    println!("\n {}", "Intelligence:".bold().bright_white());
-    if let Ok(store) = Store::open() {
-        if fix_mode {
-            match store.reclassify_historical_data() {
-                Ok(count) => {
-                    if count > 0 {
-                        println!(
-                            "   {:<15} {} records upgraded to new categories {}",
-                            "Upgrade:".bright_black(),
-                            count.to_string().yellow().bold(),
-                            "[FIXED]".green().bold()
-                        );
-                    } else {
-                        println!(
-                            "   {:<15} historical statistics are up to date {}",
-                            "Status:".bright_black(),
-                            "[OK]".green().bold()
-                        );
-                    }
-                }
-                Err(e) => {
-                    println!(
-                        "   {:<15} upgrade failed: {} {}",
-                        "Upgrade:".bright_black(),
-                        e,
-                        "[ERROR]".red().bold()
-                    );
-                }
-            }
-        } else {
-            // Diagnostic mode: check how many could be upgraded
-            // For now, simpler to just say 'Run with --fix to upgrade'
-            println!(
-                "   {:<15} Run with {} to upgrade historical stats",
-                "Status:".bright_black(),
-                "--fix".cyan()
-            );
-        }
-    }
-
     if let Some(latest) = crate::guard::update::check() {
         crate::guard::update::print_notification(&latest);
     }

src/cli/init.rs

@@ -415,7 +415,7 @@ mod tests {
     }
 
     #[test]
-    fn test_init_hook_idempotent_run_2x_tidak_duplicate() {
+    fn test_init_hook_idempotent_run_2x_not_duplicate() {
         let mut val = json!({});
         install_omni_hooks(&mut val, "/usr/bin/omni");
 

src/cli/learn.rs

@@ -91,7 +91,7 @@ pub fn run_learn(args: &[String]) -> Result<()> {
                 .bright_white()
         );
         let report = crate::pipeline::toml_filter::run_inline_tests(
-            &crate::pipeline::toml_filter::load_all_filters(),
+            crate::pipeline::toml_filter::load_all_filters(),
         );
         let total = report.passes + report.failures.len();
 

src/cli/session.rs

@@ -496,7 +496,7 @@ mod tests {
     }
 
     #[test]
-    fn test_session_command_tidak_crash_jika_tidak_ada_session() {
+    fn test_session_command_not_crash_jika_not_ada_session() {
         let (store, _dir) = get_store();
         let args = vec!["session".to_string()];
         let res = run_session(&args, store);