lssa/node_rpc/src/process.rs

use std::sync::atomic::Ordering;

use actix_web::Error as HttpError;
use node_core::generate_commitments_helper;
use serde_json::Value;

use common::rpc_primitives::{
    errors::RpcError,
    message::{Message, Request},
    parser::RpcRequest,
};
use common::transaction::ActionData;

use common::rpc_primitives::requests::{
    GetBlockDataRequest, GetBlockDataResponse, GetLastBlockRequest, GetLastBlockResponse,
    RegisterAccountRequest, RegisterAccountResponse,
};

use crate::types::{
    err_rpc::cast_common_execution_error_into_rpc_error,
    rpc_structs::{
        ExecuteScenarioMultipleSendRequest, ExecuteScenarioMultipleSendResponse,
        ExecuteScenarioSplitRequest, ExecuteScenarioSplitResponse, ExecuteSubscenarioRequest,
        ExecuteSubscenarioResponse, ShowAccountPublicBalanceRequest,
        ShowAccountPublicBalanceResponse, ShowAccountUTXORequest, ShowAccountUTXOResponse,
        ShowTransactionRequest, ShowTransactionResponse, UTXOShortEssentialStruct,
        WriteDepositPublicBalanceRequest, WriteDepositPublicBalanceResponse,
        WriteMintPrivateUTXOMultipleAssetsRequest, WriteMintPrivateUTXOMultipleAssetsResponse,
        WriteMintPrivateUTXORequest, WriteMintPrivateUTXOResponse,
        WriteSendDeshieldedBalanceRequest, WriteSendDeshieldedUTXOResponse,
        WriteSendPrivateUTXORequest, WriteSendPrivateUTXOResponse, WriteSendShieldedUTXORequest,
        WriteSendShieldedUTXOResponse, WriteSendSplitUTXOResponse, WriteSplitUTXORequest,
    },
};

pub const WRITE_REGISTER_ACCOUNT: &str = "write_register_account";
pub const EXECUTE_SUBSCENARIO: &str = "execute_subscenario";
pub const GET_BLOCK: &str = "get_block";
pub const GET_LAST_BLOCK: &str = "get_last_block";
pub const EXECUTE_SCENARIO_SPLIT: &str = "execute_scenario_split";
pub const EXECUTE_SCENARIO_MULTIPLE_SEND: &str = "execute_scenario_multiple_send";
pub const SHOW_ACCOUNT_PUBLIC_BALANCE: &str = "show_account_public_balance";
pub const SHOW_ACCOUNT_UTXO: &str = "show_account_utxo";
pub const SHOW_TRANSACTION: &str = "show_transaction";
pub const WRITE_DEPOSIT_PUBLIC_BALANCE: &str = "write_deposit_public_balance";
pub const WRITE_MINT_UTXO: &str = "write_mint_utxo";
pub const WRITE_MINT_UTXO_MULTIPLE_ASSETS: &str = "write_mint_utxo_multiple_assets";
pub const WRITE_SEND_UTXO_PRIVATE: &str = "write_send_utxo_private";
pub const WRITE_SEND_UTXO_SHIELDED: &str = "write_send_utxo_shielded";
pub const WRITE_SEND_UTXO_DESHIELDED: &str = "write_send_utxo_deshielded";
pub const WRITE_SPLIT_UTXO: &str = "write_split_utxo";

pub const  SUCCESS: &str = "success";

pub const ACCOUNT_NOT_FOUND: &str = "Account not found";
pub const TRANSACTION_NOT_FOUND: &str = "Transaction not found";

use super::{respond, types::err_rpc::RpcErr, JsonHandler};

impl JsonHandler {
    pub async fn process(&self, message: Message) -> Result<Message, HttpError> {
        let id = message.id();
        if let Message::Request(request) = message {
            let message_inner = self
                .process_request_internal(request)
                .await
                .map_err(|e| e.0);
            Ok(Message::response(id, message_inner))
        } else {
            Ok(Message::error(RpcError::parse_error(
                "JSON RPC Request format was expected".to_owned(),
            )))
        }
    }

    async fn process_request_execute_subscenario(&self, request: Request) -> Result<Value, RpcErr> {
        let req = ExecuteSubscenarioRequest::parse(Some(request.params))?;

        {
            let mut store = self.node_chain_store.lock().await;

            match req.scenario_id {
                1 => store
                    .subscenario_1()
                    .await
                    .map_err(cast_common_execution_error_into_rpc_error)?,
                2 => store
                    .subscenario_2()
                    .await
                    .map_err(cast_common_execution_error_into_rpc_error)?,
                3 => store
                    .subscenario_3()
                    .await
                    .map_err(cast_common_execution_error_into_rpc_error)?,
                4 => store
                    .subscenario_4()
                    .await
                    .map_err(cast_common_execution_error_into_rpc_error)?,
                5 => store
                    .subscenario_5()
                    .await
                    .map_err(cast_common_execution_error_into_rpc_error)?,
                _ => return Err(RpcErr(RpcError::invalid_params("Scenario id not found"))),
            }
        }

        let helperstruct = ExecuteSubscenarioResponse {
            scenario_result: SUCCESS.to_string(),
        };

        respond(helperstruct)
    }

    async fn process_request_execute_scenario_split(
        &self,
        request: Request,
    ) -> Result<Value, RpcErr> {
        let req = ExecuteScenarioSplitRequest::parse(Some(request.params))?;

        {
            let mut store = self.node_chain_store.lock().await;

            store
                .scenario_1(req.visibility_list, req.publication_index)
                .await
                .map_err(cast_common_execution_error_into_rpc_error)?;
        }

        let helperstruct = ExecuteScenarioSplitResponse {
            scenario_result: SUCCESS.to_string(),
        };

        respond(helperstruct)
    }

    async fn process_request_execute_scenario_multiple_send(
        &self,
        request: Request,
    ) -> Result<Value, RpcErr> {
        let req = ExecuteScenarioMultipleSendRequest::parse(Some(request.params))?;

        {
            let mut store = self.node_chain_store.lock().await;

            store
                .scenario_2(req.number_of_assets, req.number_to_send)
                .await
                .map_err(cast_common_execution_error_into_rpc_error)?;
        }

        let helperstruct = ExecuteScenarioMultipleSendResponse {
            scenario_result: SUCCESS.to_string(),
        };

        respond(helperstruct)
    }

    async fn process_register_account(&self, request: Request) -> Result<Value, RpcErr> {
        let _req = RegisterAccountRequest::parse(Some(request.params))?;

        let acc_addr = {
            let mut guard = self.node_chain_store.lock().await;

            guard.create_new_account().await
        };

        let helperstruct = RegisterAccountResponse {
            status: hex::encode(acc_addr),
        };

        respond(helperstruct)
    }

    async fn process_get_block_data(&self, request: Request) -> Result<Value, RpcErr> {
        let req = GetBlockDataRequest::parse(Some(request.params))?;

        let block = {
            let guard = self.node_chain_store.lock().await;

            {
                let read_guard = guard.storage.read().await;

                read_guard.block_store.get_block_at_id(req.block_id)?
            }
        };

        let helperstruct = GetBlockDataResponse { block };

        respond(helperstruct)
    }

    async fn process_get_last_block(&self, request: Request) -> Result<Value, RpcErr> {
        let _req = GetLastBlockRequest::parse(Some(request.params))?;

        let last_block = {
            let guard = self.node_chain_store.lock().await;

            guard.curr_height.load(Ordering::Relaxed)
        };

        let helperstruct = GetLastBlockResponse { last_block };

        respond(helperstruct)
    }

    async fn process_show_account_public_balance(&self, request: Request) -> Result<Value, RpcErr> {
        let req = ShowAccountPublicBalanceRequest::parse(Some(request.params))?;

        let acc_addr_hex_dec = hex::decode(req.account_addr.clone()).map_err(|_| {
            RpcError::parse_error("Failed to decode account address from hex string".to_string())
        })?;

        let acc_addr: [u8; 32] = acc_addr_hex_dec.try_into().map_err(|_| {
            RpcError::parse_error("Failed to parse account address from bytes".to_string())
        })?;

        let balance = {
            let cover_guard = self.node_chain_store.lock().await;

            {
                let under_guard = cover_guard.storage.read().await;

                let acc = under_guard
                    .acc_map
                    .get(&acc_addr)
                    .ok_or(RpcError::new_internal_error(None, ACCOUNT_NOT_FOUND))?;

                acc.balance
            }
        };

        let helperstruct = ShowAccountPublicBalanceResponse {
            addr: req.account_addr,
            balance,
        };

        respond(helperstruct)
    }

    async fn process_show_account_utxo_request(&self, request: Request) -> Result<Value, RpcErr> {
        let req = ShowAccountUTXORequest::parse(Some(request.params))?;

        let acc_addr_hex_dec = hex::decode(req.account_addr.clone()).map_err(|_| {
            RpcError::parse_error("Failed to decode account address from hex string".to_string())
        })?;

        let acc_addr: [u8; 32] = acc_addr_hex_dec.try_into().map_err(|_| {
            RpcError::parse_error("Failed to parse account address from bytes".to_string())
        })?;

        let utxo_hash_hex_dec = hex::decode(req.utxo_hash.clone()).map_err(|_| {
            RpcError::parse_error("Failed to decode hash from hex string".to_string())
        })?;

        let utxo_hash: [u8; 32] = utxo_hash_hex_dec
            .try_into()
            .map_err(|_| RpcError::parse_error("Failed to parse hash from bytes".to_string()))?;

        let (asset, amount) = {
            let cover_guard = self.node_chain_store.lock().await;

            {
                let mut under_guard = cover_guard.storage.write().await;

                let acc = under_guard
                    .acc_map
                    .get_mut(&acc_addr)
                    .ok_or(RpcError::new_internal_error(None, ACCOUNT_NOT_FOUND))?;

                let utxo = acc
                    .utxo_tree
                    .get_item(utxo_hash)
                    .map_err(|err| {
                        RpcError::new_internal_error(None, &format!("DB fetch failure {err:?}"))
                    })?
                    .ok_or(RpcError::new_internal_error(
                        None,
                        "UTXO does not exist in the tree",
                    ))?;

                (utxo.asset.clone(), utxo.amount)
            }
        };

        let helperstruct = ShowAccountUTXOResponse {
            hash: req.utxo_hash,
            asset,
            amount,
        };

        respond(helperstruct)
    }

    async fn process_show_transaction(&self, request: Request) -> Result<Value, RpcErr> {
        let req = ShowTransactionRequest::parse(Some(request.params))?;

        let tx_hash_hex_dec = hex::decode(req.tx_hash.clone()).map_err(|_| {
            RpcError::parse_error("Failed to decode hash from hex string".to_string())
        })?;

        let tx_hash: [u8; 32] = tx_hash_hex_dec
            .try_into()
            .map_err(|_| RpcError::parse_error("Failed to parse hash from bytes".to_string()))?;

        let helperstruct = {
            let cover_guard = self.node_chain_store.lock().await;

            {
                let under_guard = cover_guard.storage.read().await;

                let tx = under_guard
                    .pub_tx_store
                    .get_tx(tx_hash)
                    .ok_or(RpcError::new_internal_error(None, TRANSACTION_NOT_FOUND))?;

                ShowTransactionResponse {
                    hash: req.tx_hash,
                    tx_kind: tx.tx_kind,
                    public_input: if let Ok(action) =
                        serde_json::from_slice::<ActionData>(&tx.execution_input)
                    {
                        action.into_hexed_print()
                    } else {
                        "".to_string()
                    },
                    public_output: if let Ok(action) =
                        serde_json::from_slice::<ActionData>(&tx.execution_output)
                    {
                        action.into_hexed_print()
                    } else {
                        "".to_string()
                    },
                    utxo_commitments_created_hashes: tx
                        .utxo_commitments_created_hashes
                        .iter()
                        .map(|val| hex::encode(val.clone()))
                        .collect::<Vec<_>>(),
                    utxo_commitments_spent_hashes: tx
                        .utxo_commitments_spent_hashes
                        .iter()
                        .map(|val| hex::encode(val.clone()))
                        .collect::<Vec<_>>(),
                    utxo_nullifiers_created_hashes: tx
                        .nullifier_created_hashes
                        .iter()
                        .map(|val| hex::encode(val.clone()))
                        .collect::<Vec<_>>(),
                    encoded_data: tx
                        .encoded_data
                        .iter()
                        .map(|val| (hex::encode(val.0.clone()), hex::encode(val.1.clone())))
                        .collect::<Vec<_>>(),
                    ephemeral_pub_key: hex::encode(tx.ephemeral_pub_key.clone()),
                }
            }
        };

        respond(helperstruct)
    }

    pub async fn process_write_deposit_public_balance(
        &self,
        request: Request,
    ) -> Result<Value, RpcErr> {
        let req = WriteDepositPublicBalanceRequest::parse(Some(request.params))?;

        let acc_addr_hex_dec = hex::decode(req.account_addr.clone()).map_err(|_| {
            RpcError::parse_error("Failed to decode account address from hex string".to_string())
        })?;

        let acc_addr: [u8; 32] = acc_addr_hex_dec.try_into().map_err(|_| {
            RpcError::parse_error("Failed to parse account address from bytes".to_string())
        })?;

        {
            let mut cover_guard = self.node_chain_store.lock().await;

            cover_guard
                .operate_account_deposit_public(acc_addr, req.amount as u128)
                .await
                .map_err(cast_common_execution_error_into_rpc_error)?;
        };

        let helperstruct = WriteDepositPublicBalanceResponse {
            status: SUCCESS.to_string(),
        };

        respond(helperstruct)
    }

    pub async fn process_write_mint_utxo(&self, request: Request) -> Result<Value, RpcErr> {
        let req = WriteMintPrivateUTXORequest::parse(Some(request.params))?;

        let acc_addr_hex_dec = hex::decode(req.account_addr.clone()).map_err(|_| {
            RpcError::parse_error("Failed to decode account address from hex string".to_string())
        })?;

        let acc_addr: [u8; 32] = acc_addr_hex_dec.try_into().map_err(|_| {
            RpcError::parse_error("Failed to parse account address from bytes".to_string())
        })?;

        let (utxo, commitment_hash) = {
            let mut cover_guard = self.node_chain_store.lock().await;

            cover_guard
                .operate_account_mint_private(acc_addr, req.amount as u128)
                .await
                .map_err(cast_common_execution_error_into_rpc_error)?
        };

        let helperstruct = WriteMintPrivateUTXOResponse {
            status: SUCCESS.to_string(),
            utxo: UTXOShortEssentialStruct {
                hash: hex::encode(utxo.hash),
                commitment_hash: hex::encode(commitment_hash),
                asset: utxo.asset,
            },
        };

        respond(helperstruct)
    }

    pub async fn process_write_mint_utxo_multiple_assets(
        &self,
        request: Request,
    ) -> Result<Value, RpcErr> {
        let req = WriteMintPrivateUTXOMultipleAssetsRequest::parse(Some(request.params))?;

        let acc_addr_hex_dec = hex::decode(req.account_addr.clone()).map_err(|_| {
            RpcError::parse_error("Failed to decode account address from hex string".to_string())
        })?;

        let acc_addr: [u8; 32] = acc_addr_hex_dec.try_into().map_err(|_| {
            RpcError::parse_error("Failed to parse account address from bytes".to_string())
        })?;

        let (utxos, commitment_hashes) = {
            let mut cover_guard = self.node_chain_store.lock().await;

            cover_guard
                .operate_account_mint_multiple_assets_private(
                    acc_addr,
                    req.amount as u128,
                    req.num_of_assets,
                )
                .await
                .map_err(cast_common_execution_error_into_rpc_error)?
        };

        let helperstruct = WriteMintPrivateUTXOMultipleAssetsResponse {
            status: SUCCESS.to_string(),
            utxos: utxos
                .into_iter()
                .zip(commitment_hashes)
                .map(|(utxo, comm_hash)| UTXOShortEssentialStruct {
                    hash: hex::encode(utxo.hash),
                    commitment_hash: hex::encode(comm_hash),
                    asset: utxo.asset,
                })
                .collect(),
        };

        respond(helperstruct)
    }

    pub async fn process_write_send_private_utxo(&self, request: Request) -> Result<Value, RpcErr> {
        let req = WriteSendPrivateUTXORequest::parse(Some(request.params))?;

        let acc_addr_hex_dec_sender =
            hex::decode(req.account_addr_sender.clone()).map_err(|_| {
                RpcError::parse_error(
                    "Failed to decode account address from hex string".to_string(),
                )
            })?;

        let acc_addr_sender: [u8; 32] = acc_addr_hex_dec_sender.try_into().map_err(|_| {
            RpcError::parse_error("Failed to parse account address from bytes".to_string())
        })?;

        let acc_addr_hex_dec = hex::decode(req.account_addr_receiver.clone()).map_err(|_| {
            RpcError::parse_error("Failed to decode account address from hex string".to_string())
        })?;

        let acc_addr: [u8; 32] = acc_addr_hex_dec.try_into().map_err(|_| {
            RpcError::parse_error("Failed to parse account address from bytes".to_string())
        })?;

        let utxo_hash_hex_dec = hex::decode(req.utxo_hash.clone()).map_err(|_| {
            RpcError::parse_error("Failed to decode utxo hash from hex string".to_string())
        })?;

        let utxo_hash: [u8; 32] = utxo_hash_hex_dec.try_into().map_err(|_| {
            RpcError::parse_error("Failed to parse utxo hash from bytes".to_string())
        })?;

        let comm_hash_hex_dec = hex::decode(req.utxo_commitment.clone()).map_err(|_| {
            RpcError::parse_error("Failed to decode commitment hash from hex string".to_string())
        })?;

        let comm_hash: [u8; 32] = comm_hash_hex_dec.try_into().map_err(|_| {
            RpcError::parse_error("Failed to parse commitment hash from bytes".to_string())
        })?;

        let new_utxo_rec = {
            let mut cover_guard = self.node_chain_store.lock().await;

            let utxo_to_send = {
                let mut under_guard = cover_guard.storage.write().await;

                let acc = under_guard
                    .acc_map
                    .get_mut(&acc_addr_sender)
                    .ok_or(RpcError::new_internal_error(None, ACCOUNT_NOT_FOUND))?;

                acc.utxo_tree
                    .get_item(utxo_hash)
                    .map_err(|err| {
                        RpcError::new_internal_error(None, &format!("DB fetch failure {err:?}"))
                    })?
                    .ok_or(RpcError::new_internal_error(
                        None,
                        "UTXO does not exist in tree",
                    ))?
                    .clone()
            };

            cover_guard
                .operate_account_send_private_one_receiver(acc_addr, utxo_to_send, comm_hash)
                .await
                .map_err(cast_common_execution_error_into_rpc_error)?
        };

        let helperstruct = WriteSendPrivateUTXOResponse {
            status: SUCCESS.to_string(),
            utxo_result: UTXOShortEssentialStruct {
                hash: hex::encode(new_utxo_rec.hash),
                asset: new_utxo_rec.asset.clone(),
                commitment_hash: hex::encode(generate_commitments_helper(&vec![new_utxo_rec])[0]),
            },
        };

        respond(helperstruct)
    }

    pub async fn process_write_send_shielded_utxo(
        &self,
        request: Request,
    ) -> Result<Value, RpcErr> {
        let req = WriteSendShieldedUTXORequest::parse(Some(request.params))?;

        let acc_addr_hex_dec_sender =
            hex::decode(req.account_addr_sender.clone()).map_err(|_| {
                RpcError::parse_error(
                    "Failed to decode account address sender from hex string".to_string(),
                )
            })?;

        let acc_addr_sender: [u8; 32] = acc_addr_hex_dec_sender.try_into().map_err(|_| {
            RpcError::parse_error("Failed to parse account address sender from bytes".to_string())
        })?;

        let acc_addr_hex_dec_rec =
            hex::decode(req.account_addr_receiver.clone()).map_err(|_| {
                RpcError::parse_error(
                    "Failed to decode account address receiver from hex string".to_string(),
                )
            })?;

        let acc_addr_rec: [u8; 32] = acc_addr_hex_dec_rec.try_into().map_err(|_| {
            RpcError::parse_error("Failed to parse account address receiver from bytes".to_string())
        })?;

        let new_utxo_rec = {
            let mut cover_guard = self.node_chain_store.lock().await;

            cover_guard
                .operate_account_send_shielded_one_receiver(
                    acc_addr_sender,
                    acc_addr_rec,
                    req.amount as u128,
                )
                .await
                .map_err(cast_common_execution_error_into_rpc_error)?
        };

        let helperstruct = WriteSendShieldedUTXOResponse {
            status: SUCCESS.to_string(),
            utxo_result: UTXOShortEssentialStruct {
                hash: hex::encode(new_utxo_rec.hash),
                asset: new_utxo_rec.asset.clone(),
                commitment_hash: hex::encode(generate_commitments_helper(&vec![new_utxo_rec])[0]),
            },
        };

        respond(helperstruct)
    }

    pub async fn process_write_send_deshielded_utxo(
        &self,
        request: Request,
    ) -> Result<Value, RpcErr> {
        let req = WriteSendDeshieldedBalanceRequest::parse(Some(request.params))?;

        let acc_addr_hex_dec_sender =
            hex::decode(req.account_addr_sender.clone()).map_err(|_| {
                RpcError::parse_error(
                    "Failed to decode account address from hex string".to_string(),
                )
            })?;

        let acc_addr_sender: [u8; 32] = acc_addr_hex_dec_sender.try_into().map_err(|_| {
            RpcError::parse_error("Failed to parse account address from bytes".to_string())
        })?;

        let acc_addr_hex_dec = hex::decode(req.account_addr_receiver.clone()).map_err(|_| {
            RpcError::parse_error("Failed to decode account address from hex string".to_string())
        })?;

        let acc_addr: [u8; 32] = acc_addr_hex_dec.try_into().map_err(|_| {
            RpcError::parse_error("Failed to parse account address from bytes".to_string())
        })?;

        let utxo_hash_hex_dec = hex::decode(req.utxo_hash.clone()).map_err(|_| {
            RpcError::parse_error("Failed to decode utxo hash from hex string".to_string())
        })?;

        let utxo_hash: [u8; 32] = utxo_hash_hex_dec.try_into().map_err(|_| {
            RpcError::parse_error("Failed to parse utxo hash from bytes".to_string())
        })?;

        let comm_hash_hex_dec = hex::decode(req.utxo_commitment.clone()).map_err(|_| {
            RpcError::parse_error("Failed to decode commitment hash from hex string".to_string())
        })?;

        let comm_hash: [u8; 32] = comm_hash_hex_dec.try_into().map_err(|_| {
            RpcError::parse_error("Failed to parse commitment hash from bytes".to_string())
        })?;

        {
            let mut cover_guard = self.node_chain_store.lock().await;

            let utxo_to_send = {
                let mut under_guard = cover_guard.storage.write().await;

                let acc = under_guard
                    .acc_map
                    .get_mut(&acc_addr_sender)
                    .ok_or(RpcError::new_internal_error(None, ACCOUNT_NOT_FOUND))?;

                acc.utxo_tree
                    .get_item(utxo_hash)
                    .map_err(|err| {
                        RpcError::new_internal_error(None, &format!("DB fetch failure {err:?}"))
                    })?
                    .ok_or(RpcError::new_internal_error(
                        None,
                        "UTXO does not exist in tree",
                    ))?
                    .clone()
            };

            cover_guard
                .operate_account_send_deshielded_one_receiver(
                    acc_addr_sender,
                    acc_addr,
                    utxo_to_send,
                    comm_hash,
                )
                .await
                .map_err(cast_common_execution_error_into_rpc_error)?
        };

        let helperstruct = WriteSendDeshieldedUTXOResponse {
            status: SUCCESS.to_string(),
        };

        respond(helperstruct)
    }

    pub async fn process_write_send_split_utxo(&self, request: Request) -> Result<Value, RpcErr> {
        let req = WriteSplitUTXORequest::parse(Some(request.params))?;

        let acc_addr_hex_dec_sender =
            hex::decode(req.account_addr_sender.clone()).map_err(|_| {
                RpcError::parse_error(
                    "Failed to decode account address from hex string".to_string(),
                )
            })?;

        let acc_addr_sender: [u8; 32] = acc_addr_hex_dec_sender.try_into().map_err(|_| {
            RpcError::parse_error("Failed to parse account address from bytes".to_string())
        })?;

        let acc_addresses = {
            let mut res_addrs = vec![];

            for item in req.account_addr_receivers {
                let hex_dec_item = hex::decode(item).map_err(|_| {
                    RpcError::parse_error(
                        "Failed to decode account address from hex string".to_string(),
                    )
                })?;

                let dec_item = hex_dec_item.try_into().map_err(|_| {
                    RpcError::parse_error(
                        "Failed to decode account address from hex string".to_string(),
                    )
                })?;

                res_addrs.push(dec_item);
            }

            res_addrs.try_into().unwrap()
        };

        let utxo_hash_hex_dec = hex::decode(req.utxo_hash.clone()).map_err(|_| {
            RpcError::parse_error("Failed to decode utxo hash from hex string".to_string())
        })?;

        let utxo_hash: [u8; 32] = utxo_hash_hex_dec.try_into().map_err(|_| {
            RpcError::parse_error("Failed to parse utxo hash from bytes".to_string())
        })?;

        let comm_hash_hex_dec = hex::decode(req.utxo_commitment.clone()).map_err(|_| {
            RpcError::parse_error("Failed to decode commitment hash from hex string".to_string())
        })?;

        let comm_hash: [u8; 32] = comm_hash_hex_dec.try_into().map_err(|_| {
            RpcError::parse_error("Failed to parse commitment hash from bytes".to_string())
        })?;

        let (new_utxos, commitment_hashes) = {
            let mut cover_guard = self.node_chain_store.lock().await;

            let utxo_to_send = {
                let mut under_guard = cover_guard.storage.write().await;

                let acc = under_guard
                    .acc_map
                    .get_mut(&acc_addr_sender)
                    .ok_or(RpcError::new_internal_error(None, ACCOUNT_NOT_FOUND))?;

                acc.utxo_tree
                    .get_item(utxo_hash)
                    .map_err(|err| {
                        RpcError::new_internal_error(None, &format!("DB fetch failure {err:?}"))
                    })?
                    .ok_or(RpcError::new_internal_error(
                        None,
                        "UTXO does not exist in tree",
                    ))?
                    .clone()
            };

            cover_guard
                .operate_account_send_split_utxo(
                    acc_addresses,
                    utxo_to_send,
                    comm_hash,
                    req.visibility_list,
                )
                .await
                .map_err(cast_common_execution_error_into_rpc_error)?
        };

        let helperstruct = WriteSendSplitUTXOResponse {
            status: SUCCESS.to_string(),
            utxo_results: new_utxos
                .into_iter()
                .zip(commitment_hashes)
                .map(|(utxo, comm_hash)| UTXOShortEssentialStruct {
                    hash: hex::encode(utxo.hash),
                    commitment_hash: hex::encode(comm_hash),
                    asset: utxo.asset,
                })
                .collect(),
        };

        respond(helperstruct)
    }

    pub async fn process_request_internal(&self, request: Request) -> Result<Value, RpcErr> {
        match request.method.as_ref() {
            //Todo : Add handling of more JSON RPC methods
            WRITE_REGISTER_ACCOUNT => self.process_register_account(request).await,
            EXECUTE_SUBSCENARIO => self.process_request_execute_subscenario(request).await,
            GET_BLOCK => self.process_get_block_data(request).await,
            GET_LAST_BLOCK => self.process_get_last_block(request).await,
            EXECUTE_SCENARIO_SPLIT => self.process_request_execute_scenario_split(request).await,
            EXECUTE_SCENARIO_MULTIPLE_SEND => {
                self.process_request_execute_scenario_multiple_send(request)
                    .await
            }
            SHOW_ACCOUNT_PUBLIC_BALANCE => {
                self.process_show_account_public_balance(request).await
            }
            SHOW_ACCOUNT_UTXO => self.process_show_account_utxo_request(request).await,
            SHOW_TRANSACTION => self.process_show_transaction(request).await,
            WRITE_DEPOSIT_PUBLIC_BALANCE => {
                self.process_write_deposit_public_balance(request).await
            }
            WRITE_MINT_UTXO => self.process_write_mint_utxo(request).await,
            WRITE_MINT_UTXO_MULTIPLE_ASSETS => {
                self.process_write_mint_utxo_multiple_assets(request).await
            }
            WRITE_SEND_UTXO_PRIVATE => self.process_write_send_private_utxo(request).await,
            WRITE_SEND_UTXO_SHIELDED => self.process_write_send_shielded_utxo(request).await,
            WRITE_SEND_UTXO_DESHIELDED => self.process_write_send_deshielded_utxo(request).await,
            WRITE_SPLIT_UTXO => self.process_write_send_split_utxo(request).await,
            _ => Err(RpcErr(RpcError::method_not_found(request.method))),
        }
    }
}