Merge pull request #44 from pinax-network/feature/print_deployment_id…

…_header_on_firehose print Subgraph deployment id on Firehose connections
streamingfast · Apr 22, 2024 · 3e2320c · 3e2320c
2 parents 4877969 + 725decc
commit 3e2320c
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/stream_factory.go b/stream_factory.go
@@ -89,6 +89,9 @@ func (sf *StreamFactory) New(
 			zap.String("user_id", auth.UserID()),
 			zap.String("real_ip", auth.RealIP()),
 		)
+		if auth["x-deployment-id"] != "" {
+			fields = append(fields, zap.String("deployment_id", auth["x-deployment-id"]))
+		}
 	}
 
 	reqLogger.Info("processing incoming blocks request", fields...)