diff --git a/pkg/events/events.go b/pkg/events/events.go index 3c8a51f..9823e4f 100644 --- a/pkg/events/events.go +++ b/pkg/events/events.go @@ -272,8 +272,8 @@ func (l *Listener) Start(ctx context.Context) <-chan struct{} { l.logger.Error("failed to set last block", "error", err) return } - lastBlock = blockNumber l.logger.Info("processed logs", "from", lastBlock+1, "to", blockNumber, "count", len(logs)) + lastBlock = blockNumber } } } diff --git a/pkg/updater/updater.go b/pkg/updater/updater.go index f69ea74..2683996 100644 --- a/pkg/updater/updater.go +++ b/pkg/updater/updater.go @@ -224,6 +224,10 @@ func (u *Updater) subscribeOpenedCommitments(ctx context.Context) error { "bundle is not atomic", "commitmentIdx", common.Bytes2Hex(update.CommitmentIndex[:]), "txnHash", update.TxnHash, + "blockNumber", update.BlockNumber, + "found", found, + "posInBlock", posInBlock, + "expectedPosInBlock", txns[commitmentTxnHashes[0]]+i, ) // The committer did not include the transactions in the block // correctly, so this is a slash to be processed