darkfi/bin/darkfid2/src/rpc_blockchain.rs

use log::{debug, error};
use serde_json::{json, Value};

use darkfi::{
    crypto::merkle_node::MerkleNode,
    rpc::{
        jsonrpc,
        jsonrpc::{
            ErrorCode::{InternalError, InvalidParams},
            JsonResult,
        },
    },
};

use super::Darkfid;
use crate::{server_error, RpcError};

impl Darkfid {
    // RPCAPI:
    // Queries the blockchain database for a block in the given slot.
    // Returns a readable block upon success.
    // --> {"jsonrpc": "2.0", "method": "blockchain.get_slot", "params": [0], "id": 1}
    // <-- {"jsonrpc": "2.0", "result": {...}, "id": 1}
    pub async fn get_slot(&self, id: Value, params: &[Value]) -> JsonResult {
        if params.len() != 1 || !params[0].is_u64() {
            return jsonrpc::error(InvalidParams, None, id).into()
        }

        let blocks = match self
            .validator_state
            .read()
            .await
            .blockchain
            .get_blocks_by_slot(&[params[0].as_u64().unwrap()])
        {
            Ok(v) => v,
            Err(e) => {
                error!("Failed fetching block by slot: {}", e);
                return jsonrpc::error(InternalError, None, id).into()
            }
        };

        if blocks.is_empty() {
            return server_error(RpcError::UnknownSlot, id)
        }

        // TODO: Return block as JSON
        debug!("{:#?}", blocks[0]);
        jsonrpc::response(json!(true), id).into()
    }

    // RPCAPI:
    // Queries the blockchain database for all available merkle roots.
    // --> {"jsonrpc": "2.0", "method": "blockchain.merkle_roots", "params": [], "id": 1}
    // <-- {"jsonrpc": "2.0", "result": [..., ..., ...], "id": 1}
    pub async fn merkle_roots(&self, id: Value, _params: &[Value]) -> JsonResult {
        let roots: Vec<MerkleNode> =
            match self.validator_state.read().await.blockchain.merkle_roots.get_all() {
                Ok(v) => v.iter().map(|x| x.unwrap()).collect(),
                Err(e) => {
                    error!("Failed getting merkle roots from rootstore: {}", e);
                    return jsonrpc::error(InternalError, None, id).into()
                }
            };

        jsonrpc::response(json!(roots), id).into()
    }
}