fix: resolve compilation errors and warnings

Co-authored-by: aider (openai/andrew/openrouter/sonoma-sky-alpha) <aider@aider.chat>

src/filter_plugin/skip.rs

@@ -32,13 +32,13 @@ impl FilterPlugin for SkipBytesFilter {
     /// # Returns
     ///
     /// Returns `Ok(())` on success, or an `io::Error` if reading or writing fails.
-    fn filter(&mut self, reader: &mut dyn Read, writer: &mut dyn Write) -> Result<()> {
+    fn filter(&mut self, reader: Box<&mut dyn Read>, writer: Box<&mut dyn Write>) -> Result<()> {
         // Skip bytes in chunks
         if self.remaining > 0 {
             let mut buffer = vec![0; PIPESIZE];
             while self.remaining > 0 {
                 let to_read = std::cmp::min(self.remaining, PIPESIZE);
-                let bytes_read = reader.read(&mut buffer[..to_read])?;
+                let bytes_read = reader.as_mut().read(&mut buffer[..to_read])?;
                 if bytes_read == 0 {
                     break;
                 }
@@ -47,7 +47,7 @@ impl FilterPlugin for SkipBytesFilter {
         }
         
         // Copy the remaining data using io::copy for efficiency
-        std::io::copy(reader, writer)?;
+        std::io::copy(reader.as_mut(), writer.as_mut())?;
         Ok(())
     }
 
@@ -107,14 +107,14 @@ impl FilterPlugin for SkipLinesFilter {
     /// # Returns
     ///
     /// Returns `Ok(())` on success, or an `io::Error` if reading or writing fails.
-    fn filter(&mut self, reader: &mut dyn Read, writer: &mut dyn Write) -> Result<()> {
-        let mut buf_reader = std::io::BufReader::new(reader);
+    fn filter(&mut self, reader: Box<&mut dyn Read>, writer: Box<&mut dyn Write>) -> Result<()> {
+        let mut buf_reader = std::io::BufReader::new(reader.as_mut());
         for line in buf_reader.by_ref().lines() {
             let line = line?;
             if self.remaining > 0 {
                 self.remaining -= 1;
             } else {
-                writeln!(writer, "{}", line)?;
+                writeln!(writer.as_mut(), "{}", line)?;
             }
         }
         Ok(())
@@ -152,4 +152,4 @@ impl FilterPlugin for SkipLinesFilter {
 fn register_skip_filters() {
     register_filter_plugin("skip_bytes", || Box::new(SkipBytesFilter::new(0)));
     register_filter_plugin("skip_lines", || Box::new(SkipLinesFilter::new(0)));
-}
+}

src/filter_plugin/strip_ansi.rs

@@ -32,9 +32,9 @@ impl FilterPlugin for StripAnsiFilter {
     /// # Returns
     ///
     /// Returns `Ok(())` on success, or an `io::Error` if reading or writing fails.
-    fn filter(&mut self, reader: &mut dyn Read, writer: &mut dyn Write) -> Result<()> {
-        let mut ansi_writer = Writer::new(writer);
-        std::io::copy(reader, &mut ansi_writer)?;
+    fn filter(&mut self, reader: Box<&mut dyn Read>, writer: Box<&mut dyn Write>) -> Result<()> {
+        let mut ansi_writer = Writer::new(writer.as_mut());
+        std::io::copy(reader.as_mut(), &mut ansi_writer)?;
         ansi_writer.flush()?;
         Ok(())
     }

src/filter_plugin/tail.rs

@@ -35,10 +35,10 @@ impl FilterPlugin for TailBytesFilter {
     /// # Returns
     ///
     /// Returns `Ok(())` on success, or an `io::Error` if reading or writing fails.
-    fn filter(&mut self, reader: &mut dyn Read, writer: &mut dyn Write) -> Result<()> {
+    fn filter(&mut self, reader: Box<&mut dyn Read>, writer: Box<&mut dyn Write>) -> Result<()> {
         let mut temp_buffer = vec![0; PIPESIZE];
         loop {
-            let bytes_read = reader.read(&mut temp_buffer)?;
+            let bytes_read = reader.as_mut().read(&mut temp_buffer)?;
             if bytes_read == 0 {
                 break;
             }
@@ -54,7 +54,7 @@ impl FilterPlugin for TailBytesFilter {
         
         // Write the buffered data at the end
         let result: Vec<u8> = self.buffer.iter().cloned().collect();
-        writer.write_all(&result)?;
+        writer.as_mut().write_all(&result)?;
         Ok(())
     }
 
@@ -117,8 +117,8 @@ impl FilterPlugin for TailLinesFilter {
     /// # Returns
     ///
     /// Returns `Ok(())` on success, or an `io::Error` if reading or writing fails.
-    fn filter(&mut self, reader: &mut dyn Read, writer: &mut dyn Write) -> Result<()> {
-        let mut buf_reader = std::io::BufReader::new(reader);
+    fn filter(&mut self, reader: Box<&mut dyn Read>, writer: Box<&mut dyn Write>) -> Result<()> {
+        let mut buf_reader = std::io::BufReader::new(reader.as_mut());
         for line in buf_reader.by_ref().lines() {
             let line = line?;
             if self.lines.len() == self.count {
@@ -129,7 +129,7 @@ impl FilterPlugin for TailLinesFilter {
         
         // Write the buffered lines
         for line in &self.lines {
-            writeln!(writer, "{}", line)?;
+            writeln!(writer.as_mut(), "{}", line)?;
         }
         Ok(())
     }