|
|
@ -12,6 +12,7 @@ var Utils = require('./common/utils'); |
|
|
|
var Model = require('./model'); |
|
|
|
var log = require('npmlog'); |
|
|
|
log.debug = log.verbose; |
|
|
|
log.level = 'debug'; |
|
|
|
|
|
|
|
var PUSHNOTIFICATIONS_TYPES = { |
|
|
|
'NewCopayer': { |
|
|
@ -97,10 +98,12 @@ PushNotificationsService.prototype._sendPushNotifications = function(notificatio |
|
|
|
var notifType = PUSHNOTIFICATIONS_TYPES[notification.type]; |
|
|
|
if (!notifType) return cb(); |
|
|
|
|
|
|
|
// console.log(notification);
|
|
|
|
log.debug('\n### Notification received\n', JSON.stringify(notification)); |
|
|
|
|
|
|
|
self._checkShouldSendNotif(notification, function(err, should) { |
|
|
|
if (err) return cb(err); |
|
|
|
|
|
|
|
log.debug('\nShould send notification: ', should); |
|
|
|
if (!should) return cb(); |
|
|
|
|
|
|
|
self._getRecipientsList(notification, function(err, recipientsList) { |
|
|
@ -133,8 +136,8 @@ PushNotificationsService.prototype._sendPushNotifications = function(notificatio |
|
|
|
async.each(optsList, |
|
|
|
function(opts, next) { |
|
|
|
self._makeRequest(opts, function(err, response) { |
|
|
|
if (err) log.error(err); |
|
|
|
log.debug('Post status : ', response); |
|
|
|
if (err) log.error('ERROR!: ', err); |
|
|
|
log.debug('Request status : ', response); |
|
|
|
next(); |
|
|
|
}); |
|
|
|
}, |
|
|
|