Skip to content
This repository was archived by the owner on Mar 17, 2023. It is now read-only.

Commit ed87cd4

Browse files
sduchesneausduchesneau
committed
add eth-block-producers simple module
1 parent 8a1afbc commit ed87cd4

10 files changed

+6286
-0
lines changed

‎Cargo.lock

+15
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎Cargo.toml

+1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
[workspace]
22
members = [
33
"modules/eth-token",
4+
"modules/eth-block-producers",
45
"modules/pancakeswap",
56
"modules/sol-spl-tokens",
67
"modules/uniswap",

‎modules/eth-block-producers/.gitignore

+6
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
/target/
2+
/localblocks/
3+
/localdata/
4+
/localirr/
5+
.idea/
6+
/rpc-cache/

‎modules/eth-block-producers/Cargo.toml

+19
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,19 @@
1+
[package]
2+
name = "substreams-eth-block-producers"
3+
version = "0.1.0"
4+
description = "Substreams for Ethereum tokens"
5+
edition = "2021"
6+
7+
[lib]
8+
crate-type = ["cdylib"]
9+
10+
[dependencies]
11+
wasm-bindgen = "0.2.79"
12+
prost = { version = "0.10.1" }
13+
prost-types = "0.10.1"
14+
hex = "0.4.3"
15+
substreams = "0.0.11"
16+
substreams-ethereum = "0.1.2"
17+
num-bigint = "0.4"
18+
bigdecimal = "0.3"
19+
pad = "0.1"

‎modules/eth-block-producers/src/lib.rs

+27
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,27 @@
1+
mod pb;
2+
3+
use substreams::errors::Error;
4+
use substreams::errors::Error::Unexpected;
5+
use substreams::{log, store, Hex}; // {hex, log, proto, store, Hex};
6+
use substreams_ethereum::pb::eth as ethpb;
7+
8+
#[substreams::handlers::map]
9+
fn map_coinbase(blk: ethpb::v1::Block) -> Result<String, Error> {
10+
log::info!("patate".to_string());
11+
match blk.header {
12+
Some(h) => {
13+
let stringed = Hex(h.coinbase).to_string();
14+
log::info!(stringed.clone());
15+
Ok(stringed)
16+
}
17+
None => Err(Unexpected("no header in block".to_string())),
18+
}
19+
}
20+
21+
#[substreams::handlers::store]
22+
fn store_coinbase(coinbase: String, store: store::StoreAddInt64) {
23+
let key = coinbase;
24+
store.add(1, key.clone(), 1);
25+
log::info!("added key: {}", key);
26+
//set(1, key, &proto::encode(&token).unwrap());
27+
}

‎modules/eth-block-producers/src/pb/google.protobuf.rs

+3,909
Large diffs are not rendered by default.

‎modules/eth-block-producers/src/pb/mod.rs

Whitespace-only changes.

‎modules/eth-block-producers/src/pb/sf.ethereum.substreams.v1.rs

+89
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,89 @@
1+
// @generated
2+
#[derive(Clone, PartialEq, ::prost::Message)]
3+
pub struct RpcCalls {
4+
#[prost(message, repeated, tag="1")]
5+
pub calls: ::prost::alloc::vec::Vec<RpcCall>,
6+
}
7+
#[derive(Clone, PartialEq, ::prost::Message)]
8+
pub struct RpcCall {
9+
#[prost(bytes="vec", tag="1")]
10+
pub to_addr: ::prost::alloc::vec::Vec<u8>,
11+
#[prost(bytes="vec", tag="2")]
12+
pub method_signature: ::prost::alloc::vec::Vec<u8>,
13+
}
14+
#[derive(Clone, PartialEq, ::prost::Message)]
15+
pub struct RpcResponses {
16+
#[prost(message, repeated, tag="1")]
17+
pub responses: ::prost::alloc::vec::Vec<RpcResponse>,
18+
}
19+
#[derive(Clone, PartialEq, ::prost::Message)]
20+
pub struct RpcResponse {
21+
#[prost(bytes="vec", tag="1")]
22+
pub raw: ::prost::alloc::vec::Vec<u8>,
23+
#[prost(bool, tag="2")]
24+
pub failed: bool,
25+
}
26+
/// Encoded file descriptor set for the `sf.ethereum.substreams.v1` package
27+
pub const FILE_DESCRIPTOR_SET: &[u8] = &[
28+
0x0a, 0xb9, 0x07, 0x0a, 0x23, 0x73, 0x66, 0x2f, 0x65, 0x74, 0x68, 0x65, 0x72, 0x65, 0x75, 0x6d,
29+
0x2f, 0x73, 0x75, 0x62, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f, 0x76, 0x31, 0x2f, 0x72,
30+
0x70, 0x63, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x19, 0x73, 0x66, 0x2e, 0x65, 0x74, 0x68,
31+
0x65, 0x72, 0x65, 0x75, 0x6d, 0x2e, 0x73, 0x75, 0x62, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73,
32+
0x2e, 0x76, 0x31, 0x22, 0x44, 0x0a, 0x08, 0x52, 0x70, 0x63, 0x43, 0x61, 0x6c, 0x6c, 0x73, 0x12,
33+
0x38, 0x0a, 0x05, 0x63, 0x61, 0x6c, 0x6c, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x22,
34+
0x2e, 0x73, 0x66, 0x2e, 0x65, 0x74, 0x68, 0x65, 0x72, 0x65, 0x75, 0x6d, 0x2e, 0x73, 0x75, 0x62,
35+
0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x70, 0x63, 0x43, 0x61,
36+
0x6c, 0x6c, 0x52, 0x05, 0x63, 0x61, 0x6c, 0x6c, 0x73, 0x22, 0x4d, 0x0a, 0x07, 0x52, 0x70, 0x63,
37+
0x43, 0x61, 0x6c, 0x6c, 0x12, 0x17, 0x0a, 0x07, 0x74, 0x6f, 0x5f, 0x61, 0x64, 0x64, 0x72, 0x18,
38+
0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x06, 0x74, 0x6f, 0x41, 0x64, 0x64, 0x72, 0x12, 0x29, 0x0a,
39+
0x10, 0x6d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x5f, 0x73, 0x69, 0x67, 0x6e, 0x61, 0x74, 0x75, 0x72,
40+
0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x0f, 0x6d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x53,
41+
0x69, 0x67, 0x6e, 0x61, 0x74, 0x75, 0x72, 0x65, 0x22, 0x54, 0x0a, 0x0c, 0x52, 0x70, 0x63, 0x52,
42+
0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x73, 0x12, 0x44, 0x0a, 0x09, 0x72, 0x65, 0x73, 0x70,
43+
0x6f, 0x6e, 0x73, 0x65, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x26, 0x2e, 0x73, 0x66,
44+
0x2e, 0x65, 0x74, 0x68, 0x65, 0x72, 0x65, 0x75, 0x6d, 0x2e, 0x73, 0x75, 0x62, 0x73, 0x74, 0x72,
45+
0x65, 0x61, 0x6d, 0x73, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x70, 0x63, 0x52, 0x65, 0x73, 0x70, 0x6f,
46+
0x6e, 0x73, 0x65, 0x52, 0x09, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x73, 0x22, 0x37,
47+
0x0a, 0x0b, 0x52, 0x70, 0x63, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x10, 0x0a,
48+
0x03, 0x72, 0x61, 0x77, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x03, 0x72, 0x61, 0x77, 0x12,
49+
0x16, 0x0a, 0x06, 0x66, 0x61, 0x69, 0x6c, 0x65, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52,
50+
0x06, 0x66, 0x61, 0x69, 0x6c, 0x65, 0x64, 0x42, 0x51, 0x5a, 0x4f, 0x67, 0x69, 0x74, 0x68, 0x75,
51+
0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x66,
52+
0x61, 0x73, 0x74, 0x2f, 0x73, 0x66, 0x2d, 0x65, 0x74, 0x68, 0x65, 0x72, 0x65, 0x75, 0x6d, 0x2f,
53+
0x74, 0x79, 0x70, 0x65, 0x73, 0x2f, 0x70, 0x62, 0x2f, 0x73, 0x66, 0x2f, 0x65, 0x74, 0x68, 0x65,
54+
0x72, 0x65, 0x75, 0x6d, 0x2f, 0x73, 0x75, 0x62, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f,
55+
0x76, 0x31, 0x3b, 0x70, 0x62, 0x65, 0x74, 0x68, 0x73, 0x73, 0x4a, 0xf7, 0x03, 0x0a, 0x06, 0x12,
56+
0x04, 0x00, 0x00, 0x16, 0x01, 0x0a, 0x08, 0x0a, 0x01, 0x0c, 0x12, 0x03, 0x00, 0x00, 0x12, 0x0a,
57+
0x08, 0x0a, 0x01, 0x02, 0x12, 0x03, 0x02, 0x00, 0x22, 0x0a, 0x08, 0x0a, 0x01, 0x08, 0x12, 0x03,
58+
0x04, 0x00, 0x66, 0x0a, 0x09, 0x0a, 0x02, 0x08, 0x0b, 0x12, 0x03, 0x04, 0x00, 0x66, 0x0a, 0x0a,
59+
0x0a, 0x02, 0x04, 0x00, 0x12, 0x04, 0x06, 0x00, 0x08, 0x01, 0x0a, 0x0a, 0x0a, 0x03, 0x04, 0x00,
60+
0x01, 0x12, 0x03, 0x06, 0x08, 0x10, 0x0a, 0x0b, 0x0a, 0x04, 0x04, 0x00, 0x02, 0x00, 0x12, 0x03,
61+
0x07, 0x02, 0x1d, 0x0a, 0x0c, 0x0a, 0x05, 0x04, 0x00, 0x02, 0x00, 0x04, 0x12, 0x03, 0x07, 0x02,
62+
0x0a, 0x0a, 0x0c, 0x0a, 0x05, 0x04, 0x00, 0x02, 0x00, 0x06, 0x12, 0x03, 0x07, 0x0b, 0x12, 0x0a,
63+
0x0c, 0x0a, 0x05, 0x04, 0x00, 0x02, 0x00, 0x01, 0x12, 0x03, 0x07, 0x13, 0x18, 0x0a, 0x0c, 0x0a,
64+
0x05, 0x04, 0x00, 0x02, 0x00, 0x03, 0x12, 0x03, 0x07, 0x1b, 0x1c, 0x0a, 0x0a, 0x0a, 0x02, 0x04,
65+
0x01, 0x12, 0x04, 0x0a, 0x00, 0x0d, 0x01, 0x0a, 0x0a, 0x0a, 0x03, 0x04, 0x01, 0x01, 0x12, 0x03,
66+
0x0a, 0x08, 0x0f, 0x0a, 0x0b, 0x0a, 0x04, 0x04, 0x01, 0x02, 0x00, 0x12, 0x03, 0x0b, 0x02, 0x14,
67+
0x0a, 0x0c, 0x0a, 0x05, 0x04, 0x01, 0x02, 0x00, 0x05, 0x12, 0x03, 0x0b, 0x02, 0x07, 0x0a, 0x0c,
68+
0x0a, 0x05, 0x04, 0x01, 0x02, 0x00, 0x01, 0x12, 0x03, 0x0b, 0x08, 0x0f, 0x0a, 0x0c, 0x0a, 0x05,
69+
0x04, 0x01, 0x02, 0x00, 0x03, 0x12, 0x03, 0x0b, 0x12, 0x13, 0x0a, 0x0b, 0x0a, 0x04, 0x04, 0x01,
70+
0x02, 0x01, 0x12, 0x03, 0x0c, 0x02, 0x1d, 0x0a, 0x0c, 0x0a, 0x05, 0x04, 0x01, 0x02, 0x01, 0x05,
71+
0x12, 0x03, 0x0c, 0x02, 0x07, 0x0a, 0x0c, 0x0a, 0x05, 0x04, 0x01, 0x02, 0x01, 0x01, 0x12, 0x03,
72+
0x0c, 0x08, 0x18, 0x0a, 0x0c, 0x0a, 0x05, 0x04, 0x01, 0x02, 0x01, 0x03, 0x12, 0x03, 0x0c, 0x1b,
73+
0x1c, 0x0a, 0x0a, 0x0a, 0x02, 0x04, 0x02, 0x12, 0x04, 0x0f, 0x00, 0x11, 0x01, 0x0a, 0x0a, 0x0a,
74+
0x03, 0x04, 0x02, 0x01, 0x12, 0x03, 0x0f, 0x08, 0x14, 0x0a, 0x0b, 0x0a, 0x04, 0x04, 0x02, 0x02,
75+
0x00, 0x12, 0x03, 0x10, 0x02, 0x25, 0x0a, 0x0c, 0x0a, 0x05, 0x04, 0x02, 0x02, 0x00, 0x04, 0x12,
76+
0x03, 0x10, 0x02, 0x0a, 0x0a, 0x0c, 0x0a, 0x05, 0x04, 0x02, 0x02, 0x00, 0x06, 0x12, 0x03, 0x10,
77+
0x0b, 0x16, 0x0a, 0x0c, 0x0a, 0x05, 0x04, 0x02, 0x02, 0x00, 0x01, 0x12, 0x03, 0x10, 0x17, 0x20,
78+
0x0a, 0x0c, 0x0a, 0x05, 0x04, 0x02, 0x02, 0x00, 0x03, 0x12, 0x03, 0x10, 0x23, 0x24, 0x0a, 0x0a,
79+
0x0a, 0x02, 0x04, 0x03, 0x12, 0x04, 0x13, 0x00, 0x16, 0x01, 0x0a, 0x0a, 0x0a, 0x03, 0x04, 0x03,
80+
0x01, 0x12, 0x03, 0x13, 0x08, 0x13, 0x0a, 0x0b, 0x0a, 0x04, 0x04, 0x03, 0x02, 0x00, 0x12, 0x03,
81+
0x14, 0x02, 0x10, 0x0a, 0x0c, 0x0a, 0x05, 0x04, 0x03, 0x02, 0x00, 0x05, 0x12, 0x03, 0x14, 0x02,
82+
0x07, 0x0a, 0x0c, 0x0a, 0x05, 0x04, 0x03, 0x02, 0x00, 0x01, 0x12, 0x03, 0x14, 0x08, 0x0b, 0x0a,
83+
0x0c, 0x0a, 0x05, 0x04, 0x03, 0x02, 0x00, 0x03, 0x12, 0x03, 0x14, 0x0e, 0x0f, 0x0a, 0x0b, 0x0a,
84+
0x04, 0x04, 0x03, 0x02, 0x01, 0x12, 0x03, 0x15, 0x02, 0x12, 0x0a, 0x0c, 0x0a, 0x05, 0x04, 0x03,
85+
0x02, 0x01, 0x05, 0x12, 0x03, 0x15, 0x02, 0x06, 0x0a, 0x0c, 0x0a, 0x05, 0x04, 0x03, 0x02, 0x01,
86+
0x01, 0x12, 0x03, 0x15, 0x07, 0x0d, 0x0a, 0x0c, 0x0a, 0x05, 0x04, 0x03, 0x02, 0x01, 0x03, 0x12,
87+
0x03, 0x15, 0x10, 0x11, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
88+
];
89+
// @@protoc_insertion_point(module)

0 commit comments

Comments
 (0)