fix(chain): address review feedback (#552)

Author: rvagg

tasks/message/watch_eth.go

@@ -25,7 +25,7 @@ import (
 const (
 	// defaultEthCallTimeout is the timeout for sets of Ethereum client calls per transaction
 	// (i.e. receipt and transaction data)
-	defaultEthCallTimeout = time.Second
+	defaultEthCallTimeout = 30 * time.Second
 )
 
 // EthClient is an interface for the Ethereum client operations we need
@@ -129,6 +129,9 @@ func (mw *MessageWatcherEth) update() {
 
 	// Check if any of the transactions we have assigned are now confirmed
 	for _, txHashStr := range txHashes {
+		processed++
+		processStart := time.Now()
+
 		txHash := common.HexToHash(txHashStr)
 		log.Debugw("Checking transaction", "txHash", txHash.Hex())
 
@@ -244,8 +247,14 @@ func (mw *MessageWatcherEth) update() {
 		}
 
 		confirmed++
-		processed++
 		log.Infow("Successfully confirmed transaction", "txHash", txHash.Hex())
+
+		processDuration := time.Since(processStart)
+		if processDuration > 5*time.Second {
+			log.Warnw("Transaction processing took longer than expected",
+				"txHash", txHash.Hex(),
+				"duration", processDuration)
+		}
 	}
 
 	log.Infow("MessageWatcherEth update completed",