Native push notifications

Author: jpatel531

lib/config.js

@@ -3,16 +3,6 @@ var Token = require('./token');
 function Config(options) {
   options = options || {};
 
-  if (options.host) {
-    this.host = options.host
-  }
-  else if (options.cluster) {
-    this.host = "api-"+options.cluster+".pusher.com";
-  }
-  else {
-    this.host = "api.pusherapp.com";
-  }
-
   this.scheme = options.scheme || (options.encrypted ? "https" : "http");
   this.port = options.port;
 
@@ -25,7 +15,7 @@ function Config(options) {
 }
 
 Config.prototype.prefixPath = function(subPath) {
-  return "/apps/" + this.appId + subPath;
+  throw("NotImplementedError: #prefixPath should be implemented by subclasses");
 };
 
 Config.prototype.getBaseURL = function(subPath, queryString) {

lib/notification_client.js

@@ -0,0 +1,19 @@
+var Config = require('./config');
+var requests = require('./requests');
+var util = require('./util');
+var NotificationConfig = require('./notification_config');
+
+function NotificationClient(options){
+  this.config = new NotificationConfig(options);
+}
+
+NotificationClient.prototype.notify = function(interests, notification, callback) {
+  var body = util.mergeObjects({interests: interests}, notification);
+  requests.send(this.config, {
+    method: "POST",
+    body: body,
+    path: "/notification"
+  }, callback);
+}
+
+module.exports = NotificationClient;

lib/notification_config.js

@@ -0,0 +1,19 @@
+var Config = require('./config');
+var util = require('./util');
+
+var DEFAULT_HOST = "yolo.ngrok.io";
+var API_PREFIX = "customer_api";
+var API_VERSION = "v1";
+
+function NotificationConfig(options) {
+	Config.call(this, options);
+	this.host = options.host || DEFAULT_HOST;
+}
+
+util.mergeObjects(NotificationConfig.prototype, Config.prototype);
+
+NotificationConfig.prototype.prefixPath = function(subPath) {
+  return "/" + API_PREFIX + "/" + API_VERSION + "/apps/" + this.appId + subPath;
+};
+
+module.exports = NotificationConfig;

lib/pusher.js

@@ -6,9 +6,10 @@ var events = require('./events');
 var requests = require('./requests');
 var util = require('./util');
 
-var Config = require('./config');
+var PusherConfig = require('./pusher_config');
 var Token = require('./token');
 var WebHook = require('./webhook');
+var NotificationClient = require('./notification_client');
 
 var validateChannel = function(channel) {
   if (typeof channel !== "string" || channel === "" || channel.match(/[^A-Za-z0-9_\-=@,.;]/)) {
@@ -38,7 +39,9 @@ var validateSocketId = function(socketId) {
  * @constructor
  * @param {Object} options
  * @param {String} [options.host="api.pusherapp.com"] API hostname
+ * @param {String} [options.notification_host="api.pusherapp.com"] Notification API hostname
  * @param {Boolean} [options.encrypted=false] whether to use SSL
+ * @param {Boolean} [options.notification_encrypted=false] whether to use SSL for notifications
  * @param {Integer} [options.port] port, default depends on the scheme
  * @param {Integer} options.appId application ID
  * @param {String} options.key application key
@@ -48,7 +51,12 @@ var validateSocketId = function(socketId) {
  * @param {Boolean} [options.keepAlive] whether requests should use keep-alive
  */
 function Pusher(options) {
-  this.config = new Config(options);
+  this.config = new PusherConfig(options);
+  var notificationOptions = util.mergeObjects({}, options, {
+    host: options.notification_host || "yolo.ngrok.io",
+    encrypted: options.notification_encrypted
+  });
+  this.notificationClient = new NotificationClient(notificationOptions);
 }
 
 /** Create a Pusher instance using a URL.
@@ -156,6 +164,10 @@ Pusher.prototype.triggerBatch = function(batch, callback) {
   events.triggerBatch(this, batch, callback);
 }
 
+Pusher.prototype.notify = function() {
+  this.notificationClient.notify.apply(this.notificationClient, arguments);
+}
+
 /** Makes a POST request to Pusher, handles the authentication.
  *
  * Calls back with three arguments - error, request and response. When request

lib/pusher_config.js

@@ -0,0 +1,24 @@
+var Config = require('./config');
+var util = require('./util');
+
+function PusherConfig(options) {
+	Config.call(this, options);
+
+  if (options.host) {
+    this.host = options.host
+  }
+  else if (options.cluster) {
+    this.host = "api-"+options.cluster+".pusher.com";
+  }
+  else {
+    this.host = "api.pusherapp.com";
+  }
+}
+
+util.mergeObjects(PusherConfig.prototype, Config.prototype);
+
+PusherConfig.prototype.prefixPath = function(subPath) {
+  return "/apps/" + this.appId + subPath;
+};
+
+module.exports = PusherConfig;