chaincodec-core 0.2.0

Core decoder traits, type normalizer, and shared primitives for ChainCodec
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

//! Error types for the ChainCodec decode pipeline.

use thiserror::Error;

/// Errors that can occur while decoding a single event.
#[derive(Debug, Error)]
pub enum DecodeError {
    #[error("Schema not found for fingerprint {fingerprint}")]
    SchemaNotFound { fingerprint: String },

    #[error("ABI decode failed: {reason}")]
    AbiDecodeFailed { reason: String },

    #[error("Type mismatch: expected {expected}, got {got}")]
    TypeMismatch { expected: String, got: String },

    #[error("Unsupported chain: {chain}")]
    UnsupportedChain { chain: String },

    #[error("Invalid raw event: {reason}")]
    InvalidRawEvent { reason: String },

    #[error("Missing required field: {field}")]
    MissingField { field: String },

    #[error("IO error: {0}")]
    Io(#[from] std::io::Error),

    #[error("Serialization error: {0}")]
    Serde(#[from] serde_json::Error),

    #[error("Unknown error: {0}")]
    Other(String),
}

/// Errors that can occur during batch decoding.
#[derive(Debug, Error)]
pub enum BatchDecodeError {
    #[error("Batch aborted after {count} errors")]
    TooManyErrors { count: usize },

    #[error("Decode error at index {index}: {source}")]
    ItemFailed {
        index: usize,
        #[source]
        source: DecodeError,
    },

    #[error("Memory limit exceeded: tried to allocate {bytes} bytes")]
    MemoryLimitExceeded { bytes: usize },

    #[error("{0}")]
    Other(String),
}

/// Errors from the schema registry.
#[derive(Debug, Error)]
pub enum RegistryError {
    #[error("Schema '{name}' v{version} already exists")]
    AlreadyExists { name: String, version: u32 },

    #[error("Schema '{name}' not found")]
    NotFound { name: String },

    #[error("Schema validation failed: {reason}")]
    ValidationFailed { reason: String },

    #[error("Fingerprint mismatch: claimed {claimed}, computed {computed}")]
    FingerprintMismatch { claimed: String, computed: String },

    #[error("Parse error in CSDL: {0}")]
    ParseError(String),

    #[error("IO error: {0}")]
    Io(#[from] std::io::Error),

    #[error("Database error: {0}")]
    Database(String),
}

/// Errors from the streaming engine.
#[derive(Debug, Error)]
pub enum StreamError {
    #[error("RPC connection failed: {url}: {reason}")]
    ConnectionFailed { url: String, reason: String },

    #[error("Stream closed unexpectedly")]
    Closed,

    #[error("Subscription timeout after {ms}ms")]
    Timeout { ms: u64 },

    #[error("Decode error in stream: {0}")]
    Decode(#[from] DecodeError),

    #[error("{0}")]
    Other(String),
}