Lets go

Author: ardatan

packages/fusion-runtime/tests/polling.test.ts

@@ -17,8 +17,8 @@ import { DisposableSymbols } from '@whatwg-node/disposablestack';
 import { ExecutionResult, GraphQLSchema, parse } from 'graphql';
 import { createSchema } from 'graphql-yoga';
 import { describe, expect, it, vi } from 'vitest';
-import { UnifiedGraphManager } from '../src/unifiedGraphManager';
 import { getDefaultLogger } from '../../runtime/src/getDefaultLogger';
+import { UnifiedGraphManager } from '../src/unifiedGraphManager';
 
 describe('Polling', () => {
   const advanceTimersByTimeAsync = vi.advanceTimersByTimeAsync || setTimeout;

packages/gateway/src/bin.ts

@@ -3,8 +3,8 @@ import 'dotenv/config'; // inject dotenv options to process.env
 
 import module from 'node:module';
 import type { InitializeData } from '@graphql-hive/importer/hooks';
-import { enableModuleCachingIfPossible, handleNodeWarnings, run } from './cli';
 import { getDefaultLogger } from '../../runtime/src/getDefaultLogger';
+import { enableModuleCachingIfPossible, handleNodeWarnings, run } from './cli';
 
 // @inject-version globalThis.__VERSION__ here
 

packages/gateway/src/cli.ts

@@ -14,7 +14,6 @@ import {
   type GatewayConfigSupergraph,
   type GatewayGraphOSReportingOptions,
   type GatewayHiveReportingOptions,
-  JSONLogger,
 } from '@graphql-hive/gateway-runtime';
 import type UpstashRedisCache from '@graphql-mesh/cache-upstash-redis';
 import type { JWTAuthPluginOptions } from '@graphql-mesh/plugin-jwt-auth';
@@ -28,11 +27,11 @@ import type {
   YamlConfig,
 } from '@graphql-mesh/types';
 import parseDuration from 'parse-duration';
+import { getDefaultLogger } from '../../runtime/src/getDefaultLogger';
 import { addCommands } from './commands/index';
 import { createDefaultConfigPaths } from './config';
 import { getMaxConcurrency } from './getMaxConcurrency';
 import type { ServerConfig } from './servers/types';
-import { getDefaultLogger } from '../../runtime/src/getDefaultLogger';
 
 export type GatewayCLIConfig = (
   | GatewayCLISupergraphConfig

packages/gateway/src/commands/handleFork.ts

@@ -13,13 +13,10 @@ export function handleFork(log: Logger, config: { fork?: number }): boolean {
         const workerLogger = log.child({ worker: worker.id });
         worker.once('exit', (code, signal) => {
           if (expectedToExit) {
-            workerLogger.debug(
-              'exited',
-              {
-                code,
-                signal,
-              },
-            );
+            workerLogger.debug('exited', {
+              code,
+              signal,
+            });
           } else {
             workerLogger.error(
               'exited unexpectedly. A restart is recommended to ensure the stability of the service',

packages/runtime/src/createGatewayRuntime.ts

@@ -78,6 +78,7 @@ import {
 } from 'graphql-yoga';
 import type { GraphiQLOptions, PromiseOrValue } from 'graphql-yoga';
 import { createGraphOSFetcher } from './fetchers/graphos';
+import { getDefaultLogger } from './getDefaultLogger';
 import { getProxyExecutor } from './getProxyExecutor';
 import { getReportingPlugin } from './getReportingPlugin';
 import {
@@ -110,7 +111,6 @@ import {
   defaultQueryText,
   getExecuteFnFromExecutor,
 } from './utils';
-import { getDefaultLogger } from './getDefaultLogger';
 
 // TODO: this type export is not properly accessible from graphql-yoga
 //       "graphql-yoga/typings/plugins/use-graphiql.js" is an illegal path

packages/runtime/src/getDefaultLogger.ts

@@ -1,39 +1,39 @@
+// eslint-disable-next-line import/no-nodejs-modules
+import { Console } from 'node:console';
 import { JSONLogger } from '@graphql-hive/logger-json';
 import { process } from '@graphql-mesh/cross-helpers';
 import { LogLevel } from '@graphql-mesh/utils';
-// eslint-disable-next-line import/no-nodejs-modules
-import { Console } from 'node:console';
 import pinoPretty from 'pino-pretty';
 
-export function getDefaultLogger(opts?: { name?: string; level?: LogLevel; }) {
-    const logFormat = process.env['LOG_FORMAT'] || (globalThis as any).LOG_FORMAT;
-    if (logFormat) {
-        if (logFormat.toLowerCase() === 'json') {
-            return new JSONLogger(opts);
-        } else if (logFormat.toLowerCase() === 'pretty') {
-            return createPrettyLogger(opts);
-        }
-    }
-    const nodeEnv = process.env['NODE_ENV'] || (globalThis as any).NODE_ENV;
-    if (nodeEnv === 'production') {
-        return new JSONLogger(opts);
+export function getDefaultLogger(opts?: { name?: string; level?: LogLevel }) {
+  const logFormat = process.env['LOG_FORMAT'] || (globalThis as any).LOG_FORMAT;
+  if (logFormat) {
+    if (logFormat.toLowerCase() === 'json') {
+      return new JSONLogger(opts);
+    } else if (logFormat.toLowerCase() === 'pretty') {
+      return createPrettyLogger(opts);
     }
-    return createPrettyLogger(opts);
+  }
+  const nodeEnv = process.env['NODE_ENV'] || (globalThis as any).NODE_ENV;
+  if (nodeEnv === 'production') {
+    return new JSONLogger(opts);
+  }
+  return createPrettyLogger(opts);
 }
 
-function createPrettyLogger(opts?: { name?: string; level?: LogLevel; }) {
-    const stdOut = pinoPretty({
-        levelFirst: true,
-        colorize: true,
-        destination: process.stdout,
-    });
-    const stdErr = pinoPretty({
-        levelFirst: true,
-        colorize: true,
-        destination: process.stdout,
-    });
-    return new JSONLogger({
-        ...opts,
-        console: new Console(stdOut, stdErr)
-    });
-}
+function createPrettyLogger(opts?: { name?: string; level?: LogLevel }) {
+  const stdOut = pinoPretty({
+    levelFirst: true,
+    colorize: true,
+    destination: process.stdout,
+  });
+  const stdErr = pinoPretty({
+    levelFirst: true,
+    colorize: true,
+    destination: process.stdout,
+  });
+  return new JSONLogger({
+    ...opts,
+    console: new Console(stdOut, stdErr),
+  });
+}

packages/runtime/src/plugins/useFetchDebug.ts

@@ -14,7 +14,7 @@ export function useFetchDebug<TContext extends Record<string, any>>(opts: {
       const fetchId = fetchAPI.crypto.randomUUID();
       const loggerMeta: Record<string, string> = {
         fetchId,
-      }
+      };
       if (requestId) {
         loggerMeta['requestId'] = requestId;
       }

packages/runtime/src/plugins/useSubgraphExecuteDebug.ts

@@ -15,7 +15,7 @@ export function useSubgraphExecuteDebug<
       const subgraphExecuteId = fetchAPI.crypto.randomUUID();
       const loggerMeta: Record<string, string> = {
         subgraphExecuteId,
-      }
+      };
       if (requestId) {
         loggerMeta['requestId'] = requestId;
       }