add blob_sidecar http handler

attestantio · Oct 12, 2023 · d018578 · d018578
1 parent 7368130
commit d018578
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