Improve logging

app/common/prefixedConsole.mjs

@@ -0,0 +1,12 @@
+import { Console } from 'node:console';
+import consoleStamp from 'console-stamp';
+
+export default function prefixedConsole(...prefixes) {
+  let result = new Console({ stdout: process.stdout, stderr: process.stderr });
+
+  let prefix = prefixes.map(s => `[${s}]`).join(' ');
+  let format = `:date(dd.mm.yyyy HH:MM:ss.l) :label(7) ${prefix}`.trim();
+  consoleStamp(result, { format });
+
+  return result;
+}

app/index.mjs

@@ -1,7 +1,9 @@
 import dotenv from 'dotenv';
+import consoleStamp from 'console-stamp';
 import cron from './cron.mjs';
 import { sendTweets } from './twitter/index.mjs';
 
+consoleStamp(console);
 dotenv.config();
 
 const actions = {

app/splatnet/NsoClient.mjs

@@ -1,6 +1,7 @@
 import CoralApi from 'nxapi/coral';
 import { addUserAgent } from "nxapi";
 import ValueCache from '../common/ValueCache.mjs';
+import prefixedConsole from '../common/prefixedConsole.mjs';
 
 let _nxapiInitialized = false;
 
@@ -17,6 +18,7 @@ export default class NsoClient
   constructor(nintendoToken = null) {
     initializeNxapi();
 
+    this.console = prefixedConsole('NSO');
     this.nintendoToken = nintendoToken || process.env.NINTENDO_TOKEN;
   }
 
@@ -52,11 +54,11 @@ export default class NsoClient
   }
 
   async _createCoralSession() {
-    console.debug('Creating Coral session');
+    this.console.info('Creating Coral session...');
     let { data } = await CoralApi.createWithSessionToken(this.nintendoToken);
 
     let expires = this._calculateCacheExpiry(data.credential.expiresIn);
-    console.debug(`Caching Coral session until: ${expires}`);
+    this.console.debug(`Caching Coral session until: ${expires}`);
     await this._getCoralCache().setData(data, expires);
 
     return data;
@@ -84,11 +86,11 @@ export default class NsoClient
   async _createWebServiceToken(id, tokenCache) {
     let coral = await this.getCoralApi();
 
-    console.debug(`Creating web service token for ID ${id}`);
+    this.console.info(`Creating web service token for ID ${id}...`);
     let { result } = await coral.getWebServiceToken(id);
 
     let expires = this._calculateCacheExpiry(result.expiresIn);
-    console.debug(`Caching web service token for ID ${id} until: ${expires}`);
+    this.console.debug(`Caching web service token for ID ${id} until: ${expires}`);
     await tokenCache.setData(result, expires);
 
     return result;

app/splatnet/SplatNet3Client.mjs

@@ -1,5 +1,6 @@
 import ValueCache from "../common/ValueCache.mjs";
 import NsoClient from "./NsoClient.mjs";
+import prefixedConsole from '../common/prefixedConsole.mjs';
 
 export const SPLATNET3_WEB_SERVICE_ID = '4834290508791808';
 
@@ -10,6 +11,7 @@ export default class SplatNet3Client
   bulletToken = null;
 
   constructor(nsoClient = null) {
+    this.console = prefixedConsole('SplatNet');
     this.nsoClient = nsoClient ?? new NsoClient;
   }
 
@@ -52,7 +54,7 @@ export default class SplatNet3Client
   }
 
   async _createBulletToken(webServiceToken, bulletTokenCache) {
-    console.debug('Creating bullet token');
+    this.console.info('Creating bullet token...');
 
     let response = await fetch(this.baseUrl + '/api/bullet_tokens', {
       method: 'POST',
@@ -73,7 +75,7 @@ export default class SplatNet3Client
     let expiry = this._calculateCacheExpiry(7200);
     await bulletTokenCache.setData(bulletToken, expiry);
 
-    console.debug(`Caching bullet token until: ${expiry}`);
+    this.console.debug(`Caching bullet token until: ${expiry}`);
 
     return bulletToken;
   }

app/splatnet/index.mjs

@@ -8,7 +8,7 @@ import SplatNet3Client, { SPLATNET3_WEB_SERVICE_ID } from "./SplatNet3Client.mjs
  * even if e.g. the imink API has intermittent downtime.
  */
 export async function warmCache() {
-  console.debug('Warming caches...');
+  console.info('Warming caches...');
 
   let nso = new NsoClient;
   let splatnet = new SplatNet3Client;

package.json

@@ -10,6 +10,7 @@
     "twitter": "node app/index.mjs twitter"
   },
   "dependencies": {
+    "console-stamp": "^3.0.6",
     "cron": "^2.1.0",
     "dotenv": "^16.0.2",
     "ecstatic": "^4.1.4",