Give request headers to the cloud event handler context (#283)

chainguard-dev · Apr 18, 2024 · e845334 · e845334
1 parent 6278791
commit e845334
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/modules/cloudevent-broker/cmd/ingress/main.go b/modules/cloudevent-broker/cmd/ingress/main.go
@@ -51,7 +51,8 @@ func main() {
 	go httpmetrics.ServeMetrics()
 	httpmetrics.SetupTracer(ctx)
 
-	c, err := mce.NewClientHTTP(cloudevents.WithPort(env.Port))
+	c, err := mce.NewClientHTTP(cloudevents.WithPort(env.Port),
+		cehttp.WithRequestDataAtContextMiddleware() /* give request headers to the handler context */)
 	if err != nil {
 		clog.Fatalf("failed to create CE client, %v", err)
 	}