@@ -71,16 +71,16 @@ impl BackendManager {
7171
7272 let mut res = res2. lock ( ) . await ;
7373 for rx in res. children_receivers . iter_mut ( ) . flatten ( ) {
74- if !rx. is_empty ( ) {
75- if let Some ( message) = rx. recv ( ) . await {
76- let write_res =
77- socket_write . write_all ( & DapParser :: to_bytes ( & message ) ) . await ;
78-
79- match write_res {
80- Ok ( ( ) ) => { }
81- Err ( err ) => {
82- error ! ( "Can't write to frontend socket! Error: {err}" ) ;
83- }
74+ if !rx. is_empty ( )
75+ && let Some ( message) = rx. recv ( ) . await
76+ {
77+ let write_res =
78+ socket_write . write_all ( & DapParser :: to_bytes ( & message ) ) . await ;
79+
80+ match write_res {
81+ Ok ( ( ) ) => { }
82+ Err ( err ) => {
83+ error ! ( "Can't write to frontend socket! Error: {err}" ) ;
8484 }
8585 }
8686 }
@@ -305,52 +305,51 @@ impl BackendManager {
305305
306306 match req_type {
307307 "ct/start-replay" => {
308- if let Some ( Value :: Array ( arr) ) = args {
309- if let Some ( Value :: String ( command) ) = arr. first ( ) {
310- let mut cmd_args : Vec < & str > = Vec :: new ( ) ;
311- for arg in arr . iter ( ) . skip ( 1 ) {
312- if let Some ( s ) = arg . as_str ( ) {
313- cmd_args . push ( s ) ;
314- } else {
315- // TODO: return error
316- return Ok ( ( ) ) ;
317- }
308+ if let Some ( Value :: Array ( arr) ) = args
309+ && let Some ( Value :: String ( command) ) = arr. first ( )
310+ {
311+ let mut cmd_args : Vec < & str > = Vec :: new ( ) ;
312+ for arg in arr . iter ( ) . skip ( 1 ) {
313+ if let Some ( s ) = arg . as_str ( ) {
314+ cmd_args . push ( s ) ;
315+ } else {
316+ // TODO: return error
317+ return Ok ( ( ) ) ;
318318 }
319- self . start_replay ( command, & cmd_args) . await ?;
320- // TODO: send response
321- return Ok ( ( ) ) ;
322319 }
320+ self . start_replay ( command, & cmd_args) . await ?;
321+ // TODO: send response
322+ return Ok ( ( ) ) ;
323323 }
324324 // TODO: return error
325325 Ok ( ( ) )
326326 }
327327 "ct/stop-replay" => {
328- if let Some ( Value :: Number ( num) ) = args {
329- if let Some ( id) = num. as_u64 ( ) {
330- self . stop_replay ( id as usize ) . await ? ;
331- return Ok ( ( ) ) ;
332- }
328+ if let Some ( Value :: Number ( num) ) = args
329+ && let Some ( id) = num. as_u64 ( )
330+ {
331+ self . stop_replay ( id as usize ) . await ? ;
332+ return Ok ( ( ) ) ;
333333 }
334334 // TODO: return error
335335 Ok ( ( ) )
336336 }
337337 "ct/select-replay" => {
338- if let Some ( Value :: Number ( num) ) = args {
339- if let Some ( id) = num. as_u64 ( ) {
340- self . select_replay ( id as usize ) ? ;
341- return Ok ( ( ) ) ;
342- }
338+ if let Some ( Value :: Number ( num) ) = args
339+ && let Some ( id) = num. as_u64 ( )
340+ {
341+ self . select_replay ( id as usize ) ? ;
342+ return Ok ( ( ) ) ;
343343 }
344344 // TODO: return error
345345 Ok ( ( ) )
346346 }
347347 _ => {
348- if let Some ( Value :: Object ( obj_args) ) = args {
349- if let Some ( Value :: Number ( id) ) = obj_args. get ( "replay-id" ) {
350- if let Some ( id) = id. as_u64 ( ) {
351- return self . message ( id as usize , message) . await ;
352- }
353- }
348+ if let Some ( Value :: Object ( obj_args) ) = args
349+ && let Some ( Value :: Number ( id) ) = obj_args. get ( "replay-id" )
350+ && let Some ( id) = id. as_u64 ( )
351+ {
352+ return self . message ( id as usize , message) . await ;
354353 }
355354 self . message_selected ( message) . await
356355 }
0 commit comments