chore: bump to 1.6.3

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "beamium"
-version = "1.6.2"
+version = "1.6.3"
 authors = [ "d33d33 <[email protected]>" ]
 
 build = "build.rs"

src/config.rs

@@ -69,7 +69,7 @@ pub struct Parameters {
     pub scan_period: u64,
     pub sink_dir: String,
     pub source_dir: String,
-    pub batch_size: i64,
+    pub batch_size: u64,
     pub batch_count: u64,
     pub log_file: String,
     pub log_level: slog::Level,
@@ -393,8 +393,8 @@ fn load_path<P: AsRef<Path>>(file_path: P, config: &mut Config) -> Result<(), Co
                 let batch_size = try!(doc["parameters"]["batch-size"]
                     .as_i64()
                     .ok_or(format!("parameters.batch-size should be a number")));
-                //let batch_size = try!(cast::u64(batch_size)
-                //    .map_err(|_| format!("parameters.batch-size is invalid")));
+                let batch_size = try!(cast::u64(batch_size)
+                    .map_err(|_| format!("parameters.batch-size is invalid")));
                 config.parameters.batch_size = batch_size;
             }
 
@@ -427,8 +427,8 @@ fn load_path<P: AsRef<Path>>(file_path: P, config: &mut Config) -> Result<(), Co
 
             if !doc["parameters"]["syslog"].is_badvalue() {
                 let syslog = try!(doc["parameters"]["syslog"]
-                                       .as_bool()
-                                       .ok_or("parameters.bool should be a boolean"));
+                                      .as_bool()
+                                      .ok_or("parameters.bool should be a boolean"));
                 config.parameters.syslog = syslog;
 
             }

src/sink/mod.rs

@@ -26,7 +26,7 @@ pub struct Sink<'a> {
     token_header: &'a String,
     url: &'a String,
     batch_count: u64,
-    batch_size: i64,
+    batch_size: u64,
     max_size: u64,
     ttl: u64,
     parallel: u64,

src/sink/send.rs

@@ -29,7 +29,7 @@ pub fn send_thread(token: &str,
                    todo: Arc<Mutex<VecDeque<PathBuf>>>,
                    timeout: u64,
                    batch_count: u64,
-                   batch_size: i64,
+                   batch_size: u64,
                    sigint: Arc<AtomicBool>) {
     loop {
         Data::new(sigint.clone(), todo.clone(), batch_count, batch_size)
@@ -111,12 +111,12 @@ impl Data {
     pub fn new(sigint: Arc<AtomicBool>,
                todo: Arc<Mutex<VecDeque<PathBuf>>>,
                batch_count: u64,
-               batch_size: i64)
+               batch_size: u64)
                -> Option<Data> {
         let mut d = Data {
             sigint: sigint,
             batch_count: batch_count,
-            batch_size: batch_size,
+            batch_size: batch_size as i64,
             todo: todo,
             processing: None,
             processed: Vec::new(),