server.js

//Dotenv Config
require('dotenv').config();

const path = require('path');
const express = require('express');
var sslRedirect = require('heroku-ssl-redirect');
const app = express();

const { createChessBoard }  = require('./js/Chess');


// enable ssl redirect
if (process.env.NODE_ENV === 'production') {
  console.log('in production now');
  app.use(sslRedirect());
} else {
  console.log('not in production');
}

app.use(express.static(path.join(__dirname, '/dist')));


// Socket / Mongo Config

const http = require('http').createServer(app);
const io = require('socket.io')(http);
const MongoClient = require('mongodb').MongoClient;
const ObjectId = require('mongodb').ObjectId;
const mongoUri = process.env.MONGO_URI || `mongodb://${process.env.MONGO_USER}:${process.env.MONGO_PASSWORD}@ds155577.mlab.com:55577/saynplay`;

MongoClient.connect(mongoUri, { useNewUrlParser: true }, (err, client) => {
  if (err) return console.log(err);
  db = client.db('saynplay');

  console.log('Connected to MongoDB database');
  // SOCKET CONFIG
  io.on('connection', (socket) => {
    console.log(`${socket.id} just connected to socket server`);
    socket.on('request to play', (id) => {
      // send a private message to the socket with the given id
      socket.to(id).emit('received request', socket.id);
    });

    // socket.broadcast.emit('somebody just connected');

    updateClients();

    socket.on('accept', (socket_id) => {
      createGame(db, (startTime) => {
        findGameByStart(db, startTime, (game) => {
          const id = game['_id'];
          // Create socket group here
          socket.join( `${id}`);
          const socket2 = io.sockets.connected[socket_id];
          socket2.join(`${id}`);
          io.to(`${id}`).emit('game update', game);
        })
      })
    });

    socket.on('fetch game', (id) => {
      findGameById(db, id, (game) => {
        const id = game['_id'];
        socket.join(`${id}`);
        io.to(`${id}`).emit('game update', game);
      })
    });

    socket.on('update game', (board, game_id) => {
      findGameById(db, game_id, (game) => {  // switch the game turn on each update
        updateGameById(db, game_id, board, game['turn'] === 'light' ? 'dark' : 'light', (res) => {
          findGameById(db, game_id, (game) => {
            const id = game['_id'];
            socket.join(`${id}`);
            io.to(`${id}`).emit('game update', game);
          })
        })
      })
    });

    socket.on('decline', (socket_id) => {
      console.log('Declined Request');
    });

    socket.on('update clients', () => {
      updateClients();
    });

    socket.on('disconnect', () => {
      updateClients();
    });
  });

  // Api end points

  app.get('/api/get-start-board', (req, res) => {
    res.send({'board': createChessBoard()});
  });

  app.get('*', (req, res) => {
    res.sendFile(__dirname+"/dist/index.html");
  });
});


// SOCKET IO CODE

function updateClients() {
  io.clients((error, clients) => {
    if (error) throw error;
    io.emit('updated clients', clients);
  });
}

// Setup basic user
const createuser = function(db, name, callback) {
  db.collection('users').insertOne({
    name: name,
    created: Date.now()
  }, () => {
    callback(true)
  })
};

// CHESS DB OPERATIONS
const createGame = function(db, callback) {
  const collection = db.collection('games');
  const time = Date.now();
  collection.insertOne({
    game: createChessBoard(),
    startTime: time,
    turn: 'light'
  }, (err, result) => {
    callback(time);
  })
};

const findGameByStart = function(db, startTime, callback) {
  const collection = db.collection('games');
  collection.find({startTime: startTime}).toArray((err, games) => {
    if (games.length === 1) {
      const game = games[0];
      callback(game);
    }
  })
};

const findGameById = function(db, id, callback) {
  const collection = db.collection('games');
  collection.find({_id: ObjectId(id)}).toArray((err, games) => {
    if (games.length === 1) {
      const game = games[0];
      callback(game);
    }
  })
};

const updateGameById = function(db, id, board, turn,  callback) {
  const collection = db.collection('games');
  collection.updateOne({_id: ObjectId(id)}, {$set: {game : board, turn: turn}}, (err, res) => {
    callback(res);
  })
};


const port = process.env.PORT || 3000;
http.listen( port , () => {
  console.log('listening to port ' + port)
});

//Comment
/*
Once a person accepts a request to play, create a new board
Save that board with the following attributes
{
  board: board,
  startTime: Date.now()
  _id: id
}
Store the game startTime in a variable
Once the board has been successfully saved, fetch the board with the start time as indicated in the stored variable
Create a Socket Group with the name of the id of the board
Add the two sockets to the group
Emit the fetched board to both sockets in the group


*/