server.js

'use strict';

const path = require('path');
const express = require('express');
const http = require('http');
const socketio = require('socket.io');
const UserService = require('./services/UserService');
const mongoose = require('mongoose');
const authRouter = require('./auth/authRouter');
const bodyParser = require('body-parser');
const formatMessage = require('./helpers/formatMessage');

const jsonParser = bodyParser.json();
const PORT = process.env.PORT || '3000';

const app = express();
const server = http.createServer(app);
const io = socketio(server, {
  cors: {
    origin: `http://localhost:${PORT}`,
    methods: ['GET', 'POST'],
    transports: ['websocket', 'polling'],
    credentials: true
  },
  allowEIO3: true
});
const userManager = new UserService();

//set static folder
app.use(
  bodyParser.urlencoded({
    extended: false
  })
);
app.use(jsonParser);

app.use(express.static(path.join(__dirname, 'public')));
app.use(express.json());
app.use('/auth', jsonParser, authRouter);


const botName = 'Messenger Bot';

// Run when client connects
io.on('connection', socket => {
  const { id } = socket;

  socket.on('joinRoom', ({ username, room }) => {
    const user = userManager.addUser({ id, username, room });
    socket.join(room);

    // Broadcast when a user connects
    socket.broadcast
      .to(room)
      .emit(
        'message',
        formatMessage(botName, `${user.username} has joined the chat`)
      );

    // Send users and room info
    io.to(room).emit('roomUsers', {
      room,
      users: userManager.getRoomUsers(room)
    });
  });

  // Listen for chatMessage
  socket.on('chatMessage', msg => {
    const user = userManager.getUser(id);
    io.to(user.room).emit('message', formatMessage(user.username, msg));
  });

  // Runs when client disconnects
  socket.on('disconnect', () => {
    const user = userManager.removeUser(id);

    if (user) {
      const { room } = user;
      io.to(room).emit(
        'message',
        formatMessage(botName, `${user.username} has left the chat`)
      );

      // Send users and room info
      io.to(room).emit('roomUsers', {
        room,
        users: userManager.getRoomUsers(room)
      });
    }
  });
});


const runServer = async () => {
  try {
    await mongoose.connect('mongodb+srv://ulu:ul67d3@cluster0.xnfaj.mongodb.net/messager?retryWrites=true&w=majority');
    server.listen(PORT, () => console.log(`Server is running at ${PORT}`));
  } catch (e) {
    console.log(e);
  }
};

runServer();