@@ -727,7 +727,7 @@ pub(crate) async fn build_queue_handler(
727
727
// reverse the list, so the oldest comes first
728
728
active_deployments. reverse ( ) ;
729
729
730
- Ok ( ( queue, active_deployments) )
730
+ Ok ( ( queue, dbg ! ( active_deployments) ) )
731
731
} )
732
732
. await ?;
733
733
@@ -1378,17 +1378,32 @@ mod tests {
1378
1378
fn test_deployment_queue ( ) {
1379
1379
wrapper ( |env| {
1380
1380
let web = env. frontend ( ) ;
1381
+ let db = env. db ( ) ;
1381
1382
1382
- cdn:: queue_crate_invalidation ( & mut * env . db ( ) . conn ( ) , & env. config ( ) , "krate_2" ) ?;
1383
+ cdn:: queue_crate_invalidation ( & mut * ( db . conn ( ) ) , & env. config ( ) , "krate_2" ) ?;
1383
1384
1384
- let empty = kuchiki:: parse_html ( ) . one ( web. get ( "/releases/queue" ) . send ( ) ?. text ( ) ?) ;
1385
- assert ! ( empty
1385
+ let response = web. get ( "/releases/queue" ) . send ( ) ?;
1386
+ assert ! ( response. status( ) . is_success( ) ) ;
1387
+
1388
+ let content = kuchiki:: parse_html ( ) . one ( response. text ( ) ?) ;
1389
+
1390
+ let headings: Vec < _ > = content
1386
1391
. select ( ".release > strong" )
1387
1392
. expect ( "missing heading" )
1388
- . any ( |el| el . text_contents ( ) . contains ( "active CDN deployments" ) ) ) ;
1393
+ . collect ( ) ;
1389
1394
1390
- let full = kuchiki:: parse_html ( ) . one ( web. get ( "/releases/queue" ) . send ( ) ?. text ( ) ?) ;
1391
- let items = full
1395
+ assert ! (
1396
+ headings
1397
+ . iter( )
1398
+ . any( |el| el. text_contents( ) . contains( "active CDN deployments" ) ) ,
1399
+ "{:?}" ,
1400
+ headings
1401
+ . iter( )
1402
+ . map( |el| el. text_contents( ) )
1403
+ . collect:: <Vec <_>>( )
1404
+ ) ;
1405
+
1406
+ let items = content
1392
1407
. select ( ".queue-list > li" )
1393
1408
. expect ( "missing list items" )
1394
1409
. collect :: < Vec < _ > > ( ) ;
0 commit comments