File tree Expand file tree Collapse file tree 1 file changed +11
-3
lines changed
Expand file tree Collapse file tree 1 file changed +11
-3
lines changed Original file line number Diff line number Diff line change @@ -103,7 +103,6 @@ func (m *ChainHeaderManager) startPolling() {
103103 // Attempt an initial fetch of the latest block, so we know where to begin
104104 initCtx , cancel := context .WithTimeout (context .Background (), m .networkCfg .Timeout .Duration )
105105 defer cancel ()
106- m .ethClient .HeaderByNumber (initCtx , nil )
107106 latestHeader , err := m .ethClient .HeaderByNumber (initCtx , nil )
108107 if err != nil {
109108 m .logger .Error ().
@@ -164,7 +163,10 @@ func (m *ChainHeaderManager) fanOutRoutine() {
164163 case hdr := <- m .headersChan :
165164 m .mu .RLock ()
166165 for sub := range m .subscribers {
167- sub .receiveHeader (hdr )
166+ err := sub .receiveHeader (hdr )
167+ if err != nil {
168+ m .logger .Err (err ).Msg ("Finalizer received error during HTTP polling" )
169+ }
168170 }
169171 m .mu .RUnlock ()
170172 }
@@ -233,10 +235,16 @@ func convertToSafeEVMHeader(hdr *types.Header) *SafeEVMHeader {
233235 if hdr == nil {
234236 return nil
235237 }
238+ var safeTime int64
239+ if hdr .Time > math .MaxInt64 {
240+ safeTime = math .MaxInt64
241+ } else {
242+ safeTime = int64 (hdr .Time )
243+ }
236244 return & SafeEVMHeader {
237245 Hash : hdr .Hash (),
238246 Number : hdr .Number ,
239247 BaseFee : hdr .BaseFee ,
240- Timestamp : time .Unix (int64 ( hdr . Time ) , 0 ),
248+ Timestamp : time .Unix (safeTime , 0 ),
241249 }
242250}
You can’t perform that action at this time.
0 commit comments