Check if blobs are expired before returning (#695)

Co-authored-by: Robert Raynor <[email protected]>
Layr-Labs · Aug 12, 2024 · f2d2d9c · f2d2d9c
1 parent a24d0ad
commit f2d2d9c
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/disperser/apiserver/server.go b/disperser/apiserver/server.go
@@ -727,6 +727,12 @@ func (s *DispersalServer) RetrieveBlob(ctx context.Context, req *pb.RetrieveBlob
 		return nil, api.NewInternalError("failed to get blob metadata, please retry")
 	}
 
+	if blobMetadata.Expiry < uint64(time.Now().Unix()) {
+		s.metrics.HandleNotFoundRpcRequest("RetrieveBlob")
+		s.metrics.HandleNotFoundRequest("RetrieveBlob")
+		return nil, api.NewNotFoundError("no metadata found for the given batch header hash and blob index")
+	}
+
 	// Check throughout rate limit
 	blobSize := encoding.GetBlobSize(blobMetadata.ConfirmationInfo.BlobCommitment.Length)