@@ -482,47 +482,46 @@ pub async fn gitlab_tokens_actor(
482482
483483 // We now wait for some messages
484484 loop {
485- let msg = receiver. recv ( ) . await ;
486- if let Some ( msg_value) = msg {
487- match msg_value {
488- Message :: Get { respond_to } => {
489- debug ! ( "received Message::Get" ) ;
490- respond_to. send ( state. clone ( ) ) . unwrap_or_else ( |_| {
491- warn ! ( "Failed to send reponse : oneshot channel was closed" ) ;
492- } ) ;
493- }
494- Message :: Update => {
495- // We are going to spawn a async task to get the data from gitlab.
496- // This task will send us Message::Set with the result to
497- // update our 'state' variable
498- debug ! ( "received Message::Update" ) ;
499- tokio:: spawn ( get_gitlab_data (
500- gitlab_connection. clone ( ) ,
501- owned_entities_only,
502- sender. clone ( ) ,
503- max_concurrent_requests,
504- skip_users_tokens,
505- skip_non_expiring_tokens,
506- ) ) ;
507- }
508- Message :: Set ( gitlab_data) => {
509- debug ! ( "received Message::Set" ) ;
510- match gitlab_data {
511- Ok ( data) => {
512- if data. is_empty ( ) {
513- warn ! ( "No token has been found" ) ;
514- state = ActorState :: NoToken ;
515- } else {
516- state = ActorState :: Loaded ( data) ;
517- }
485+ let Some ( msg) = receiver. recv ( ) . await else {
486+ error ! ( "recv failed" ) ;
487+ break ;
488+ } ;
489+
490+ match msg {
491+ Message :: Get { respond_to } => {
492+ debug ! ( "received Message::Get" ) ;
493+ respond_to. send ( state. clone ( ) ) . unwrap_or_else ( |_| {
494+ warn ! ( "Failed to send reponse : oneshot channel was closed" ) ;
495+ } ) ;
496+ }
497+ Message :: Update => {
498+ // We are going to spawn a async task to get the data from gitlab.
499+ // This task will send us Message::Set with the result to
500+ // update our 'state' variable
501+ debug ! ( "received Message::Update" ) ;
502+ tokio:: spawn ( get_gitlab_data (
503+ gitlab_connection. clone ( ) ,
504+ owned_entities_only,
505+ sender. clone ( ) ,
506+ max_concurrent_requests,
507+ skip_users_tokens,
508+ skip_non_expiring_tokens,
509+ ) ) ;
510+ }
511+ Message :: Set ( gitlab_data) => {
512+ debug ! ( "received Message::Set" ) ;
513+ match gitlab_data {
514+ Ok ( data) => {
515+ if data. is_empty ( ) {
516+ warn ! ( "No token has been found" ) ;
517+ state = ActorState :: NoToken ;
518+ } else {
519+ state = ActorState :: Loaded ( data) ;
518520 }
519- Err ( err) => state = ActorState :: Error ( err) ,
520521 }
522+ Err ( err) => state = ActorState :: Error ( err) ,
521523 }
522524 }
523- } else {
524- error ! ( "recv failed" ) ;
525- break ;
526525 }
527526 }
528527}
0 commit comments