systemprompt-runtime 0.55.0

Application runtime for systemprompt.io AI governance infrastructure. AppContext, lifecycle builder, extension registry, and module wiring for the MCP governance pipeline.
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
79
80
81
82
83
84
85
86
87
88
89
90
91

//! Core inventory orchestration uses configured services roots and
//! organizational ownership.
//!
//! Copyright (c) systemprompt.io — Business Source License 1.1.
//! See <https://systemprompt.io> for licensing details.

use super::OrchestrationError;
use crate::AppContext;
use systemprompt_identifiers::UserId;
use systemprompt_marketplace::inventory::{
    BaselineCapture, BaselinePreparation, BaselineScope, InventoryService, InventoryStatus,
};
pub use systemprompt_marketplace::inventory::{LatestPublication, LatestPublicationStatus};

pub async fn refresh(
    ctx: &AppContext,
    owner: &UserId,
) -> Result<InventoryStatus, OrchestrationError> {
    let services = load_services(ctx, owner).await?;
    Ok(
        InventoryService::new(ctx.managed_repository().as_ref().clone())
            .refresh(owner, ctx.app_paths().system().services(), &services)
            .await?,
    )
}

pub async fn prepare_baselines(
    ctx: &AppContext,
    owner: &UserId,
    actor: &UserId,
    request: &BaselinePreparation,
) -> Result<Vec<BaselineCapture>, OrchestrationError> {
    let services = load_services(ctx, owner).await?;
    let service = InventoryService::new(ctx.managed_repository().as_ref().clone());
    service
        .refresh(owner, ctx.app_paths().system().services(), &services)
        .await?;
    Ok(service
        .prepare_baselines(
            &BaselineScope {
                owner,
                actor,
                root: ctx.app_paths().system().services(),
                services: &services,
            },
            request,
        )
        .await?)
}

pub async fn publish_latest(
    ctx: &AppContext,
    owner: &UserId,
    actor: &UserId,
) -> Result<Vec<LatestPublication>, OrchestrationError> {
    let services = load_services(ctx, owner).await?;
    let service = InventoryService::new(ctx.managed_repository().as_ref().clone());
    service
        .refresh(owner, ctx.app_paths().system().services(), &services)
        .await?;
    let mut guard = ctx.publish_guard().lock().await;
    Ok(service
        .publish_latest(
            &BaselineScope {
                owner,
                actor,
                root: ctx.app_paths().system().services(),
                services: &services,
            },
            &mut guard,
        )
        .await?)
}

async fn load_services(
    ctx: &AppContext,
    owner: &UserId,
) -> Result<systemprompt_models::services::ServicesConfig, OrchestrationError> {
    match systemprompt_loader::ConfigLoader::load() {
        Ok(services) => Ok(services),
        Err(error) => {
            tracing::warn!(%error, "Configured inventory could not be loaded; previous inventory retained");
            ctx.managed_repository()
                .record_inventory_failure(owner)
                .await?;
            Err(OrchestrationError::Source(format!(
                "Configured inventory could not be loaded; previous inventory retained: {error}"
            )))
        },
    }
}