drachtio-bridge-test.js

const Srf = require('drachtio-srf');
const Mrf = require('drachtio-fsmrf');
const config = require('config');
const srf = new Srf() ;
const mrf = new Mrf(srf) ;

// Connect to drachtio server using SRF - sync
srf.connect(config.get('drachtio'), (err, srf) => {
  if (err) return log_to_console(false, `error connecting to drachtio: ${err}`);
});

// Connect to freeswitch using MRF - sync
mrf.connect(config.get('freeswitch'), (err, mediaserver) => {
  if (err) return log_to_console(false, `error connecting to mediaserver: ${err}`);
  // This is important, this adds the mediaserver object to the SRF object so we can access it directly outside of this function
  srf.locals.ms = mediaserver
  console.log(`connected to mediaserver listening on ${JSON.stringify(mediaserver.sip)}`);
});

// Log connection and information - async, this is a listener
srf.on('connect', (err, hostport) => {
  if (err) return log_to_console(false, `error on drachtio connect: ${err}`);
  console.log(`successfully connected to drachtio listening on ${hostport}`);
});

srf.on('destroy', () => {
  console.log("SRF destroyed");
});

srf.options((req, res) => {
  // Shuts up the noise!
  res.send(200);
});

// Listener for an INVITE coming in - async
srf.invite(async(req, res) => {
  // req = request
  // res = result
  // Localised media server reference
  const ms = req.app.locals.ms;

  try {
    // Create a media endpoint - "answer" the call
    const {endpoint, dialog} = await ms.connectCaller(req, res);
    console.log(`Endpoint UUID: ${endpoint.uuid} Dialog Call-Id: ${dialog.sip['callId']}`);
    await endpoint.play(`test.wav`);
    endpoint.execute('endless_playback', 'tone_stream://%(400,200,400,425);%(400,2000,400,425)')
    .then(() => {
      console.log(`Finished playing back ringing`);
    });
    srf.createUAC(`sip:${config.to_number}@${config.outbound_sbc}`,
        {
          localSdp: b_endpoint.local.sdp
        },
        {
          cbRequest: (err, req) => invite = req,
        })
    ));
    if (err) {
      console.log("Hanging up B leg (CANCEL) due to ring timeout")
      invite.cancel()
      b_endpoint.destroy()
      endpoint.destroy()
    }
    else {
      b_endpoint.modify(b_dialog.remote.sdp);
      ep.bridge(b_endpoint)
    }
  }
});