Debug feature and improved logging

This dramatically increases logging verbosity and adds a feature that
allows logging to be enabled in production use cases without the test or
debug flag.

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "compressed_log"
-version = "0.3.4"
+version = "0.3.7"
 authors = ["Michał Papierski <[email protected]>, Justin Kilpatrick <[email protected]>"]
 edition = "2018"
 include = [
@@ -24,4 +24,8 @@ futures = "0.3"
 backoff = "0.3"
 serde_json = "1.0"
 serde_derive = "1.0"
-serde = "1.0"
+serde = "1.0"
+
+[features]
+# prints debug messages as a feature
+debug = []

src/logger.rs

@@ -78,6 +78,7 @@ impl Logger {
 
 impl Drop for Logger {
     fn drop(&mut self) {
+        debug_eprintln!("Drop handler called!");
         // Unconditional rotation of log
         let encoder = self.encoder.lock().expect("Unable to acquire buffer lock");
         let data = self.rotate(&encoder).expect("Unable to rotate the buffer");
@@ -112,15 +113,16 @@ impl Log for Logger {
             let log_string = (self.format)(&record);
 
             // First, write whole formatted string
-            encoder.borrow_mut().add_line(log_string);
+            encoder.borrow_mut().add_line(log_string.clone());
 
             // Rotate the buffer based on a threshold
             let current_size = {
                 let encoder = encoder.borrow();
                 encoder.len()
             };
             if current_size < self.threshold {
-                //debug_eprintln!("Buffer {} of {}", current_size, self.threshold);
+                debug_eprintln!("Buffer {} of {}", current_size, self.threshold);
+                debug_eprintln!("Line {}", log_string);
                 // Compressed log didn't hit the size threshold
                 return;
             }
@@ -149,9 +151,11 @@ impl Log for Logger {
 }
 
 fn upload_logs(url: String, data: FinishValue) {
+    debug_eprintln!("Uploading logs");
     // create a new thread for the actix executor
     // to adopt in order to run the future to completion
     thread::spawn(|| {
+        debug_eprintln!("thread spawned");
         let runner = System::new();
         runner.block_on(async move {
             match data {

src/macros.rs

@@ -1,11 +1,10 @@
-#[allow(unused_macros)]
 macro_rules! debug_eprintln {
     () => ({
-        #[cfg(any(debug_assertions,test))]
+        #[cfg(any(debug_assertions,test,feature = "debug"))]
         eprint!("\n")
     });
     ($($arg:tt)*) => ({
-        #[cfg(any(debug_assertions,test))]
+        #[cfg(any(debug_assertions,test,feature = "debug"))]
         eprintln!($($arg)*);
     })
 }