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
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
// src/error.rs
//
// Manejo centralizado de errores para NopalDB
//
// Refactorizado: 2026-01-12
// - Consolidado de 90+ variantes a ~15 variantes semánticas
// - Mensajes claros y en inglés para consistencia
/// Errores de NopalDB
///
/// Cada variante representa una categoría de error semánticamente distinta.
/// Para errores específicos, usa el campo `String` con contexto adicional.
#[derive(Debug, thiserror::Error)]
pub enum NopalError {
// ═══════════════════════════════════════════════════════════════
// ERRORES DE ENTIDADES (Nodos y Aristas)
// ═══════════════════════════════════════════════════════════════
/// Nodo no encontrado
#[error("Node not found: {0}")]
NodeNotFound(String),
/// Arista no encontrada
#[error("Edge not found: {0}")]
EdgeNotFound(String),
// ═══════════════════════════════════════════════════════════════
// ERRORES DE STORAGE
// ═══════════════════════════════════════════════════════════════
/// Error del motor de storage (sled)
#[error("Storage error: {0}")]
StorageError(#[from] sled::Error),
/// Error de I/O
#[error("IO error: {0}")]
IoError(#[from] std::io::Error),
/// Error de serialización/deserialización
#[error("Serialization error: {0}")]
SerializationError(String),
/// Formato de clave inválido
#[error("Invalid key format: {0}")]
InvalidKey(String),
// ═══════════════════════════════════════════════════════════════
// ERRORES DE TRANSACCIONES
// ═══════════════════════════════════════════════════════════════
/// Transacción no está activa
#[error("Transaction is not active")]
TransactionNotActive,
/// Conflicto de transacción (write-write conflict)
#[error("Transaction conflict: {0}")]
TransactionConflict(String),
/// Deadlock detectado
#[error("Deadlock detected: {0}")]
Deadlock(String),
/// Error de concurrencia genérico
#[error("Concurrency error: {0}")]
ConcurrencyError(String),
// ═══════════════════════════════════════════════════════════════
// ERRORES DE QUERIES (NQL)
// ═══════════════════════════════════════════════════════════════
/// Error al parsear query NQL
#[error("Query parse error: {0}")]
QueryParseError(String),
/// Error al ejecutar query NQL
#[error("Query execution error: {0}")]
QueryExecutionError(String),
/// Error al planificar query
#[error("Query planning error: {0}")]
QueryPlanningError(String),
// ═══════════════════════════════════════════════════════════════
// ERRORES DE SKETCH/COMMIT (NQL v0.2)
// ═══════════════════════════════════════════════════════════════
/// Sketch no encontrado
#[error("Sketch not found: {0}")]
SketchNotFound(String),
/// Sketch inválido
#[error("Invalid sketch: {0}")]
InvalidSketch(String),
/// Commit inválido
#[error("Invalid commit: {0}")]
InvalidCommit(String),
/// Error de validación semántica
#[error("Semantic validation error: {0}")]
SemanticError(String),
#[error("Index error: {0}")]
IndexError(String),
#[error("Ambiguous upsert key: {0}")]
AmbiguousUpsertKey(String),
// ═══════════════════════════════════════════════════════════════
// ERRORES GENÉRICOS
// ═══════════════════════════════════════════════════════════════
/// Error personalizado (catch-all)
///
/// Usar cuando ninguna otra variante aplica.
/// Incluir contexto descriptivo en el mensaje.
#[error("{0}")]
Custom(String),
}
/// Result type alias para NopalDB
pub type Result<T> = std::result::Result<T, NopalError>;
// ═══════════════════════════════════════════════════════════════
// HELPERS PARA CONSTRUCCIÓN DE ERRORES
// ═══════════════════════════════════════════════════════════════
impl NopalError {
/// Crea un error de nodo no encontrado
pub fn node_not_found(id: impl std::fmt::Display) -> Self {
NopalError::NodeNotFound(id.to_string())
}
/// Crea un error de arista no encontrada
pub fn edge_not_found(id: impl std::fmt::Display) -> Self {
NopalError::EdgeNotFound(id.to_string())
}
/// Crea un error de serialización
pub fn serialization(msg: impl Into<String>) -> Self {
NopalError::SerializationError(msg.into())
}
/// Crea un error personalizado
pub fn custom(msg: impl Into<String>) -> Self {
NopalError::Custom(msg.into())
}
/// Crea un error de query
pub fn query_error(msg: impl Into<String>) -> Self {
NopalError::QueryExecutionError(msg.into())
}
pub fn index_error(msg: impl Into<String>) -> Self {
NopalError::IndexError(msg.into())
}
/// Crea un error de sketch no encontrado
pub fn sketch_not_found(name: impl Into<String>) -> Self {
NopalError::SketchNotFound(name.into())
}
/// Crea un error de sketch inválido
pub fn invalid_sketch(msg: impl Into<String>) -> Self {
NopalError::InvalidSketch(msg.into())
}
/// Crea un error de commit inválido
pub fn invalid_commit(msg: impl Into<String>) -> Self {
NopalError::InvalidCommit(msg.into())
}
/// Crea un error semántico
pub fn semantic(msg: impl Into<String>) -> Self {
NopalError::SemanticError(msg.into())
}
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn test_error_display() {
let err = NopalError::NodeNotFound("abc-123".to_string());
assert!(err.to_string().contains("abc-123"));
}
#[test]
fn test_error_helpers() {
let err = NopalError::node_not_found("test-id");
assert!(matches!(err, NopalError::NodeNotFound(_)));
let err = NopalError::custom("something went wrong");
assert!(matches!(err, NopalError::Custom(_)));
}
}