allow pause/resume background listen with silence/blank (#1300)

* allow pause/resume background listen with silence/blank

* wip

* wip

* wip

* wip

* update drachtio-fsmrf version

lib/session/call-session.js

@@ -10,8 +10,9 @@ const {
   RecordState,
   AllowedSipRecVerbs,
   AllowedConfirmSessionVerbs,
-  TtsStreamingEvents
-} = require('../utils/constants');
+  TtsStreamingEvents,
+  ListenStatus
+} = require('../utils/constants.json');
 const moment = require('moment');
 const assert = require('assert');
 const sessionTracker = require('./session-tracker');
@@ -716,10 +717,25 @@ class CallSession extends Emitter {
     return this._fillerNoise;
   }
 
+  async pauseOrResumeBackgroundListenIfRequired(action, silence = false) {
+    if ((action == 'pauseCallRecording' || action == 'resumeCallRecording') &&
+    this.backgroundTaskManager.isTaskRunning('record')) {
+      this.logger.debug({action, silence}, 'CallSession:pauseOrResumeBackgroundListenIfRequired');
+      const backgroundListenTask = this.backgroundTaskManager.getTask('record');
+      const status = action === 'pauseCallRecording' ? ListenStatus.Pause : ListenStatus.Resume;
+      backgroundListenTask.updateListen(
+        status,
+        silence
+      );
+    }
+  }
+
   async notifyRecordOptions(opts) {
-    const {action} = opts;
+    const {action, silence} = opts;
     this.logger.debug({opts}, 'CallSession:notifyRecordOptions');
 
+    this.pauseOrResumeBackgroundListenIfRequired(action, silence);
+
     /* if we have not answered yet, just save the details for later */
     if (!this.dlg) {
       if (action === 'startCallRecording') {

lib/tasks/listen.js

@@ -1,5 +1,5 @@
 const Task = require('./task');
-const {TaskName, TaskPreconditions, ListenEvents, ListenStatus} = require('../utils/constants');
+const {TaskName, TaskPreconditions, ListenEvents, ListenStatus} = require('../utils/constants.json');
 const makeTask = require('./make_task');
 const moment = require('moment');
 const MAX_PLAY_AUDIO_QUEUE_SIZE = 10;
@@ -103,9 +103,12 @@ class TaskListen extends Task {
     this.notifyTaskDone();
   }
 
-  async updateListen(status) {
+  async updateListen(status, silence = false) {
     if (!this.killed && this.ep && this.ep.connected) {
-      const args = this._bugname ? [this._bugname] : [];
+      const args = [
+        ...(this._bugname ? [this._bugname] : []),
+        ...(status === ListenStatus.Pause ? ([silence]) : []),
+      ];
       this.logger.info(`TaskListen:updateListen status ${status}`);
       switch (status) {
         case ListenStatus.Pause:

package-lock.json

@@ -32,7 +32,7 @@
         "bent": "^7.3.12",
         "debug": "^4.3.4",
         "deepcopy": "^2.1.0",
-        "drachtio-fsmrf": "^4.0.4",
+        "drachtio-fsmrf": "^4.1.2",
         "drachtio-srf": "^5.0.5",
         "express": "^4.19.2",
         "express-validator": "^7.0.1",
@@ -3856,9 +3856,9 @@
       }
     },
     "node_modules/drachtio-fsmrf": {
-      "version": "4.1.1",
-      "resolved": "https://registry.npmjs.org/drachtio-fsmrf/-/drachtio-fsmrf-4.1.1.tgz",
-      "integrity": "sha512-cI8gcs51TO9cZnO4TICFB6XlY85vWUBZqugw6cSSamcusNf+lm53WJWRUsPFHXHC6WKmAiVc/hPb62cvkkOcqw==",
+      "version": "4.1.2",
+      "resolved": "https://registry.npmjs.org/drachtio-fsmrf/-/drachtio-fsmrf-4.1.2.tgz",
+      "integrity": "sha512-Ftakpp3IdbiM4E3ZqFxVGoTRQAGf+gmOVDzQtqOtQA/BRBdCoZX2SR07XUcnfUpfo/VEH9X7tZnLwee4RKdYvg==",
       "license": "MIT",
       "dependencies": {
         "camel-case": "^4.1.2",

package.json

@@ -48,7 +48,7 @@
     "bent": "^7.3.12",
     "debug": "^4.3.4",
     "deepcopy": "^2.1.0",
-    "drachtio-fsmrf": "^4.0.4",
+    "drachtio-fsmrf": "^4.1.2",
     "drachtio-srf": "^5.0.5",
     "express": "^4.19.2",
     "express-validator": "^7.0.1",