semioscan 0.11.3

Production-grade Rust library for blockchain analytics: gas calculation, price extraction, and block window calculations for EVM chains
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

// SPDX-FileCopyrightText: 2025 Semiotic AI, Inc.
//
// SPDX-License-Identifier: Apache-2.0

//! Error types for event processing.
//!
//! This module provides error types for operations in the `events` module,
//! particularly for scanning and processing Transfer events and token discovery.

use super::RpcError;

/// Errors that can occur during event processing.
///
/// This error type covers event decoding failures, configuration issues,
/// and RPC failures that can occur when scanning for and processing
/// blockchain events.
///
/// # Examples
///
/// ```rust,ignore
/// use semioscan::{extract_transferred_to_tokens, EventProcessingError};
/// use alloy_chains::NamedChain;
///
/// async fn example() -> Result<(), EventProcessingError> {
///     match extract_transferred_to_tokens(&provider, NamedChain::Arbitrum, router_address, start_block, end_block).await {
///         Ok(tokens) => println!("Found {} tokens", tokens.len()),
///         Err(EventProcessingError::ConfigurationMissing { field }) => {
///             eprintln!("Missing configuration: {}", field);
///         }
///         Err(EventProcessingError::Rpc(e)) => {
///             eprintln!("RPC error: {}", e);
///         }
///         Err(e) => eprintln!("Other error: {}", e),
///     }
///     Ok(())
/// }
/// ```
#[derive(Debug, thiserror::Error)]
pub enum EventProcessingError {
    /// Failed to decode an event from log data.
    ///
    /// This occurs when a log entry doesn't match the expected event signature
    /// (e.g., Transfer event) or contains invalid data. Note that in some
    /// contexts, decode failures are logged as warnings and processing continues.
    #[error("Failed to decode event: {details}")]
    DecodeFailed {
        /// Details about why the decode failed
        details: String,
    },

    /// Required configuration is missing.
    ///
    /// This typically occurs when environment variables (like RPC URLs)
    /// are not set, preventing event processing from proceeding.
    #[error("Missing configuration: {field}")]
    ConfigurationMissing {
        /// Name of the missing configuration field
        field: String,
    },

    /// RPC error when communicating with blockchain provider.
    ///
    /// This wraps [`RpcError`] for blockchain provider failures during
    /// event processing (e.g., fetching logs, scanning for events).
    #[error("RPC error: {0}")]
    Rpc(#[from] RpcError),

    /// Invalid input provided to an operation.
    ///
    /// This occurs when function arguments don't meet requirements,
    /// such as a filter missing required block range bounds.
    #[error("Invalid input: {details}")]
    InvalidInput {
        /// Details about what was invalid
        details: String,
    },

    /// RPC failure with contextual information.
    ///
    /// Used when an RPC call fails and we want to include additional context
    /// (such as block ranges or operation details) in the error message.
    /// Prefer this over [`Rpc`] when the context would aid debugging.
    ///
    /// [`Rpc`]: EventProcessingError::Rpc
    #[error("RPC call failed: {details}")]
    RpcFailed {
        /// Details about the failure including context
        details: String,
    },
}

impl EventProcessingError {
    /// Create a `DecodeFailed` error with details.
    pub fn decode_failed(details: impl Into<String>) -> Self {
        EventProcessingError::DecodeFailed {
            details: details.into(),
        }
    }

    /// Create a `ConfigurationMissing` error for a specific field.
    pub fn configuration_missing(field: impl Into<String>) -> Self {
        EventProcessingError::ConfigurationMissing {
            field: field.into(),
        }
    }

    /// Helper to create a missing RPC URL configuration error.
    pub fn missing_rpc_url(chain: impl std::fmt::Display) -> Self {
        Self::configuration_missing(format!("RPC_URL for chain {}", chain))
    }

    /// Create an `InvalidInput` error with details.
    pub fn invalid_input(details: impl Into<String>) -> Self {
        EventProcessingError::InvalidInput {
            details: details.into(),
        }
    }

    /// Create an `RpcFailed` error with details.
    pub fn rpc_failed(details: impl Into<String>) -> Self {
        EventProcessingError::RpcFailed {
            details: details.into(),
        }
    }
}