port push notifications in api v3

website/src/controllers/api-v2/challenges.js

@@ -11,7 +11,7 @@ var logging = require('./../../libs/api-v2/logging');
 var csv = require('express-csv');
 var utils = require('../../libs/api-v2/utils');
 var api = module.exports;
-var pushNotify = require('./../pushNotifications');
+var pushNotify = require('./pushNotifications');
 
 /*
   ------------------------------------------------------------------------

website/src/controllers/api-v2/groups.js

@@ -17,7 +17,7 @@ var Challenge = require('./../../models/challenge').model;
 var EmailUnsubscription = require('./../../models/emailUnsubscription').model;
 var isProd = nconf.get('NODE_ENV') === 'production';
 var api = module.exports;
-var pushNotify = require('./../pushNotifications');
+var pushNotify = require('./pushNotifications');
 var analytics = utils.analytics;
 var firebase = require('../../libs/api-v2/firebase');
 

website/src/controllers/api-v2/members.js

@@ -7,7 +7,7 @@ var _ = require('lodash');
 var shared = require('../../../../common');
 var utils = require('../../libs/api-v2/utils');
 var nconf = require('nconf');
-var pushNotify = require('./../pushNotifications');
+var pushNotify = require('./pushNotifications');
 
 var fetchMember = function(uuid, restrict){
   return function(cb){

website/src/controllers/api-v2/pushNotifications.js

@@ -0,0 +1,58 @@
+// TODO move to /api-v2
+var api = module.exports;
+var _ = require('lodash');
+var nconf = require('nconf');
+
+var pushNotify = require('push-notify');
+
+var gcmApiKey = nconf.get("PUSH_CONFIGS:GCM_SERVER_API_KEY");
+
+var gcm = gcmApiKey ? pushNotify.gcm({
+  apiKey: gcmApiKey,
+  retries: 3
+}) : undefined;
+
+if(gcm){
+  gcm.on('transmitted', function (result, message, registrationId) {
+    //console.info("transmitted", result, message, registrationId);
+  });
+
+  gcm.on('transmissionError', function (error, message, registrationId) {
+    //console.info("transmissionError", error, message, registrationId);
+  });
+  gcm.on('updated', function (result, registrationId) {
+    //console.info("updated", result, registrationId);
+  });
+}
+
+api.sendNotify = function(user, title, msg, timeToLive){
+  timeToLive = timeToLive || 15;
+
+  // need investigation:
+  // https://github.com/HabitRPG/habitrpg/issues/5252
+  if(!user)
+    return;
+
+  _.forEach(user.pushDevices, function(pushDevice){
+    switch(pushDevice.type){
+      case "android":
+        if(gcm){
+          gcm.send({
+            registrationId: pushDevice.regId,
+            //collapseKey: 'COLLAPSE_KEY',
+            delayWhileIdle: true,
+            timeToLive: timeToLive,
+            data: {
+              title: title,
+              message: msg
+            }
+        });
+      }
+
+      break;
+
+      case "ios":
+        break;
+    }
+  });
+};