Fix: add blobkey in blob response (#1087)

Layr-Labs · Jan 10, 2025 · 2699b91 · 2699b91
1 parent b09cdc3
commit 2699b91
Show file tree

Hide file tree

Showing 4 changed files with 16 additions and 0 deletions.
diff --git a/disperser/dataapi/docs/v2/V2_docs.go b/disperser/dataapi/docs/v2/V2_docs.go
@@ -817,6 +817,9 @@ const docTemplateV2 = `{
                 "blob_header": {
                     "$ref": "#/definitions/github_com_Layr-Labs_eigenda_core_v2.BlobHeader"
                 },
+                "blob_key": {
+                    "type": "string"
+                },
                 "blob_size_bytes": {
                     "type": "integer"
                 },

diff --git a/disperser/dataapi/docs/v2/V2_swagger.json b/disperser/dataapi/docs/v2/V2_swagger.json
@@ -814,6 +814,9 @@
                 "blob_header": {
                     "$ref": "#/definitions/github_com_Layr-Labs_eigenda_core_v2.BlobHeader"
                 },
+                "blob_key": {
+                    "type": "string"
+                },
                 "blob_size_bytes": {
                     "type": "integer"
                 },

diff --git a/disperser/dataapi/docs/v2/V2_swagger.yaml b/disperser/dataapi/docs/v2/V2_swagger.yaml
@@ -232,6 +232,8 @@ definitions:
     properties:
       blob_header:
         $ref: '#/definitions/github_com_Layr-Labs_eigenda_core_v2.BlobHeader'
+      blob_key:
+        type: string
       blob_size_bytes:
         type: integer
       dispersed_at:

diff --git a/disperser/dataapi/v2/server_v2.go b/disperser/dataapi/v2/server_v2.go
@@ -51,6 +51,7 @@ type (
 	}
 
 	BlobResponse struct {
+		BlobKey       string             `json:"blob_key"`
 		BlobHeader    *corev2.BlobHeader `json:"blob_header"`
 		Status        string             `json:"status"`
 		DispersedAt   uint64             `json:"dispersed_at"`
@@ -321,7 +322,14 @@ func (s *ServerV2) FetchBlobHandler(c *gin.Context) {
 		errorResponse(c, err)
 		return
 	}
+	bk, err := metadata.BlobHeader.BlobKey()
+	if err != nil || bk != blobKey {
+		s.metrics.IncrementFailedRequestNum("FetchBlob")
+		errorResponse(c, err)
+		return
+	}
 	response := &BlobResponse{
+		BlobKey:       bk.Hex(),
 		BlobHeader:    metadata.BlobHeader,
 		Status:        metadata.BlobStatus.String(),
 		DispersedAt:   metadata.RequestedAt,