rightkit-agent-engine-api-integrations 0.1.3

Agent engine integrations HTTP API: plugin discovery, manifest projection and plugin middleware wiring
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
67
68
69
70
71
72
73
74
75
76
77
78

//! Portable plugin path & manifest projections.

use crate::plugin_signature::{read_record, SignatureStatus};
use std::path::{Path, PathBuf};

pub fn default_plugin_dir() -> PathBuf {
    // An explicit directory is already the catalog root; only home-derived
    // defaults need the plugins suffix.
    if let Some(dir) = std::env::var_os("RIGHTKIT_PLUGIN_DIR") {
        return PathBuf::from(dir);
    }
    // No fallback location: a missing state root fails, it never redirects plugins into the
    // working directory.
    rightkit_agent_config::state_root()
        .unwrap_or_else(|| {
            eprintln!("rightkit: cannot continue without a state directory; refusing to fall back");
            std::process::exit(2)
        })
        .join("plugins")
}

pub fn plugin_manifest_json(
    manifest: &rightkit_agent_plugins::PluginManifest,
) -> serde_json::Value {
    serde_json::json!({
        "id": manifest.id,
        "name": manifest.name,
        "version": manifest.version,
        "description": manifest.description,
        "entry": manifest.entry,
        "providesTools": manifest.provides_tools,
        "providesCommands": manifest.provides_commands,
        "tools": manifest.tools,
        "commands": manifest.commands,
        "prompts": manifest.prompts,
        "middleware": manifest.middleware,
        "sandbox": manifest.sandbox,
        "enabled": manifest.enabled,
    })
}

/// Where the plugin marketplace file lives; rightkit-agent-server's marketplace routes read it.
pub fn default_plugin_marketplace_path() -> PathBuf {
    std::env::var_os("RIGHTKIT_PLUGIN_MARKETPLACE")
        .map(PathBuf::from)
        .or_else(|| rightkit_agent_config::state_root().map(|root| root.join("marketplace.json")))
        .unwrap_or_else(|| {
            std::env::current_dir()
                .unwrap_or_else(|_| PathBuf::from("."))
                .join(".rightkit")
                .join("marketplace.json")
        })
}

/// A plugin manifest as JSON with its recorded signature status and signer (rightkit-agent-server plugin routes).
pub fn plugin_manifest_json_with_provenance(
    manifest: &rightkit_agent_plugins::PluginManifest,
    install_dir: &Path,
) -> serde_json::Value {
    let mut value = plugin_manifest_json(manifest);
    let record = read_record(install_dir);
    let status = match record.status {
        SignatureStatus::Signed => "signed",
        SignatureStatus::Unsigned => "unsigned",
        SignatureStatus::Unknown => "unknown",
    };
    if let Some(object) = value.as_object_mut() {
        object.insert(
            "signatureStatus".into(),
            serde_json::Value::String(status.into()),
        );
        object.insert(
            "signatureSignedBy".into(),
            serde_json::Value::String(record.signed_by),
        );
    }
    value
}