fix: improved logging (#120)

* improved logging

* fix demux log line

package.json

@@ -1,6 +1,6 @@
 {
   "name": "rtcstats-server",
-  "version": "2.24.1",
+  "version": "2.24.3",
   "description": "The rtcstats-server represents the server side component of the rtcstats ecosystem, the client side being https://github.com/jitsi/rtcstats which collects and sends WebRTC related statistics.",
   "main": "websocket.js",
   "private": true,

src/app.js

@@ -317,8 +317,6 @@ function wsConnectionHandler(client, upgradeReq) {
         const demuxSink = new DemuxSink(demuxSinkOptions);
 
         demuxSink.on('close-sink', ({ id, meta }) => {
-            logger.info('[App] Queue for processing id %s', id);
-
             const { confID = '' } = meta;
             const tenantInfo = extractTenantDataFromUrl(confID);
 
@@ -344,6 +342,10 @@ function wsConnectionHandler(client, upgradeReq) {
                 ...tenantInfo
             };
 
+            const obfuscatedDumpData = obfuscatePII(dumpData);
+
+            logger.info('[App] Processing dump id %s, metadata %o', id, obfuscatedDumpData);
+
             // Don't process dumps generated by JVB & Jigasi, there should be a more formal process to
             if (config.features.disableFeatExtraction
                 || connectionInfo.clientProtocol?.includes('JVB')

src/demux.js

@@ -112,8 +112,8 @@ class DemuxSink extends Writable {
      * @param {string} id - UniqueId associated with the sink
      * @param {WriteStream} sink - Opened file writable stream associated with the id
      */
-    _sinkClose({ id, sink, meta }) {
-        this.log.info('[Demux] close-sink %s, metadata: %o', id, meta);
+    _sinkClose({ id, sink }) {
+        this.log.info('[Demux] close-sink %s', id);
 
         sink.end();
     }

src/worker-pool/WorkerPool.js

@@ -4,7 +4,7 @@ const { Worker } = require('worker_threads');
 
 const logger = require('../logging');
 const PromCollector = require('../metrics/PromCollector');
-const { ResponseType, obfuscatePII } = require('../utils/utils');
+const { ResponseType } = require('../utils/utils');
 
 const WorkerStatus = Object.freeze({
     IDLE: 'IDLE',
@@ -131,10 +131,14 @@ class WorkerPool extends EventEmitter {
      * @param {*} task
      */
     _processTask(workerMeta, task) {
-        const { body = {} } = task;
-        const obfuscatedBody = obfuscatePII(body);
+        const { body = {}, body: { clientId = '' } = {} } = task;
+
+        logger.info(
+            '[WorkerPool] Processing task with clientId %s, current queue size %d',
+            clientId,
+            this.taskQueue.length
+        );
 
-        logger.info('[WorkerPool] Processing task %o, current queue size %d', obfuscatedBody, this.taskQueue.length);
         workerMeta.currentTaskMeta = body;
         workerMeta.worker.postMessage(task);
         workerMeta.status = WorkerStatus.RUNNING;