diff --git a/pkg/events/events.go b/pkg/events/events.go index 657e57a..3c8a51f 100644 --- a/pkg/events/events.go +++ b/pkg/events/events.go @@ -273,6 +273,7 @@ func (l *Listener) Start(ctx context.Context) <-chan struct{} { return } lastBlock = blockNumber + l.logger.Info("processed logs", "from", lastBlock+1, "to", blockNumber, "count", len(logs)) } } } diff --git a/pkg/updater/updater.go b/pkg/updater/updater.go index bc946c5..f69ea74 100644 --- a/pkg/updater/updater.go +++ b/pkg/updater/updater.go @@ -141,6 +141,7 @@ func (u *Updater) subscribeEncryptedCommitments(ctx context.Context) error { return err } u.metrics.EncryptedCommitmentsCount.Inc() + u.logger.Debug("added encrypted commitment", "commitmentIdx", common.Bytes2Hex(update.CommitmentIndex[:])) return nil }, ) @@ -175,6 +176,7 @@ func (u *Updater) subscribeOpenedCommitments(ctx context.Context) error { if alreadySettled { // both bidders and providers could open commitments, so this could // be a duplicate event + u.logger.Info("duplicate open commitment event", "commitmentIdx", common.Bytes2Hex(update.CommitmentIndex[:])) return nil } @@ -312,6 +314,7 @@ func (u *Updater) addSettlement( case settler.SettlementTypeSlash: u.metrics.SlashesCount.Inc() } + u.logger.Info("added settlement", "commitmentIdx", common.Bytes2Hex(update.CommitmentIndex[:]), "type", settlementType) return nil }