7
7
8
8
"github.com/ethereum/go-ethereum/accounts/abi/bind"
9
9
"github.com/ethereum/go-ethereum/core/types"
10
+ "github.com/ethereum/go-ethereum/log"
10
11
11
12
"github.com/taikoxyz/taiko-mono/packages/taiko-client/bindings"
12
13
"github.com/taikoxyz/taiko-mono/packages/taiko-client/bindings/metadata"
@@ -111,6 +112,8 @@ func assembleBlockProposedIteratorCallback(
111
112
) error {
112
113
endHeight := end .Number .Uint64 ()
113
114
115
+ log .Debug ("Iterating BlockProposed events" , "start" , start .Number , "end" , endHeight )
116
+
114
117
iterOntake , err := taikoL1 .FilterBlockProposedV2 (
115
118
& bind.FilterOpts {Start : start .Number .Uint64 (), End : & endHeight , Context : ctx },
116
119
filterQuery ,
@@ -124,10 +127,12 @@ func assembleBlockProposedIteratorCallback(
124
127
event := iterOntake .Event
125
128
126
129
if err := callback (ctx , metadata .NewTaikoDataBlockMetadataOntake (event ), eventIter .end ); err != nil {
130
+ log .Warn ("Error while processing BlockProposedV2 events, keep retrying" , "error" , err )
127
131
return err
128
132
}
129
133
130
134
if eventIter .isEnd {
135
+ log .Debug ("BlockProposedIterator is ended" , "start" , start .Number , "end" , endHeight )
131
136
endFunc ()
132
137
return nil
133
138
}
@@ -137,9 +142,16 @@ func assembleBlockProposedIteratorCallback(
137
142
return err
138
143
}
139
144
145
+ log .Debug ("Updating current block cursor for processing BlockProposedV2 events" , "block" , current .Number )
146
+
140
147
updateCurrentFunc (current )
141
148
}
142
149
143
- return iterOntake .Error ()
150
+ if err := iterOntake .Error (); err != nil {
151
+ log .Error ("Error while iterating BlockProposedV2 events" , "error" , err )
152
+ return err
153
+ }
154
+
155
+ return nil
144
156
}
145
157
}
0 commit comments