darwinia-shadow 0.2.5

The shadow service for relayers and verify workers to retrieve header data and generate proof.
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

use reqwest::Client;
use serde::Serialize;
use serde_json::Value;

use std::{env, fmt::Debug};

use crate::result::Error;

#[derive(Serialize, Deserialize, Debug)]
pub struct EthBlockNumberResp {
    jsonrpc: String,
    id: i32,
    pub result: String,
}

/// Get ethereum confirmations
pub async fn get(client: &Client, block: u64) -> Result<u64, Error> {
    let map: Value = serde_json::from_str(&format! {
        "{{{}}}", vec![
            r#""jsonrpc":"2.0","#,
            r#""method":"eth_blockNumber","#,
            r#""params":[],"#,
            r#""id": 1"#,
        ].concat(),
    })?;

    Ok(i64::from_str_radix(
        &client
            .post(&env::var("ETHEREUM_RPC").unwrap_or_else(|_| {
                if env::var("ETHEREUM_ROPSTEN").is_ok() {
                    crate::conf::DEFAULT_ETHEREUM_ROPSTEN_RPC.into()
                } else {
                    crate::conf::DEFAULT_ETHEREUM_RPC.into()
                }
            }))
            .json(&map)
            .send()
            .await?
            .json::<EthBlockNumberResp>()
            .await?
            .result
            .trim_start_matches("0x"),
        16,
    )
    .unwrap_or(0) as u64
        - block)
}