@@ -629,7 +629,10 @@ mod tests {
629629 let timestamps: Vec < u64 > = results. iter ( ) . map ( |e| e. timestamp_ns ) . collect ( ) ;
630630 let mut sorted = timestamps. clone ( ) ;
631631 sorted. sort_unstable ( ) ;
632- assert_eq ! ( timestamps, sorted, "W5-INV-CHAIN-ORDER: results must be in ASC order" ) ;
632+ assert_eq ! (
633+ timestamps, sorted,
634+ "W5-INV-CHAIN-ORDER: results must be in ASC order"
635+ ) ;
633636 }
634637
635638 // ── New Test 5 ──────────────────────────────────────────────────────────
@@ -642,11 +645,36 @@ mod tests {
642645 let spo_b = 0xBBBB_u64 ;
643646
644647 // 5 entries with timestamps 100-500
645- corpus. insert ( WitnessEntry { spo : spo_a, timestamp_ns : 100 , source_url : None , evidence_blob : Bytes :: new ( ) } ) ;
646- corpus. insert ( WitnessEntry { spo : spo_b, timestamp_ns : 200 , source_url : None , evidence_blob : Bytes :: new ( ) } ) ;
647- corpus. insert ( WitnessEntry { spo : spo_a, timestamp_ns : 300 , source_url : None , evidence_blob : Bytes :: new ( ) } ) ;
648- corpus. insert ( WitnessEntry { spo : spo_b, timestamp_ns : 400 , source_url : None , evidence_blob : Bytes :: new ( ) } ) ;
649- corpus. insert ( WitnessEntry { spo : spo_a, timestamp_ns : 500 , source_url : None , evidence_blob : Bytes :: new ( ) } ) ;
648+ corpus. insert ( WitnessEntry {
649+ spo : spo_a,
650+ timestamp_ns : 100 ,
651+ source_url : None ,
652+ evidence_blob : Bytes :: new ( ) ,
653+ } ) ;
654+ corpus. insert ( WitnessEntry {
655+ spo : spo_b,
656+ timestamp_ns : 200 ,
657+ source_url : None ,
658+ evidence_blob : Bytes :: new ( ) ,
659+ } ) ;
660+ corpus. insert ( WitnessEntry {
661+ spo : spo_a,
662+ timestamp_ns : 300 ,
663+ source_url : None ,
664+ evidence_blob : Bytes :: new ( ) ,
665+ } ) ;
666+ corpus. insert ( WitnessEntry {
667+ spo : spo_b,
668+ timestamp_ns : 400 ,
669+ source_url : None ,
670+ evidence_blob : Bytes :: new ( ) ,
671+ } ) ;
672+ corpus. insert ( WitnessEntry {
673+ spo : spo_a,
674+ timestamp_ns : 500 ,
675+ source_url : None ,
676+ evidence_blob : Bytes :: new ( ) ,
677+ } ) ;
650678
651679 // Evict entries with ts < 300 (removes ts=100, ts=200)
652680 let evicted = corpus. evict_stale_before ( 300 ) ;
@@ -655,7 +683,11 @@ mod tests {
655683
656684 // spo_a: ts=300 and ts=500 remain
657685 let a_results: Vec < u64 > = corpus. query ( spo_a) . map ( |e| e. timestamp_ns ) . collect ( ) ;
658- assert_eq ! ( a_results, vec![ 300 , 500 ] , "spo_a: ts=300 and ts=500 remain, in order" ) ;
686+ assert_eq ! (
687+ a_results,
688+ vec![ 300 , 500 ] ,
689+ "spo_a: ts=300 and ts=500 remain, in order"
690+ ) ;
659691
660692 // spo_b: ts=400 remains
661693 let b_results: Vec < u64 > = corpus. query ( spo_b) . map ( |e| e. timestamp_ns ) . collect ( ) ;
@@ -714,18 +746,29 @@ mod tests {
714746
715747 // cam_pq_search with k=3: must return exactly 3 entries
716748 let results = corpus. cam_pq_search ( spo, 3 ) ;
717- assert_eq ! ( results. len( ) , 3 , "cam_pq_search must return exactly k=3 entries" ) ;
749+ assert_eq ! (
750+ results. len( ) ,
751+ 3 ,
752+ "cam_pq_search must return exactly k=3 entries"
753+ ) ;
718754
719755 // The 3 returned must be the first 3 in chain order (ts=10,20,30)
720756 let timestamps: Vec < u64 > = results. iter ( ) . map ( |e| e. timestamp_ns ) . collect ( ) ;
721757 assert_eq ! ( timestamps, vec![ 10 , 20 , 30 ] , "first 3 in chain order" ) ;
722758
723759 // k > total entries: returns all
724760 let all_results = corpus. cam_pq_search ( spo, 100 ) ;
725- assert_eq ! ( all_results. len( ) , 10 , "cam_pq_search(k>N) returns all N entries" ) ;
761+ assert_eq ! (
762+ all_results. len( ) ,
763+ 10 ,
764+ "cam_pq_search(k>N) returns all N entries"
765+ ) ;
726766
727767 // Unknown spo: returns empty
728768 let empty = corpus. cam_pq_search ( 0xDEAD , 5 ) ;
729- assert ! ( empty. is_empty( ) , "cam_pq_search on unknown spo returns empty" ) ;
769+ assert ! (
770+ empty. is_empty( ) ,
771+ "cam_pq_search on unknown spo returns empty"
772+ ) ;
730773 }
731774}
0 commit comments