Update

taikoxyz · Feb 19, 2024 · a156cdf · a156cdf
1 parent 1019f38
commit a156cdf
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/packages/relayer/processor/process_single.go b/packages/relayer/processor/process_single.go
@@ -8,12 +8,13 @@ import (
 
 	"github.com/ethereum/go-ethereum/accounts/abi"
 	"github.com/ethereum/go-ethereum/common"
+
 	"github.com/taikoxyz/taiko-mono/packages/relayer/bindings/bridge"
 	"github.com/taikoxyz/taiko-mono/packages/relayer/pkg/queue"
 )
 
 func (p *Processor) processSingle(ctx context.Context) error {
-	slog.Info("Processing tx", "p.estimateGas:", common.Hash(*p.targetTxHash).Hex())
+	slog.Info("processing tx", "estimateGas", common.Hash(*p.targetTxHash).Hex())
 
 	bridgeAbi, err := abi.JSON(strings.NewReader(bridge.BridgeABI))
 	if err != nil {

diff --git a/packages/relayer/processor/processor.go b/packages/relayer/processor/processor.go
@@ -367,6 +367,7 @@ func (p *Processor) Start() error {
 		if err != nil {
 			slog.Error(err.Error())
 		}
+
 		os.Exit(0)
 	}
 
@@ -421,8 +422,9 @@ func (p *Processor) eventLoop(ctx context.Context) {
 							slog.Error("Err acking message", "err", err.Error())
 						}
 					} else {
-						slog.Error("err processing message", "err", err.Error())
-						if err := p.queue.Nack(ctx, msg); err != nil {
+						slog.Error("process message failed", "err", err.Error())
+
+						if err = p.queue.Nack(ctx, msg); err != nil {
 							slog.Error("Err nacking message", "err", err.Error())
 						}
 					}