rename function GetFirstUnuploadedBatchByPlatform

Author: yiweichi

rollup/internal/controller/blob_uploader/blob_uploader.go

@@ -200,7 +200,7 @@ func (b *BlobUploader) constructBlobCodec(dbBatch *orm.Batch) (*kzg4844.Blob, er
 // GetFirstUnuploadedBatchByPlatform retrieves the first batch that either hasn't been uploaded to corresponding blob storage service
 // The batch must have a commit_tx_hash (committed).
 func (b *BlobUploader) GetFirstUnuploadedBatchByPlatform(ctx context.Context, startBatch uint64, platform types.BlobStoragePlatform) (*orm.Batch, error) {
-	batchIndex, err := b.blobUploadOrm.GetFirstUnuploadedBatchIndexByPlatform(ctx, startBatch, platform)
+	batchIndex, err := b.blobUploadOrm.GetNextBatchIndexToUploadByPlatform(ctx, startBatch, platform)
 	if err != nil {
 		return nil, err
 	}

rollup/internal/orm/blob_upload.go

@@ -37,8 +37,8 @@ func (*BlobUpload) TableName() string {
 	return "blob_upload"
 }
 
-// GetFirstUnuploadedBatchIndexByPlatform retrieves the first batch index that hasn't been uploaded to corresponding blob storage service
-func (o *BlobUpload) GetFirstUnuploadedBatchIndexByPlatform(ctx context.Context, startBatch uint64, platform types.BlobStoragePlatform) (uint64, error) {
+// GetNextBatchIndexToUploadByPlatform retrieves the next batch index that hasn't been uploaded to corresponding blob storage service
+func (o *BlobUpload) GetNextBatchIndexToUploadByPlatform(ctx context.Context, startBatch uint64, platform types.BlobStoragePlatform) (uint64, error) {
 	db := o.db.WithContext(ctx)
 	db = db.Model(&BlobUpload{})
 	db = db.Where("platform = ? AND status = ? AND deleted_at IS NULL", platform, types.BlobUploadStatusUploaded)
@@ -51,7 +51,7 @@ func (o *BlobUpload) GetFirstUnuploadedBatchIndexByPlatform(ctx context.Context,
 		if errors.Is(err, gorm.ErrRecordNotFound) {
 			batchIndex = startBatch
 		} else {
-			return 0, fmt.Errorf("BlobUpload.GetFirstUnuploadedBatchIndexByPlatform error: %w", err)
+			return 0, fmt.Errorf("BlobUpload.GetNextBatchIndexToUploadByPlatform error: %w", err)
 		}
 	} else {
 		batchIndex = blobUpload.BatchIndex + 1