Add a defensive check on blob status (#258)

Layr-Labs · Feb 21, 2024 · 402eafb · 402eafb
1 parent a46bd99
commit 402eafb
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/disperser/batcher/finalizer.go b/disperser/batcher/finalizer.go
@@ -124,6 +124,10 @@ func (f *finalizer) updateBlobs(ctx context.Context, metadatas []*disperser.Blob
 	for _, m := range metadatas {
 		stageTimer := time.Now()
 		blobKey := m.GetBlobKey()
+		if m.BlobStatus != disperser.Confirmed {
+			f.logger.Error("FinalizeBlobs: the blob retrieved by status Confirmed is actually", m.BlobStatus.String(), "blobKey", blobKey.String())
+			continue
+		}
 		confirmationMetadata, err := f.blobStore.GetBlobMetadata(ctx, blobKey)
 		if err != nil {
 			f.logger.Error("FinalizeBlobs: error getting confirmed metadata", "blobKey", blobKey.String(), "err", err)