From 6f02fc13af98ee5be1042f1640e20178ee179a1f Mon Sep 17 00:00:00 2001
From: Dominik Werder <dominik.werder@gmail.com>
Date: Mon, 17 Feb 2025 13:35:53 +0100
Subject: [PATCH] Factor out msp div

---
 Cargo.toml |  3 ++-
 src/dbg.rs | 13 ++++++++++
 src/lib.rs |  2 ++
 src/msp.rs | 75 ++++++++++++++++++++++++++++++++++++++++++++++++++++++
 4 files changed, 92 insertions(+), 1 deletion(-)
 create mode 100644 src/dbg.rs
 create mode 100644 src/msp.rs

diff --git a/Cargo.toml b/Cargo.toml
index 1362c3f..e38fd75 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -6,4 +6,5 @@ edition = "2021"
 
 [dependencies]
 serde = { version = "1.0", features = ["derive"] }
-#log = { path = "../log" }
+netpod = { path = "../daqbuf-netpod", package = "daqbuf-netpod" }
+autoerr = "0.0.3"
diff --git a/src/dbg.rs b/src/dbg.rs
new file mode 100644
index 0000000..b106f64
--- /dev/null
+++ b/src/dbg.rs
@@ -0,0 +1,13 @@
+pub fn dbg_chn(chn: &str) -> bool {
+    if true {
+        let chns = [
+            "ARS05-RAMP-0060:COUNTER",
+            "SSL2-LENC-MF05:H_SCALE",
+            "SINEG01:QE-B1-OP",
+            "STSRD01-TCWL-STX02:AMP1CURR",
+        ];
+        chns.contains(&chn)
+    } else {
+        false
+    }
+}
diff --git a/src/lib.rs b/src/lib.rs
index d82fc15..869c2b3 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -1,3 +1,5 @@
+pub mod dbg;
+pub mod msp;
 pub mod series;
 
 pub use series::ChannelStatusSeriesId;
diff --git a/src/msp.rs b/src/msp.rs
new file mode 100644
index 0000000..7c1df03
--- /dev/null
+++ b/src/msp.rs
@@ -0,0 +1,75 @@
+use netpod::DtMs;
+use std::fmt;
+
+autoerr::create_error_v1!(
+    name(Error, "BinMsp"),
+    enum variants {
+        PrebinnedPartitioningInvalid,
+    },
+);
+
+pub enum PrebinnedPartitioning {
+    Sec1,
+    Sec10,
+    Min1,
+    Min10,
+    Hour1,
+    Day1,
+}
+
+impl PrebinnedPartitioning {
+    pub fn bin_len(&self) -> DtMs {
+        use PrebinnedPartitioning::*;
+        match self {
+            Sec1 => DtMs::from_ms_u64(1000 * 1),
+            Sec10 => DtMs::from_ms_u64(1000 * 10),
+            Min1 => DtMs::from_ms_u64(1000 * 60 * 1),
+            Min10 => DtMs::from_ms_u64(1000 * 60 * 10),
+            Hour1 => DtMs::from_ms_u64(1000 * 60 * 60 * 1),
+            Day1 => DtMs::from_ms_u64(1000 * 60 * 60 * 24),
+        }
+    }
+
+    pub fn msp_div(&self) -> DtMs {
+        use PrebinnedPartitioning::*;
+        match self {
+            Sec1 => DtMs::from_ms_u64(1000 * 60 * 10),
+            Sec10 => DtMs::from_ms_u64(1000 * 60 * 60 * 2),
+            Min1 => DtMs::from_ms_u64(1000 * 60 * 60 * 8),
+            Min10 => DtMs::from_ms_u64(1000 * 60 * 60 * 24 * 4),
+            Hour1 => DtMs::from_ms_u64(1000 * 60 * 60 * 24 * 28),
+            Day1 => DtMs::from_ms_u64(1000 * 60 * 60 * 24 * 400),
+        }
+    }
+
+    pub fn off_max(&self) -> u32 {
+        self.msp_div().ms() as u32 / self.bin_len().ms() as u32
+    }
+
+    pub fn clamp_off(&self, off: u32) -> u32 {
+        self.off_max().min(off)
+    }
+}
+
+impl TryFrom<DtMs> for PrebinnedPartitioning {
+    type Error = Error;
+
+    fn try_from(value: DtMs) -> Result<Self, Self::Error> {
+        use PrebinnedPartitioning::*;
+        if value == DtMs::from_ms_u64(1000) {
+            Ok(Sec1)
+        } else if value == DtMs::from_ms_u64(1000 * 10) {
+            Ok(Sec10)
+        } else if value == DtMs::from_ms_u64(1000 * 60) {
+            Ok(Min1)
+        } else if value == DtMs::from_ms_u64(1000 * 60 * 10) {
+            Ok(Min10)
+        } else if value == DtMs::from_ms_u64(1000 * 60 * 60) {
+            Ok(Hour1)
+        } else if value == DtMs::from_ms_u64(1000 * 60 * 60 * 24) {
+            Ok(Day1)
+        } else {
+            Err(Error::PrebinnedPartitioningInvalid)
+        }
+    }
+}