@@ -72,9 +72,9 @@ func (l *Listener) parseDeposit(ctx context.Context, dl ethTypes.Log) (*Deposit,
7272 d .SenderAddress = common .BytesToAddress (dl .Topics [1 ].Bytes ())
7373 block , err := l .client .BlockByNumber (ctx , new (big.Int ).SetUint64 (dl .BlockNumber ))
7474 if err == nil {
75- log .Warn ().Msgf ("Failed fetching block with number %d because of: %+v" , dl .BlockNumber , err )
7675 d .Timestamp = time .Unix (int64 (block .Time ()), 0 )
7776 } else {
77+ log .Warn ().Msgf ("Failed fetching block with number %d because of: %+v" , dl .BlockNumber , err )
7878 d .Timestamp = time .Now ()
7979 }
8080
@@ -119,7 +119,7 @@ func (l *Listener) FetchRetryDepositEvents(event RetryV1Event, bridgeAddress com
119119}
120120
121121func (l * Listener ) FetchRetryV1Events (ctx context.Context , contractAddress common.Address , startBlock * big.Int , endBlock * big.Int ) ([]RetryV1Event , error ) {
122- logs , err := l .client .FetchEventLogs (ctx , contractAddress , string (RetrySig ), startBlock , endBlock )
122+ logs , err := l .client .FetchEventLogs (ctx , contractAddress , string (RetryV1Sig ), startBlock , endBlock )
123123 if err != nil {
124124 return nil , err
125125 }
@@ -141,7 +141,7 @@ func (l *Listener) FetchRetryV1Events(ctx context.Context, contractAddress commo
141141}
142142
143143func (l * Listener ) FetchRetryV2Events (ctx context.Context , contractAddress common.Address , startBlock * big.Int , endBlock * big.Int ) ([]RetryV2Event , error ) {
144- logs , err := l .client .FetchEventLogs (ctx , contractAddress , string (RetrySig ), startBlock , endBlock )
144+ logs , err := l .client .FetchEventLogs (ctx , contractAddress , string (RetryV2Sig ), startBlock , endBlock )
145145 if err != nil {
146146 return nil , err
147147 }
0 commit comments