@@ -83,7 +83,6 @@ func (b *BlobUploader) UploadBlobToS3() {
8383 return
8484 }
8585
86-
8786 // calculate versioned blob hash
8887 versionedBlobHash , err := utils .CalculateVersionedBlobHash (* blob )
8988 if err != nil {
@@ -132,7 +131,7 @@ func (b *BlobUploader) constructBlobCodec(dbBatch *orm.Batch) (*kzg4844.Blob, er
132131
133132 var encodingBatch * encoding.Batch
134133 codecVersion := encoding .CodecVersion (dbBatch .CodecVersion )
135- switch codecVersion {
134+ switch codecVersion {
136135 case encoding .CodecV0 , encoding .CodecV1 , encoding .CodecV2 , encoding .CodecV3 , encoding .CodecV4 , encoding .CodecV5 , encoding .CodecV6 :
137136 chunks := make ([]* encoding.Chunk , len (dbChunks ))
138137 for i , c := range dbChunks {
@@ -142,7 +141,7 @@ func (b *BlobUploader) constructBlobCodec(dbBatch *orm.Batch) (*kzg4844.Blob, er
142141 }
143142 chunks [i ] = & encoding.Chunk {Blocks : blocks }
144143 }
145-
144+
146145 encodingBatch = & encoding.Batch {
147146 Index : dbBatch .Index ,
148147 TotalL1MessagePoppedBefore : dbChunks [0 ].TotalL1MessagesPoppedBefore ,
@@ -156,15 +155,15 @@ func (b *BlobUploader) constructBlobCodec(dbBatch *orm.Batch) (*kzg4844.Blob, er
156155 if dbBatch .CodecVersion != dbChunk .CodecVersion {
157156 return nil , fmt .Errorf ("batch codec version is different from chunk codec version, batch index: %d, chunk index: %d, batch codec version: %d, chunk codec version: %d" , dbBatch .Index , dbChunk .Index , dbBatch .CodecVersion , dbChunk .CodecVersion )
158157 }
159-
158+
160159 blocks , err := b .l2BlockOrm .GetL2BlocksInRange (b .ctx , dbChunk .StartBlockNumber , dbChunk .EndBlockNumber )
161160 if err != nil {
162161 return nil , fmt .Errorf ("failed to get blocks in range for batch %d: %w" , dbBatch .Index , err )
163162 }
164-
163+
165164 batchBlocks = append (batchBlocks , blocks ... )
166165 }
167-
166+
168167 encodingBatch = & encoding.Batch {
169168 Index : dbBatch .Index ,
170169 ParentBatchHash : common .HexToHash (dbBatch .ParentBatchHash ),
@@ -176,7 +175,7 @@ func (b *BlobUploader) constructBlobCodec(dbBatch *orm.Batch) (*kzg4844.Blob, er
176175 log .Error ("unsupported codec version in UploadBlobToS3" , "codecVersion" , codecVersion , "batch index" , dbBatch .Index )
177176 return nil , fmt .Errorf ("unsupported codec version, batch index: %d, batch codec version: %d, %w" , dbBatch .Index , codecVersion , err )
178177 }
179-
178+
180179 codec , err := encoding .CodecFromVersion (codecVersion )
181180 if err != nil {
182181 return nil , fmt .Errorf ("failed to get codec from version %d, err: %w" , dbBatch .CodecVersion , err )
@@ -188,5 +187,4 @@ func (b *BlobUploader) constructBlobCodec(dbBatch *orm.Batch) (*kzg4844.Blob, er
188187 }
189188
190189 return daBatch .Blob (), nil
191-
192- }
190+ }
0 commit comments