app.js

//Importing npm packages
const express = require("express");
const http = require("http");
const cookieParser = require("cookie-parser");
const cookieSession = require("cookie-session");
const bodyParser = require("body-parser");
const methodOverride = require('method-override');
const passport = require("passport");
const keys = require("./config/keys");
const socketio = require("socket.io");
const formatMessage = require('./utils/messages');
const moment  = require("moment");
//Importing MongoDB models
require("./db/mongoose");
const User = require("./models/User");
const webScraper = require("./db/webScraper");

//Importing Routes
const user = require("./routes/user");
const auth = require("./routes/auth");
const friend = require("./routes/friend");

//Variables
const port = process.env.PORT||3000;

const app = express();
const server=http.createServer(app);

const io = socketio(server);

app.use(express.json());
app.set("view engine", "ejs");
app.use(bodyParser.json());
app.use(methodOverride('_method'));
app.use(express.static("./assets"));

app.use(
    cookieSession({
      name: "session",
      keys: [keys.sessionSecret]
    })
  );

app.use(cookieParser());

//Passport Middleware

require("./middleware/PassportMiddleware");
app.use(passport.initialize());
app.use(passport.session());

app.use("/user",user);
app.use("/auth",auth);
app.use("/friend",friend);

app.get("/",(req,res)=>{
    webScraper();
    // console.log(req.user);
    if(req.session.token == null){
      res.render("home",{
         currentUser:req.user
      });
    }else{
      User.findOne({email:req.user.email},(err,user)=>{
          if(err) Error(err);
          if(user){
            res.redirect("/user/dashboard");
          }
      });
    }
});



io.on('connection',(socket)=>{
  
  console.log("New Web Socket Connection");
   
  // Runs when user joins room 
    socket.on('joinRoom',({user_id})=>{
      socket.join(user_id);
      console.log("Room Joined");
    });
  
  // Listen for chat message
  socket.on('chatMessage',({msg,friend_id,user_id})=>{

    User.findOne({_id:user_id},async(err,user)=>{
      User.findOne({_id:friend_id},async (err,friend)=>{

            user.friends.forEach(async (x,i)=>{
                if(x.friend_id==friend_id){
                   user.friends[i].chats.push({
                     //sender
                     user_id,
                     //receiver
                     friend_id,
                     msg,
                     time:moment().format('h:mm a')
                   });
                   await user.save();
                }
            });

            friend.friends.forEach(async(y,i)=>{
              if(y.friend_id==user_id){
                friend.friends[i].chats.push({
                  user_id,
                  friend_id,
                  msg,
                  time:moment().format('h:mm a')
                });
                await friend.save();
              }
            });

            io.to(user_id).emit('message',formatMessage(user_id,msg,friend_id));
            io.to(friend_id).emit('message',formatMessage(user_id,msg,user_id));
      });
    });
  });

  // socket.on('disconnect',()=>{
  //   io.emit('message',formatMessage('Chat BOT',"User Disconnected"))
  // });
})


server.listen(port,()=>{
    console.log("Server started on "+ port + "!");
});