feat(logger): provide a Nest.js logger for runner

Author: madeindjs

CHANGELOG.md

@@ -3,6 +3,7 @@
 ## Current
 
 - **feat(task)**: provide a `@Task(name)` decorator to define your injectable tasks
+- **feat(logger)**: provide a Nest.js logger for GraphileWorker runner
 - **fix(hooks)**: Set all worker hooks (was only `job:success`)
 - **refactor(configuration)**: Remove `ConfigurationService` class and use a plain object `RunnerOptions`
 - **refactor()**: Rename `GraphileWorkerService` to `WorkerService`

src/graphile-worker.module.spec.ts

@@ -41,6 +41,7 @@ describe(GraphileWorkerModule.name, () => {
 
       expect(runnerOptions.connectionString).toEqual(connectionString);
       expect(runnerOptions.events).toBeDefined;
+      expect(runnerOptions.logger).toBeDefined;
     });
   });
 
@@ -72,6 +73,7 @@ describe(GraphileWorkerModule.name, () => {
 
       expect(runnerOptions.connectionString).toEqual(connectionString);
       expect(runnerOptions.events).toBeDefined;
+      expect(runnerOptions.logger).toBeDefined;
     });
   });
 });

src/graphile-worker.module.ts

@@ -11,6 +11,7 @@ import { ListenerExplorerService } from './services/listener-explorer.service';
 import { MetadataAccessorService } from './services/metadata-accessor.service';
 import { TaskExplorerService } from './services/task-explorer.service';
 import { WorkerService } from './services/worker.service';
+import { RunnerLogger } from './utils/graphile-worker-logger.utils';
 
 export const GRAPHILE_WORKER_TOKEN = Symbol.for('NestJsGraphileWorker');
 
@@ -112,6 +113,7 @@ function buildRunnerOptions(
 
   return {
     ...configuration,
+    logger: RunnerLogger,
     events,
   };
 }

src/utils/graphile-worker-logger.utils.ts

@@ -0,0 +1,34 @@
+import {
+  LogFunction,
+  Logger as GraphileLogger,
+  LogLevel,
+  LogMeta,
+} from '@graphile/logger';
+import { Logger } from '@nestjs/common';
+
+function graphileWorkerLogFactory(_scope): LogFunction {
+  const logger = new Logger('GraphileWorker');
+
+  return (level: LogLevel, message: string, meta?: LogMeta) => {
+    if (meta !== undefined) {
+      message += ` - ${JSON.stringify(meta)}`;
+    }
+
+    switch (level) {
+      case LogLevel.ERROR:
+        logger.error(message);
+        break;
+      case LogLevel.WARNING:
+        logger.warn(message);
+        break;
+      case LogLevel.INFO:
+        logger.log(message);
+        break;
+      case LogLevel.DEBUG:
+        logger.debug(message, meta);
+        break;
+    }
+  };
+}
+
+export const RunnerLogger = new GraphileLogger(graphileWorkerLogFactory);