event-scanner 1.1.0

Event Scanner is a library for scanning events from any EVM-based blockchain.
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

//! Types yielded by event subscription streams.
//!
//! Defines [`Message`] and [`EventScannerResult`], along with conversions and comparisons
//! for working with logs.

use alloy::{rpc::types::Log, sol_types::SolEvent};

use crate::{
    ScannerMessage,
    types::{IntoScannerResult, ScannerResult},
};

/// The item type yielded by event subscription streams.
///
/// This is a [`ScannerMessage`] whose data payload is a batch of [`Log`] values.
pub type Message = ScannerMessage<Vec<Log>>;

/// The `Result` type yielded by event subscription streams.
///
/// Successful items are [`Message`] values; failures are [`crate::ScannerError`].
pub type EventScannerResult = ScannerResult<Vec<Log>>;

impl From<Vec<Log>> for Message {
    fn from(logs: Vec<Log>) -> Self {
        Message::Data(logs)
    }
}

impl IntoScannerResult<Vec<Log>> for Vec<Log> {
    fn into_scanner_message_result(self) -> EventScannerResult {
        Ok(Message::Data(self))
    }
}

impl<E: SolEvent> PartialEq<Vec<E>> for Message {
    fn eq(&self, other: &Vec<E>) -> bool {
        self.eq(&other.as_slice())
    }
}

impl<E: SolEvent> PartialEq<&Vec<E>> for Message {
    fn eq(&self, other: &&Vec<E>) -> bool {
        self.eq(&other.as_slice())
    }
}

impl<E: SolEvent, const N: usize> PartialEq<&[E; N]> for Message {
    fn eq(&self, other: &&[E; N]) -> bool {
        self.eq(&other.as_slice())
    }
}

impl<E: SolEvent> PartialEq<&[E]> for Message {
    fn eq(&self, other: &&[E]) -> bool {
        if let Message::Data(logs) = self {
            logs.iter().map(|l| l.data().clone()).eq(other.iter().map(SolEvent::encode_log_data))
        } else {
            false
        }
    }
}