issue-108, unnecessary comments and code were removed

Cargo.toml

@@ -1,8 +1,6 @@
 [workspace]
 members = [
     "brro-compressor",
-    "optimizer",
-    "prometheus-remote",
     "tools",
     "wavbrro",
     "vsri",

brro-compressor/src/compare.rs

@@ -14,84 +14,14 @@ See the License for the specific language governing permissions and
 limitations under the License.
 */
 
-use crate::{
-    compressor::{
-        constant::constant_compressor,
-        fft::fft,
-        polynomial::{polynomial, PolynomialType},
-    },
-    optimizer::utils::DataStats,
-};
-use std::thread;
-
-/// Enum to represent the decision between compressors.
 #[derive(PartialEq, Debug)]
 enum CompressionDecision {
     Constant,
     Fft,
     Polynomial,
 }
 
-impl CompressionDecision {
-    /// Function to perform compression and make a decision based on the results.
-    pub fn compress_and_decide() -> Result<(), Box<dyn std::error::Error>> {
-        // Sample data for testing
-        let data = vec![1.0, 2.0, 3.0, 4.0, 5.0];
-        let stats = DataStats::new(&data);
-
-        // Clone data for each compressor
-        let data_constant = data.clone();
-        let data_fft = data.clone();
-        let data_polynomial = data.clone();
-
-        // Create threads for each compressor
-        let thread_constant = thread::spawn(move || constant_compressor(&data_constant, stats));
-        let thread_fft = thread::spawn(move || fft(&data_fft));
-        let thread_polynomial =
-            thread::spawn(move || polynomial(&data_polynomial, PolynomialType::Polynomial));
-
-        // Wait for threads to finish and collect their results with error handling
-        let result_constant = thread_constant
-            .join()
-            .map_err(|e| format!("Constant thread error: {:?}", e))?;
-        let result_fft = thread_fft
-            .join()
-            .map_err(|e| format!("FFT thread error: {:?}", e))?;
-        let result_polynomial = thread_polynomial
-            .join()
-            .map_err(|e| format!("Polynomial thread error: {:?}", e))?;
-
-        // Use the decision logic to determine the compression decision
-        let decision = match (
-            result_constant.compressed_data.len(),
-            result_fft.len(),
-            result_polynomial.len(),
-        ) {
-            (constant_len, fft_len, poly_len)
-                if constant_len < fft_len && constant_len < poly_len =>
-            {
-                CompressionDecision::Constant
-            }
-            (_, fft_len, poly_len) if fft_len < poly_len => CompressionDecision::Fft,
-            _ => CompressionDecision::Polynomial,
-        };
-
-        // Use the decision to perform further actions
-        match decision {
-            CompressionDecision::Constant => {
-                println!("Selected Constant Compressor");
-            }
-            CompressionDecision::Fft => {
-                println!("Selected FFT Compressor");
-            }
-            CompressionDecision::Polynomial => {
-                println!("Selected Polynomial Compressor");
-            }
-        }
-
-        Ok(())
-    }
-}
+impl CompressionDecision {}
 fn get_compression_decision(
     result_constant: &[f64],
     result_fft: &[f64],

brro-compressor/src/compressor/constant.rs

@@ -69,7 +69,6 @@ impl Decode for Constant {
     ) -> Result<Self, ::bincode::error::DecodeError> {
         let id = Decode::decode(decoder)?;
         let bitdepth = Decode::decode(decoder)?;
-        // Here is where the pig twists the tail
         let constant: f64 = match bitdepth {
             Bitdepth::U8 => {
                 debug!("Decoding as u8");
@@ -112,11 +111,6 @@ impl Constant {
         }
     }
 
-    /// This compressor is about having a single constant for the whole segment
-    pub fn set_constant(&mut self, constant_value: f64) {
-        self.constant = constant_value;
-    }
-
     /// Receives a data stream and generates a Constant
     pub fn decompress(data: &[u8]) -> Self {
         let config = BinConfig::get();
@@ -126,7 +120,6 @@ impl Constant {
 
     /// This function transforms the structure into a Binary stream
     pub fn to_bytes(&self) -> Vec<u8> {
-        // Use Bincode and flate2-rs? Do this at the Stream Level?
         let config = BinConfig::get();
         bincode::encode_to_vec(self, config).unwrap()
     }
@@ -141,9 +134,7 @@ impl Constant {
 
 pub fn constant_compressor(data: &[f64], stats: DataStats) -> CompressorResult {
     debug!("Initializing Constant Compressor. Error and Stats provided");
-    // Initialize the compressor
     let c = Constant::new(data.len(), stats.min, stats.bitdepth);
-    // Convert to bytes
     CompressorResult::new(c.to_bytes(), 0.0)
 }
 

brro-compressor/src/compressor/fft.rs

@@ -39,30 +39,6 @@ pub struct FrequencyPoint {
 }
 
 impl FrequencyPoint {
-    pub fn new(real: f32, img: f32) -> Self {
-        FrequencyPoint {
-            pos: 0,
-            freq_real: real,
-            freq_img: img,
-        }
-    }
-
-    pub fn with_position(real: f32, img: f32, pos: u16) -> Self {
-        FrequencyPoint {
-            pos,
-            freq_real: real,
-            freq_img: img,
-        }
-    }
-
-    pub fn from_complex(complex: Complex<f32>) -> Self {
-        FrequencyPoint {
-            pos: 0,
-            freq_real: complex.re,
-            freq_img: complex.im,
-        }
-    }
-
     pub fn from_complex_with_position(complex: Complex<f32>, pos: u16) -> Self {
         FrequencyPoint {
             pos,
@@ -132,15 +108,10 @@ impl Ord for FrequencyPoint {
 /// FFT Compressor. Applies FFT to a signal, picks the N best frequencies, discards the rest. Always LOSSY
 #[derive(PartialEq, Debug)]
 pub struct FFT {
-    /// Compressor ID
     pub id: u8,
-    /// Stored frequencies
     pub frequencies: Vec<FrequencyPoint>,
-    /// The maximum numeric value of the points in the frame
     pub max_value: f32,
-    /// The minimum numeric value of the points in the frame
     pub min_value: f32,
-    /// Compression error
     pub error: Option<f64>,
 }
 
@@ -391,7 +362,7 @@ impl FFT {
     }
 
     /// Compresses data via FFT
-    /// The set of frequencies to store is 1/100 of the data lenght OR 3, which is bigger.
+    /// The set of frequencies to store is 1/100 of the data length OR 3, which is bigger.
     pub fn compress(&mut self, data: &[f64]) {
         if self.max_value == self.min_value {
             debug!("Same max and min, we're done here!");
@@ -415,8 +386,6 @@ impl FFT {
         buffer.truncate(size);
         self.frequencies = FFT::fft_trim(&mut buffer, max_freq);
     }
-
-    /// Decompresses data
     pub fn decompress(data: &[u8]) -> Self {
         let config = BinConfig::get();
         let (fft, _) = bincode::decode_from_slice(data, config).unwrap();

brro-compressor/src/compressor/mod.rs

@@ -118,7 +118,6 @@ pub struct BinConfig {
 
 impl BinConfig {
     pub fn get() -> Configuration {
-        // Little endian and Variable int encoding
         config::standard()
     }
 }

brro-compressor/src/compressor/noop.rs

@@ -34,17 +34,14 @@ impl Noop {
             data: Vec::with_capacity(sample_count),
         }
     }
-    ///Optimize
     pub fn optimize(data: &[f64]) -> Vec<i64> {
         let mut out_vec = Vec::with_capacity(data.len());
         for &element in data {
-            // Round the floating-point number before casting to i64
             out_vec.push(element.round() as i64);
         }
         out_vec
     }
 
-    /// "Compress"
     pub fn compress(&mut self, data: &[f64]) {
         self.data = Noop::optimize(data);
         debug!(
@@ -54,20 +51,17 @@ impl Noop {
         );
     }
 
-    /// Receives a data stream and generates a Noop
     pub fn decompress(data: &[u8]) -> Self {
         let config = BinConfig::get();
         let (noop, _) = bincode::decode_from_slice(data, config).unwrap();
         noop
     }
 
-    /// This function transforms the structure in a Binary stream to be appended to the frame
     pub fn to_bytes(&self) -> Vec<u8> {
         let config = BinConfig::get();
         bincode::encode_to_vec(self, config).unwrap()
     }
 
-    /// Returns an array of data
     pub fn to_data(&self, _frame_size: usize) -> Vec<i64> {
         self.data.clone()
     }
@@ -116,9 +110,8 @@ mod tests {
 
     #[test]
     fn test_optimize() {
-        // Test case with floating-point numbers that have fractional parts
         let input_data = [1.5, 2.7, 3.3, 4.9];
-        let expected_output = [2, 3, 3, 5]; // Rounded to the nearest integer
+        let expected_output = [2, 3, 3, 5];
 
         let result = Noop::optimize(&input_data);
         assert_eq!(result, expected_output);

brro-compressor/src/compressor/polynomial.rs

@@ -42,17 +42,12 @@ pub enum Method {
 
 #[derive(PartialEq, Debug, Clone)]
 pub struct Polynomial {
-    /// Compressor ID
     pub id: PolynomialType,
-    /// Stored Points
     pub data_points: Vec<f64>,
     pub min: f64,
     pub max: f64,
-    /// What is the base step between points
     pub point_step: u8,
-    /// Compression error
     pub error: Option<f64>,
-    /// Target bitdepth
     pub bitdepth: Bitdepth,
 }
 
@@ -97,7 +92,6 @@ impl Decode for Polynomial {
     ) -> Result<Self, ::bincode::error::DecodeError> {
         let id = Decode::decode(decoder)?;
         let bitdepth = Decode::decode(decoder)?;
-        // Here is where the pig twists the tail
         let data_points: Vec<f64> = match bitdepth {
             Bitdepth::U8 => {
                 debug!("Decoding as u8");
@@ -205,10 +199,6 @@ impl Polynomial {
         }
     }
 
-    fn locate_in_data_points(&self, point: f64) -> bool {
-        self.data_points.iter().any(|&i| i == point)
-    }
-
     fn get_method(&self) -> Method {
         match self.id {
             PolynomialType::Idw => Method::Idw,
@@ -223,7 +213,7 @@ impl Polynomial {
         }
         // TODO: Big one, read below
         // To reduce error we add more points to the polynomial, but, we also might add residuals
-        // each residual is 1/data_lenght * 100% less compression, each jump is 5% less compression.
+        // each residual is 1/data_length * 100% less compression, each jump is 5% less compression.
         // We can do the math and pick the one which fits better.
         let method = self.get_method();
         let data_len = data.len();
@@ -280,7 +270,7 @@ impl Polynomial {
         }
         self.error = Some(current_err);
         debug!(
-            "Final Stored Data Lenght: {} Iterations: {}",
+            "Final Stored Data Length: {} Iterations: {}",
             self.data_points.len(),
             iterations
         );
@@ -314,7 +304,6 @@ impl Polynomial {
         self.point_step = step as u8;
     }
 
-    // --- MANDATORY METHODS ---
     pub fn compress(&mut self, data: &[f64]) {
         let points = if 3 >= (data.len() / 100) {
             3
@@ -324,7 +313,6 @@ impl Polynomial {
         self.compress_hinted(data, points)
     }
 
-    /// Decompresses data
     pub fn decompress(data: &[u8]) -> Self {
         let config = BinConfig::get();
         let (poly, _) = bincode::decode_from_slice(data, config).unwrap();
@@ -336,7 +324,6 @@ impl Polynomial {
         bincode::encode_to_vec(self, config).unwrap()
     }
 
-    // --- END OF MANDATORY METHODS ---
     /// Since IDW and Polynomial are the same code everywhere, this function prepares the data
     /// to be used by one of the polynomial decompression methods
     fn get_positions(&self, frame_size: usize) -> Vec<usize> {
@@ -393,7 +380,6 @@ impl Polynomial {
             .map(|&f| f as f64)
             .collect();
         let idw = IDW::new(points, self.data_points.clone());
-        // Build the data
         (0..frame_size)
             .map(|f| {
                 round_and_limit_f64(
@@ -421,11 +407,8 @@ impl Polynomial {
 pub fn polynomial(data: &[f64], p_type: PolynomialType) -> Vec<u8> {
     info!("Initializing Polynomial Compressor");
     let stats = DataStats::new(data);
-    // Initialize the compressor
     let mut c = Polynomial::new(data.len(), stats.min, stats.max, p_type, stats.bitdepth);
-    // Convert the data
     c.compress(data);
-    // Convert to bytes
     c.to_bytes()
 }
 
@@ -436,14 +419,11 @@ pub fn polynomial_allowed_error(
 ) -> CompressorResult {
     info!("Initializing Polynomial Compressor");
     let stats = DataStats::new(data);
-    // Initialize the compressor
     let mut c = Polynomial::new(data.len(), stats.min, stats.max, p_type, stats.bitdepth);
-    // Convert the data
     c.compress_bounded(data, allowed_error);
     CompressorResult::new(c.to_bytes(), c.error.unwrap_or(0.0))
 }
 
-/// Uncompress
 pub fn to_data(sample_number: usize, compressed_data: &[u8]) -> Vec<f64> {
     let c = Polynomial::decompress(compressed_data);
     c.to_data(sample_number)

brro-compressor/src/data.rs

@@ -27,7 +27,6 @@ pub struct CompressedStream {
 }
 
 impl CompressedStream {
-    /// Creates an empty compressor stream
     pub fn new() -> Self {
         CompressedStream {
             header: CompressorHeader::new(),
@@ -87,8 +86,6 @@ impl CompressedStream {
         let (compressed_stream, _) = bincode::decode_from_slice(data, config).unwrap();
         compressed_stream
     }
-
-    /// Decompresses all the frames and returns a vector with the data
     pub fn decompress(&self) -> Vec<f64> {
         self.data_frames
             .iter()