fix: fixed sorting when some lines are empty

Cargo.toml

@@ -4,7 +4,7 @@ members = [".", "crate/encstr"]
 [workspace.package]
 repository = "https://github.com/pamburus/hl"
 authors = ["Pavel Ivanov <[email protected]>"]
-version = "0.29.2-alpha.3"
+version = "0.29.2-alpha.4"
 edition = "2021"
 license = "MIT"
 

src/app.rs

@@ -107,6 +107,11 @@ impl Options {
         Self { raw, ..self }
     }
 
+    #[cfg(test)]
+    fn with_sort(self, sort: bool) -> Self {
+        Self { sort, ..self }
+    }
+
     #[cfg(test)]
     fn with_input_info(self, input_info: Option<InputInfo>) -> Self {
         Self { input_info, ..self }
@@ -1178,8 +1183,29 @@ mod tests {
         assert_eq!(std::str::from_utf8(&output).unwrap(), format!("{}\n\n{}\n", L1, L2),);
     }
 
+    #[test]
+    fn test_sort_with_blank_lines() {
+        let input = input(concat!(
+            r#"{"level":"debug","ts":"2024-01-25T19:10:20.435369+01:00","msg":"m2"}"#,
+            "\n\r\n",
+            r#"{"level":"debug","ts":"2024-01-25T19:09:16.860711+01:00","msg":"m1"}"#,
+            "\n",
+        ));
+
+        let mut output = Vec::new();
+        let app = App::new(options().with_sort(true));
+        app.run(vec![input], &mut output).unwrap();
+        assert_eq!(
+            std::str::from_utf8(&output).unwrap(),
+            concat!(
+                "2024-01-25 18:09:16.860 |DBG| m1\n",
+                "2024-01-25 18:10:20.435 |DBG| m2\n",
+            ),
+        );
+    }
+
     fn input<S: Into<String>>(s: S) -> InputHolder {
-        InputHolder::new(InputReference::File("-".into()), Some(Box::new(Cursor::new(s.into()))))
+        InputHolder::new(InputReference::Stdin, Some(Box::new(Cursor::new(s.into()))))
     }
 
     fn options() -> Options {

src/index.rs

@@ -442,6 +442,8 @@ impl Indexer {
                         }
                     }
                 }
+            } else {
+                stat.add_invalid();
             }
             lines.push((ts.or(prev_ts), i as u32, offset));
             offset += data_len as u32 + 1;

src/input.rs

@@ -141,7 +141,7 @@ impl InputHolder {
 
     pub fn open(self) -> io::Result<Input> {
         match self.reference {
-            InputReference::Stdin => Ok(Input::new(self.reference, Box::new(stdin()))),
+            InputReference::Stdin => Ok(Input::new(self.reference.clone(), self.stdin())),
             InputReference::File(path) => match self.stream {
                 Some(stream) => Input::open_stream(&path, stream),
                 None => Input::open(&path),
@@ -151,13 +151,19 @@ impl InputHolder {
 
     pub fn index(self, indexer: &Indexer) -> Result<IndexedInput> {
         match self.reference {
-            InputReference::Stdin => IndexedInput::open_sequential(self.reference.clone(), Box::new(stdin()), indexer),
+            InputReference::Stdin => IndexedInput::open_sequential(self.reference.clone(), self.stdin(), indexer),
             InputReference::File(path) => match self.stream {
                 Some(stream) => IndexedInput::open_stream(&path, stream, indexer),
                 None => IndexedInput::open(&path, indexer),
             },
         }
     }
+
+    fn stdin(self) -> InputStream {
+        self.stream
+            .map(|s| Box::new(ReadSeekToRead(s)) as InputStream)
+            .unwrap_or_else(|| Box::new(stdin()))
+    }
 }
 
 pub struct Input {
@@ -515,6 +521,17 @@ pub trait ReadSeek: Read + Seek {}
 
 impl<T: Read + Seek> ReadSeek for T {}
 
+pub struct ReadSeekToRead<T>(T);
+
+impl<T> Read for ReadSeekToRead<T>
+where
+    T: ReadSeek,
+{
+    fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> {
+        self.0.read(buf)
+    }
+}
+
 trait AsInputStream {
     fn as_input_stream(self) -> InputStream;
 }