print Subgraph deployment id on Firehose connections

streamingfast · Apr 22, 2024 · 725decc · 725decc
1 parent 4877969
commit 725decc
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...)