@@ -19,6 +19,7 @@ use networking::{
19
19
} ;
20
20
use oreo_errors:: OreoError ;
21
21
use serde_json:: json;
22
+ use tracing:: error;
22
23
use utils:: { default_secp, sign, verify, Signature } ;
23
24
24
25
use crate :: SharedState ;
@@ -242,10 +243,22 @@ pub async fn update_scan_status_handler<T: DBHandler>(
242
243
return e. into_response ( ) ;
243
244
}
244
245
let account = db_account. unwrap ( ) ;
246
+ let reset_created_at = account. create_head . is_none ( ) || account. create_head . unwrap ( ) == 1 ;
247
+ let reset = shared. rpc_handler . reset_account ( RpcResetAccountRequest {
248
+ account : account. name . clone ( ) ,
249
+ reset_scanning_enabled : Some ( false ) ,
250
+ reset_created_at : Some ( reset_created_at) ,
251
+ } ) ;
252
+ if let Err ( e) = reset {
253
+ return e. into_response ( ) ;
254
+ }
245
255
message. account = account. name . clone ( ) ;
246
- let scan_complete = message. scan_complete ;
247
- let _ = shared. rpc_handler . set_account_head ( message) ;
248
- if scan_complete {
256
+ let resp = shared. rpc_handler . set_account_head ( message. clone ( ) ) ;
257
+
258
+ if resp. is_err ( ) {
259
+ error ! ( "Failed to update account head: {:?}" , resp. unwrap_err( ) ) ;
260
+ }
261
+ if message. scan_complete {
249
262
let _ = shared. rpc_handler . set_scanning ( RpcSetScanningRequest {
250
263
account : account. name . clone ( ) ,
251
264
enabled : true ,
0 commit comments