Factor out msp div

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"

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
+    }
+}

src/lib.rs

@@ -1,3 +1,5 @@
+pub mod dbg;
+pub mod msp;
 pub mod series;
 
 pub use series::ChannelStatusSeriesId;

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)
+        }
+    }
+}