async fn restart_chain_monitoring_for_all_coinbase_transactions(
        &mut self,
        join_handles: &mut FuturesUnordered<JoinHandle<Result<u64, TransactionServiceProtocolError>>>,
    ) -> Result<(), TransactionServiceError>
    {
        trace!(
            target: LOG_TARGET,
            "Starting Coinbase monitoring for all Broadcast Transactions"
        );
        let completed_txs = self.db.get_completed_transactions().await?;
        for completed_tx in completed_txs.values() {
            if completed_tx.status == TransactionStatus::Coinbase {
                self.start_coinbase_transaction_monitoring_protocol(completed_tx.tx_id, join_handles)
                    .await?;
            }
        }

        Ok(())
    }
/// Go through all completed transactions that have the Coinbase status and start querying the base_node to see if
/// they have been mined
Go through all completed transactions that have the Coinbase status and start querying the base_node to see if
they have been mined
Go through all completed transactions that have the Coinbase status and start querying the base_node to see if they have been mined
async fn restart_chain_monitoring_for_all_coinbase_transactions(
        &mut self,
        join_handles: &mut FuturesUnordered<JoinHandle<Result<u64, TransactionServiceProtocolError>>>,
    ) -> Result<(), TransactionServiceError>
    {
        trace!(
            target: LOG_TARGET,
            "Starting Coinbase monitoring for all Broadcast Transactions"
        );
        let completed_txs = self.db.get_completed_transactions().await?;
        for completed_tx in completed_txs.values() {
            if completed_tx.status == TransactionStatus::Coinbase {
                self.start_coinbase_transaction_monitoring_protocol(completed_tx.tx_id, join_handles)
                    .await?;
            }
        }
        Ok(())
    }
async fn restart_chain_monitoring_for_all_coinbase_transactions ( & mut self , join_handles : & mut FuturesUnordered < JoinHandle < Result < u64 , TransactionServiceProtocolError > > > , ) -> Result < ( ) , TransactionServiceError > { trace ! ( target LOG_TARGET " " ) ; let completed_txs = self . db . get_completed_transactions ( ) . await ? ; for completed_tx in completed_txs . values ( ) { if completed_tx . status == TransactionStatus :: Coinbase { self . start_coinbase_transaction_monitoring_protocol ( completed_tx . tx_id , join_handles ) . await ? ; } } Ok ( ( ) ) }
Go through all completed transactions that have the Coinbase status and start querying the base_node to see if
they have been mined
Go through all completed transactions that have the Coinbase status and start querying the base_node to see if they have been mined
&mut self
join_handles
&mut FuturesUnordered<JoinHandle<Result<u64, TransactionServiceProtocolError>>>
&mut self
join_handles
&mut FuturesUnordered<JoinHandle<Result<u64, TransactionServiceProtocolError>>>