reddb_engine/storage/
error.rs

1//! Canonical storage errors shared by native and browser hosts.
2use super::entity::EntityId;
3use super::segment::SegmentError;
4use std::fmt;
5
6#[derive(Debug, Clone, PartialEq, Eq)]
7pub struct StorageIntegrityError {
8    pub zone: String,
9    pub id: String,
10    pub collection: Option<String>,
11    pub detail: String,
12}
13
14impl StorageIntegrityError {
15    pub fn new(
16        zone: impl Into<String>,
17        id: impl Into<String>,
18        collection: Option<String>,
19        detail: impl Into<String>,
20    ) -> Self {
21        Self {
22            zone: zone.into(),
23            id: id.into(),
24            collection,
25            detail: detail.into(),
26        }
27    }
28}
29
30impl fmt::Display for StorageIntegrityError {
31    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
32        write!(
33            f,
34            "storage integrity failure: zone={} id={}",
35            self.zone, self.id
36        )?;
37        if let Some(collection) = &self.collection {
38            write!(f, " collection={collection}")?;
39        }
40        write!(
41            f,
42            ": {}. RedDB refused to serve unverified bytes; run the `SCRUB` statement to classify the fault, or `red salvage` to recover trusted rows.",
43            self.detail
44        )
45    }
46}
47
48/// Errors from UnifiedStore operations
49#[derive(Debug)]
50pub enum StoreError {
51    /// Collection already exists
52    CollectionExists(String),
53    /// Collection not found
54    CollectionNotFound(String),
55    /// Entity not found
56    EntityNotFound(EntityId),
57    /// Too many cross-references
58    TooManyRefs(EntityId),
59    /// Segment error
60    Segment(SegmentError),
61    /// I/O error
62    Io(std::io::Error),
63    /// Checksummed storage bytes failed validation.
64    StorageIntegrity(StorageIntegrityError),
65    /// Serialization error
66    Serialization(String),
67    /// Internal error (lock poisoning, invariant violation)
68    Internal(String),
69}
70
71impl std::fmt::Display for StoreError {
72    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
73        match self {
74            Self::CollectionExists(name) => write!(f, "Collection already exists: {}", name),
75            Self::CollectionNotFound(name) => write!(f, "Collection not found: {}", name),
76            Self::EntityNotFound(id) => write!(f, "Entity not found: {}", id),
77            Self::TooManyRefs(id) => write!(f, "Too many cross-references for entity: {}", id),
78            Self::Segment(e) => write!(f, "Segment error: {:?}", e),
79            Self::Io(e) => write!(f, "I/O error: {}", e),
80            Self::StorageIntegrity(e) => write!(f, "{e}"),
81            Self::Serialization(msg) => write!(f, "Serialization error: {}", msg),
82            Self::Internal(msg) => write!(f, "Internal error: {}", msg),
83        }
84    }
85}
86
87impl std::error::Error for StoreError {}
88
89impl From<SegmentError> for StoreError {
90    fn from(e: SegmentError) -> Self {
91        Self::Segment(e)
92    }
93}
94
95impl From<std::io::Error> for StoreError {
96    fn from(e: std::io::Error) -> Self {
97        Self::Io(e)
98    }
99}
reddb_engine/storage/error.rs

reddb_engine/storage/
error.rs
