indexer1 0.2.19

A library that is used to collect events from EVM compatible 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

//! Trait that describes the persistent storage used in indexing
use alloy::rpc::types::{Filter, Log};
use futures::Future;

use crate::indexer1::Processor;

pub mod postgres;
pub mod sqlite;

pub trait LogStorage {
    /// Type of transaction, &mut Self::Transaction will be propagated into processor function
    type Transaction: Sized;

    /// Method should open up a transaction, then invoke ```log_processor``` and update the ```last_observed_block```
    fn insert_logs<P: Processor<Self::Transaction>>(
        &self,
        chain_id: u64,
        logs: &[Log],
        filter_id: &str,
        prev_saved_block: u64,
        new_saved_block: u64,
        log_processor: &mut P,
    ) -> impl Future<Output = anyhow::Result<()>>;

    /// Method is used to lazily initialize filter store (if not) and extract filter from storage
    /// if it present. In case it doesn't it should create the instance and return
    /// ```from_block``` as a start point of indexing.
    /// Returns u64 block number and String filter_id
    fn get_or_create_filter(
        &self,
        filter: &Filter,
        chain_id: u64,
    ) -> impl Future<Output = anyhow::Result<(u64, String)>>;
}