systemprompt-extension 0.78.0

Compile-time extension framework for systemprompt.io AI governance infrastructure. Built on the inventory crate — registers schemas, API routes, jobs, and providers in 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

//! The consolidation seam: an extension-supplied [`FactConsolidator`] reads
//! the stored facts of one kind and subject and proposes the facts that
//! should replace or summarise them.
//!
//! Scaffolding, inactive unless an extension opts in: core registers no
//! consolidator, the daily `brain_consolidate` job runs only when
//! `brain.consolidation.enabled` is `true` and at least one consolidator is
//! registered, and its candidates land as `proposed` facts for a person to
//! confirm. The model client in the input is the only way a consolidator
//! reaches a model, so every call is metered and audited through the
//! gateway under the job's token budget.
//!
//! Copyright (c) systemprompt.io — Business Source License 1.1.
//! See <https://systemprompt.io> for licensing details.

use std::fmt;
use std::sync::Arc;

use systemprompt_models::brain::{BrainFact, FactCandidate, KindDecl, SubjectKey};

use super::errors::BrainConsolidateError;
use super::traits::BrainModelClient;

/// What one consolidator is asked to read: the facts of one kind about one
/// subject, the model client it may call and the tokens it may spend.
pub struct ConsolidationInput {
    pub kind: KindDecl,
    pub subject: SubjectKey,
    pub facts: Vec<BrainFact>,
    pub model: Arc<dyn BrainModelClient>,
    pub budget_tokens: u64,
}

impl fmt::Debug for ConsolidationInput {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        f.debug_struct("ConsolidationInput")
            .field("kind", &self.kind.kind)
            .field("subject", &self.subject)
            .field("facts", &self.facts.len())
            .field("budget_tokens", &self.budget_tokens)
            .finish_non_exhaustive()
    }
}

/// Proposes consolidated facts for the kinds it `handles`; held as
/// `Arc<dyn FactConsolidator>`. The candidates it returns are entered as
/// `proposed` facts of the kind they name.
///
/// `#[async_trait]` keeps the trait dyn-compatible.
#[async_trait::async_trait]
pub trait FactConsolidator: Send + Sync {
    fn name(&self) -> &'static str;

    fn handles(&self, kind: &KindDecl) -> bool;

    async fn consolidate(
        &self,
        input: &ConsolidationInput,
    ) -> Result<Vec<FactCandidate>, BrainConsolidateError>;
}