Merge pull request #3 from foo-comments/reactions

Reactions

.env.docker

@@ -0,0 +1,7 @@
+MONGODB_URI=mongodb://mongo:27017/foo-comments
+API_URL=http://localhost:9547/api
+PORT=9547
+
+ADMIN_EMAIL_ADDR=
+BOT_EMAIL_ADDR=
+BOT_EMAIL_PASS=

.gitignore

@@ -12,3 +12,5 @@ jsconfig.json
 yarn.lock
 .DS_Store
 *package-lock.json
+
+mongo-data

Dockerfile

@@ -0,0 +1,11 @@
+FROM node:18-alpine
+
+WORKDIR /app
+
+COPY ["package.json", "package-lock.json*", "./"]
+
+RUN npm install --production
+
+COPY . .
+
+CMD ["node", "index.js"]

Makefile

@@ -0,0 +1,12 @@
+build:
+	docker build -t foo-comments-server .
+
+up:
+	docker-compose up -d
+
+
+down:
+	docker-compose down
+
+dev:
+	docker-compose -f docker-compose.dev.yml up

README.md

@@ -31,3 +31,27 @@ $ npm run kill
 ```
 
 
+## Docker
+
+modify `.env.docker` to run with docker.
+
+### run mongo with docker
+
+```
+make dev
+```
+### build the docker image
+```
+make build
+```
+
+### start/stop system
+To start
+```
+make up
+```
+
+To stop
+```
+make down
+```

docker-compose.dev.yml

@@ -0,0 +1,11 @@
+version: '3.8'
+
+services:
+
+  mongo:
+    image: mongo
+    restart: always    
+    volumes:
+      - './mongo-data:/data/db'
+    ports:
+      - 27017:27017

docker-compose.yml

@@ -0,0 +1,18 @@
+version: '3.8'
+
+services:
+  mongo:
+    image: mongo
+    restart: always
+    volumes:
+      - './mongo-data:/data/db'
+
+  foo-comment-server:
+    image: foo-comments-server
+    restart: always
+    volumes:
+      - ./.env.docker:/app/.env:ro
+    ports:
+      - 9547:9547
+    depends_on:
+      - mongo

package.json

@@ -26,7 +26,7 @@
     "handlebars": "^4.7.6",
     "handlebars-dateformat": "^1.1.1",
     "moment": "^2.29.1",
-    "mongoose": "^5.10.11",
+    "mongoose": "^7.4.0",
     "nodemailer": "^6.4.15",
     "nodemon": "^2.0.6",
     "pm2": "^4.5.0"

src/api/index.js

@@ -1,8 +1,10 @@
 import { Router } from 'express';
 import comments from './comments';
+import reactions from './reactions';
 
 const router = new Router();
 
 router.use('/comments', comments);
+router.use('/reactions', reactions);
 
 export default router;

src/api/reactions/controller.js

@@ -0,0 +1,40 @@
+import Reaction from './model';
+import { getPageData } from './helper';
+import { asyncRoute } from '../../services/express';
+
+export const add = asyncRoute(async (req, res) => {
+  const fingerprint = req.headers.fingerprint;
+  const pageId = req.body.pageId || req.query.pageId;
+  const reaction = req.body.reaction.slice(0, 20); // Just in case, limit characters by 20
+
+  if (!fingerprint) {
+    return res.status(500).send('Fingerprint required for reacting.');
+  }
+
+  const searchCondition = { pageId, fingerprint };
+  const recordInDB = await Reaction.findOne(searchCondition);
+
+  if (!recordInDB) {
+    await Reaction.create({ ...searchCondition, reaction });
+  } else {
+    if (recordInDB.reaction === reaction) {
+      await Reaction.deleteOne(recordInDB);
+    } else {
+      recordInDB.reaction = reaction;
+      await recordInDB.save();
+    }
+  }
+
+  const reactions = await getPageData(searchCondition);
+
+  return res.status(200).json(reactions);
+});
+
+export const list = asyncRoute(async (req, res) => {
+  const fingerprint = req.headers.fingerprint;
+  const pageId = req.body.pageId || req.query.pageId;
+
+  const reactions = await getPageData({ pageId, fingerprint });
+
+  return res.status(200).json(reactions);
+});

src/api/reactions/helper.js

@@ -0,0 +1,24 @@
+import Reaction from './model';
+
+export const getPageData = async ({ fingerprint, pageId }) => {
+  const userReactionPromise = Reaction.findOne({
+    fingerprint,
+    pageId
+  }).select('reaction -_id');
+
+  const aggregationPromise = Reaction.aggregate()
+    .match({
+      pageId
+    })
+    .group({
+      _id: '$reaction',
+      count: { $count: {} }
+    });
+
+  const [aggregation, userReaction] = await Promise.all([
+    aggregationPromise,
+    userReactionPromise
+  ]);
+
+  return { aggregation, userReaction };
+};

src/api/reactions/index.js

@@ -0,0 +1,9 @@
+import { Router } from 'express';
+import { list, add } from './controller';
+
+const router = new Router();
+
+router.post('/', add);
+router.get('/', list);
+
+export default router;

src/api/reactions/model.js

@@ -0,0 +1,30 @@
+import mongoose, { Schema } from 'mongoose';
+
+const schema = new Schema(
+  {
+    owner: {
+      ip: {
+        type: String,
+        required: false
+      }
+    },
+    fingerprint: {
+      type: String,
+      required: true
+    },
+    pageId: {
+      type: String,
+      required: true
+    },
+    reaction: {
+      type: String,
+    }
+  },
+  {
+    timestamps: true
+  }
+);
+
+const model = mongoose.model('Reaction', schema);
+
+export default model;

src/services/mailer/index.js

@@ -1,6 +1,10 @@
 import nodemailer from 'nodemailer';
 import moment from 'moment';
 
+if (!process.env.ADMIN_EMAIL_ADDR) {
+  console.warn('WARNIGN: ADMIN_EMAIL_ADDR Admin email is not present, you will not be notified about new emails.');
+}
+
 const transporter = nodemailer.createTransport({
   port: 465,
   secure: true,
@@ -12,6 +16,9 @@ const transporter = nodemailer.createTransport({
 });
 
 export async function newCommentNotification(comment) {
+  if (!process.env.ADMIN_EMAIL_ADDR) {
+    return;
+  }
   const date = moment(comment.createdAt).format('DD.MMM.YYYY - HH:mm');
   await transporter.sendMail({
     from: `"FooCommmets" <${process.env.BOT_EMAIL_ADDR}>`,

src/services/mongoose/index.js

@@ -1,10 +1,6 @@
 import mongoose from 'mongoose';
 
 mongoose.Promise = Promise;
-mongoose.set('useNewUrlParser', true);
-mongoose.set('useFindAndModify', false);
-mongoose.set('useUnifiedTopology', true);
-mongoose.set('useCreateIndex', true);
 
 mongoose.connection.on('error', err => {
   console.error('MongoDB connection error: ' + err);