mirrors/lemmy
1
0
Fork 0
mirror of https://github.com/LemmyNet/lemmy.git synced 2024-11-18 15:31:13 +00:00
Code Issues Projects Releases Wiki Activity

fixes

Browse source
This commit is contained in:
Felix Ableitner 2024-05-30 12:21:53 +02:00
parent ed48d3bc9d
commit 17336b9797
1 changed files with 5 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
crates/federate/src/worker.rs
View file

@ -314,13 +314,12 @@ mod test {
let sent = send_activity(person.actor_id, &context).await?; let sent = send_activity(person.actor_id, &context).await?;
sleep(WORK_FINISHED_RECHECK_DELAY).await; sleep(WORK_FINISHED_RECHECK_DELAY * 2).await;
// first receive at startup // first receive at startup
let rcv = stats_receiver.recv().await.unwrap(); let rcv = stats_receiver.recv().await.unwrap();
assert_eq!(instance.id, rcv.0); assert_eq!(instance.id, rcv.state.instance_id);
assert_eq!(instance.id, rcv.1.instance_id); assert_eq!(Some(ActivityId(0)), rcv.state.last_successful_id);
assert_eq!(Some(ActivityId(0)), rcv.1.last_successful_id);
// receive for successfully sent activity // receive for successfully sent activity
let inbox_rcv = inbox_receiver.recv().await.unwrap(); let inbox_rcv = inbox_receiver.recv().await.unwrap();
@ -328,9 +327,8 @@ mod test {
assert_eq!(&sent.data, parsed_activity.inner()); assert_eq!(&sent.data, parsed_activity.inner());
let rcv = stats_receiver.recv().await.unwrap(); let rcv = stats_receiver.recv().await.unwrap();
assert_eq!(instance.id, rcv.0); assert_eq!(instance.id, rcv.state.instance_id);
assert_eq!(instance.id, rcv.1.instance_id); assert_eq!(Some(sent.id), rcv.state.last_successful_id);
assert_eq!(Some(sent.id), rcv.1.last_successful_id);
// cleanup // cleanup
cancel.cancel(); cancel.cancel();