jambonz-api-server/test/recent-calls.js

const test = require('tape') ;
const fs = require('fs');
const jwt = require('jsonwebtoken');
const ADMIN_TOKEN = '38700987-c7a4-4685-a5bb-af378f9734de';
const authAdmin = {bearer: ADMIN_TOKEN};
const { createClient } = require('./http-client');
const request = createClient({
  baseUrl: 'http://127.0.0.1:3000/v1'
});
const consoleLogger = {debug: console.log, info: console.log, error: console.error}
const {writeCdrs} = require('@jambonz/time-series')(consoleLogger, '127.0.0.1');
const {createServiceProvider, createAccount, deleteObjectBySid} = require('./utils');

process.on('unhandledRejection', (reason, p) => {
  console.log('Unhandled Rejection at: Promise', p, 'reason:', reason);
});

test('recent calls tests', async(t) => {
  const app = require('../app');
  const jsonKey = fs.readFileSync(`${__dirname}/data/test.json`, {encoding: 'utf8'});
  let sid;
  try {
    let result;
    const service_provider_sid = await createServiceProvider(request);
    const account_sid = await createAccount(request, service_provider_sid);

    const token = jwt.sign({
      account_sid,
      scope: "account",
      permissions: ["PROVISION_USERS", "PROVISION_SERVICES", "VIEW_ONLY"]
    }, process.env.JWT_SECRET, { expiresIn: '1h' });
    const authUser = {bearer: token};

    const tokenSP = jwt.sign({
      service_provider_sid,
      scope: "account",
      permissions: ["PROVISION_USERS", "PROVISION_SERVICES", "VIEW_ONLY"]
    }, process.env.JWT_SECRET, { expiresIn: '1h' });
    const authUserSP = {bearer: token};

    /* write sample cdr data */
    const points = 500;
    const data = [];
    const start = new Date(Date.now() - (30 * 24 * 60 * 60 * 1000));
    const now = new Date();
    const increment = (now.getTime() - start.getTime()) / points;
    for (let i =0 ; i < 5; i++) {
      const attempted_at = new Date(start.getTime() + (i * increment));
      const failed = 0 === i % 5;
      data.push({
        call_sid: 'b6f48929-8e86-4d62-ae3b-64fb574d91f6',
        from: '15083084809',
        to: '18882349999',
        answered:  !failed,
        sip_callid: '685cd008-0a66-4974-b37a-bdd6d9a3c4aa@192.168.1.100',
        sip_status: 200,
        duration: failed ? 0 : 45,
        attempted_at: attempted_at.getTime(),
        answered_at: attempted_at.getTime() + 3000,
        terminated_at: attempted_at.getTime() + 45000,
        termination_reason: 'caller hungup',
        host: "192.168.1.100",
        remote_host: '3.55.24.34',
        account_sid,
        service_provider_sid,
        direction: 0 === i % 2 ? 'inbound' : 'outbound',
        trunk:  0 === i % 2 ? 'twilio' : 'user'
      });
    }
  
    await writeCdrs(data);
    t.pass('seeded cdr data');
        
    /* query last 7 days by account */
    result = await request.get(`/Accounts/${account_sid}/RecentCalls?page=1&count=25`, {
      auth: authUser,
      json: true,
    });
    console.log(JSON.stringify(result));
    t.ok(result.data.length === 5, 'retrieved 5 recent calls by account');

    result = await request.get(`/Accounts/${account_sid}/RecentCalls?page=1&count=25&filter=1508`, {
      auth: authUser,
      json: true,
    });
    console.log(JSON.stringify(result));
    t.ok(result.data.length === 5, 'retrieved 5 recent calls by account and from');

    result = await request.get(`/Accounts/${account_sid}/RecentCalls?page=1&count=25&filter=15080`, {
      auth: authUser,
      json: true,
    });
    console.log(JSON.stringify(result));
    t.ok(result.data.length === 0, 'retrieved 0 recent calls by account and non-matching from');

    result = await request.get(`/Accounts/${account_sid}/RecentCalls?page=1&count=25&filter=1888`, {
      auth: authUser,
      json: true,
    });
    console.log(JSON.stringify(result));
    t.ok(result.data.length === 5, 'retrieved 5 recent calls by account and to');

    /* query last 7 days by service provider */
    result = await request.get(`/ServiceProviders/${service_provider_sid}/RecentCalls?page=1&count=25`, {
      auth: authAdmin,
      json: true,
    });
    t.ok(result.data.length === 5, 'retrieved 5 recent calls by service provider');

    result = await request.get(`/ServiceProviders/${service_provider_sid}/RecentCalls?page=1&count=25&filter=1508`, {
      auth: authAdmin,
      json: true,
    });
    t.ok(result.data.length === 5, 'retrieved 5 recent calls by service provider and from');

    result = await request.get(`/ServiceProviders/${service_provider_sid}/RecentCalls?page=1&count=25&filter=1888`, {
      auth: authAdmin,
      json: true,
    });
    t.ok(result.data.length === 5, 'retrieved 5 recent calls by service provider and to');

    //console.log({data: result.data}, 'SP recent calls');

    /* pull sip traces and pcap from homer */
    /*
    result = await request.get(`/Accounts/${account_sid}/RecentCalls/224f0f24-69aa-123a-eaa6-0ea24be4d211`, {
      auth: authUser,
      json: true
    });
    console.log(result);

    const writeStream = fs.createWriteStream('./call.pcap');
    const ret = await request.get(`/Accounts/${account_sid}/RecentCalls/224f0f24-69aa-123a-eaa6-0ea24be4d211/pcap`, {
      auth: authUser,
      resolveWithFullResponse: true
    });
    writeStream.write(ret.body);
    */
   
    await deleteObjectBySid(request, '/Accounts', account_sid);
    await deleteObjectBySid(request, '/ServiceProviders', service_provider_sid);

    //t.end();
  }
  catch (err) {
    console.error(err);
    t.end(err);
  }
});