Finish router.

src/rest.rs

@@ -4,25 +4,244 @@ use anyhow::Result;
 use axum::{
     http::StatusCode,
     response::{IntoResponse, Response},
-    routing::get,
+    routing::{get, post},
     Router,
 };
 use tower_http::cors::CorsLayer;
 
 use crate::config::Config;
 
-#[axum::debug_handler]
-async fn get_blocks_tip_hash() -> Result<impl IntoResponse, AppError> {
+// Transactions
+async fn get_tx() -> Result<impl IntoResponse, AppError> {
     Ok(StatusCode::OK)
 }
 
+async fn get_tx_status() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_tx_hex() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_tx_raw() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_tx_merkleblock_proof() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_tx_merkle_proof() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_tx_outspend_and_vout() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_tx_outspends() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn post_tx() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+// Addresses
+async fn get_address() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_scripthash() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_address_txs() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_scripthash_txs() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_confirmed_txs_by_address() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_last_seen_txs_by_address() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_confirmed_txs_by_scripthash() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_last_seen_txs_by_scripthash() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_unconfirmed_txs_by_address() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_unconfirmed_txs_by_scripthash() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_utxos_by_address() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_utxos_by_scripthash() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_addresses_by_prefix() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+// Blocks
+async fn get_block() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_block_header() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_block_status() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_block_txs() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_block_txs_by_index() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_block_txids() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_block_tx() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_block_raw() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_block_height_hash() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_blocks() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_blocks_by_height() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_block_height() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_block_tip_hash() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+// Mempool
+async fn get_mempool() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_mempool_txids() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+async fn get_mempool_recent() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+// Fee estimates
+async fn get_fee_estimates() -> Result<impl IntoResponse, AppError> {
+    Ok(StatusCode::OK)
+}
+
+/// Esplora HTTP API according to these docs:
+/// <https://github.com/Blockstream/esplora/blob/master/API.md#esplora-http-api>
 pub async fn serve(config: Arc<Config>) -> Result<()> {
     let app = Router::new()
-        .route("/blocks/tip/hash", get(get_blocks_tip_hash))
+        // Transactions
+        .route("/tx/:txid", get(get_tx))
+        .route("/tx/:txid/status", get(get_tx_status))
+        .route("/tx/:txid/hex", get(get_tx_hex))
+        .route("/tx/:txid/raw", get(get_tx_raw))
+        .route("/tx/:txid/merkleblock-proof", get(get_tx_merkleblock_proof))
+        .route("/tx/:txid/merkle-proof", get(get_tx_merkle_proof))
+        .route("/tx/:txid/outspend/:vout", get(get_tx_outspend_and_vout))
+        .route("/tx/:txid/outspends", get(get_tx_outspends))
+        .route("/tx", post(post_tx))
+        // Addresses
+        .route("/address/:address", get(get_address))
+        .route("/scripthash/:hash", get(get_scripthash))
+        .route("/address/:address/txs", get(get_address_txs))
+        .route("/scripthash/:hash/txs", get(get_scripthash_txs))
+        .route(
+            "/address/:address/txs/chain",
+            get(get_confirmed_txs_by_address),
+        )
+        .route(
+            "/address/:address/txs/chain/:last_seen_txid",
+            get(get_last_seen_txs_by_address),
+        )
+        .route(
+            "/scripthash/:hash/txs/chain",
+            get(get_confirmed_txs_by_scripthash),
+        )
+        .route(
+            "/scripthash/:hash/txs/chain/:last_seen_txid",
+            get(get_last_seen_txs_by_scripthash),
+        )
+        .route(
+            "/address/:address/txs/mempool",
+            get(get_unconfirmed_txs_by_address),
+        )
+        .route(
+            "/scripthash/:hash/txs/mempool",
+            get(get_unconfirmed_txs_by_scripthash),
+        )
+        .route("/address/:address/utxo", get(get_utxos_by_address))
+        .route("/scripthash/:hash/utxo", get(get_utxos_by_scripthash))
+        .route("/address-prefix/:prefix", get(get_addresses_by_prefix))
+        // Blocks
+        .route("/block/:hash", get(get_block))
+        .route("/block/:hash/header", get(get_block_header))
+        .route("/block/:hash/status", get(get_block_status))
+        .route("/block/:hash/txs", get(get_block_txs))
+        .route("/block/:hash/txs/:start_index", get(get_block_txs_by_index))
+        .route("/block/:hash/txids", get(get_block_txids))
+        .route("/block/:hash/txid/:index", get(get_block_tx))
+        .route("/block/:hash/raw", get(get_block_raw))
+        .route("/block-height/:height", get(get_block_height_hash))
+        .route("/blocks", get(get_blocks))
+        .route("/blocks/:start_height", get(get_blocks_by_height))
+        .route("/blocks/tip/height", get(get_block_height))
+        .route("/blocks/tip/hash", get(get_block_tip_hash))
+        // Mempool
+        .route("/mempool", get(get_mempool))
+        .route("/mempool/txids", get(get_mempool_txids))
+        .route("/mempool/recent", get(get_mempool_recent))
+        // Fee estimates
+        .route("/fee-estimates", get(get_fee_estimates))
         .layer(CorsLayer::permissive());
 
     info!(
-        "bitmaskd REST server successfully running at {}",
+        "electrs HTTP REST API server successfully running at {}",
         config.http_addr
     );