Merge pull request #81 from Savid/fix-blob-sidecar-http

add blob_sidecar http handler
attestantio · Oct 12, 2023 · 0eff364 · 0eff364
2 parents 7368130 + d018578
commit 0eff364
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/http/events.go b/http/events.go
@@ -167,6 +167,14 @@ func (s *Service) handleEvent(ctx context.Context, msg *sse.Event, handler clien
 			return
 		}
 		event.Data = payloadAttributesEvent
+	case "blob_sidecar":
+		blobSidecar := &api.BlobSidecarEvent{}
+		err := json.Unmarshal(msg.Data, blobSidecar)
+		if err != nil {
+			log.Error().Err(err).RawJSON("data", msg.Data).Msg("Failed to parse blob sidecar event")
+			return
+		}
+		event.Data = blobSidecar
 	case "":
 		// Used as keepalive.  Ignore.
 		return