pn abstraction

pn.js

angular.module('keychain.services.pn', [])

.factory('PN', function($rootScope, $q, PubNub, User) {

  return {

    publish: function(channel, body) {
      console.log('Publishing to', channel);
      var dfd = $q.defer();

      body.user_id = User.carrier.id;
      body.user_name = User.carrier.name;
      body.driver_name = User.carrier.name;
      body.driver_phone = User.carrier.phone;
      body.driver_email = User.carrier.email;

      body.company_id = User.company.id;
      body.carrier_company_name = User.company.name;
      body.carrier_mc = User.company.mcNumber;

      PubNub.ngPublish({
        channel: channel,
        error: function(err) {
          console.log('ngPublish error', err);
          dfd.reject(err);
        },
        callback: function(data) {
          dfd.resolve(data);
        },
        message: {
          req: body
        }
      });

      return dfd.promise;
    },

    subscribe: function(channel, cb) {
      console.log('Subscribing to', channel);
      PubNub.ngSubscribe({
        channel: channel,
        error: function(err) {
          console.log('Subscribe Error for', channel, err);
        },
        callback: function(data) {
          $rootScope.$evalAsync(function() {
            cb(data);
          });
        }
      });
    },

    history: function(config) {
      var dfd = $q.defer();

      PubNub.jsapi.history({
        channel: config.channel,
        count: config.count,
        // start: config.time * 10000000,
        callback: function(data) {
          dfd.resolve(config.callback(data[0]));
        }
      });

      return dfd.promise;
    }

  };

});