Revert mgs_fs parsing function to not use top level parser and add unit tests

Signed-off-by: Gaurang Tapase <[email protected]>

Author: gaurangtapase

.cargo/config.toml

@@ -1,6 +1,9 @@
 [target.x86_64-unknown-linux-musl]
 linker = "rust-lld"
 
+[target.aarch64-apple-darwin]
+linker = "rust-lld"
+
 [alias]
 build-musl = "build --release --target x86_64-unknown-linux-musl"
 

lustre-collector/src/fixtures/mgs-fs.txt

@@ -0,0 +1,2 @@
+mgs.MGS.live.params
+mgs.MGS.live.testfs

lustre-collector/src/lib.rs

@@ -63,7 +63,7 @@ pub fn parse_lctl_output(lctl_output: &[u8]) -> Result<Vec<Record>, LustreCollec
 pub fn parse_mgs_fs_output(mgs_fs_output: &[u8]) -> Result<Vec<Record>, LustreCollectorError> {
     let mgs_fs = str::from_utf8(mgs_fs_output)?;
 
-    let (mgs_fs_record, state) = parser::parse()
+    let (mgs_fs_record, state) = mgs::mgs_fs_parser::parse()
         .easy_parse(mgs_fs)
         .map_err(|err| err.map_position(|p| p.translate_position(mgs_fs)))?;
 
@@ -89,7 +89,7 @@ pub fn parse_recovery_status_output(
 
 #[cfg(test)]
 mod tests {
-    use crate::{parse_lctl_output, parse_recovery_status_output};
+    use crate::{parse_lctl_output, parse_mgs_fs_output, parse_recovery_status_output};
 
     #[test]
     fn ex8761_job_stats() {
@@ -107,6 +107,14 @@ mod tests {
         insta::assert_debug_snapshot!(expected);
     }
 
+    #[test]
+    fn test_parse_mgs_fs_output() {
+        let xs = include_bytes!("./fixtures/mgs-fs.txt");
+        let expected = parse_mgs_fs_output(xs).unwrap();
+
+        insta::assert_debug_snapshot!(expected);
+    }
+
     #[test]
     fn es_6_2_0_job_stats_unhealthy() {
         let xs = include_bytes!("./fixtures/valid/params-6.2.0-r9.txt");

lustre-collector/src/snapshots/lustre_collector__tests__parse_mgs_fs_output.snap

@@ -0,0 +1,24 @@
+---
+source: lustre-collector/src/lib.rs
+expression: expected
+---
+[
+    Target(
+        FsNames(
+            TargetStat {
+                kind: Mgt,
+                param: Param(
+                    "fsnames",
+                ),
+                target: Target(
+                    "MGS",
+                ),
+                value: [
+                    FsName(
+                        "testfs",
+                    ),
+                ],
+            },
+        ),
+    ),
+]