Adding likes backend

api/app.js

@@ -1,36 +1,34 @@
-const createError = require("http-errors");
-const express = require("express");
-const path = require("path");
-const logger = require("morgan");
-const JWT = require("jsonwebtoken");
+const createError = require('http-errors');
+const express = require('express');
+const path = require('path');
+const logger = require('morgan');
+const JWT = require('jsonwebtoken');
 
-const postsRouter = require("./routes/posts");
-const tokensRouter = require("./routes/tokens");
-const usersRouter = require("./routes/users");
+const postsRouter = require('./routes/posts');
+const tokensRouter = require('./routes/tokens');
+const usersRouter = require('./routes/users');
+const accountRouter = require('./routes/account');
 
 const app = express();
 
-// setup for receiving JSON
-app.use(express.json())
+app.use(express.json());
 
-app.use(logger("dev"));
+app.use(logger('dev'));
 app.use(express.json());
-app.use(express.static(path.join(__dirname, "public")));
+app.use(express.static(path.join(__dirname, 'public')));
 
 // middleware function to check for valid tokens
 const tokenChecker = (req, res, next) => {
-
   let token;
-  const authHeader = req.get("Authorization")
-
-  if(authHeader) {
-    token = authHeader.slice(7)
+  const authHeader = req.get('Authorization');
+  if (authHeader) {
+    token = authHeader.slice(7);
   }
 
   JWT.verify(token, process.env.JWT_SECRET, (err, payload) => {
-    if(err) {
-      console.log(err)
-      res.status(401).json({message: "auth error"});
+    if (err) {
+      console.log(err);
+      res.status(401).json({ message: 'auth error' });
     } else {
       req.user_id = payload.user_id;
       next();
@@ -39,9 +37,10 @@ const tokenChecker = (req, res, next) => {
 };
 
 // route setup
-app.use("/posts", tokenChecker, postsRouter);
-app.use("/tokens", tokensRouter);
-app.use("/users", usersRouter);
+app.use('/posts', tokenChecker, postsRouter);
+app.use('/tokens', tokensRouter);
+app.use('/users', usersRouter);
+app.use('/account', tokenChecker, accountRouter);
 
 // catch 404 and forward to error handler
 app.use((req, res, next) => {
@@ -52,10 +51,10 @@ app.use((req, res, next) => {
 app.use((err, req, res) => {
   // set locals, only providing error in development
   res.locals.message = err.message;
-  res.locals.error = req.app.get("env") === "development" ? err : {};
+  res.locals.error = req.app.get('env') === 'development' ? err : {};
 
   // respond with details of the error
-  res.status(err.status || 500).json({message: 'server error'})
+  res.status(err.status || 500).json({ message: 'server error' });
 });
 
 module.exports = app;

api/bin/www

@@ -4,30 +4,29 @@
  * Module dependencies.
  */
 
-var app = require("../app");
-var debug = require("debug")("acebook:server");
-var http = require("http");
-var mongoose = require("mongoose");
-
+var app = require('../app');
+var debug = require('debug')('acebook:server');
+var http = require('http');
+var mongoose = require('mongoose');
 /**
  * Get port from environment and store in Express.
  */
 
-var port = normalizePort(process.env.PORT || "8080");
-app.set("port", port);
+var port = normalizePort(process.env.PORT || '8080');
+app.set('port', port);
 
 /**
  * Connect to MongoDB
  **/
 
-var mongoDbUrl = process.env.MONGODB_URL || "mongodb://0.0.0.0/acebook";
+var mongoDbUrl = process.env.MONGODB_URL || 'mongodb://0.0.0.0/acebook';
 mongoose.connect(mongoDbUrl, {
   useNewUrlParser: true,
   useUnifiedTopology: true,
 });
 
 var db = mongoose.connection;
-db.on("error", console.error.bind(console, "MongoDB connection error:"));
+db.on('error', console.error.bind(console, 'MongoDB connection error:'));
 
 /**
  * Create HTTP server.
@@ -40,8 +39,8 @@ var server = http.createServer(app);
  */
 
 server.listen(port);
-server.on("error", onError);
-server.on("listening", onListening);
+server.on('error', onError);
+server.on('listening', onListening);
 
 /**
  * Normalize a port into a number, string, or false.
@@ -68,20 +67,20 @@ function normalizePort(val) {
  */
 
 function onError(error) {
-  if (error.syscall !== "listen") {
+  if (error.syscall !== 'listen') {
     throw error;
   }
 
-  var bind = typeof port === "string" ? "Pipe " + port : "Port " + port;
+  var bind = typeof port === 'string' ? 'Pipe ' + port : 'Port ' + port;
 
   // handle specific listen errors with friendly messages
   switch (error.code) {
-    case "EACCES":
-      console.error(bind + " requires elevated privileges");
+    case 'EACCES':
+      console.error(bind + ' requires elevated privileges');
       process.exit(1);
       break;
-    case "EADDRINUSE":
-      console.error(bind + " is already in use");
+    case 'EADDRINUSE':
+      console.error(bind + ' is already in use');
       process.exit(1);
       break;
     default:
@@ -95,7 +94,7 @@ function onError(error) {
 
 function onListening() {
   var addr = server.address();
-  var bind = typeof addr === "string" ? "pipe " + addr : "port " + addr.port;
-  console.log("Now listening on " + bind);
-  debug("Listening on " + bind);
+  var bind = typeof addr === 'string' ? 'pipe ' + addr : 'port ' + addr.port;
+  console.log('Now listening on ' + bind);
+  debug('Listening on ' + bind);
 }

api/controllers/account.js

@@ -0,0 +1,21 @@
+const { collection } = require("../models/post");
+const Post = require("../models/post");
+const TokenGenerator = require("../models/token_generator");
+
+const AccountController = {
+  Index: (req, res) => {
+    Post.find({ user_id: req.user_id }, async (err, posts) => {
+      if (err) {
+        // res.status(401).json({ message: "Bad request" });
+        throw err;
+      } else {
+        const token = await TokenGenerator.jsonwebtoken(req.user_id);
+
+        res.status(200).json({ posts: posts, token: token });
+        // res.status(200).json({ message: "ok" });
+      }
+    });
+  },
+};
+
+module.exports = AccountController;

api/controllers/posts.js

@@ -7,7 +7,9 @@ const PostsController = {
       if (err) {
         throw err;
       }
-      const token = await TokenGenerator.jsonwebtoken(req.user_id)
+
+      const token = await TokenGenerator.jsonwebtoken(req.user_id);
+
       res.status(200).json({ posts: posts, token: token });
     });
   },
@@ -17,11 +19,63 @@ const PostsController = {
       if (err) {
         throw err;
       }
+      const token = await TokenGenerator.jsonwebtoken(req.user_id);
 
-      const token = await TokenGenerator.jsonwebtoken(req.user_id)
-      res.status(201).json({ message: 'OK', token: token });
+      res.status(201).json({ message: "OK", token: token });
     });
   },
-};
 
-module.exports = PostsController;
+  Delete: (req, res) => {
+    Post.deleteOne({ _id: req.body._id }, async (err) => {
+      if (err) {
+        throw err;
+      } else {
+        const token = await TokenGenerator.jsonwebtoken(req.user_id);
+
+        res.status(204).json({ message: "OK", token: token });
+      }
+    });
+  },
+  Update: (req, res) => {
+    Post.updateOne(
+      { _id: req.body._id, message: req.body.message },
+      async (err) => {
+        if (err) {
+          throw err;
+        } else {
+          const token = await TokenGenerator.jsonwebtoken(req.user_id);
+          res.status(204).json({ message: "OK", token: token });
+        }
+      }
+    );
+  },
+  Likes: (req, res) => {
+    Post.updateOne(
+      { _id: req.body._id },
+      { $addToSet: { likes: req.body._user_id } }, //addToSet searches the array and if it matches it doesn't push
+      async (err) => {
+        if (err) {
+          throw err;
+        } else {
+          const token = await TokenGenerator.jsonwebtoken(req.user_id);
+          res.status(204).json({ message: "OK", token: token });
+        }
+      }
+    );
+  },
+  Unlikes: (req, res) => {
+    Post.updateOne(
+      { _id: req.body._id },
+      { $pull: { likes: req.body._user_id } }, //addToSet searches the array and if it matches it doesn't push
+      async (err) => {
+        if (err) {
+          throw err;
+        } else {
+          const token = await TokenGenerator.jsonwebtoken(req.user_id);
+          res.status(204).json({ message: "OK", token: token });
+        }
+      }
+    );
+  },
+}
+module.exports = PostsController;

api/controllers/tokens.js

@@ -1,25 +1,25 @@
-const User = require("../models/user");
-const TokenGenerator = require("../models/token_generator")
+const User = require('../models/user');
+const TokenGenerator = require('../models/token_generator');
 
 const SessionsController = {
-
   Create: (req, res) => {
     const email = req.body.email;
     const password = req.body.password;
 
     User.findOne({ email: email }).then(async (user) => {
+      // checks credentials
       if (!user) {
-        console.log("auth error: user not found")
-        res.status(401).json({ message: "auth error" });
+        console.log('auth error: user not found');
+        res.status(401).json({ message: 'auth error' });
       } else if (user.password !== password) {
-        console.log("auth error: passwords do not match")
-        res.status(401).json({ message: "auth error" });
+        console.log('auth error: passwords do not match');
+        res.status(401).json({ message: 'auth error' });
       } else {
-        const token = await TokenGenerator.jsonwebtoken(user.id)
-        res.status(201).json({ token: token, message: "OK" });
+        const token = await TokenGenerator.jsonwebtoken(user.id);
+        res.status(201).json({ token: token, message: 'OK', user_id: user.id });
       }
     });
-  }
+  },
 };
 
 module.exports = SessionsController;

api/controllers/users.js

@@ -1,11 +1,19 @@
-const User = require("../models/user");
+const User = require('../models/user');
 
 const UsersController = {
   Create: (req, res) => {
-    const user = new User(req.body);
+    const user = new User({
+      email: req.body.email,
+      password: req.body.password,
+    });
+
+    if (req.file) {
+      user.image = req.file.buffer;
+    }
+
     user.save((err) => {
       if (err) {
-        res.status(400).json({message: 'Bad request'})
+        res.status(400).json({ message: 'Bad request' });
       } else {
         res.status(201).json({ message: 'OK' });
       }

api/jest.config.js

@@ -4,7 +4,7 @@
 module.exports = {
   // All imported modules in your tests should be mocked automatically
   // automock: false,
-
+  maxWorkers: 1,
   // Stop running tests after `n` failures
   // bail: 0,
 

api/models/post.js

@@ -1,9 +1,24 @@
-const mongoose = require("mongoose");
+const { ObjectID } = require('mongodb');
+const mongoose = require('mongoose');
 
-const PostSchema = new mongoose.Schema({
-  message: String
-});
+/**
+ * create a schema for Posts
+ * it contains a list of the fields that you wish to have in the data
+ * e.g. message: {type: String, required: true}
+ */
+const PostSchema = new mongoose.Schema(
+  {
+    user_id: {
+      type: mongoose.Types.ObjectId,
+      ref: 'User',
+      required: true,
+    },
+    message: { type: String, required: true },
+    likes: [{type: mongoose.Types.ObjectId, ref:'User'}]
+  },
+  { timestamps: true }  
+);
 
-const Post = mongoose.model("Post", PostSchema);
+const Post = mongoose.model('Post', PostSchema);
 
 module.exports = Post;