tycho-rpc 0.3.9

Public RPC service.
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

use tycho_storage::kv::{
    Migrations, NamedTables, StateVersionProvider, TableContext, WithMigrations,
};
use tycho_util::sync::CancellationFlag;
use weedb::{MigrationError, Semver, WeeDb};

use super::tables;

pub type RpcDb = WeeDb<RpcTables>;

impl NamedTables for RpcTables {
    const NAME: &'static str = "rpc";
}

impl WithMigrations for RpcTables {
    const VERSION: Semver = [0, 1, 0];

    type VersionProvider = StateVersionProvider<tables::State>;

    fn new_version_provider() -> Self::VersionProvider {
        StateVersionProvider::new::<Self>()
    }

    fn register_migrations(
        _migrations: &mut Migrations<Self::VersionProvider, Self>,
        _cancelled: CancellationFlag,
    ) -> Result<(), MigrationError> {
        // migrations.register([0, 0, 1], [0, 0, 2], move |db| Ok(()))?;

        Ok(())
    }
}

weedb::tables! {
    pub struct RpcTables<TableContext> {
        pub state: tables::State,
        pub transactions: tables::Transactions,
        pub transactions_by_hash: tables::TransactionsByHash,
        pub transactions_by_in_msg: tables::TransactionsByInMsg,
        pub known_blocks: tables::KnownBlocks,
        pub block_transactions: tables::BlockTransactions,
        pub blocks_by_mc_seqno: tables::BlocksByMcSeqno,
        pub code_hashes: tables::CodeHashes,
        pub code_hashes_by_address: tables::CodeHashesByAddress,
    }
}