kkernel 0.9.0

khive kernel — stdio MCP server binary and admin CLI (sync, pack introspection, db ops)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

//! Operator-only management of pinned tool-source definitions.
use anyhow::{Context, Result};
use clap::Subcommand;
use khive_mcp::serve::{
    build_registry_for_multi_backend_with_db_anchor, resolve_runtime_config_with_db_anchor,
    RuntimeConfigInputs,
};
use khive_runtime::{KhiveConfig, Namespace, PackRegistry};
use std::path::PathBuf;

#[derive(Debug, Subcommand)]
pub enum MountCommand {
    /// Replace a configured source's pinned catalog and audit the change.
    Repin {
        name: String,
        #[arg(long, env = "KHIVE_CONFIG")]
        config: Option<PathBuf>,
        #[arg(long, env = "KHIVE_DB")]
        db: Option<String>,
    },
}

pub async fn run(command: MountCommand) -> Result<()> {
    let MountCommand::Repin { name, config, db } = command;
    let (mut runtime, anchor) = resolve_runtime_config_with_db_anchor(RuntimeConfigInputs {
        db: db.as_deref(),
        config: config.as_deref(),
        namespace: Namespace::local(),
        namespace_explicit: false,
        actor_explicit: false,
        no_embed: true,
        packs: None,
        brain_profile: None,
    })?;
    let source = runtime
        .mounts
        .iter()
        .find(|mount| mount.name == name)
        .cloned()
        .context("mount is not configured")?;
    anyhow::ensure!(
        !PackRegistry::discovered_names().contains(&name.as_str()),
        "mount namespace collides with a native pack"
    );
    let operator = runtime
        .actor_id
        .clone()
        .unwrap_or_else(|| "operator".into());
    let cfg = KhiveConfig::load_with_home_fallback(
        config.as_deref(),
        khive_mcp::serve::config_discovery_db_anchor(db.as_deref()).as_deref(),
    )?
    .unwrap_or_default();
    // Prepare the configured storage topology without starting unrelated sources.
    runtime.mounts.clear();
    let built = build_registry_for_multi_backend_with_db_anchor(
        runtime,
        &cfg,
        db.as_deref(),
        anchor.as_deref(),
    )
    .await?;
    let mount = khive_mounts::MountedPack::start(source, built.default_runtime).await?;
    println!("{}", serde_json::to_string(&mount.repin(&operator).await?)?);
    Ok(())
}