diff options
Diffstat (limited to 'tests')
| -rw-r--r-- | tests/purgatory_persistence.rs | 21 |
1 files changed, 7 insertions, 14 deletions
diff --git a/tests/purgatory_persistence.rs b/tests/purgatory_persistence.rs index acefb41..fe37c33 100644 --- a/tests/purgatory_persistence.rs +++ b/tests/purgatory_persistence.rs | |||
| @@ -260,8 +260,7 @@ async fn test_purgatory_downtime_adjustment() { | |||
| 260 | let purgatory = Purgatory::new(&git_data_path); | 260 | let purgatory = Purgatory::new(&git_data_path); |
| 261 | let keys = Keys::generate(); | 261 | let keys = Keys::generate(); |
| 262 | 262 | ||
| 263 | let state_event = create_state_event_with_refs(&keys, "repo1", &[("main", "abc123")]) | 263 | let state_event = create_state_event_with_refs(&keys, "repo1", &[("main", "abc123")]).unwrap(); |
| 264 | .unwrap(); | ||
| 265 | 264 | ||
| 266 | purgatory.add_state(state_event.clone(), "repo1".to_string(), keys.public_key()); | 265 | purgatory.add_state(state_event.clone(), "repo1".to_string(), keys.public_key()); |
| 267 | 266 | ||
| @@ -339,8 +338,7 @@ async fn test_purgatory_file_cleanup_after_restore() { | |||
| 339 | let purgatory = Purgatory::new(&git_data_path); | 338 | let purgatory = Purgatory::new(&git_data_path); |
| 340 | let keys = Keys::generate(); | 339 | let keys = Keys::generate(); |
| 341 | 340 | ||
| 342 | let state_event = create_state_event_with_refs(&keys, "repo1", &[("main", "abc123")]) | 341 | let state_event = create_state_event_with_refs(&keys, "repo1", &[("main", "abc123")]).unwrap(); |
| 343 | .unwrap(); | ||
| 344 | 342 | ||
| 345 | purgatory.add_state(state_event, "repo1".to_string(), keys.public_key()); | 343 | purgatory.add_state(state_event, "repo1".to_string(), keys.public_key()); |
| 346 | 344 | ||
| @@ -546,10 +544,8 @@ async fn test_purgatory_multiple_state_events_same_identifier() { | |||
| 546 | let keys1 = Keys::generate(); | 544 | let keys1 = Keys::generate(); |
| 547 | let keys2 = Keys::generate(); | 545 | let keys2 = Keys::generate(); |
| 548 | 546 | ||
| 549 | let event1 = create_state_event_with_refs(&keys1, "repo1", &[("main", "abc123")]) | 547 | let event1 = create_state_event_with_refs(&keys1, "repo1", &[("main", "abc123")]).unwrap(); |
| 550 | .unwrap(); | 548 | let event2 = create_state_event_with_refs(&keys2, "repo1", &[("main", "def456")]).unwrap(); |
| 551 | let event2 = create_state_event_with_refs(&keys2, "repo1", &[("main", "def456")]) | ||
| 552 | .unwrap(); | ||
| 553 | 549 | ||
| 554 | purgatory.add_state(event1.clone(), "repo1".to_string(), keys1.public_key()); | 550 | purgatory.add_state(event1.clone(), "repo1".to_string(), keys1.public_key()); |
| 555 | purgatory.add_state(event2.clone(), "repo1".to_string(), keys2.public_key()); | 551 | purgatory.add_state(event2.clone(), "repo1".to_string(), keys2.public_key()); |
| @@ -579,8 +575,7 @@ async fn test_purgatory_continues_working_after_restore() { | |||
| 579 | let purgatory = Purgatory::new(&git_data_path); | 575 | let purgatory = Purgatory::new(&git_data_path); |
| 580 | let keys = Keys::generate(); | 576 | let keys = Keys::generate(); |
| 581 | 577 | ||
| 582 | let event1 = create_state_event_with_refs(&keys, "repo1", &[("main", "abc123")]) | 578 | let event1 = create_state_event_with_refs(&keys, "repo1", &[("main", "abc123")]).unwrap(); |
| 583 | .unwrap(); | ||
| 584 | 579 | ||
| 585 | purgatory.add_state(event1.clone(), "repo1".to_string(), keys.public_key()); | 580 | purgatory.add_state(event1.clone(), "repo1".to_string(), keys.public_key()); |
| 586 | 581 | ||
| @@ -591,8 +586,7 @@ async fn test_purgatory_continues_working_after_restore() { | |||
| 591 | purgatory2.restore_from_disk(&state_path).unwrap(); | 586 | purgatory2.restore_from_disk(&state_path).unwrap(); |
| 592 | 587 | ||
| 593 | // Add new events after restore | 588 | // Add new events after restore |
| 594 | let event2 = create_state_event_with_refs(&keys, "repo2", &[("main", "xyz789")]) | 589 | let event2 = create_state_event_with_refs(&keys, "repo2", &[("main", "xyz789")]).unwrap(); |
| 595 | .unwrap(); | ||
| 596 | 590 | ||
| 597 | purgatory2.add_state(event2.clone(), "repo2".to_string(), keys.public_key()); | 591 | purgatory2.add_state(event2.clone(), "repo2".to_string(), keys.public_key()); |
| 598 | 592 | ||
| @@ -673,8 +667,7 @@ async fn test_purgatory_entries_expired_during_downtime() { | |||
| 673 | let purgatory = Purgatory::new(&git_data_path); | 667 | let purgatory = Purgatory::new(&git_data_path); |
| 674 | let keys = Keys::generate(); | 668 | let keys = Keys::generate(); |
| 675 | 669 | ||
| 676 | let event = create_state_event_with_refs(&keys, "repo1", &[("main", "abc123")]) | 670 | let event = create_state_event_with_refs(&keys, "repo1", &[("main", "abc123")]).unwrap(); |
| 677 | .unwrap(); | ||
| 678 | 671 | ||
| 679 | purgatory.add_state(event.clone(), "repo1".to_string(), keys.public_key()); | 672 | purgatory.add_state(event.clone(), "repo1".to_string(), keys.public_key()); |
| 680 | 673 | ||