+
+
+
+ Well ${names}, congratulations for choosing AuthorsHaven.
+ To verify that ${to} is your email, could you please click this link below to verify your AuthorsHaven's account?
+
+ Click here to verify your account
+
+ Here there is the link below where you can visit ahmedkhaled4d and get more information about what's ahmedkhaled4d
+
+
${data.message}
`; + return message; +}; diff --git a/src/helpers/notifications/EventEmitter.js b/src/helpers/notifications/EventEmitter.js new file mode 100644 index 0000000..4742900 --- /dev/null +++ b/src/helpers/notifications/EventEmitter.js @@ -0,0 +1,3 @@ +import EventEmitter from 'events'; + +export default new EventEmitter(); diff --git a/src/helpers/notifications/EventListener.js b/src/helpers/notifications/EventListener.js new file mode 100644 index 0000000..c903a37 --- /dev/null +++ b/src/helpers/notifications/EventListener.js @@ -0,0 +1,7 @@ +import eventEmitter from './EventEmitter'; +import commentArticle from './commentArticle'; +import publishArticle from './publishArticle'; + +eventEmitter.on('commentArticle', commentArticle); +eventEmitter.on('publishArticle', publishArticle); +eventEmitter.on('error', err => process.stdout.write('Oops! an event error occurred') && err); diff --git a/src/helpers/notifications/Notify.js b/src/helpers/notifications/Notify.js new file mode 100644 index 0000000..a4fe757 --- /dev/null +++ b/src/helpers/notifications/Notify.js @@ -0,0 +1,57 @@ +import db from '../../sequelize/models'; +import sendMail from '../mailer/SendAnyEmail'; +import eventEmitter from './EventEmitter'; + +const { Notification, Opt, User } = db; + +const notify = async (data) => { + let inAppNotification = {}; + let emailNotification = {}; + + const { + resource, user, inAppMessage, emailMessage + } = data; + const optedin = await Opt.findAll({ + where: { + userId: user.followerId + } + }); + optedin.map(async (subscription) => { + const { dataValues } = await User.findOne({ + where: { + id: user.userId + } + }); + switch (subscription.type) { + case 'email': + emailNotification = await Notification.create({ + userId: user.userId, + resource, + message: emailMessage, + type: subscription.type + }); + await sendMail(dataValues.email, 'notification', { + message: emailMessage + }); + break; + case 'inapp': + inAppNotification = await Notification.create({ + userId: user.userId, + resource, + message: inAppMessage, + type: subscription.type + }); + eventEmitter.emit('new_inapp', inAppMessage, dataValues); + break; + default: + break; + } + }); + const response = { + inAppNotification, + emailNotification + }; + return response; +}; + +export default notify; diff --git a/src/helpers/notifications/NotifyForBookmarks.js b/src/helpers/notifications/NotifyForBookmarks.js new file mode 100644 index 0000000..ba34a16 --- /dev/null +++ b/src/helpers/notifications/NotifyForBookmarks.js @@ -0,0 +1,57 @@ +import db from '../../sequelize/models'; +import sendMail from '../mailer/SendAnyEmail'; +import eventEmitter from './EventEmitter'; + +const { Notification, Opt, User } = db; + +const notify = async (data) => { + let inAppNotification = {}; + let emailNotification = {}; + + const { + resource, user, inAppMessage, emailMessage + } = data; + const optedin = await Opt.findAll({ + where: { + userId: user.id + } + }); + optedin.map(async (subscription) => { + const { dataValues } = await User.findOne({ + where: { + id: user.id + } + }); + switch (subscription.type) { + case 'email': + await sendMail(dataValues.email, 'notification', { + message: emailMessage + }); + emailNotification = await Notification.create({ + userId: user.id, + resource, + message: emailMessage, + type: subscription.type + }); + break; + case 'inapp': + inAppNotification = await Notification.create({ + userId: user.id, + resource, + message: inAppMessage, + type: subscription.type + }); + eventEmitter.emit('new_inapp', inAppMessage, dataValues); + break; + default: + break; + } + }); + const response = { + inAppNotification, + emailNotification + }; + return response; +}; + +export default notify; diff --git a/src/helpers/notifications/commentArticle.js b/src/helpers/notifications/commentArticle.js new file mode 100644 index 0000000..712190d --- /dev/null +++ b/src/helpers/notifications/commentArticle.js @@ -0,0 +1,49 @@ +import db from '../../sequelize/models'; +import favouritedBy from '../Favourites'; +import notify from './NotifyForBookmarks'; + +const { User, Bookmarks } = db; + +const commentArticle = async (comment) => { + try { + const author = await User.findOne({ + where: { + id: comment.userId + } + }); + const favourites = await Bookmarks.findAll({ + where: { + slug: comment.slug, + } + }); + if (favourites) { + favourites.map(async (fav) => { + const user = await favouritedBy(fav.userId); + const inAppMessage = `Dear ${user.firstName} ${user.lastName}, ${author.dataValues.lastName} commented on the article you bookmarked! + `; + const emailMessage = ` + Hello ${user.firstName}, ${author.lastName} commented on the article you bookmarked!