index.js

//Initialization
const express = require("express"),
  app = express(),
  dotenv = require("dotenv"),
  mongoose = require("mongoose"),
  passport = require("passport"),
  Pet = require("./models/pet"),
  User = require("./models/user"),
  bodyParser = require("body-parser"),
  methodOverride = require("method-override"),
  flash = require("connect-flash");

dotenv.config();

app.use(bodyParser.urlencoded({ extended: true }));
app.set("view engine", "ejs");
app.use(flash());
app.use(methodOverride("_method"));

//Connecting to database
var mongourl = process.env.MONGO;
mongoose.connect(mongourl, {
  useNewUrlParser: true,
  useCreateIndex: true,
  useFindAndModify: false,
});

//Get the default connection
var db = mongoose.connection;

//Bind connection to error event (to get notification of connection errors)
db.on("error", console.error.bind(console, "MongoDB connection error:"));

//Success message when connected to database
db.once("open", function () {
  console.log("Sucessfully connected to database!");
});

//To be able to use external css
app.use(express.static(__dirname + "/public"));

//Passport configuration
app.use(
  require("express-session")({
    secret: "process.env.SECRET",
    resave: false,
    saveUninitialized: false,
  })
);

app.use(passport.initialize());
app.use(passport.session());

//Getting fontawesome link from env variables
var fontawesome = process.env.FONTAWESOME;

//Function to pass current user to all routes
app.use(function (req, res, next) {
  res.locals.currentUser = req.user;
  next();
});

//Funciton to send success or failure to all routes
app.use(function (req, res, next) {
  res.locals.error = req.flash("error");
  res.locals.successfulllogout = req.flash("successfulllogout");
  res.locals.success = req.flash("success");
  res.locals.failure = req.flash("failure");
  res.locals.successfullsignup = req.flash("successfullsignup");
  res.locals.loginrequired = req.flash("loginrequired");
  next();
});

//ROUTES

//Homepage
//Redirecting / to adopt/1
app.get("/", function (req, res) {
  res.redirect("/adopt/1");
});
//Redirecting /adopt to /adopt/1
app.get("/adopt", function (req, res) {
  res.redirect("/adopt/1");
});

app.get("/adopt/:page", function (req, res) {
  //No of ads per page
  var perPage = 8;
  //Current page
  var page = req.params.page || 1;

  //Get all the pets from database
  Pet.find({ price: { $eq: 0 } })
    .populate("user")
    .skip(perPage * page - perPage)
    .limit(perPage)
    .exec(function (err, pets) {
      //Count the no of ads
      Pet.countDocuments({ price: { $eq: 0 } }).exec(function (err, count) {
        if (err) {
          console.log(err);
        } else {
          //Render the page
          res.render("homepage", {
            pets: pets,
            current: page,
            pages: Math.ceil(count / perPage),
          });
        }
      });
    });
});

//Redirecting shop page to shop/1
app.get("/shop", function (req, res) {
  res.redirect("/shop/1");
});

//Shop page with pagenaton
app.get("/shop/:page", function (req, res) {
  //No of ads per page
  var perPage = 8;
  //Current page no
  var page = req.params.page || 1;
  //if page is less than 1 change it to 1
  if (page < 1) {
    res.redirect("/shop/1");
  }
  //Retrieve pets from database whose price is greater than 0
  Pet.find({ price: { $gt: 0 } })
    .populate("user")
    .skip(perPage * page - perPage)
    .limit(perPage)
    .exec(function (err, pets) {
      //Count the no of ads
      Pet.countDocuments({ price: { $gt: 0 } }).exec(function (err, count) {
        if (err) {
          console.log(err);
        } else {
          res.render("shop", {
            pets: pets,
            current: page,
            pages: Math.ceil(count / perPage),
          });
        }
      });
    });
});

//Post a new ad
app.get("/new", isLoggedIn, function (req, res) {
  res.render("new");
});

app.post("/new", isLoggedIn, function (req, res) {
  //Get details from form
  var title = req.body.title,
    imageurl = req.body.imageurl,
    discription = req.body.discription,
    category = req.body.category,
    location = req.body.location,
    price = req.body.price,
    user = req.user;

  //Create a new pet object
  var newPet = {
    title: title,
    imageurl: imageurl,
    discription: discription,
    category: category,
    location: location,
    price: price,
    user: user,
  };

  //Push the object to database
  Pet.create(newPet, function (err, newlyCreatedPet) {
    if (err) {
      res.send(err);
    } else {
      //Checking to see if the pet is posted in adoption or it's an ad
      if (newlyCreatedPet.price == 0) {
        //Look for the user creating the post
        User.findOne({ username: req.user.username }, function (
          err,
          foundUser
        ) {
          if (err) {
            res.send(err);
          } else {
            //Add the pet posted to user's list of ads
            foundUser.ads.push(newlyCreatedPet);
            foundUser.save(function (err, adPushedToUser) {
              if (err) {
                res.send(err);
              } else {
                req.flash("success", "Your post has been successfully posted.");
                res.redirect("/adopt/1");
              }
            });
          }
        });
      } else {
        User.findOne({ username: req.user.username }, function (
          err,
          foundUser
        ) {
          if (err) {
            res.send(err);
          } else {
            //Add the pet posted to user's list of ads
            foundUser.ads.push(newlyCreatedPet);
            foundUser.save(function (err, adPushedToUser) {
              if (err) {
                res.send(err);
              } else {
                req.flash("success", "Your ad has been successfully posted.");
                res.redirect("/shop/1");
              }
            });
          }
        });
      }
    }
  });
});

//Edit ad page
app.get("/ads/:id/edit", isLoggedIn, isOwner, function (req, res) {
  Pet.findById(req.params.id, function (err, foundPet) {
    if (err) {
      res.flash("failure", "Ad not found.");
      res.redirect("/adopt/1");
    } else {
      res.render("edit", { ad: foundPet });
    }
  });
});

app.put("/ads/:id", isLoggedIn, isOwner, function (req, res) {
  Pet.findByIdAndUpdate(req.params.id, req.body.pet, function (err, updatedAd) {
    if (err) {
      req.flash("failure", "The ad could not be updated");
      res.redirect("/ads/" + req.params.id);
    } else {
      req.flash("success", "Your ad has been successfully edited.");
      res.redirect("/ads/" + req.params.id);
    }
  });
});

//View ad route
app.get("/ads/:id", isLoggedIn, function (req, res) {
  //Get the pet from database
  Pet.findById(req.params.id)
    .populate("user")
    .exec(function (err, foundPet) {
      if (err) {
        console.log(err);
      } else {
        res.render("pet", { pet: foundPet, curUser: req.user });
      }
    });
});

//Delete an ad route
app.delete("/ads/:id", isOwner, function (req, res) {
  Pet.findByIdAndRemove(req.params.id, function (err) {
    if (err) {
      req.flash("failure", "The ad could not be deleted");
      res.redirect("/adopt/1");
    } else {
      req.flash("success", "The ad was successfully deleted");
      res.redirect("/adopt/1");
    }
  });
});

//User's profile route
app.get("/user/:id", isLoggedIn, isSameUser, function (req, res) {
  User.findById(req.params.id)
    .populate("ads")
    .exec(function (err, foundUser) {
      if (err) {
        console.log(err);
      } else {
        res.render("profile", { user: foundUser });
      }
    });
});

//Edit user's profile route
app.get("/user/:id/edit", isLoggedIn, isSameUser, function (req, res) {
  User.findById(req.params.id, function (err, foundUser) {
    if (err) {
      req.flash("failure", "The user was not found.");
      res.redirect("/adopt/1");
    } else {
      res.render("useredit", { user: foundUser });
    }
  });
});

app.put("/user/:id", isLoggedIn, isSameUser, function (req, res) {
  User.findByIdAndUpdate(req.params.id, req.body.user, function (
    err,
    updatedUser
  ) {
    if (err) {
      req.flash("failure", "Updating user's profile failed");
      res.redirect("/user/" + req.params.id);
    } else {
      req.flash("success", "Your profile has been updated.");
      res.redirect("/user/" + req.params.id);
    }
  });
});

//AUTH ROUTES

//Signin
app.get("/signin", function (req, res) {
  res.render("signin");
});

app.post(
  "/signin",
  passport.authenticate("local", {
    successRedirect: "/adopt/1",
    failureRedirect: "/signin",
    failureFlash: true,
    successFlash: "You have successfully logged in.",
  }),
  function (req, res) {}
);

//Signup
app.get("/signup", function (req, res) {
  res.render("signup");
});

app.post("/signup", function (req, res) {
  var newUser = new User({
    username: req.body.username,
    email: req.body.email,
    phone: req.body.phone,
  });
  User.register(newUser, req.body.password, function (err, user) {
    if (err) {
      console.log(err);
      req.flash("error", "Signup failed, Please check your details.");
      res.redirect("/signup");
    }
    passport.authenticate("local")(req, res, function () {
      req.flash("successfullsignup", "You have been successfully signed up.");
      res.redirect("/adopt/1");
    });
  });
});

//Logout route
app.get("/logout", function (req, res) {
  req.logout();
  req.flash("successfulllogout", "You have been successfully logged out.");
  res.redirect("/adopt/1");
});

//404
app.get("*", function (req, res) {
  res.send("Oops! Page not found.");
});

//Login middleware
function isLoggedIn(req, res, next) {
  if (req.isAuthenticated()) {
    return next();
  }
  req.flash("loginrequired", "Please login first.");
  res.redirect("/signin");
}

//Check if the user is the same middleware
function isSameUser(req, res, next) {
  if (req.params.id == req.user._id) {
    return next();
  }
  req.flash("loginrequired", "Please login as the user first");
  res.redirect("/signin");
}

//Middleware to check if the user is owner of post while editing
function isOwner(req, res, next) {
  Pet.findById(req.params.id, function (err, foundPet) {
    if (foundPet.user[0] == req.user.id) {
      return next();
    } else {
      req.flash("failure", "Only owners are allowed to modify the ads");
      res.redirect("/adopt/1");
    }
  });
}

//Port to listen on
port = process.env.PORT || 3000;
app.listen(port, function () {
  console.log("Petexchange app has started");
});