zeph-core 0.19.0

Core agent loop, configuration, context builder, metrics, and vault for Zeph
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

// SPDX-FileCopyrightText: 2026 Andrei G <bug-ops>
// SPDX-License-Identifier: MIT OR Apache-2.0

//! Knowledge graph extraction and semantic labeling state for the agent's memory subsystem.
//!
//! [`MemoryExtractionState`] groups fields that control how the agent extracts structured
//! knowledge: graph extraction configuration, the RPE (Retrieval-Path Expansion) router,
//! document config, and semantic classification configs (persona, trajectory, category).

/// Graph extraction config, RPE router, document config, and semantic classification configs.
///
/// These fields are primarily accessed together in graph extraction passes and
/// semantic labeling paths. Isolating them reduces cognitive load when reasoning about
/// knowledge graph and classification logic.
#[derive(Default)]
pub(crate) struct MemoryExtractionState {
    /// Document indexing and chunking configuration.
    pub(crate) document_config: crate::config::DocumentConfig,
    /// Knowledge graph extraction configuration.
    pub(crate) graph_config: crate::config::GraphConfig,
    /// D-MEM RPE router. `Some` when `graph_config.rpe.enabled = true`.
    ///
    /// Protected by `std::sync::Mutex` for non-async access from `maybe_spawn_graph_extraction`.
    pub(crate) rpe_router: Option<std::sync::Mutex<zeph_memory::RpeRouter>>,
    /// Goal text for the current user turn, derived from raw user input (#2483).
    ///
    /// Passed to A-MAC admission control to enable goal-conditioned write gating.
    /// Reset at the start of each user turn. `None` only before the first user message.
    pub(crate) goal_text: Option<String>,
    /// Persona memory configuration (#2461).
    pub(crate) persona_config: zeph_config::PersonaConfig,
    /// Trajectory-informed memory configuration (#2498).
    pub(crate) trajectory_config: zeph_config::TrajectoryConfig,
    /// Category-aware memory configuration (#2428).
    pub(crate) category_config: zeph_config::CategoryConfig,
}

impl MemoryExtractionState {
    /// Apply an updated graph configuration, reinitializing the RPE router if needed.
    ///
    /// Rebuilds the RPE router when `config.rpe.enabled = true`, clears it otherwise.
    /// Emits a warning when graph-memory is enabled because PII redaction is not yet implemented.
    pub(crate) fn apply_graph_config(&mut self, config: crate::config::GraphConfig) {
        if config.enabled {
            tracing::warn!(
                "graph-memory is enabled: extracted entities are stored without PII redaction. \
                 Do not use with sensitive personal data until redaction is implemented."
            );
        }
        if config.rpe.enabled {
            self.rpe_router = Some(std::sync::Mutex::new(zeph_memory::RpeRouter::new(
                config.rpe.threshold,
                config.rpe.max_skip_turns,
            )));
        } else {
            self.rpe_router = None;
        }
        self.graph_config = config;
    }
}