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

use crate::{
    context::ContextLock,
    intercom::{self, TransactionMsg},
};
use chain_impl_mockchain::ledger::Error as LedgerError;
use futures::channel::mpsc::TrySendError;
use jormungandr_lib::interfaces::FragmentsProcessingSummary;
use jsonrpsee_http_server::{HttpServerBuilder, RpcModule};
use std::net::SocketAddr;
use thiserror::Error;

pub struct Config {
    pub listen: SocketAddr,
}

#[derive(Debug, Error)]
pub enum Error {
    #[error(transparent)]
    ContextError(#[from] crate::context::Error),
    #[error(transparent)]
    Storage(#[from] crate::blockchain::StorageError),
    #[error("Currently we dont support archive and full modes, so unfortunately this functionality is not working at this moment")]
    NonArchiveNode,
    #[error(transparent)]
    IntercomError(#[from] intercom::Error),
    #[error(transparent)]
    AccountLedgerError(#[from] chain_impl_mockchain::account::LedgerError),
    #[error(transparent)]
    TxMsgSendError(#[from] Box<TrySendError<TransactionMsg>>),
    #[error("Can not estimate gas fees transaction, error: {0}")]
    EstimationError(#[from] Box<LedgerError>),
    #[error("Could not process fragment")]
    Fragment(FragmentsProcessingSummary),
    #[error("Cound not decode Ethereum transaction bytes, error: {0}")]
    TransactionDecodedError(String),
    #[error("Mining is not currently supported")]
    MiningIsNotAllowed,
    #[error("Ethereum signature error: {0}")]
    EthereumSignatureError(String),
}

pub async fn start_jrpc_server(config: Config, _context: ContextLock) {
    let server = HttpServerBuilder::default()
        .build(config.listen)
        .await
        .unwrap();

    #[allow(unused_mut)]
    let mut modules = RpcModule::new(());

    server.start(modules).unwrap().await
}