Function extract_stamps

nodedb/src/event/bitemporal_extract.rs:32–45

Extract `(system_time_ms, valid_time_ms)` from a serialized row payload. See module docs for the contract.

(payload: Option<&[u8]>)

/// Extract `(system_time_ms, valid_time_ms)` from a serialized row
/// payload. See module docs for the contract.
pub fn extract_stamps(payload: Option<&[u8]>) -> (Option<i64>, Option<i64>) {
    let bytes = match payload {
        Some(b) => b,
        None => return (None, None),
    };
    let map = match deserialize_event_payload(bytes) {
        Some(m) => m,
        None => return (None, None),
    };
    (
        extract_i64(&map, TS_SYSTEM),
        extract_i64(&map, TS_VALID_FROM),
    )
}

fn extract_i64(map: &serde_json::Map<String, serde_json::Value>, key: &str) -> Option<i64> {
    map.get(key).and_then(|v| v.as_i64())