@@ -37,8 +37,9 @@ pub async fn run(cli: &Cli, command: &UsersCommand) -> Result<()> {
3737
3838async fn build_auth (
3939 cli : & Cli ,
40- ) -> Result < rs_firebase_admin_sdk:: auth:: FirebaseAuth < rs_firebase_admin_sdk:: client:: ReqwestApiClient > >
41- {
40+ ) -> Result <
41+ rs_firebase_admin_sdk:: auth:: FirebaseAuth < rs_firebase_admin_sdk:: client:: ReqwestApiClient > ,
42+ > {
4243 let conn = resolve_connection (
4344 & cli. profile ,
4445 & cli. project ,
@@ -85,7 +86,9 @@ fn format_claims(user: &User) -> String {
8586}
8687
8788async fn lookup_user_by_email (
88- auth : & rs_firebase_admin_sdk:: auth:: FirebaseAuth < rs_firebase_admin_sdk:: client:: ReqwestApiClient > ,
89+ auth : & rs_firebase_admin_sdk:: auth:: FirebaseAuth <
90+ rs_firebase_admin_sdk:: client:: ReqwestApiClient ,
91+ > ,
8992 email : & str ,
9093) -> Result < User > {
9194 let ids = UserIdentifiers :: builder ( )
@@ -180,8 +183,7 @@ async fn create(
180183 ( "Email" , user. email. unwrap_or( email) ) ,
181184 (
182185 "Display Name" ,
183- user. display_name
184- . unwrap_or_else( || "N/A" . to_string( ) ) ,
186+ user. display_name. unwrap_or_else( || "N/A" . to_string( ) ) ,
185187 ) ,
186188 ] ;
187189 if auto_generated {
@@ -202,9 +204,7 @@ async fn disable(cli: &Cli, email: Option<String>) -> Result<()> {
202204 return Ok ( ( ) ) ;
203205 }
204206
205- let update = UserUpdate :: builder ( user. uid )
206- . disabled ( true )
207- . build ( ) ;
207+ let update = UserUpdate :: builder ( user. uid ) . disabled ( true ) . build ( ) ;
208208 auth. update_user ( update) . await . into_anyhow ( ) ?;
209209
210210 render_message ( & format ! ( "User {email} has been disabled." ) ) ;
@@ -216,9 +216,7 @@ async fn enable(cli: &Cli, email: Option<String>) -> Result<()> {
216216 let email = resolve_email ( email) ?;
217217 let user = lookup_user_by_email ( & auth, & email) . await ?;
218218
219- let update = UserUpdate :: builder ( user. uid )
220- . disabled ( false )
221- . build ( ) ;
219+ let update = UserUpdate :: builder ( user. uid ) . disabled ( false ) . build ( ) ;
222220 auth. update_user ( update) . await . into_anyhow ( ) ?;
223221
224222 render_message ( & format ! ( "User {email} has been enabled." ) ) ;
@@ -275,9 +273,7 @@ async fn remove(cli: &Cli, csv_path: Option<String>) -> Result<()> {
275273 let mut resolved = Vec :: with_capacity ( values. len ( ) ) ;
276274 let mut not_found: Vec < String > = Vec :: new ( ) ;
277275 for email in & values {
278- let ids = UserIdentifiers :: builder ( )
279- . with_email ( email. clone ( ) )
280- . build ( ) ;
276+ let ids = UserIdentifiers :: builder ( ) . with_email ( email. clone ( ) ) . build ( ) ;
281277 match auth. get_user ( ids) . await . into_anyhow ( ) ? {
282278 Some ( user) => resolved. push ( user. uid ) ,
283279 None => not_found. push ( email. clone ( ) ) ,
@@ -290,7 +286,12 @@ async fn remove(cli: &Cli, csv_path: Option<String>) -> Result<()> {
290286 eprintln ! (
291287 "Warning: {} email(s) not found and will be skipped: {}" ,
292288 not_found. len( ) ,
293- not_found. iter( ) . take( 5 ) . cloned( ) . collect:: <Vec <_>>( ) . join( ", " )
289+ not_found
290+ . iter( )
291+ . take( 5 )
292+ . cloned( )
293+ . collect:: <Vec <_>>( )
294+ . join( ", " )
294295 ) ;
295296 if not_found. len ( ) > 5 {
296297 eprintln ! ( " ... and {} more" , not_found. len( ) - 5 ) ;
@@ -404,9 +405,8 @@ async fn list_inactive(cli: &Cli, days: u64) -> Result<()> {
404405 . as_millis ( ) as i64
405406 - ( days as i64 * 86_400 * 1000 ) ;
406407
407- let threshold_dt =
408- OffsetDateTime :: from_unix_timestamp_nanos ( threshold_ms as i128 * 1_000_000 )
409- . map_err ( |e| anyhow ! ( "Invalid threshold timestamp: {e}" ) ) ?;
408+ let threshold_dt = OffsetDateTime :: from_unix_timestamp_nanos ( threshold_ms as i128 * 1_000_000 )
409+ . map_err ( |e| anyhow ! ( "Invalid threshold timestamp: {e}" ) ) ?;
410410
411411 let spinner = ProgressBar :: new_spinner ( ) ;
412412 spinner. set_style (
@@ -446,10 +446,7 @@ async fn list_inactive(cli: &Cli, days: u64) -> Result<()> {
446446 ] ) ;
447447 }
448448 }
449- spinner. set_message ( format ! (
450- "scanned {scanned}, found {} inactive" ,
451- rows. len( )
452- ) ) ;
449+ spinner. set_message ( format ! ( "scanned {scanned}, found {} inactive" , rows. len( ) ) ) ;
453450 page = Some ( user_list) ;
454451 }
455452 None => break ,
0 commit comments