GameCult/Odin
Watch
9
0
Fork
You've already forked Odin
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Use observation time for Move freshness

Browse source
This commit is contained in:
Meta Vens 2026-06-14 14:15:27 +01:00
commit d995fb8503
1 changed files with 8 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

9
crates/muninn-daemon/src/main.rs
View file

@ -1217,7 +1217,7 @@ fn verify_move_sources_fresh(
let latest = states
.iter()
.filter(|state| state.host_id == options.host_id && state.move_id == source.move_id)
.max_by_key(|state| state.sequence)
.max_by_key(|state| unix_timestamp_sort_key(&state.observed_at))
.ok_or_else(|| {
anyhow!(
"Muninn Move source {} has no controller-state records",
@ -1252,6 +1252,10 @@ fn parse_unix_timestamp(value: &str) -> Result<u64> {
.context("timestamp seconds must be an integer")
}
fn unix_timestamp_sort_key(value: &str) -> u64 {
parse_unix_timestamp(value).unwrap_or(0)
}
fn request_move_light(options: Options) -> Result<()> {
ensure_state_dirs(&options)?;
let mut node = open_node(&options, "muninn-move-light-request")?;
@ -1300,6 +1304,9 @@ fn move_state_status(options: Options) -> Result<()> {
states.sort_by(|a, b| {
a.stream_id
.cmp(&b.stream_id)
.then(unix_timestamp_sort_key(&a.observed_at).cmp(&unix_timestamp_sort_key(
&b.observed_at,
)))
.then(a.sequence.cmp(&b.sequence))
});
if states.is_empty() {