@@ -147,14 +147,14 @@ export const processMessage = (
147147 trackDataReceived ( aggregatedData , intermediate , message . recipient , "pb" , message . id ) ;
148148 } else if ( message . type === EMessageType . EBGenerated ) {
149149 trackDataGenerated ( aggregatedData , intermediate , message . producer , "eb" , message . id , message . size_bytes ) ;
150- for ( const { id : ibId } of message . input_blocks ?? [ ] ) {
150+ for ( const { id : ibId } of message . input_blocks ) {
151151 for ( const tx of intermediate . ibs . get ( ibId ) ?. txs ?? [ ] ) {
152152 if ( intermediate . txStatuses [ tx ] === 'created' || intermediate . txStatuses [ tx ] === 'inIb' ) {
153153 intermediate . txStatuses [ tx ] = 'inEb' ;
154154 }
155155 }
156156 }
157- for ( const { id : txId } of message . transactions ?? [ ] ) {
157+ for ( const { id : txId } of message . transactions ) {
158158 const tx = Number ( txId ) ;
159159 if ( intermediate . txStatuses [ tx ] === 'created' || intermediate . txStatuses [ tx ] === 'inIb' ) {
160160 intermediate . txStatuses [ tx ] = 'inEb' ;
@@ -164,8 +164,8 @@ export const processMessage = (
164164 slot : message . slot ,
165165 pipeline : message . pipeline ,
166166 bytes : message . size_bytes ,
167- txs : message . transactions ? .map ( tx => tx . id ) ?? [ ] ,
168- ibs : message . input_blocks ? .map ( ib => ib . id ) ?? [ ] ,
167+ txs : message . transactions . map ( tx => tx . id ) ,
168+ ibs : message . input_blocks . map ( ib => ib . id ) ,
169169 ebs : message . endorser_blocks . map ( eb => eb . id ) ,
170170 } ) ;
171171 } else if ( message . type === EMessageType . EBSent ) {
0 commit comments