clawdb-cli 0.1.2

Command-line interface for the ClawDB cognitive database.
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
131
132
133
134
135
136
137
138
139

use serde::{Deserialize, Serialize};

/// Generic API error body returned by the server.
#[derive(Debug, Deserialize, Serialize, Default, Clone)]
pub struct ApiErrorBody {
    #[serde(default)]
    pub error: String,
    #[serde(default)]
    pub detail: Option<String>,
    #[serde(default)]
    pub message: Option<String>,
}

/// A stored memory record.
#[derive(Debug, Deserialize, Serialize, Clone)]
pub struct MemoryRecord {
    pub id: String,
    pub content: String,
    #[serde(default)]
    pub memory_type: String,
    #[serde(default)]
    pub tags: Vec<String>,
    pub score: Option<f64>,
    pub created_at: Option<String>,
}

/// A single search result hit.
#[derive(Debug, Deserialize, Serialize, Clone)]
pub struct SearchHit {
    pub id: String,
    pub content: String,
    #[serde(default)]
    pub score: f64,
    #[serde(default)]
    pub tags: Vec<String>,
    pub memory_type: Option<String>,
}

/// Server health response.
#[derive(Debug, Deserialize, Serialize, Clone)]
pub struct HealthResponse {
    pub ok: bool,
    #[serde(default)]
    pub components: std::collections::HashMap<String, serde_json::Value>,
    pub uptime_secs: Option<f64>,
}

/// Session info returned by the server.
#[derive(Debug, Deserialize, Serialize, Clone)]
pub struct SessionInfo {
    #[serde(default, alias = "id")]
    pub session_id: String,
    pub token: String,
    #[serde(default)]
    pub agent_id: String,
    #[serde(default)]
    pub role: String,
    #[serde(default)]
    pub scopes: Vec<String>,
    pub expires_at: Option<String>,
}

/// A branch record.
#[derive(Debug, Deserialize, Serialize, Clone)]
pub struct BranchRecord {
    #[serde(alias = "branch_id")]
    pub id: String,
    pub name: String,
    #[serde(default)]
    pub status: String,
    pub created_at: Option<String>,
    pub parent_id: Option<String>,
}

/// Merge result.
#[derive(Debug, Deserialize, Serialize, Clone, Default)]
pub struct MergeResult {
    #[serde(default)]
    pub merged: u64,
    #[serde(default)]
    pub conflicts: u64,
}

/// Branch diff result.
#[derive(Debug, Deserialize, Serialize, Clone, Default)]
pub struct DiffResult {
    #[serde(default)]
    pub added: u64,
    #[serde(default)]
    pub modified: u64,
    #[serde(default)]
    pub removed: u64,
}

/// Sync result.
#[derive(Debug, Deserialize, Serialize, Clone, Default)]
pub struct SyncResult {
    #[serde(default)]
    pub pushed: u64,
    #[serde(default)]
    pub pulled: u64,
    #[serde(default)]
    pub conflicts: u64,
}

/// Reflect job status.
#[derive(Debug, Deserialize, Serialize, Clone, Default)]
pub struct ReflectJob {
    #[serde(default)]
    pub job_id: String,
    #[serde(default)]
    pub status: String,
    pub memories_processed: Option<u64>,
    pub summaries_created: Option<u64>,
}

/// A policy record.
#[derive(Debug, Deserialize, Serialize, Clone)]
pub struct PolicyRecord {
    pub id: String,
    pub name: String,
    #[serde(default)]
    pub effect: String,
    pub created_at: Option<String>,
}

/// Result of a policy test.
#[derive(Debug, Deserialize, Serialize, Clone)]
pub struct PolicyTestResult {
    pub allowed: bool,
    pub reason: Option<String>,
}

/// Response body from POST /v1/memories.
#[derive(Debug, Deserialize, Serialize, Clone)]
pub struct CreateMemoryResponse {
    #[serde(alias = "memory_id")]
    pub id: String,
}