dont overwrite log instances

Author: enisdenjo

packages/fusion-runtime/src/federation/supergraph.ts

@@ -158,7 +158,7 @@ export const handleFederationSupergraph: UnifiedGraphHandler = function ({
   onDelegateHooks,
   additionalTypeDefs: additionalTypeDefsFromConfig = [],
   additionalResolvers: additionalResolversFromConfig = [],
-  log,
+  log: rootLog,
 }: UnifiedGraphHandlerOpts): UnifiedGraphHandlerResult {
   const additionalTypeDefs = [...asArray(additionalTypeDefsFromConfig)];
   const additionalResolvers = [...asArray(additionalResolversFromConfig)];
@@ -230,7 +230,7 @@ export const handleFederationSupergraph: UnifiedGraphHandler = function ({
                     originalResolver,
                     typeName,
                     onDelegationStageExecuteHooks,
-                    log,
+                    rootLog,
                   );
                 }
               }
@@ -278,7 +278,7 @@ export const handleFederationSupergraph: UnifiedGraphHandler = function ({
     executableUnifiedGraph,
     // @ts-expect-error Legacy Mesh RawSource is not compatible with new Mesh
     subschemas,
-    LegacyLogger.from(log),
+    LegacyLogger.from(rootLog),
     onDelegateHooks || [],
   );
   const stitchingInfo = executableUnifiedGraph.extensions?.[

packages/plugins/hmac-upstream-signature/src/index.ts

@@ -93,8 +93,13 @@ export function useHmacUpstreamSignature(
     onYogaInit({ yoga }) {
       fetchAPI = yoga.fetchAPI;
     },
-    onSubgraphExecute({ subgraphName, subgraph, executionRequest, log }) {
-      log = log.child('[useHmacUpstreamSignature] ');
+    onSubgraphExecute({
+      subgraphName,
+      subgraph,
+      executionRequest,
+      log: rootLog,
+    }) {
+      const log = rootLog.child('[useHmacUpstreamSignature] ');
       log.debug('Running shouldSign for subgraph %s', subgraphName);
 
       if (shouldSign({ subgraphName, subgraph, executionRequest })) {

packages/runtime/src/plugins/useWebhooks.ts

@@ -9,10 +9,10 @@ export interface GatewayWebhooksPluginOptions {
 }
 
 export function useWebhooks({
-  log,
+  log: rootLog,
   pubsub,
 }: GatewayWebhooksPluginOptions): GatewayPlugin {
-  log = log.child('[useWebhooks] ');
+  const log = rootLog.child('[useWebhooks] ');
   if (!pubsub) {
     throw new Error(`You must provide a pubsub instance to webhooks feature!
     Example:

packages/transports/http-callback/src/index.ts

@@ -73,7 +73,7 @@ export default {
     transportEntry,
     fetch,
     pubsub,
-    log,
+    log: rootLog,
   }): DisposableExecutor {
     let headersInConfig: Record<string, string> | undefined;
     if (typeof transportEntry.headers === 'string') {
@@ -106,7 +106,7 @@ export default {
       executionRequest: ExecutionRequest,
     ) {
       const subscriptionId = crypto.randomUUID();
-      log = log.child({
+      const log = rootLog.child({
         executor: 'http-callback',
         subscription: subscriptionId,
       });
@@ -226,7 +226,7 @@ export default {
             },
           ),
         (e) => {
-          log.debug(e, `Subscription request failed`);
+          log.error(e, 'Subscription request failed');
           stopSubscription(e);
         },
       );

packages/transports/ws/src/index.ts

@@ -33,7 +33,7 @@ export interface WSTransportOptions {
 
 export default {
   getSubgraphExecutor(
-    { transportEntry, log },
+    { transportEntry, log: rootLog },
     /**
      * Do not use this option unless you know what you are doing.
      * @internal
@@ -76,7 +76,7 @@ export default {
 
       let wsExecutor = wsExecutorMap.get(hash);
       if (!wsExecutor) {
-        log = log.child({
+        const log = rootLog.child({
           executor: 'GraphQL WS',
           wsUrl,
           connectionParams,