use serde::Serialize;
use std::collections::HashMap;
use std::net::UdpSocket;
-use std::time::{Duration, SystemTime};
+use std::time::{Duration, SystemTime, UNIX_EPOCH};
const MESSAGE_SIZE: usize = 12;
const LOGFILENAME: &str = "log.csv";
#[derive(Debug)]
struct Message {
key: MessageKey,
- t: SystemTime,
+ t: u64,
}
impl From<&[u8; MESSAGE_SIZE]> for Message {
fn from(value: &[u8; MESSAGE_SIZE]) -> Self {
let ago = u32::from_be_bytes(value[8..=11].try_into().expect("I can't count"));
+ let press_time = SystemTime::now() - Duration::new(ago.into(), 0);
Self {
key: MessageKey {
epoch: u32::from_be_bytes(value[0..=3].try_into().expect("I can't count")),
device: u16::from_be_bytes(value[4..=5].try_into().expect("I can't count")),
seq: u16::from_be_bytes(value[6..=7].try_into().expect("I can't count")),
},
- t: SystemTime::now() - Duration::new(ago.into(), 0),
+ t: press_time
+ .duration_since(UNIX_EPOCH)
+ .expect("Bad time?")
+ .as_secs(),
}
}
}
#[derive(Debug)]
struct Range {
- start: SystemTime,
- end: SystemTime,
+ start: u64,
+ end: u64,
}
impl Range {
- fn new(t: &SystemTime) -> Self {
+ fn new(t: &u64) -> Self {
Self { start: *t, end: *t }
}
- fn contains(&self, t: &SystemTime) -> bool {
+ fn contains(&self, t: &u64) -> bool {
t > &self.start && t < &self.end
}
- fn extend(&mut self, t: &SystemTime) {
+ fn extend(&mut self, t: &u64) {
if t < &self.start {
self.start = *t;
}