Exports stats (#57)

* Export stats

* Add new fixture

* Add unit test

* Do not update existing fixture

* Apply suggestions from code review

---------

Co-authored-by: Joe Grund <jgrund@whamcloud.io>

src/base_parsers.rs

@@ -78,14 +78,6 @@ where
     take_until(period())
 }
 
-pub(crate) fn till_equals<I>() -> impl Parser<I, Output = String>
-where
-    I: Stream<Token = char>,
-    I::Error: ParseError<I::Token, I::Range, I::Position>,
-{
-    take_until(equals())
-}
-
 pub(crate) fn string_to<I>(x: &'static str, y: &'static str) -> impl Parser<I, Output = String>
 where
     I: Stream<Token = char>,
@@ -120,6 +112,16 @@ where
         .message("while getting param")
 }
 
+pub(crate) fn param_period<I>(x: &'static str) -> impl Parser<I, Output = Param>
+where
+    I: Stream<Token = char>,
+    I::Error: ParseError<I::Token, I::Range, I::Position>,
+{
+    attempt(string(x).skip(token('.')))
+        .map(|x| Param(x.to_string()))
+        .message("while getting param")
+}
+
 #[cfg(test)]
 mod tests {
     use super::*;
@@ -131,4 +133,14 @@ mod tests {
 
         assert_eq!(result, Ok((Param("memused".to_string()), "77991501\n")))
     }
+
+    #[test]
+    fn test_param_period() {
+        let result = param_period("exports").parse("exports.1.2.3.130@o2ib.stats=Y\n");
+
+        assert_eq!(
+            result,
+            Ok((Param("exports".to_string()), "1.2.3.130@o2ib.stats=Y\n"))
+        )
+    }
 }

src/exports_parser.rs

@@ -0,0 +1,56 @@
+// Copyright (c) 2024 DDN. All rights reserved.
+// Use of this source code is governed by a MIT-style
+// license that can be found in the LICENSE file.
+
+use crate::{
+    base_parsers::{equals, period},
+    stats_parser::stats,
+    ExportStats,
+};
+use combine::{
+    attempt,
+    error::ParseError,
+    many, many1,
+    parser::char::{alpha_num, string},
+    stream::Stream,
+    token, Parser,
+};
+
+/// Parses a single nid
+pub(crate) fn nid<I>() -> impl Parser<I, Output = String>
+where
+    I: Stream<Token = char>,
+    I::Error: ParseError<I::Token, I::Range, I::Position>,
+{
+    (
+        many1::<String, _, _>(alpha_num().or(period())),
+        token('@'),
+        many1::<String, _, _>(alpha_num()),
+    )
+        .map(|(ip, _, lnet)| format!("{ip}@{lnet}"))
+        .message("while parsing nid")
+}
+
+/// Parses a single obdfilter.*OST*.exports.*.stats line
+fn exports_stat<I>() -> impl Parser<I, Output = ExportStats>
+where
+    I: Stream<Token = char>,
+    I::Error: ParseError<I::Token, I::Range, I::Position>,
+{
+    attempt((
+        nid().skip(period()),
+        string("stats").skip(equals()),
+        stats(),
+    ))
+    .map(|(nid, _, stats)| ExportStats { nid, stats })
+    .message("while parsing export_stats")
+}
+
+/// Parses multiple obdfilter.*OST*.exports.*.stats lines
+pub(crate) fn exports_stats<I>() -> impl Parser<I, Output = Vec<ExportStats>>
+where
+    I: Stream<Token = char>,
+    I::Error: ParseError<I::Token, I::Range, I::Position>,
+{
+    (many(exports_stat())).map(|x| x)
+}