@@ -19,7 +19,7 @@ use crate::{
19
19
Application , Auth ,
20
20
} ;
21
21
use adapter:: { client:: Locked , Adapter , Dummy } ;
22
- use axum:: { Extension , Json , extract:: Path } ;
22
+ use axum:: { extract:: Path , Extension , Json } ;
23
23
use futures:: future:: try_join_all;
24
24
use hyper:: { Body , Request , Response } ;
25
25
use primitives:: {
@@ -275,7 +275,9 @@ pub async fn get_spender_limits_axum<C: Locked + 'static>(
275
275
) -> Result < Json < SpenderResponse > , ResponseError > {
276
276
let channel = & channel_context. context ;
277
277
278
- let spender = params. get ( "addr" ) . ok_or ( ResponseError :: BadRequest ( "Invalid spender address" . to_string ( ) ) ) ?;
278
+ let spender = params. get ( "addr" ) . ok_or_else ( || ResponseError :: BadRequest (
279
+ "Invalid spender address" . to_string ( ) ,
280
+ ) ) ?;
279
281
let spender = Address :: from_str ( spender) ?;
280
282
281
283
let latest_spendable = fetch_spendable ( app. pool . clone ( ) , & spender, & channel. id ( ) ) . await ?;
@@ -295,12 +297,14 @@ pub async fn get_spender_limits_axum<C: Locked + 'static>(
295
297
296
298
let new_state = match get_corresponding_new_state ( & app. pool , & app. logger , channel) . await ? {
297
299
Some ( new_state) => new_state,
298
- None => return Ok ( Json ( SpenderResponse {
299
- spender : Spender {
300
- total_deposited : latest_spendable. deposit . total ,
301
- total_spent : None ,
302
- } ,
303
- } ) ) ,
300
+ None => {
301
+ return Ok ( Json ( SpenderResponse {
302
+ spender : Spender {
303
+ total_deposited : latest_spendable. deposit . total ,
304
+ total_spent : None ,
305
+ } ,
306
+ } ) )
307
+ }
304
308
} ;
305
309
306
310
let total_spent = new_state
@@ -379,7 +383,7 @@ pub async fn get_all_spender_limits<C: Locked + 'static>(
379
383
pub async fn get_all_spender_limits_axum < C : Locked + ' static > (
380
384
Extension ( app) : Extension < Arc < Application < C > > > ,
381
385
Extension ( channel_context) : Extension < ChainOf < Channel > > ,
382
- Qs ( query) : Qs < AllSpendersQuery >
386
+ Qs ( query) : Qs < AllSpendersQuery > ,
383
387
) -> Result < Json < AllSpendersResponse > , ResponseError > {
384
388
let channel = channel_context. context ;
385
389
@@ -493,7 +497,9 @@ pub async fn add_spender_leaf_axum<C: Locked + 'static>(
493
497
Extension ( app) : Extension < Arc < Application < C > > > ,
494
498
Extension ( channel) : Extension < ChainOf < Channel > > ,
495
499
) -> Result < Json < SpenderResponse > , ResponseError > {
496
- let spender = params. get ( "addr" ) . ok_or ( ResponseError :: BadRequest ( "Invalid spender address" . to_string ( ) ) ) ?;
500
+ let spender = params. get ( "addr" ) . ok_or_else ( || ResponseError :: BadRequest (
501
+ "Invalid spender address" . to_string ( ) ,
502
+ ) ) ?;
497
503
let spender = Address :: from_str ( spender) ?;
498
504
499
505
update_accounting (
@@ -519,12 +525,14 @@ pub async fn add_spender_leaf_axum<C: Locked + 'static>(
519
525
let new_state =
520
526
match get_corresponding_new_state ( & app. pool , & app. logger , & channel. context ) . await ? {
521
527
Some ( new_state) => new_state,
522
- None => return Ok ( Json ( SpenderResponse {
523
- spender : Spender {
524
- total_deposited : latest_spendable. deposit . total ,
525
- total_spent : None ,
526
- } ,
527
- } ) ) ,
528
+ None => {
529
+ return Ok ( Json ( SpenderResponse {
530
+ spender : Spender {
531
+ total_deposited : latest_spendable. deposit . total ,
532
+ total_spent : None ,
533
+ } ,
534
+ } ) )
535
+ }
528
536
} ;
529
537
530
538
let total_spent = new_state
0 commit comments