setup debugging

ferveo/src/debug.rs

@@ -0,0 +1,86 @@
+use std::{
+    fs::File,
+    io::{self, BufRead},
+    path::PathBuf,
+};
+
+use hex::FromHex;
+
+#[derive(Debug)]
+struct ValidatorTranscript {
+    validator_address: String,
+    validator_pk: Vec<u8>,
+    transcript: Vec<u8>,
+}
+
+fn parse_file(file_path: &PathBuf) -> io::Result<Vec<ValidatorTranscript>> {
+    let mut records = Vec::new();
+
+    let file = File::open(file_path)?;
+    let reader = io::BufReader::new(file);
+
+    for line in reader.lines() {
+        let line = line?;
+        let parts: Vec<&str> = line.split_whitespace().collect();
+        if parts.len() != 3 {
+            eprintln!("Invalid line: {line}");
+            return Err(io::Error::new(
+                io::ErrorKind::InvalidData,
+                "Invalid line",
+            ));
+        }
+
+        let validator_address = parts[0].to_string();
+        let validator_pk = Vec::from_hex(parts[1])
+            .map_err(|e| io::Error::new(io::ErrorKind::InvalidData, e))?;
+        let transcript = Vec::from_hex(parts[2])
+            .map_err(|e| io::Error::new(io::ErrorKind::InvalidData, e))?;
+
+        if validator_address.len() != 42 {
+            eprintln!(
+                "Invalid validator_address length: {}",
+                validator_address.len()
+            );
+            return Err(io::Error::new(
+                io::ErrorKind::InvalidData,
+                "Invalid validator_address length",
+            ));
+        }
+        if validator_pk.len() != 96 {
+            eprintln!("Invalid validator_pk length: {}", validator_pk.len());
+            return Err(io::Error::new(
+                io::ErrorKind::InvalidData,
+                "Invalid validator_pk length",
+            ));
+        }
+        if transcript.len() != 3784 {
+            eprintln!("Invalid transcript length: {}", transcript.len());
+            return Err(io::Error::new(
+                io::ErrorKind::InvalidData,
+                "Invalid transcript length",
+            ));
+        }
+
+        records.push(ValidatorTranscript {
+            validator_address,
+            validator_pk,
+            transcript,
+        });
+    }
+
+    Ok(records)
+}
+
+#[cfg(test)]
+mod test {
+    use super::*;
+
+    #[test]
+    fn test_parse_file() {
+        let filename = "gistfile1.csv";
+        let file_path =
+            std::path::Path::new(env!("CARGO_MANIFEST_DIR")).join(filename);
+        let records = parse_file(&file_path).unwrap();
+        assert_eq!(records.len(), 30);
+    }
+}

ferveo/src/lib.rs

@@ -16,6 +16,8 @@ pub mod pvss;
 pub mod refresh;
 pub mod validator;
 
+#[cfg(test)]
+mod debug;
 #[cfg(test)]
 mod test_common;