update rtpengine-utils again

Co-authored-by: Markus Frindt <m.frindt@cognigy.com>

Dockerfile

@@ -1,4 +1,4 @@
-FROM --platform=linux/amd64 node:18.8.0-alpine as base
+FROM --platform=linux/amd64 node:18.9.0-alpine3.16 as base
 
 RUN apk --update --no-cache add --virtual .builds-deps build-base python3
 

app.js

@@ -69,7 +69,7 @@ const {
 const ngProtocol = process.env.JAMBONES_NG_PROTOCOL || 'udp';
 const ngPort = process.env.RTPENGINE_PORT || ('udp' === ngProtocol ? 22222 : 8080);
 const {getRtpEngine, setRtpEngines} = require('@jambonz/rtpengine-utils')([], logger, {
-  emitter: stats,
+  //emitter: stats,
   dtmfListenPort: process.env.DTMF_LISTEN_PORT || 22224,
   protocol: ngProtocol
 });

lib/call-session.js

@@ -80,6 +80,10 @@ class CallSession extends Emitter {
     return tp && -1 !== tp.indexOf('SAVP');
   }
 
+  get isFive9VoiceStream() {
+    return this.req.has('X-Five9-StreamingPairId');
+  }
+
   async connect() {
     const {sdp} = this.req.locals;
     this.logger.info('inbound call accepted for routing');
@@ -148,137 +152,139 @@ class CallSession extends Emitter {
     else uri = `${obj.scheme}:${host}`;
     this.logger.info(`uri will be: ${uri}, proxy ${proxy}`);
 
-    const opts = {
-      ...this.rtpEngineOpts.common,
-      ...this.rtpEngineOpts.uac.mediaOpts,
-      'from-tag': this.rtpEngineOpts.uas.tag,
-      direction:  ['public', 'private'],
-      sdp
-    };
-    const startAt = process.hrtime();
-    this.offer(opts, async(err, response) => {
-      try {
-        if (err || 'ok' !== response.result) {
-          this.logger.error({}, `rtpengine offer failed with ${JSON.stringify(response)}`);
-          return this.res.send(480, {
-            headers: {
-              'X-Reason': 'RTPENGINE_OFFER_FAILED'
-            }
-          });
-        }
-        this.rtpengineIp = opts.sdp ? parseConnectionIp(opts.sdp) : 'undefined';
-        const rtt = roundTripTime(startAt);
-        this.stats.histogram('app.rtpengine.response_time', rtt, [
-          'direction:inbound', 'command:offer', `rtpengine:${this.rtpengineIp}`]);
-        this.logger.debug({opts, response, rtt, rtpengine: this.rtpengineIp}, 'response from rtpengine to offer');
-        if ('ok' !== response.result) {
-        }
-        let headers = {
-          'From': createBLegFromHeader(this.req),
-          'To': this.req.get('To'),
-          'X-Account-Sid': this.req.locals.account_sid,
-          'X-CID': this.req.get('Call-ID'),
-          'X-Forwarded-For': `${this.req.source_address}`
-        };
-        if (this.privateSipAddress) headers = {...headers, Contact: `<sip:${this.privateSipAddress}>`};
+    try {
+      const opts = {
+        ...this.rtpEngineOpts.common,
+        ...this.rtpEngineOpts.uac.mediaOpts,
+        'from-tag': this.rtpEngineOpts.uas.tag,
+        direction:  ['public', 'private'],
+        sdp
+      };
+      const startAt = process.hrtime();
+      const response = await this.offer(opts);
+      this.rtpengineIp = opts.sdp ? parseConnectionIp(opts.sdp) : 'undefined';
+      const rtt = roundTripTime(startAt);
+      this.stats.histogram('app.rtpengine.response_time', rtt, [
+        'direction:inbound', 'command:offer', `rtpengine:${this.rtpengineIp}`]);
+      this.logger.debug({opts, response, rtt, rtpengine: this.rtpengineIp}, 'response from rtpengine to offer');
+      if ('ok' !== response.result) {
+        this.logger.error({}, `rtpengine offer failed with ${JSON.stringify(response)}`);
+        throw new Error('rtpengine failed: answer');
+      }
 
-        const spdOfferB = this.siprec && this.xml ?
-          createSiprecBody(headers, response.sdp, this.xml.type, this.xml.content) :
-          response.sdp;
+      let headers = {
+        'From': createBLegFromHeader(this.req),
+        'To': this.req.get('To'),
+        'X-Account-Sid': this.req.locals.account_sid,
+        'X-CID': this.req.get('Call-ID'),
+        'X-Forwarded-For': `${this.req.source_address}`
+      };
+      if (this.privateSipAddress) headers = {...headers, Contact: `<sip:${this.privateSipAddress}>`};
 
-        const responseHeaders = {};
-        if (this.req.locals.carrier) {
-          Object.assign(headers, {
-            'X-Originating-Carrier': this.req.locals.carrier,
-            'X-Voip-Carrier-Sid': this.req.locals.voip_carrier_sid
-          });
-        }
-        if (this.req.locals.msTeamsTenantFqdn) {
-          Object.assign(headers, {'X-MS-Teams-Tenant-FQDN': this.req.locals.msTeamsTenantFqdn});
+      const spdOfferB = this.siprec && this.xml ?
+        createSiprecBody(headers, response.sdp, this.xml.type, this.xml.content) :
+        response.sdp;
 
-          // for Microsoft Teams the Contact header must include the tenant FQDN
-          Object.assign(responseHeaders, {
-            Allow: 'INVITE, ACK, OPTIONS, CANCEL, BYE, NOTIFY, UPDATE, PRACK',
-            Contact: `sip:${this.req.locals.msTeamsTenantFqdn}`
-          });
+      const responseHeaders = {};
+      if (this.req.locals.carrier) {
+        Object.assign(headers, {
+          'X-Originating-Carrier': this.req.locals.carrier,
+          'X-Voip-Carrier-Sid': this.req.locals.voip_carrier_sid
+        });
+      }
+      if (this.req.locals.msTeamsTenantFqdn) {
+        Object.assign(headers, {'X-MS-Teams-Tenant-FQDN': this.req.locals.msTeamsTenantFqdn});
+
+        // for Microsoft Teams the Contact header must include the tenant FQDN
+        Object.assign(responseHeaders, {
+          Allow: 'INVITE, ACK, OPTIONS, CANCEL, BYE, NOTIFY, UPDATE, PRACK',
+          Contact: `sip:${this.req.locals.msTeamsTenantFqdn}`
+        });
+      }
+      if (this.req.locals.application_sid) {
+        Object.assign(headers, {'X-Application-Sid': this.req.locals.application_sid});
+      }
+      else if (this.req.authorization) {
+        if (this.req.authorization.grant && this.req.authorization.grant.application_sid) {
+          Object.assign(headers, {'X-Application-Sid': this.req.authorization.grant.application_sid});
         }
-        if (this.req.locals.application_sid) {
-          Object.assign(headers, {'X-Application-Sid': this.req.locals.application_sid});
+        if (this.req.authorization.challengeResponse) {
+          const {username, realm} = this.req.authorization.challengeResponse;
+          Object.assign(headers, {'X-Authenticated-User': `${username}@${realm}`});
         }
-        else if (this.req.authorization) {
-          if (this.req.authorization.grant && this.req.authorization.grant.application_sid) {
-            Object.assign(headers, {'X-Application-Sid': this.req.authorization.grant.application_sid});
+      }
+
+      if (this.req.canceled) throw new Error('call canceled');
+
+      // now send the INVITE in towards the feature servers
+      debug(`sending INVITE to ${proxy} with ${uri}`);
+      const {uas, uac} = await this.srf.createB2BUA(this.req, this.res, uri, {
+        proxy,
+        headers,
+        responseHeaders,
+        proxyRequestHeaders: [
+          'all',
+          '-Authorization',
+          '-Max-Forwards',
+          '-Record-Route',
+          '-Session-Expires',
+          '-X-Subspace-Forwarded-For'
+        ],
+        proxyResponseHeaders: ['all', '-X-Trace-ID'],
+        localSdpB: spdOfferB,
+        localSdpA: async(sdp, res) => {
+          this.rtpEngineOpts.uac.tag = res.getParsedHeader('To').params.tag;
+          const opts = {
+            ...this.rtpEngineOpts.common,
+            ...this.rtpEngineOpts.uas.mediaOpts,
+            'from-tag': this.rtpEngineOpts.uas.tag,
+            'to-tag': this.rtpEngineOpts.uac.tag,
+            sdp
+          };
+          const startAt = process.hrtime();
+          const response = await this.answer(opts);
+          const rtt = roundTripTime(startAt);
+          this.stats.histogram('app.rtpengine.response_time', rtt, [
+            'direction:inbound', 'command:answer', `rtpengine:${this.rtpengineIp}`]);
+          if ('ok' !== response.result) {
+            this.logger.error(`rtpengine answer failed with ${JSON.stringify(response)}`);
+            throw new Error('rtpengine failed: answer');
           }
-          if (this.req.authorization.challengeResponse) {
-            const {username, realm} = this.req.authorization.challengeResponse;
-            Object.assign(headers, {'X-Authenticated-User': `${username}@${realm}`});
-          }
-        }
-
-        if (this.req.canceled) throw new Error('call canceled');
-
-        // now send the INVITE in towards the feature servers
-        debug(`sending INVITE to ${proxy} with ${uri}`);
-        const {uas, uac} = await this.srf.createB2BUA(this.req, this.res, uri, {
-          proxy,
-          headers,
-          responseHeaders,
-          proxyRequestHeaders: [
-            'all',
-            '-Authorization',
-            '-Max-Forwards',
-            '-Record-Route',
-            '-Session-Expires',
-            '-X-Subspace-Forwarded-For'
-          ],
-          proxyResponseHeaders: ['all', '-X-Trace-ID'],
-          localSdpB: spdOfferB,
-          localSdpA: async(sdp, res) => {
-            this.rtpEngineOpts.uac.tag = res.getParsedHeader('To').params.tag;
+          /* special case: Five9 Voicestream calls do not advertise a:sendonly, though they should */
+          if (this.isFive9VoiceStream) {
             const opts = {
               ...this.rtpEngineOpts.common,
-              ...this.rtpEngineOpts.uas.mediaOpts,
-              'from-tag': this.rtpEngineOpts.uas.tag,
-              'to-tag': this.rtpEngineOpts.uac.tag,
-              sdp
+              'from-tag':this.rtpEngineOpts.uac.tag
             };
-            const startAt = process.hrtime();
-            const response = await this.answer(opts);
-            const rtt = roundTripTime(startAt);
-            this.stats.histogram('app.rtpengine.response_time', rtt, [
-              'direction:inbound', 'command:answer', `rtpengine:${this.rtpengineIp}`]);
-            if ('ok' !== response.result) {
-              this.logger.error(`rtpengine answer failed with ${JSON.stringify(response)}`);
-              throw new Error('rtpengine failed: answer');
-            }
-            return response.sdp;
+            this.logger.info('Voicestream call from Five9, blocking audio in the reverse direction');
+            const response = await Promise.all([this.blockMedia(opts), this.blockDTMF(opts)]);
+            this.logger.debug({response}, 'response to blockMedia/blockDTMF');
           }
-        });
 
-        // successfully connected
-        this.logger.info('call connected successfully to feature server');
-        debug('call connected successfully to feature server');
-        this._setHandlers({uas, uac});
-
-
-      } catch (err) {
-        // eslint-disable-next-line promise/no-promise-in-callback
-        this.rtpEngineResource.destroy()
-          .catch((err) => this.logger.info({err}, 'Error destroying rtpe after failure'));
-        this.activeCallIds.delete(this.req.get('Call-ID'));
-        this.stats.gauge('sbc.sip.calls.count', this.activeCallIds.size);
-        if (err instanceof SipError) {
-          const tags = ['accepted:no', `sipStatus:${err.status}`, `originator:${this.req.locals.originator}`];
-          this.stats.increment('sbc.terminations', tags);
-          this.logger.info(`call failed to connect to feature server with ${err.status}`);
-          this.emit('failed');
+          return response.sdp;
         }
-        else if (err.message !== 'call canceled') {
-          this.logger.error(err, 'unexpected error routing inbound call');
-        }
-        this.srf.endSession(this.req);
+      });
+
+      // successfully connected
+      this.logger.info('call connected successfully to feature server');
+      debug('call connected successfully to feature server');
+      this._setHandlers({uas, uac});
+      return;
+    } catch (err) {
+      this.rtpEngineResource.destroy().catch((err) => this.logger.info({err}, 'Error destroying rtpe after failure'));
+      this.activeCallIds.delete(this.req.get('Call-ID'));
+      this.stats.gauge('sbc.sip.calls.count', this.activeCallIds.size);
+      if (err instanceof SipError) {
+        const tags = ['accepted:no', `sipStatus:${err.status}`, `originator:${this.req.locals.originator}`];
+        this.stats.increment('sbc.terminations', tags);
+        this.logger.info(`call failed to connect to feature server with ${err.status}`);
+        this.emit('failed');
       }
-    });
+      else if (err.message !== 'call canceled') {
+        this.logger.error(err, 'unexpected error routing inbound call');
+      }
+      this.srf.endSession(this.req);
+    }
   }
 
   _setDlgHandlers(dlg) {
@@ -517,11 +523,16 @@ Duration=${payload.duration} `
         req.body;
 
       const reason = req.get('X-Reason');
+      const isReleasingMedia = reason && dlg.type === 'uas' && ['release-media', 'anchor-media'].includes(reason);
       const fromTag = dlg.type === 'uas' ? this.rtpEngineOpts.uas.tag : this.rtpEngineOpts.uac.tag;
       const toTag = dlg.type === 'uas' ? this.rtpEngineOpts.uac.tag : this.rtpEngineOpts.uas.tag;
       const offerMedia = dlg.type === 'uas' ? this.rtpEngineOpts.uac.mediaOpts : this.rtpEngineOpts.uas.mediaOpts;
       const answerMedia = dlg.type === 'uas' ? this.rtpEngineOpts.uas.mediaOpts : this.rtpEngineOpts.uac.mediaOpts;
       const direction =  dlg.type === 'uas' ? ['public', 'private'] : ['private', 'public'];
+      if (isReleasingMedia) {
+        if (!offerMedia.flags.includes('asymmetric')) offerMedia.flags.push('asymmetric');
+        offerMedia.flags = offerMedia.flags.filter((f) => f !== 'media handover');
+      }
       let opts = {
         ...this.rtpEngineOpts.common,
         ...offerMedia,
@@ -540,11 +551,11 @@ Duration=${payload.duration} `
 
       /* if this is a re-invite from the FS to change media anchoring, avoid sending the reinvite out */
       let sdp;
-      if (reason && dlg.type === 'uac' && ['release-media', 'anchor-media'].includes(reason) &&
-        !this.callerIsUsingSrtp) {
+      if (isReleasingMedia && !this.callerIsUsingSrtp) {
         this.logger.info({response}, `got a reinvite from FS to ${reason}`);
         sdp = dlg.other.remote.sdp;
-        answerMedia.flags = ['asymmetric', 'port latching'];
+        if (!answerMedia.flags.includes('asymmetric')) answerMedia.flags.push('asymmetric');
+        answerMedia.flags = answerMedia.flags.filter((f) => f !== 'media handover');
         this._mediaReleased = 'release-media' === reason;
       }
       else {
@@ -785,10 +796,10 @@ Duration=${payload.duration} `
       res.send(202);
 
       // invite to new fs
-      const headers = {};
-      if (req.has('X-Retain-Call-Sid')) {
-        Object.assign(headers, {'X-Retain-Call-Sid': req.get('X-Retain-Call-Sid')});
-      }
+      const headers = {
+        ...(req.has('X-Retain-Call-Sid') && {'X-Retain-Call-Sid': req.get('X-Retain-Call-Sid')}),
+        ...(req.has('X-Account-Sid') && {'X-Account-Sid': req.get('X-Account-Sid')})
+      };
       const uac = await this.srf.createUAC(referTo.uri, {localSdp: dlg.local.sdp, headers});
       this.uac = uac;
       uac.other = this.uas;

lib/db-utils.js

@@ -139,7 +139,7 @@ module.exports = (srf, logger) => {
           /* we have one or more carriers that match.  Now we need to find one with a provisioned phone number */
           const vc_sids = matches.map((m) => `'${m.voip_carrier_sid}'`).join(',');
           const did = normalizeDID(req.calledNumber);
-          const sql =  `SELECT * FROM phone_numbers WHERE number = ${did} AND voip_carrier_sid IN (${vc_sids})`;
+          const sql =  `SELECT * FROM phone_numbers WHERE number = '${did}' AND voip_carrier_sid IN (${vc_sids})`;
           logger.debug({matches, sql, did, vc_sids}, 'looking up DID');
 
           const [r] = await pp.query(sql);

lib/utils.js

@@ -12,10 +12,12 @@ const getAppserver = (srf) => {
 };
 
 function makeRtpEngineOpts(req, srcIsUsingSrtp, dstIsUsingSrtp, teams = false) {
+  const rtpCopy = JSON.parse(JSON.stringify(rtpCharacteristics));
+  const srtpCopy = JSON.parse(JSON.stringify(srtpCharacteristics));
   const from = req.getParsedHeader('from');
-  const srtpOpts = teams ? srtpCharacteristics['teams'] : srtpCharacteristics['default'];
-  const dstOpts = dstIsUsingSrtp ? srtpOpts : rtpCharacteristics;
-  const srcOpts = srcIsUsingSrtp ? srtpOpts : rtpCharacteristics;
+  const srtpOpts = teams ? srtpCopy['teams'] : srtpCopy['default'];
+  const dstOpts = dstIsUsingSrtp ? srtpOpts : rtpCopy;
+  const srcOpts = srcIsUsingSrtp ? srtpOpts : rtpCopy;
 
   /* webrtc clients (e.g. sipjs) send DMTF via SIP INFO */
   if ((srcIsUsingSrtp || dstIsUsingSrtp) && !teams) {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "sbc-inbound",
-  "version": "v0.7.6",
+  "version": "v0.7.7",
   "main": "app.js",
   "engines": {
     "node": ">= 12.0.0"
@@ -29,10 +29,10 @@
     "@jambonz/http-authenticator": "^0.2.2",
     "@jambonz/http-health-check": "^0.0.1",
     "@jambonz/realtimedb-helpers": "^0.4.29",
-    "@jambonz/rtpengine-utils": "^0.3.6",
+    "@jambonz/rtpengine-utils": "^0.3.10",
     "@jambonz/siprec-client-utils": "^0.1.4",
     "@jambonz/stats-collector": "^0.1.6",
-    "@jambonz/time-series": "^0.2.4",
+    "@jambonz/time-series": "^0.2.5",
     "aws-sdk": "^2.1152.0",
     "bent": "^7.3.12",
     "cidr-matcher": "^2.1.1",