Fire comments email notifications

imports/modules/get-email-of-user.js

@@ -0,0 +1,19 @@
+/* eslint-disable import/no-absolute-path */
+
+import getOAuthProfile from '/imports/modules/get-oauth-profile';
+
+const getEmailOf = (user) => {
+  const hasPassword = user.services && user.services.password && user.services.password.bcrypt;
+
+  // console.log(`Has password: ${hasPassword}`);
+  const OAuthProfile = getOAuthProfile({
+    password: hasPassword,
+    profile: user.profile
+  }, user);
+  const firstName = OAuthProfile ? OAuthProfile.name.first : user.profile.name.first;
+  const emailAddress = OAuthProfile ? OAuthProfile.email :
+    user && user.emails[0] && user.emails[0].verified ? user.emails[0].address : null;
+  return { emailAddress, firstName };
+};
+
+export default getEmailOf;

imports/modules/server/send-email.js

@@ -1,11 +1,21 @@
+/* eslint-disable import/no-absolute-path */
+
 import { Meteor } from 'meteor/meteor';
-// import { Email } from 'meteor/email';
+import i18n from 'i18next';
+import { getFileNameOfLang } from '/imports/api/Utility/server/files.js';
+import sendMail from '/imports/startup/server/email';
 import getPrivateFile from './get-private-file';
 import templateToText from './handlebars-email-to-text';
 import templateToHTML from './handlebars-email-to-html';
-import { getFileNameOfLang } from '/imports/api/Utility/server/files.js';
-import sendMail from '/imports/startup/server/email';
-import i18n from 'i18next';
+
+export function subjectTruncate(n = 70, useWordBoundary = true) {
+  // https://stackoverflow.com/questions/1199352/smart-way-to-shorten-long-strings-with-javascript
+  if (this.length <= n) {
+    return `${this}`;
+  }
+  const subString = this.substr(0, n - 1);
+  return `${useWordBoundary ? subString.substr(0, subString.lastIndexOf(' ')) : subString}...`;
+}
 
 const sendEmail = (options, { resolve, reject }) => {
   try {

imports/startup/common/comments.js

@@ -3,7 +3,8 @@
 // Client and Server
 Comments.config({
   rating: 'likes-and-dislikes',
-  allowAnonymous: () => true,
+  allowAnonymous: () => false,
+  allowReplies: () => false, // disabled right now: I don't know hot to get referenceId of replies
   anonymousSalt: 'klasddl3lala0l3lasdlas0ol3lasdlao3lasdoaslaldal3lasdclasdlal3lasdladlaq',
   publishUserFields: {
     profile: 1

imports/startup/server/comments.js

@@ -0,0 +1,80 @@
+/* global Comments */
+/* eslint-disable import/no-absolute-path */
+
+import { Meteor } from 'meteor/meteor';
+import i18n from 'i18next';
+import sendEmail, { subjectTruncate } from '/imports/modules/server/send-email';
+import getEmailOf from '/imports/modules/get-email-of-user';
+import '../common/comments';
+
+/* import i18n from 'i18next';
+import moment from 'moment';
+import { dateLongFormat } from '/imports/api/Common/dates';
+import Notifications from '/imports/api/Notifications/Notifications';
+// import sendMail from '/imports/startup/server/email';
+// import { hr } from '/imports/startup/server/email';
+import getOAuthProfile from '/imports/modules/get-oauth-profile';
+import image from 'google-maps-image-api-url';
+import { trim } from '/imports/ui/components/NotificationsObserver/util.js'; */
+
+Meteor.startup(() => {
+  // On Server or Client (preferably on Server)
+  Comments.config({
+    onEvent: (name, action, payload) => {
+      // e.g send a mail
+      // console.log(`name: ${name}, action: ${action}, payload: ${JSON.stringify(payload)}`);
+
+      // Samples:
+
+      // name: comment, action: add, payload: {"referenceId":"fire-56a9cc5a5586879eb9cc6dd7","content":"asdfasdf asd fasd fas","userId":"tdK4e43ikjDXct7Gj","isAnonymous":false,"createdAt":"2018-03-04T14:53:40.319Z","likes":[],"dislikes":[],"replies":[],"media":{},"status":"approved","starRatings":[],"ratingScore":0,"_id":"mfAe3HL9qNofhiAnh"}
+      // name: reply, action: add, payload: {"replyId":"teSLaz4f8RxHjptBm","content":"sas fasdfasdasdf","userId":"tdK4e43ikjDXct7Gj","createdAt":"2018-03-04T14:54:56.965Z","replies":[],"likes":[],"lastUpdatedAt":"2018-03-04T14:54:56.965Z","isAnonymous":false,"status":"approved","media":{},"ratingScore":0,"_id":"DyHt28rF6rTDnC5fP","rootUserId":"tdK4e43ikjDXct7Gj"}
+      // name: reply, action: like, payload: {"replyId":"teSLaz4f8RxHjptBm","content":"sas fasdfasdasdf","userId":"tdK4e43ikjDXct7Gj","createdAt":"2018-03-04T14:54:56.965Z","replies":[],"likes":["tdK4e43ikjDXct7Gj"],"lastUpdatedAt":"2018-03-04T14:54:56.965Z","isAnonymous":false,"status":"approved","media":{},"ratingScore":1,"_id":"DyHt28rF6rTDnC5fP","ratedUserId":"tdK4e43ikjDXct7Gj","rootUserId":"tdK4e43ikjDXct7Gj"}
+      // name: comment, action: like, payload: {"_id":"mfAe3HL9qNofhiAnh","ratedUserId":"tdK4e43ikjDXct7Gj"}
+      // name: reply, action: edit, payload: {"_id":"DyHt28rF6rTDnC5fP","replyId":"teSLaz4f8RxHjptBm","content":"sas fasdfasdasdf dasd fadsfa","userId":"tdK4e43ikjDXct7Gj","createdAt":"2018-03-04T14:54:56.965Z","replies":[],"likes":[],"lastUpdatedAt":"2018-03-04T14:54:56.965Z","isAnonymous":false,"status":"approved","media":{},"ratingScore":0,"starRatings":[],"ratedUserId":"tdK4e43ikjDXct7Gj","rootUserId":"tdK4e43ikjDXct7Gj"}
+      // name: reply, action: remove, payload: {"_id":"DyHt28rF6rTDnC5fP","rootUserId":"tdK4e43ikjDXct7Gj"}
+
+      // name: (comment|reply)
+      // action: (add|like|edit|remove)
+
+      if (name === 'comment' && action.match(/add|like|edit/)) {
+        if (action === 'add') {
+          // Check for other users that did comments and send an email (uniq users, and not this user)
+          // console.log(payload.referenceId);
+          const query = payload.isAnonymous ?
+            { referenceId: payload.referenceId } :
+            { referenceId: payload.referenceId, userId: { $ne: payload.userId } };
+          Comments.getCollection().rawCollection().distinct('userId', query).then((users) => {
+            // console.log(users);
+            const path = payload.referenceId.replace(/fire-/, 'fire/archive/');
+            const fireUrl = Meteor.absoluteUrl(path);
+            // console.log(fireUrl);
+            Meteor.users.find({ _id: { $in: users } }).forEach((user) => {
+              const { firstName, emailAddress } = getEmailOf(user);
+              // console.log(JSON.stringify(user));
+              if (emailAddress) {
+                const emailOpts = {
+                  to: emailAddress,
+                  subject: subjectTruncate.apply(i18n.t('Hay más información sobre un fuego')),
+                  lang: user.lang,
+                  template: 'new-fire-comment',
+                  templateVars: {
+                    applicationName: i18n.t('AppName'),
+                    firstName,
+                    fireUrl
+                  }
+                };
+                sendEmail(emailOpts).catch((error) => {
+                  throw new Meteor.Error('500', `${error}`);
+                });
+              }
+            });
+          });
+        }
+      }
+      if (name === 'reply' && action.match(/add|like|edit/)) {
+        // Check for other previous users to this thread and send an email
+        // console.log('Reply op');
+      }
+    }
+  });
+});

imports/startup/server/index.js

@@ -8,7 +8,7 @@ import './IPGeocoder';
 import './migrations';
 import './notificationsObserver';
 import './facts';
-import '../common/comments';
+import './comments';
 import './sitemaps';
 import './subsUnion';
 import './prerender';

imports/startup/server/migrations.js

@@ -1,4 +1,4 @@
-/* global Migrations */
+/* global Migrations, Comments */
 /* eslint-disable import/no-absolute-path */
 import { Meteor } from 'meteor/meteor';
 import { Accounts } from 'meteor/accounts-base';
@@ -157,6 +157,12 @@ Meteor.startup(() => {
     }
   });
 
+  Migrations.add({
+    version: 11,
+    up: function noAnonComments() {
+      Comments.getCollection().remove({ isAnonymous: true });
+    }
+  });
 
   // Set createdAt in users & subs
   Migrations.migrateTo('latest');

imports/startup/server/notificationsObserver.js

@@ -6,24 +6,13 @@ import moment from 'moment';
 import { dateLongFormat } from '/imports/api/Common/dates';
 import Notifications from '/imports/api/Notifications/Notifications';
 // import sendMail from '/imports/startup/server/email';
-import sendEmail from '/imports/modules/server/send-email';
+import sendEmail, { subjectTruncate } from '/imports/modules/server/send-email';
 // import { hr } from '/imports/startup/server/email';
-import getOAuthProfile from '/imports/modules/get-oauth-profile';
+import getEmailOf from '/imports/modules/get-email-of-user';
 import image from 'google-maps-image-api-url';
 import { trim } from '/imports/ui/components/NotificationsObserver/util.js';
 
 Meteor.startup(() => {
-  // https://stackoverflow.com/questions/1199352/smart-way-to-shorten-long-strings-with-javascript
-  function truncate(n, useWordBoundary) {
-    if (this.length <= n) {
-      return this;
-    }
-    const subString = this.substr(0, n - 1);
-    return `${useWordBoundary ?
-      subString.substr(0, subString.lastIndexOf(' ')) :
-      subString}...`;
-  }
-
   // https://www.npmjs.com/package/google-maps-image-api-url
   // https://stackoverflow.com/questions/24355007/is-there-no-way-to-embed-a-google-map-into-an-html-email
   // https://developers.google.com/maps/documentation/static-maps/intro
@@ -49,16 +38,8 @@ Meteor.startup(() => {
   function process(notif) {
     if (notif.type === 'web' && !notif.emailNotified) {
       const user = Meteor.users.findOne({ _id: notif.userId });
-      const hasPassword = user.services && user.services.password && user.services.password.bcrypt;
+      const { firstName, emailAddress } = getEmailOf(user);
 
-      // console.log(`Has password: ${hasPassword}`);
-      const OAuthProfile = getOAuthProfile({
-        password: hasPassword,
-        profile: user.profile
-      }, user);
-      const firstName = OAuthProfile ? OAuthProfile.name.first : user.profile.name.first;
-      const emailAddress = OAuthProfile ? OAuthProfile.email :
-        user && user.emails[0] && user.emails[0].verified ? user.emails[0].address : null;
       if (emailAddress) {
         const img = imgUrl(notif.geo.coordinates[1], notif.geo.coordinates[0]);
         //    const url = imgUrl(notif.geo.coordinates[1], notif.geo.coordinates[0]);
@@ -77,7 +58,7 @@ Meteor.startup(() => {
           to: emailAddress,
           // userName: firstName,
           // sendAt: new Date(),
-          subject: truncate.apply(message, [50, true]),
+          subject: subjectTruncate.apply(message),
           // text: `${message}\n\n${fireTextUrl}\n\n`,
           // template: '<body><h2>{{appName}}</h2>{{{html}}}</body>',
           lang: user.lang,