})
`;
+ } */
+
+// Cutover flag (fase 1a): channels listed in
+// Meteor.settings.private.notifDisabledChannels (e.g. ['mobile','web']) are
+// handled by the tcef-notifications microservice, so the old observer/cron must
+// NOT send them. Mutual exclusion per channel — reversible by editing settings,
+// no code deploy needed. ES5-compatible on purpose (Meteor 1.6 / Node 8).
+const notifDisabledChannels = (Meteor.settings.private && Meteor.settings.private.notifDisabledChannels) || [];
+
+const processNotif = (notif) => {
+ if (notifDisabledChannels.indexOf(notif.type) !== -1) {
+ // This channel was migrated to tcef-notifications; do nothing here.
+ return;
+ }
+ if (isMailServerMaster && validFcmSender && notif.type === 'mobile' && notif.notified !== true) {
+ const fcmSender = new gcm.Sender(Meteor.settings.private.fcmApiToken);
+ const user = Meteor.users.findOne({ _id: notif.userId });
+ moment.locale(user.lang);
+ // duplicate code below
+ const body = `${trim(notif.content)}`;
+
+ // https://firebase.google.com/docs/cloud-messaging/concept-options
+ const msg = new gcm.Message();
+
+ msg.addNotification({
+ title: i18n.t('Alerta de fuego'),
+ body,
+ click_action: 'FLUTTER_NOTIFICATION_CLICK',
+ tag: notif._id, // prevent duplication of fire notifications
+ sound: 'default', // Indicates sound to be played. Supports only default currently.
+ icon: 'launch_image' // 'ic_launcher'
+ });
+
+ msg.addData('id', notif._id._str);
+ msg.addData('description', body);
+ msg.addData('lat', notif.geo.coordinates[1]);
+ msg.addData('lon', notif.geo.coordinates[0]);
+ msg.addData('when', notif.when);
+ msg.addData('subsId', notif.subsId._str);
+ msg.addData('sealed', notif.sealed);
+
+ const registrationTokens = [];
+ if (!user.fireBaseToken) {
+ console.warn('This mobile user doesn\'t have a firebase registration token');
+ } else {
+ registrationTokens.push(user.fireBaseToken);
+ // FIXME: better join users
+ if (validFcmSender) {
+ fcmSender.send(msg, { registrationTokens }, Meteor.bindEnvironment(function processResult(err, response) {
+ if (err) {
+ console.error(`FCM error: ${err}`);
+ // FIXME send to sentry
+ ravenLogger.log(err);
+ } else {
+ // console.log(`FCM response: ${response}`);
+ Notifications.update(notif._id, { $set: { notified: true, notifiedAt: new Date() } });
+ }
+ }));
+ }
+ }
+ }
+ if (isMailServerMaster && notif.type === 'web' && notif.emailNotified !== true) {
+ const user = Meteor.users.findOne({ _id: notif.userId });
+ const { firstName, emailAddress } = getEmailOf(user);
+
+ if (emailAddress) {
+ const img = imgUrl(notif.geo.coordinates[1], notif.geo.coordinates[0]);
+ // const url = imgUrl(notif.geo.coordinates[1], notif.geo.coordinates[0]);
+ const fireUrl = `${Meteor.absoluteUrl('fire/')}${notif.sealed}`;
+ // const fireHtmlUrl = `${i18n.t('Más información sobre este fuego')}`;
+ // TODO get _id of fire
+ // const fireTextUrl = `${i18n.t('Más información sobre este fuego')}:\n${fireUrl}`;
+ // FIXME use our map as url and static map as img
+ moment.locale(user.lang);
+ // moment user tz ?
+ const message = `${trim(notif.content)} (${i18n.t('fireDetectedAt', { when: dateLongFormat(notif.when) })}).`;
+
+ // TODO Comunes Address
+
+ const emailOpts = {
+ to: emailAddress,
+ // userName: firstName,
+ // sendAt: new Date(),
+ subject: subjectTruncate.apply(message),
+ // text: `${message}\n\n${fireTextUrl}\n\n`,
+ // template: '