fix: skip empty chunks when decoding gz

components/chainhook-cli/src/archive/mod.rs

@@ -41,48 +41,55 @@ pub async fn download_tsv_file(config: &Config) -> Result<(), String> {
 
     // Download chunks
     let (tx, rx) = flume::bounded(0);
-    destination_path.push(default_tsv_file_path(&config.network.stacks_network));
-
-    let decoder_thread = std::thread::spawn(move || {
-        let input = ChannelRead::new(rx);
-        let mut decoder = GzDecoder::new(input);
-        let mut file = fs::File::create(&destination_path).unwrap();
-        let mut buffer = [0; 512_000];
-        loop {
-            match decoder.read(&mut buffer) {
-                Ok(0) => break,
-                Ok(n) => {
-                    if let Err(e) = file.write_all(&buffer[..n]) {
-                        let err = format!("unable to update compressed archive: {}", e.to_string());
+
+    if res.status() == reqwest::StatusCode::OK {
+        destination_path.push(default_tsv_file_path(&config.network.stacks_network));
+
+        let decoder_thread = std::thread::spawn(move || {
+            let mut file = fs::File::create(&destination_path).unwrap();
+            let input = ChannelRead::new(rx);
+            let mut decoder = GzDecoder::new(input);
+            let mut buffer = [0; 512_000];
+            loop {
+                match decoder.read(&mut buffer) {
+                    Ok(0) => break,
+                    Ok(n) => {
+                        if let Err(e) = file.write_all(&buffer[..n]) {
+                            let err =
+                                format!("unable to update compressed archive: {}", e.to_string());
+                            return Err(err);
+                        }
+                    }
+                    Err(e) => {
+                        let err = format!("unable to write compressed archive: {}", e.to_string());
                         return Err(err);
                     }
                 }
-                Err(e) => {
-                    let err = format!("unable to write compressed archive: {}", e.to_string());
-                    return Err(err);
-                }
             }
-        }
-        let _ = file.flush();
-        Ok(())
-    });
-
-    if res.status() == reqwest::StatusCode::OK {
+            let _ = file.flush();
+            Ok(())
+        });
         let mut stream = res.bytes_stream();
         while let Some(item) = stream.next().await {
-            let chunk = item.or(Err(format!("Error while downloading file")))?;
+            let chunk = match item {
+                Ok(i) => Ok(i),
+                Err(e) => Err(format!("Error while downloading file {}", e.to_string())),
+            }?;
+            if chunk.is_empty() {
+                continue;
+            }
             tx.send_async(chunk.to_vec())
                 .await
-                .map_err(|e| format!("unable to download stacks event: {}", e.to_string()))?;
+                .map_err(|e| format!("unable to download stacks archive: {}", e.to_string()))?;
         }
         drop(tx);
-    }
 
-    tokio::task::spawn_blocking(|| decoder_thread.join())
-        .await
-        .unwrap()
-        .unwrap()
-        .unwrap();
+        tokio::task::spawn_blocking(|| decoder_thread.join())
+            .await
+            .unwrap()
+            .unwrap()
+            .unwrap();
+    }
 
     Ok(())
 }

docs/chainhook-openapi.json

@@ -521,6 +521,18 @@
                   }
                 },
                 "additionalProperties": false
+              },
+              {
+                "type": "object",
+                "required": [
+                  "descriptor"
+                ],
+                "properties": {
+                  "descriptor": {
+                    "$ref": "#/components/schemas/DescriptorMatchingRule"
+                  }
+                },
+                "additionalProperties": false
               }
             ],
             "required": [
@@ -726,6 +738,29 @@
           }
         ]
       },
+      "DescriptorMatchingRule": {
+        "type": "object",
+        "required": [
+          "expression"
+        ],
+        "properties": {
+          "expression": {
+            "type": "string"
+          },
+          "range": {
+            "default": null,
+            "type": "array",
+            "items": {
+              "type": "integer",
+              "format": "uint32",
+              "minimum": 0.0
+            },
+            "maxItems": 2,
+            "minItems": 2,
+            "nullable": true
+          }
+        }
+      },
       "HookAction": {
         "oneOf": [
           {