tel-carrier.js

'use strict';

var request = require('request')
  , allGateways
  ;

request.get('http://tel-carrier.coolaj86.com/gateways', function (err, req, data) {
  try {
    allGateways = JSON.parse(data);
  } catch(e) {
    // ignore
    allGateways = {};
  }
});

function updateRegistry(number, map, opts) {
  opts = opts || {};

  if (!allGateways) {
    setTimeout(function () {
      updateRegistry(number, map, opts);
    }, 500);
    return;
  }

  var data = { carriers: {}, numbers: {} }
    ;

  if ((map.smsGateway && !(allGateways[map.carrier]||{}).sms) || (map.mmsGateway && !(allGateways[map.carrier]||{}).mms)) {
    data.carriers[map.carrier] = { sms: (map.smsGateway||'').replace(/.*@/, ''), mms: (map.mmsGateway||'').replace(/.*@/, '') };
  }

  data.numbers[number] = { wireless: map.wireless, carrier: map.carrier };

  if (false === opts.authoritative) {
    delete data.carriers;
    delete data.numbers[number].carrier;
    delete data.numbers[number].wireless;
  }

  if (data.carriers) {
    allGateways[map.carrier] = data.carriers[map.carrier];
  }
  request.post('http://tel-carrier.coolaj86.com/analytics', { json: data }, function (/*err, req, data*/) {
    // ignore
  });
}

module.exports.create = function (opts) {
  var jar = request.jar()
    , services
    , service
    ;

  services = require('./services');
  service = services[opts.service];

  // TODO move
  function normalize(number, map/*, opts*/) {
    map.number = '+1' + /(?=\+?1)?(\d{10})$/.exec(String(map.number))[1];
    if (map.smsGateway) {
      map.smsGateway = map.number.replace(/^\+1/, '') + map.smsGateway.replace(/.*@/, '@');
    }
    if (map.mmsGateway) {
      map.mmsGateway = map.number.replace(/^\+1/, '') + map.mmsGateway.replace(/.*@/, '@');
    }
    return map;
  }

  function normalizeNum(number) {
    return String(number).replace(/(?=\+?1)?(\d{10})$/, '$1');
  }
  
  return {
    lookup: function (numbers, fn, pre, post) {
      if (!Array.isArray(numbers)) {
        service = service.one || service;
        numbers = normalizeNum(numbers);
      } else {
        service = service.many;
        numbers.forEach(function (n, i) {
          numbers[i] = normalizeNum(n);
        });
        numbers = numbers.filter(function (n) { return n; });
      }

      service(request, jar, numbers, opts, function (err, maps, opts) {
        if (!Array.isArray(numbers)) {
          if (maps && maps.carrier) {
            maps = normalize(numbers, maps, opts);
            updateRegistry(numbers, maps, opts);
          }
        } else {
          numbers.forEach(function (n, i) {
            maps[i] = normalize(n, maps[i], opts);
            updateRegistry(n, maps[i], opts);
          });
        }
        fn(err, maps);
      }, pre, post);
    }
  };
};