app.js

const express = require('express');
const dotenv = require('dotenv');
const morgan = require('morgan');
const path = require('path');
const flash = require('connect-flash');
const session = require("express-session");
const passport = require('passport');
const http = require('http');
const socketio = require('socket.io');
const MongoStore = require("connect-mongo");
const {engine} = require('express-handlebars');
const methodOverride = require('method-override');

// Importing some utilities needed
const {formatMessage, object_With_resume} = require('./utils/messages');    
const { userOnline, getCurrentUser, userOffline, getRoomUsers } = require('./utils/user');

// Load config variable
dotenv.config({ path: './config/config.env' });

const app = express();

const server = http.createServer(app)
const io = socketio(server);

// connection to the database
const connectDB = require('./config/db');

// calling the function
connectDB();

// Body Parser Configuration
app.use(express.urlencoded({ extended: false }));
app.use(express.json());

// Method Overridemiddleware
app.use(methodOverride(function(req, res) {
    if(req.body && typeof req.body === 'object' && '_method' in req.body ) {
        // look in urlencoded POST bodies and delete it
        var method = req.body._method;
        delete req.body._method;
        return method;
    }
}));

// Setting Up Morgan
if(process.env.NODE_ENV == "development") {
    // app.use(morgan('dev'));
}

// Setting static folder
app.use(express.static(path.join(__dirname, 'public')));

// Handlebars Helpers
const { json, ifEquals, statusList, statusIcon, profile } = require('./helpers/hbs');
const { logins } = require('./helpers/date');

// Setting Our Engine
app.engine('.hbs', engine({
     helpers: { json, ifEquals, statusList, statusIcon, profile, logins },
     extname:'.hbs',
     defaultLayout: false
}));
app.set('views', './views');
app.set('view engine', '.hbs');

// Session configuration
app.use(
    session({
        secret: process.env.SESSION_SECRET,
        resave: false,
        saveUninitialized: false,
        store: MongoStore.create({ mongoUrl: process.env.MONGO_URI })
    })
);

// Passport Configuration
require('./config/passport')(passport);

// Passport Google Configuration
require('./config/oauth_google')(passport);

// Passport Facebook Configuration
require('./config/oauth_facebook')(passport);

// Passport Github Configuration
require('./config/oauth_github')(passport);

// Initializing passport middelware
app.use(passport.initialize());
app.use(passport.session());

// Set global var
app.use(function(req, res, next) {
    res.locals.user = req.user || null
    next()
});

// Connecting flash
app.use(flash());

// Setting global variables for the flash
app.use(function(req, res, next) {
    res.locals.error_msg = req.flash("error_msg");
    res.locals.success_msg = req.flash("success_msg");
    res.locals.error = req.flash("error");
    res.locals.friend_msg_success = req.flash("friend_msg_success");
    res.locals.friend_msg_decline = req.flash("friend_msg_decline");
    res.locals.update_info = req.flash("update_info");
    next();
});

// Setting the routes 
app.use('/', require('./routes/frontpage/index'));
app.use('/users', require('./routes/user/user.js'));
app.use('/users/auth', require('./routes/oauth/index'));
app.use('/users/friends', require('./routes/friends/index'));
app.use('/users/groups', require('./routes/groups/index'));
app.use('/users/message', require('./routes/message/index'));
app.use('/users/track', require('./routes/track/index'));

// routing the user to all page if page is not found
app.all('*', (req, res) => {
    res.status(404).redirect('/errors/404');
    return;
});

// socket io is here
io.on('connection', socket => {

    socket.on('joinUser', (object) => {
       
        const user = userOnline(socket.id, object.sessionId, object.roomId);
       
        socket.join(user.room)

        // console.log("It is connected here", socket);
       // socket.emit('message', formatMessage('Application', 'Welcome to chatcord'))

         // Broadcast when a user connects // then put time login here
         socket.broadcast.to(user.room).emit('message', formatMessage('Application', `${object.userId} user has joined the chat`));

    });

    // Listen for Chatmessage
    socket.on('chatMessage', ({sessionId, msg}) => {
        const user = getCurrentUser(socket.id);
        io.to(user.room).emit('message', object_With_resume('USER', sessionId,  msg))

        // broadcast when a user connects
        // connect to all users except the current user
        // socket.broadcast.to(user.room).emit('online', object_With_resume('USER', `${sessionId} has joined the chat`))

        // // send user and and room
        // io.to(user.room).emit('onlineUsers', {
        //     room: user.room,
        //     users: getRoomUsers(user.room)
        // });
    });

    // Runs when client disconnects
    socket.on('disconnect', () => {   

        const user = getCurrentUser(socket.id);

        // console.log(user);

       // io.to(user.room).emit('message', formatMessage('Application', 'A user has left the chat'))
    });
})

const PORT = process.env.PORT || 5000;

server.listen(PORT, console.log(`Server is running on 🔥  ${process.env.NODE_ENV} mode on 🚢 ${PORT}`));