Changeset View
Changeset View
Standalone View
Standalone View
chronik/chronik-http/src/handlers.rs
| //! Module for Chronik handlers. | //! Module for Chronik handlers. | ||||
| use std::{collections::HashMap, fmt::Display, str::FromStr}; | use std::{collections::HashMap, fmt::Display, str::FromStr}; | ||||
| use abc_rust_error::{Report, Result}; | use abc_rust_error::{Report, Result}; | ||||
| use bitcoinsuite_slp::token_id::TokenId; | use bitcoinsuite_slp::token_id::TokenId; | ||||
| use chronik_indexer::indexer::ChronikIndexer; | use chronik_indexer::indexer::{ChronikIndexer, Node}; | ||||
| use chronik_proto::proto; | use chronik_proto::proto; | ||||
| use hyper::Uri; | use hyper::Uri; | ||||
| use thiserror::Error; | use thiserror::Error; | ||||
| use crate::{error::ReportError, parse::parse_script_variant_hex}; | use crate::{error::ReportError, parse::parse_script_variant_hex}; | ||||
| /// Errors for HTTP handlers. | /// Errors for HTTP handlers. | ||||
| #[derive(Debug, Error, PartialEq)] | #[derive(Debug, Error, PartialEq)] | ||||
| Show All 38 Lines | pub async fn handle_not_found(uri: Uri) -> Result<(), ReportError> { | ||||
| Err(Report::from(RouteNotFound(uri)).into()) | Err(Report::from(RouteNotFound(uri)).into()) | ||||
| } | } | ||||
| /// Return a page of the txs of a block. | /// Return a page of the txs of a block. | ||||
| pub async fn handle_block_txs( | pub async fn handle_block_txs( | ||||
| hash_or_height: String, | hash_or_height: String, | ||||
| query_params: &HashMap<String, String>, | query_params: &HashMap<String, String>, | ||||
| indexer: &ChronikIndexer, | indexer: &ChronikIndexer, | ||||
| node: &Node, | |||||
| ) -> Result<proto::TxHistoryPage> { | ) -> Result<proto::TxHistoryPage> { | ||||
| let blocks = indexer.blocks(); | let blocks = indexer.blocks(node); | ||||
| let page_num: u32 = get_param(query_params, "page")?.unwrap_or(0); | let page_num: u32 = get_param(query_params, "page")?.unwrap_or(0); | ||||
| let page_size: u32 = get_param(query_params, "page_size")?.unwrap_or(25); | let page_size: u32 = get_param(query_params, "page_size")?.unwrap_or(25); | ||||
| blocks.block_txs(hash_or_height, page_num as usize, page_size as usize) | blocks.block_txs(hash_or_height, page_num as usize, page_size as usize) | ||||
| } | } | ||||
| /// Return a page of the confirmed txs of the given script. | /// Return a page of the confirmed txs of the given script. | ||||
| /// Scripts are identified by script_type and payload. | /// Scripts are identified by script_type and payload. | ||||
| pub async fn handle_script_confirmed_txs( | pub async fn handle_script_confirmed_txs( | ||||
| script_type: &str, | script_type: &str, | ||||
| payload: &str, | payload: &str, | ||||
| query_params: &HashMap<String, String>, | query_params: &HashMap<String, String>, | ||||
| indexer: &ChronikIndexer, | indexer: &ChronikIndexer, | ||||
| node: &Node, | |||||
| ) -> Result<proto::TxHistoryPage> { | ) -> Result<proto::TxHistoryPage> { | ||||
| let script_variant = parse_script_variant_hex(script_type, payload)?; | let script_variant = parse_script_variant_hex(script_type, payload)?; | ||||
| let script_history = indexer.script_history()?; | let script_history = indexer.script_history(node)?; | ||||
| let page_num: u32 = get_param(query_params, "page")?.unwrap_or(0); | let page_num: u32 = get_param(query_params, "page")?.unwrap_or(0); | ||||
| let page_size: u32 = get_param(query_params, "page_size")?.unwrap_or(25); | let page_size: u32 = get_param(query_params, "page_size")?.unwrap_or(25); | ||||
| let script = script_variant.to_script(); | let script = script_variant.to_script(); | ||||
| script_history.confirmed_txs(&script, page_num as usize, page_size as usize) | script_history.confirmed_txs(&script, page_num as usize, page_size as usize) | ||||
| } | } | ||||
| /// Return a page of the tx history of the given script, in reverse | /// Return a page of the tx history of the given script, in reverse | ||||
| /// chronological order, i.e. the latest transaction first and then going back | /// chronological order, i.e. the latest transaction first and then going back | ||||
| /// in time. Scripts are identified by script_type and payload. | /// in time. Scripts are identified by script_type and payload. | ||||
| pub async fn handle_script_history( | pub async fn handle_script_history( | ||||
| script_type: &str, | script_type: &str, | ||||
| payload: &str, | payload: &str, | ||||
| query_params: &HashMap<String, String>, | query_params: &HashMap<String, String>, | ||||
| indexer: &ChronikIndexer, | indexer: &ChronikIndexer, | ||||
| node: &Node, | |||||
| ) -> Result<proto::TxHistoryPage> { | ) -> Result<proto::TxHistoryPage> { | ||||
| let script_variant = parse_script_variant_hex(script_type, payload)?; | let script_variant = parse_script_variant_hex(script_type, payload)?; | ||||
| let script_history = indexer.script_history()?; | let script_history = indexer.script_history(node)?; | ||||
| let page_num: u32 = get_param(query_params, "page")?.unwrap_or(0); | let page_num: u32 = get_param(query_params, "page")?.unwrap_or(0); | ||||
| let page_size: u32 = get_param(query_params, "page_size")?.unwrap_or(25); | let page_size: u32 = get_param(query_params, "page_size")?.unwrap_or(25); | ||||
| let script = script_variant.to_script(); | let script = script_variant.to_script(); | ||||
| script_history.rev_history(&script, page_num as usize, page_size as usize) | script_history.rev_history(&script, page_num as usize, page_size as usize) | ||||
| } | } | ||||
| /// Return a page of the unconfirmed txs of the given script. | /// Return a page of the unconfirmed txs of the given script. | ||||
| /// Scripts are identified by script_type and payload. | /// Scripts are identified by script_type and payload. | ||||
| pub async fn handle_script_unconfirmed_txs( | pub async fn handle_script_unconfirmed_txs( | ||||
| script_type: &str, | script_type: &str, | ||||
| payload: &str, | payload: &str, | ||||
| indexer: &ChronikIndexer, | indexer: &ChronikIndexer, | ||||
| node: &Node, | |||||
| ) -> Result<proto::TxHistoryPage> { | ) -> Result<proto::TxHistoryPage> { | ||||
| let script_variant = parse_script_variant_hex(script_type, payload)?; | let script_variant = parse_script_variant_hex(script_type, payload)?; | ||||
| let script_history = indexer.script_history()?; | let script_history = indexer.script_history(node)?; | ||||
| let script = script_variant.to_script(); | let script = script_variant.to_script(); | ||||
| script_history.unconfirmed_txs(&script) | script_history.unconfirmed_txs(&script) | ||||
| } | } | ||||
| /// Return the UTXOs of the given script. | /// Return the UTXOs of the given script. | ||||
| /// Scripts are identified by script_type and payload. | /// Scripts are identified by script_type and payload. | ||||
| pub async fn handle_script_utxos( | pub async fn handle_script_utxos( | ||||
| script_type: &str, | script_type: &str, | ||||
| Show All 10 Lines | ) -> Result<proto::ScriptUtxos> { | ||||
| }) | }) | ||||
| } | } | ||||
| /// Return a page of the confirmed txs of the given token ID. | /// Return a page of the confirmed txs of the given token ID. | ||||
| pub async fn handle_token_id_confirmed_txs( | pub async fn handle_token_id_confirmed_txs( | ||||
| token_id_hex: &str, | token_id_hex: &str, | ||||
| query_params: &HashMap<String, String>, | query_params: &HashMap<String, String>, | ||||
| indexer: &ChronikIndexer, | indexer: &ChronikIndexer, | ||||
| node: &Node, | |||||
| ) -> Result<proto::TxHistoryPage> { | ) -> Result<proto::TxHistoryPage> { | ||||
| let token_id = token_id_hex.parse::<TokenId>()?; | let token_id = token_id_hex.parse::<TokenId>()?; | ||||
| let token_id_history = indexer.token_id_history(); | let token_id_history = indexer.token_id_history(node); | ||||
| let page_num: u32 = get_param(query_params, "page")?.unwrap_or(0); | let page_num: u32 = get_param(query_params, "page")?.unwrap_or(0); | ||||
| let page_size: u32 = get_param(query_params, "page_size")?.unwrap_or(25); | let page_size: u32 = get_param(query_params, "page_size")?.unwrap_or(25); | ||||
| token_id_history.confirmed_txs( | token_id_history.confirmed_txs( | ||||
| token_id, | token_id, | ||||
| page_num as usize, | page_num as usize, | ||||
| page_size as usize, | page_size as usize, | ||||
| ) | ) | ||||
| } | } | ||||
| /// Return a page of the tx history of the given token ID, in reverse | /// Return a page of the tx history of the given token ID, in reverse | ||||
| /// chronological order, i.e. the latest transaction first and then going back | /// chronological order, i.e. the latest transaction first and then going back | ||||
| /// in time. | /// in time. | ||||
| pub async fn handle_token_id_history( | pub async fn handle_token_id_history( | ||||
| token_id_hex: &str, | token_id_hex: &str, | ||||
| query_params: &HashMap<String, String>, | query_params: &HashMap<String, String>, | ||||
| indexer: &ChronikIndexer, | indexer: &ChronikIndexer, | ||||
| node: &Node, | |||||
| ) -> Result<proto::TxHistoryPage> { | ) -> Result<proto::TxHistoryPage> { | ||||
| let token_id = token_id_hex.parse::<TokenId>()?; | let token_id = token_id_hex.parse::<TokenId>()?; | ||||
| let token_id_history = indexer.token_id_history(); | let token_id_history = indexer.token_id_history(node); | ||||
| let page_num: u32 = get_param(query_params, "page")?.unwrap_or(0); | let page_num: u32 = get_param(query_params, "page")?.unwrap_or(0); | ||||
| let page_size: u32 = get_param(query_params, "page_size")?.unwrap_or(25); | let page_size: u32 = get_param(query_params, "page_size")?.unwrap_or(25); | ||||
| token_id_history.rev_history( | token_id_history.rev_history( | ||||
| token_id, | token_id, | ||||
| page_num as usize, | page_num as usize, | ||||
| page_size as usize, | page_size as usize, | ||||
| ) | ) | ||||
| } | } | ||||
| /// Return a page of the unconfirmed txs of the given token ID. | /// Return a page of the unconfirmed txs of the given token ID. | ||||
| pub async fn handle_token_id_unconfirmed_txs( | pub async fn handle_token_id_unconfirmed_txs( | ||||
| token_id_hex: &str, | token_id_hex: &str, | ||||
| indexer: &ChronikIndexer, | indexer: &ChronikIndexer, | ||||
| node: &Node, | |||||
| ) -> Result<proto::TxHistoryPage> { | ) -> Result<proto::TxHistoryPage> { | ||||
| let token_id = token_id_hex.parse::<TokenId>()?; | let token_id = token_id_hex.parse::<TokenId>()?; | ||||
| let token_id_history = indexer.token_id_history(); | let token_id_history = indexer.token_id_history(node); | ||||
| token_id_history.unconfirmed_txs(token_id) | token_id_history.unconfirmed_txs(token_id) | ||||
| } | } | ||||
| /// Return the UTXOs of the given token ID. | /// Return the UTXOs of the given token ID. | ||||
| pub async fn handle_token_id_utxos( | pub async fn handle_token_id_utxos( | ||||
| token_id_hex: &str, | token_id_hex: &str, | ||||
| indexer: &ChronikIndexer, | indexer: &ChronikIndexer, | ||||
| ) -> Result<proto::Utxos> { | ) -> Result<proto::Utxos> { | ||||
| let token_id = token_id_hex.parse::<TokenId>()?; | let token_id = token_id_hex.parse::<TokenId>()?; | ||||
| let token_id_utxos = indexer.token_id_utxos(); | let token_id_utxos = indexer.token_id_utxos(); | ||||
| let utxos = token_id_utxos.utxos(token_id)?; | let utxos = token_id_utxos.utxos(token_id)?; | ||||
| Ok(proto::Utxos { utxos }) | Ok(proto::Utxos { utxos }) | ||||
| } | } | ||||