systemprompt-api 0.55.0

Axum-based HTTP server and API gateway for systemprompt.io AI governance infrastructure. Exposes governed agents, MCP, A2A, and admin endpoints with rate limiting and RBAC.
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

//! Filesystem and tar/gzip helpers backing the file-download handlers.
//!
//! The walk, hashing and packing themselves live in
//! [`systemprompt_loader::bundle::pack`], shared with the bundle publisher so
//! a downloaded tree and a published bundle are hashed the same way. These
//! are blocking, CPU- and syscall-bound operations invoked from
//! [`super::files`] inside `spawn_blocking`.
//!
//! Copyright (c) systemprompt.io — Business Source License 1.1.
//! See <https://systemprompt.io> for licensing details.

use std::path::{Path, PathBuf};

use systemprompt_loader::bundle::pack::{collect_files, create_tarball_bytes, manifest_checksum};
use systemprompt_runtime::AppContext;

use super::types::FileManifest;

const ALLOWED_DIRS: &[&str] = &[
    "agents", "skills", "rules", "content", "mcp", "ai", "config", "profiles",
];

pub(super) fn get_services_path(ctx: &AppContext) -> Result<PathBuf, String> {
    let services = ctx.app_paths().system().services();
    if services.exists() {
        return Ok(services.to_path_buf());
    }

    Err("Services path not configured".into())
}

pub(super) fn collect_manifest(
    services_path: &Path,
    directories: &[&str],
) -> Result<FileManifest, String> {
    let requested: Vec<&str> = directories
        .iter()
        .copied()
        .filter(|d| ALLOWED_DIRS.contains(d))
        .collect();
    let files = collect_files(services_path, &requested)
        .map_err(|e| format!("Failed to walk services tree: {e}"))?;
    let (checksum, total_size) = manifest_checksum(&files);

    Ok(FileManifest {
        files,
        timestamp: chrono::Utc::now(),
        checksum,
        total_size,
    })
}

pub(super) fn create_tarball(base: &Path, manifest: &FileManifest) -> Result<Vec<u8>, String> {
    create_tarball_bytes(base, &manifest.files).map_err(|e| e.to_string())
}