do-memory-mcp 0.1.30

Model Context Protocol (MCP) server for AI agents
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
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130

//! Audit logging operations - Episode operations
//!
//! This module provides logging methods for episode-related operations.

use super::core::AuditLogger;
use super::types::AuditLogLevel;
use serde_json::json;

impl AuditLogger {
    /// Log episode creation
    pub async fn log_episode_creation(
        &self,
        client_id: &str,
        episode_id: &str,
        task_description: &str,
        success: bool,
        error: Option<&str>,
    ) {
        let metadata = json!({
            "episode_id": episode_id,
            "task_description": task_description,
            "error": error
        });

        self.log_event(
            AuditLogLevel::Info,
            client_id,
            "create_episode",
            if success { "success" } else { "failure" },
            metadata,
        )
        .await;
    }

    /// Log episode modification
    pub async fn log_episode_modification(
        &self,
        client_id: &str,
        episode_id: &str,
        operation: &str,
        success: bool,
        error: Option<&str>,
    ) {
        let metadata = json!({
            "episode_id": episode_id,
            "modification_type": operation,
            "error": error
        });

        self.log_event(
            AuditLogLevel::Info,
            client_id,
            "modify_episode",
            if success { "success" } else { "failure" },
            metadata,
        )
        .await;
    }

    /// Log episode deletion
    pub async fn log_episode_deletion(
        &self,
        client_id: &str,
        episode_id: &str,
        success: bool,
        error: Option<&str>,
    ) {
        let metadata = json!({
            "episode_id": episode_id,
            "error": error
        });

        self.log_event(
            AuditLogLevel::Warn,
            client_id,
            "delete_episode",
            if success { "success" } else { "failure" },
            metadata,
        )
        .await;
    }

    /// Log episode step addition
    pub async fn log_episode_step(
        &self,
        client_id: &str,
        episode_id: &str,
        step_number: u32,
        tool: &str,
        success: bool,
    ) {
        let metadata = json!({
            "episode_id": episode_id,
            "step_number": step_number,
            "tool": tool
        });

        self.log_event(
            AuditLogLevel::Debug,
            client_id,
            "add_episode_step",
            if success { "success" } else { "failure" },
            metadata,
        )
        .await;
    }

    /// Log episode completion
    pub async fn log_episode_completion(
        &self,
        client_id: &str,
        episode_id: &str,
        outcome: &str,
        success: bool,
    ) {
        let metadata = json!({
            "episode_id": episode_id,
            "outcome": outcome
        });

        self.log_event(
            AuditLogLevel::Info,
            client_id,
            "complete_episode",
            if success { "success" } else { "failure" },
            metadata,
        )
        .await;
    }
}