feat(logger): custom message key (#1546)

Author: JacopoDaeli

docs/configuration.md

@@ -25,6 +25,7 @@ Some less common environment variables are:
 | `LOG_FORMAT`          | -                                                                     | By default, logs are formatted for readability in development. You can set this to `json` in order to disable the formatting                                                                                                                                                                                |
 | `LOG_LEVEL`           | `const log = require('pino')({ level })`                              | The verbosity of logs to show when running your app, which can be `fatal`, `error`, `warn`, `info`, `debug`, `trace` or `silent`. Default: `info`                                                                                                                                                           |
 | `LOG_LEVEL_IN_STRING` | -                                                                     | By default, when using the `json` format, the level printed in the log records is an int (`10`, `20`, ..). This option tells the logger to print level as a string: `{"level": "info"}`. Default `false`                                                                                                    |
+| `LOG_MESSAGE_KEY`     | `const log = require('pino')({ messageKey: 'msg' })`                  | Only relevant when `LOG_FORMAT` is set to `json`. Sets the json key for the log message. Default: `msg`                                                                                                                                                                                                     |
 | `SENTRY_DSN`          | -                                                                     | Set to a [Sentry](https://sentry.io/) DSN to report all errors thrown by your app. <p>_(Example: `https://1234abcd@sentry.io/12345`)_</p>                                                                                                                                                                   |
 | `PORT`                | `new Server({ host })`                                                | The port to start the local server on. Default: `3000`                                                                                                                                                                                                                                                      |
 | `HOST`                | `new Server({ host })`                                                | The host to start the local server on.                                                                                                                                                                                                                                                                      |

src/bin/probot-receive.ts

@@ -50,6 +50,11 @@ async function main() {
       "Set to log levels (trace, debug, info, ...) as words instead of numbers (10, 20, 30, ...)",
       process.env.LOG_LEVEL_IN_STRING === "true"
     )
+    .option(
+      "--log-message-key",
+      "Set to the string key for the 'message' in the log JSON object",
+      process.env.LOG_MESSAGE_KEY || "msg"
+    )
     .option(
       "--sentry-dsn <dsn>",
       'Set to your Sentry DSN, e.g. "https://1234abcd@sentry.io/12345"',
@@ -75,6 +80,7 @@ async function main() {
     level: program.logLevel,
     logFormat: program.logFormat,
     logLevelInString: program.logLevelInString,
+    logMessageKey: program.logMessageKey,
     sentryDsn: program.sentryDsn,
   });
 

src/bin/read-env-options.ts

@@ -18,6 +18,7 @@ export function readEnvOptions(
     logLevel: env.LOG_LEVEL as LogLevel,
     logFormat: env.LOG_FORMAT as PinoOptions["logFormat"],
     logLevelInString: env.LOG_LEVEL_IN_STRING === "true",
+    logMessageKey: env.LOG_MESSAGE_KEY,
     sentryDsn: env.SENTRY_DSN,
     redisConfig: env.REDIS_URL,
     baseUrl: env.GHE_HOST

src/create-probot.ts

@@ -19,6 +19,7 @@ const DEFAULTS = {
   LOG_FORMAT: "",
   LOG_LEVEL: "warn",
   LOG_LEVEL_IN_STRING: "",
+  LOG_MESSAGE_KEY: "msg",
   REDIS_URL: "",
   SENTRY_DSN: "",
 };
@@ -63,6 +64,7 @@ export function createProbot({
     level: probotOptions.logLevel,
     logFormat: envWithDefaults.LOG_FORMAT as PinoOptions["logFormat"],
     logLevelInString: envWithDefaults.LOG_LEVEL_IN_STRING === "true",
+    logMessageKey: envWithDefaults.LOG_MESSAGE_KEY,
     sentryDsn: envWithDefaults.SENTRY_DSN,
   };
 

src/helpers/get-log.ts

@@ -17,12 +17,19 @@
 import pino, { LoggerOptions } from "pino";
 import { getTransformStream, Options, LogLevel } from "@probot/pino";
 
-export type GetLogOptions = { level?: LogLevel } & Options;
+export type GetLogOptions = {
+  level?: LogLevel;
+  logMessageKey?: string;
+} & Options;
 
 export function getLog(options: GetLogOptions = {}) {
-  const { level, ...getTransformStreamOptions } = options;
+  const { level, logMessageKey, ...getTransformStreamOptions } = options;
 
-  const pinoOptions: LoggerOptions = { level: level || "info", name: "probot" };
+  const pinoOptions: LoggerOptions = {
+    level: level || "info",
+    name: "probot",
+    messageKey: logMessageKey || "msg",
+  };
   const transform = getTransformStream(getTransformStreamOptions);
   // @ts-ignore TODO: check out what's wrong here
   transform.pipe(pino.destination(1));

src/probot.ts

@@ -50,8 +50,9 @@ export class Probot {
     options.secret = options.secret || "development";
 
     let level = options.logLevel;
+    const logMessageKey = options.logMessageKey;
 
-    this.log = aliasLog(options.log || getLog({ level }));
+    this.log = aliasLog(options.log || getLog({ level, logMessageKey }));
 
     // TODO: support redis backend for access token cache if `options.redisConfig`
     const cache = new LRUCache<number, string>({

src/run.ts

@@ -34,6 +34,7 @@ export async function run(
     logLevel: level,
     logFormat,
     logLevelInString,
+    logMessageKey,
     sentryDsn,
 
     // server options
@@ -57,6 +58,7 @@ export async function run(
     level,
     logFormat,
     logLevelInString,
+    logMessageKey,
     sentryDsn,
   };
 

src/types.ts

@@ -20,6 +20,7 @@ export interface Options {
   secret?: string;
   webhookPath?: string;
   logLevel?: "trace" | "debug" | "info" | "warn" | "error" | "fatal";
+  logMessageKey?: string;
   port?: number;
   host?: string;
   baseUrl?: string;

test/create-probot.test.ts

@@ -1,3 +1,4 @@
+import SonicBoom from "sonic-boom";
 import { createProbot, Probot } from "../src";
 
 const env = {
@@ -62,4 +63,31 @@ describe("createProbot", () => {
     });
     expect(probot.log.level).toEqual("trace");
   });
+
+  test("env, logger message key", () => {
+    let outputData = "";
+
+    const sbWrite = SonicBoom.prototype.write;
+    SonicBoom.prototype.write = function (data) {
+      outputData += data;
+    };
+
+    const probot = createProbot({
+      env: {
+        ...env,
+        LOG_LEVEL: "info",
+        LOG_FORMAT: "json",
+        LOG_MESSAGE_KEY: "myMessage",
+      },
+      defaults: { logLevel: "trace" },
+    });
+
+    probot.log.info("Ciao");
+
+    try {
+      expect(JSON.parse(outputData).myMessage).toEqual("Ciao");
+    } finally {
+      SonicBoom.prototype.write = sbWrite;
+    }
+  });
 });