blocks_bulk

Author: RandyMcMillan

src/args.rs

@@ -71,13 +71,30 @@ pub fn block_txs(block_hash: &str, start_index: &str) {
 /// <https://mempool.space/docs/api/rest#get-blocks>
 pub fn blocks(start_height: &str) {
     //TODO blocks_tip_height
+    let blocks_tip_height = generic_sys_call("blocks_tip_height", &"extraneous_arg");
+    let blocks_tip_height_int = blocks_tip_height.parse::<i32>().unwrap_or(0);
     let start_height_int = start_height.parse::<i32>().unwrap_or(0);
-    if start_height_int >= 0 {
+    if start_height_int >= 0 && start_height_int <= blocks_tip_height_int {
         let _res = blocking(&format!("v1/blocks/{}", start_height));
     } else {
         let _res = blocking(&format!("v1/blocks"));
     }
 }
+/// GET /api/v1/blocks-bulk/:minHeight[/:maxHeight]
+/// <https://mempool.space/docs/api/rest#get-blocks-bulk>
+pub fn blocks_bulk(min_height: &str, max_height: &str) {
+    //TODO blocks_tip_height
+    let min_height_int = min_height.parse::<i32>().unwrap_or(0);
+    let max_height_int = max_height.parse::<i32>().unwrap_or(0);
+    if min_height_int >= 0 && max_height_int >= 0 && min_height_int <= max_height_int {
+        let _res = blocking(&format!("v1/blocks-bulk/{}/{}", min_height, max_height));
+    } else if min_height_int >= 0 && max_height_int >= 0 && min_height_int >= max_height_int {
+        let _res = blocking(&format!("v1/blocks-bulk/{}/{}", max_height, min_height));
+    } else {
+        let blocks_tip_height = generic_sys_call("blocks_tip_height", &"extraneous_arg");
+        let _res = blocking(&format!("v1/blocks-bulk/{}/{}", min_height, blocks_tip_height));
+    }
+}
 
 /// <https://mempool.space/docs/api/rest>
 /// - [API/REST](https://mempool.space/docs/api/rest)

src/bin/mempool-space_blocks_bulk.rs

@@ -0,0 +1,19 @@
+use mempool_space::blocking;
+use std::env;
+
+fn main() {
+    {
+        let args: Vec<String> = env::args().collect();
+        if args.len() == 2 {
+            let min_height = &args[1];
+            let _res = blocking(&format!("v1/blocks-bulk/{}", &min_height));
+        } else if args.len() == 3 {
+            let min_height = &args[1];
+            let max_height = &args[2];
+            let _res = blocking(&format!("v1/blocks-bulk/{}/{}", &min_height, &max_height));
+        } else {
+            // silence is golden
+            std::process::exit(0);
+        }
+    }
+}

src/lib.rs

@@ -435,6 +435,22 @@ mod tests {
         wait("1");
     }
     #[test]
+    //#[should_panic(expected = "This API is disabled. Set config.MEMPOOL.MAX_BLOCKS_BULK_QUERY to a positive number to enable it.
+    #[should_panic]
+    fn test_blocks_bulk() {
+        // GET /api/v1/blocks-bulk/:minHeight[/:maxHeight]
+        let binding = format!("v1/blocks-bulk/730000/840000").clone();
+        let get_block_txid: &str = blocking(&binding).expect("returns current txid from block index");
+
+        let get_block_txid = generic_sys_call("blocks_bulk", "730000/840000");
+        let blocks_tip_height = generic_sys_call("blocks_tip_height", "extraneous_arg");
+        use crate::args::blocks_bulk;
+        blocks_bulk(&"0", &"0");
+        blocks_bulk(&"0", &"1");
+        blocks_bulk(&"730000", &"840000");
+        wait("1");
+    }
+    #[test]
     fn test_blockheight() {
         let blockheight = blockheight::blockheight();
         assert_ne!(0 as f64, blockheight.unwrap());