add try catch for mp3 encoder

lib/record/encoder.js

@@ -2,7 +2,7 @@ const { Transform } = require('stream');
 const lamejs = require('@jambonz/lamejs');
 
 class PCMToMP3Encoder extends Transform {
-  constructor(options) {
+  constructor(options, logger) {
     super(options);
 
     const channels = options.channels || 1;
@@ -11,33 +11,40 @@ class PCMToMP3Encoder extends Transform {
 
     this.encoder = new lamejs.Mp3Encoder(channels, sampleRate, bitRate);
     this.channels = channels;
+    this.logger = logger;
   }
 
   _transform(chunk, encoding, callback) {
-    // Convert chunk buffer into Int16Array for lamejs
-    const samples = new Int16Array(chunk.buffer, chunk.byteOffset, chunk.length / 2);
+    try {
+      // Convert chunk buffer into Int16Array for lamejs
+      const samples = new Int16Array(chunk.buffer, chunk.byteOffset, chunk.length / 2);
 
-    // Split input samples into left and right channel arrays if stereo
-    let leftChannel, rightChannel;
-    if (this.channels === 2) {
-      leftChannel = new Int16Array(samples.length / 2);
-      rightChannel = new Int16Array(samples.length / 2);
+      // Split input samples into left and right channel arrays if stereo
+      let leftChannel, rightChannel;
+      if (this.channels === 2) {
+        leftChannel = new Int16Array(samples.length / 2);
+        rightChannel = new Int16Array(samples.length / 2);
 
-      for (let i = 0; i < samples.length; i += 2) {
-        leftChannel[i / 2] = samples[i];
-        rightChannel[i / 2] = samples[i + 1];
+        for (let i = 0; i < samples.length; i += 2) {
+          leftChannel[i / 2] = samples[i];
+          rightChannel[i / 2] = samples[i + 1];
+        }
+      } else {
+        leftChannel = samples;
       }
-    } else {
-      leftChannel = samples;
-    }
 
-    // Encode the input data
-    const mp3Data = this.encoder.encodeBuffer(leftChannel, rightChannel);
+      // Encode the input data
+      const mp3Data = this.encoder.encodeBuffer(leftChannel, rightChannel);
 
-    if (mp3Data.length > 0) {
-      this.push(Buffer.from(mp3Data));
+      if (mp3Data.length > 0) {
+        this.push(Buffer.from(mp3Data));
+      }
+      callback();
+    } catch (err) {
+      this.logger.error(
+        { err },
+        'Error while mp3 transform');
     }
-    callback();
   }
 
   _flush(callback) {

lib/record/upload.js

@@ -58,7 +58,7 @@ async function upload(logger, socket) {
               channels: 2,
               sampleRate: sampleRate,
               bitrate: 128
-            });
+            }, logger);
           }
           const handleError = (err, streamType) => {
             logger.error(