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

tests: an urgency in the same receipt as her turn is consumed, not pending (strictly after)

Browse source 
Co-Authored-By: Claude Sonnet 5.5 <noreply@anthropic.com>
This commit is contained in:
Meta Vens 2026-10-31 10:17:08 +01:00
commit b69d02a4ce
1 changed files with 22 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

22
crates/mind-body/src/heartbeat/tests.rs
View file

@ -720,6 +720,28 @@ fn an_urgency_is_consumed_by_a_turn_admitted_after_it_by_ordinal_not_by_the_cloc
assert_eq!(trace.instances[ANN].urgency_permille, 700, "the clock stepping back does not consume it");
}
#[test]
fn an_urgency_admitted_in_the_batch_of_her_turn_is_consumed_by_it() {
let rig = Rig::new();
rig.turn(BOB, 3000);
rig.minds[ANN].admit_at(rig.now() - Duration::seconds(3000));
rig.minds[ANN].committed(vec![
run_in(NAMES[ANN], "joint", RunTurn::PersonaTurn, RunOperator::Mind, &[]),
eureka_pipeline::PipelineDocument::Pulse(eureka_pipeline::PipelinePulse {
instance: Slug(NAMES[ANN].into()),
label: eureka_pipeline::Label("joint-p".into()),
tempo_vote_beat_s: None,
tempo_vote_withdrawn: false,
urgency_permille: Some(800),
note: "test".into(),
}),
]);
rig.minds[ANN].committed(vec![close(reference(K::Run, &format!("{}:run:joint", NAMES[ANN])), recorded())]);
rig.poll();
let trace = rig.store.traces.borrow().last().cloned().unwrap();
assert_eq!(trace.instances[ANN].urgency_permille, 0, "one receipt is one ordinal: a declaration is pending only when admitted strictly after her turn");
}
#[test]
fn every_newest_read_asks_for_exactly_one_header() {
let rig = Rig::new();