adds test for fixes #106

src/adapters/custom.rs

@@ -21,7 +21,6 @@ use tokio::io::AsyncReadExt;
 use tokio::process::Child;
 use tokio::process::Command;
 
-
 use tokio_util::io::StreamReader;
 // mostly the same as AdapterMeta + SpawningFileAdapter
 #[derive(Debug, Deserialize, Serialize, JsonSchema, Default, PartialEq, Clone)]
@@ -307,12 +306,7 @@ mod test {
 
     #[tokio::test]
     async fn poppler() -> Result<()> {
-        let adapter = BUILTIN_SPAWNING_ADAPTERS
-            .iter()
-            .find(|e| e.name == "poppler")
-            .expect("no poppler adapter");
-
-        let adapter = adapter.to_adapter();
+        let adapter = poppler_adapter();
 
         let filepath = test_data_dir().join("short.pdf");
 

src/adapters/postproc.rs

@@ -221,9 +221,13 @@ pub fn postproc_pagebreaks(input: impl AsyncRead + Send) -> impl AsyncRead + Sen
 
 #[cfg(test)]
 mod tests {
+    use crate::preproc::loop_adapt;
+    use crate::test_utils::*;
+
     use super::*;
     use anyhow::Result;
     use pretty_assertions::assert_eq;
+    use tokio::fs::File;
     use tokio::pin;
     use tokio_test::io::Builder;
     use tokio_test::io::Mock;
@@ -243,6 +247,30 @@ mod tests {
         );
     }
 
+    #[tokio::test]
+    async fn test_pdf_twoblank() -> Result<()> {
+        let adapter = poppler_adapter();
+        let fname = test_data_dir().join("twoblankpages.pdf");
+        let rd = File::open(&fname).await?;
+        let (a, d) = simple_adapt_info(&fname, Box::pin(rd));
+        let res = loop_adapt(&adapter, d, a)?;
+
+        let buf = adapted_to_vec(res).await?;
+
+        assert_eq!(
+            String::from_utf8(buf)?,
+            "PREFIX:Page 1: 
+PREFIX:Page 2: 
+PREFIX:Page 3: HelloWorld
+PREFIX:Page 3: 
+PREFIX:Page 3: 
+PREFIX:Page 4: 
+",
+        );
+
+        Ok(())
+    }
+
     #[tokio::test]
     async fn test_postproc_prefix() {
         let mut output: Vec<u8> = Vec::new();

src/test_utils.rs

@@ -1,6 +1,9 @@
 use crate::{
     adapted_iter::AdaptedFilesIterBox,
-    adapters::{AdaptInfo, ReadBox},
+    adapters::{
+        custom::{CustomSpawningFileAdapter, BUILTIN_SPAWNING_ADAPTERS},
+        AdaptInfo, ReadBox,
+    },
     config::RgaConfig,
     matching::{FastFileMatcher, FileMatcher},
     recurse::concat_read_streams,
@@ -41,3 +44,13 @@ pub async fn adapted_to_vec(adapted: AdaptedFilesIterBox) -> Result<Vec<u8>> {
     res.read_to_end(&mut buf).await?;
     Ok(buf)
 }
+
+pub fn poppler_adapter() -> CustomSpawningFileAdapter {
+    let adapter = BUILTIN_SPAWNING_ADAPTERS
+        .iter()
+        .find(|e| e.name == "poppler")
+        .expect("no poppler adapter");
+
+    let adapter = adapter.to_adapter();
+    adapter
+}