@@ -400,7 +400,7 @@ async fn prepare_lander_task(
400400 } ;
401401
402402 let batch_to_process = confirm_already_submitted_operations (
403- entrypoint. clone ( ) ,
403+ entrypoint. clone ( ) as Arc < dyn Entrypoint + Send + Sync > ,
404404 & confirm_queue,
405405 db. clone ( ) ,
406406 batch,
@@ -423,7 +423,7 @@ async fn prepare_lander_task(
423423/// If the payload is not dropped, the operation is pushed to the confirmation queue.
424424/// If the payload is dropped, does not exist or there is issue in retrieving payload or its status, the operation will go through prepare logic.
425425async fn confirm_already_submitted_operations (
426- entrypoint : Arc < DispatcherEntrypoint > ,
426+ entrypoint : Arc < dyn Entrypoint + Send + Sync > ,
427427 confirm_queue : & OpQueue ,
428428 db : Arc < dyn HyperlaneDb > ,
429429 batch : Vec < QueueOperation > ,
@@ -448,7 +448,7 @@ async fn confirm_already_submitted_operations(
448448}
449449
450450async fn has_operation_been_submitted (
451- entrypoint : Arc < DispatcherEntrypoint > ,
451+ entrypoint : Arc < dyn Entrypoint + Send + Sync > ,
452452 db : Arc < dyn HyperlaneDb > ,
453453 op : & QueueOperation ,
454454) -> bool {
@@ -1073,3 +1073,6 @@ impl MessageProcessorMetrics {
10731073 }
10741074 }
10751075}
1076+
1077+ #[ cfg( test) ]
1078+ mod tests;
0 commit comments