You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
550 lines
13 KiB
550 lines
13 KiB
/**
|
|
* 1-27-18
|
|
*
|
|
* Main server file which handles users, rooms -- everythang
|
|
*/
|
|
|
|
//eh?
|
|
const serverUtils = require('./serverUtils.js');
|
|
|
|
//used for the getting the word array
|
|
const utils = require("./utils.js");
|
|
|
|
//gets the trending data
|
|
const trendingAPI = require("./trendsAPI.js");
|
|
|
|
//const sqlStuff = require("./sql.js");
|
|
|
|
/**
|
|
* Object used for storing rooms
|
|
* @param capacityP -- the number of people that can be in room
|
|
* @param pass -- the room password -- null if none
|
|
* @param owner -- the person who is creating the room
|
|
*/
|
|
var room = function(capacityP, pass, owner)
|
|
{
|
|
//max capacity of room -- default is 4 for now
|
|
this.capacity = capacityP;
|
|
|
|
//name of the room
|
|
this.roomName = owner.name;
|
|
|
|
//list of words used in the game
|
|
//7 for now will change later to be room specific
|
|
this.words = utils.getRandomWords(7);
|
|
|
|
this.currentWord = this.words.pop();
|
|
|
|
//list players -- so we can push requests to them
|
|
this.users = [];
|
|
|
|
//increments when rounds pass
|
|
this.currentRound = 0;
|
|
|
|
// the password of the room -- null if no password
|
|
this.password = pass;
|
|
|
|
/**
|
|
1 = Waiting for users
|
|
2 = Word shown, Waiting for response from users
|
|
3 = Showing Result
|
|
4 = Game Over, Display Final Results
|
|
*/
|
|
this.state = 1;
|
|
|
|
/**
|
|
* creates json to send in the 'roomUpdate' socket event
|
|
*
|
|
* {users: gameState: roundWinner: currentWord: }
|
|
*/
|
|
this.generateRoomUpdate = function()
|
|
{
|
|
var result = new Object();
|
|
|
|
result.users = [];
|
|
|
|
this.users.forEach(function(u)
|
|
{
|
|
result.users.push(u.genJASON());
|
|
});
|
|
|
|
//sort the users based on score
|
|
var countOuter = 0;
|
|
var countInner = 0;
|
|
var countSwap = 0;
|
|
|
|
// var swapped;
|
|
// do
|
|
// {
|
|
// countOuter++;
|
|
// swapped = false;
|
|
// for(var i = 0; i < result.users.length; i++)
|
|
// {
|
|
// countInner++;
|
|
// if(result.users[i].score && result.users[i + 1].score &&
|
|
// result.users[i].score > result.users[i + 1].score)
|
|
// {
|
|
// countSwap++;
|
|
// var temp = result.users[i];
|
|
// result.users[i] = result.users[j];
|
|
// result.users[j] = temp;
|
|
// swapped = true;
|
|
// }
|
|
// }
|
|
// } while(swapped);
|
|
|
|
|
|
result.gameState = this.state;
|
|
|
|
|
|
//sets round winner
|
|
var rWinner = -1;
|
|
|
|
for(var i = 0; i < this.users.length; i++)
|
|
{
|
|
if(rWinner < this.users[i].roundScore)
|
|
{
|
|
result.roundWinner = this.users[i].name;
|
|
rWinner = this.users[i].roundScore;
|
|
}
|
|
}
|
|
|
|
result.currentWord = this.currentWord;
|
|
|
|
return result;
|
|
}
|
|
|
|
/**
|
|
* grabs roomUpdate json and beams it to every user in the channel
|
|
*/
|
|
this.sendRoomUpdate = function()
|
|
{
|
|
var message = this.generateRoomUpdate();
|
|
this.users.forEach(function(u)
|
|
{
|
|
//console.log("room update called");
|
|
u.socket.emit('roomUpdate', message);
|
|
//console.log(message);
|
|
});
|
|
}
|
|
|
|
/**
|
|
* adds a user to a room
|
|
* @param p
|
|
* return 0 if they could join
|
|
*/
|
|
this.addUser = function(player)
|
|
{
|
|
//console.log("user added");
|
|
//check if room is not full
|
|
this.users.push(player);
|
|
player.room = this;
|
|
|
|
if(this.users.length == this.capacity)
|
|
{
|
|
this.state = 2;
|
|
}
|
|
|
|
console.log("user added to room " + player.name);
|
|
//console.log(this.users);
|
|
|
|
this.update();
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
* Removes a specific user from the room and adjusts the size of the array
|
|
* if the array is empty, the room closes
|
|
* @param p
|
|
*/
|
|
this.removeUser = function(p)
|
|
{
|
|
console.log("remove users fnc called");
|
|
var temp = new Array();
|
|
|
|
for(var i = 0; i < temp.length; i++)
|
|
{
|
|
if(p.name === this.users[i].name)
|
|
{
|
|
|
|
}
|
|
else
|
|
{
|
|
temp.push(this.users[i]);
|
|
}
|
|
}
|
|
|
|
this.users = temp;
|
|
|
|
//if room is empty remove the room from rooms list
|
|
if(this.users.length == 0)
|
|
{
|
|
console.log("room scrubbed");
|
|
delete rooms[this.roomName];
|
|
}
|
|
|
|
this.update();
|
|
}
|
|
|
|
/**
|
|
* Whether or not a user can join this room -- checks for number of people are
|
|
* already in the room and the password
|
|
* @param p
|
|
* @returns {boolean}
|
|
*/
|
|
this.canJoin = function(p)
|
|
{
|
|
if(this.password == null)
|
|
{
|
|
return (this.users.length < this.capacity);
|
|
}
|
|
else
|
|
{
|
|
return (this.users.length < this.capacity) && (p === this.password);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* starts new round for the room -- called once all the players have submitted
|
|
*/
|
|
this.newRound = function()
|
|
{
|
|
console.log("new round started");
|
|
if(this.words.length == 0)
|
|
{
|
|
this.state == 4;
|
|
}
|
|
else
|
|
{
|
|
this.currentRound++;
|
|
this.users.forEach(function(u)
|
|
{
|
|
u.submission = '';
|
|
});
|
|
this.currentWord = this.words.pop();
|
|
this.state = 2;
|
|
}
|
|
this.sendRoomUpdate();
|
|
}
|
|
|
|
//updates room variables
|
|
this.update = function()
|
|
{
|
|
switch(this.state)
|
|
{
|
|
case 1: //waiting for users to join
|
|
{
|
|
if(this.users.length == this.capacity)
|
|
{
|
|
this.newRound();
|
|
}
|
|
break;
|
|
}
|
|
case 2: // waiting for responses
|
|
{
|
|
var flag = true;
|
|
var test = "";
|
|
this.users.forEach(function(u)
|
|
{
|
|
test+=u.submission;
|
|
if(u.submission === '')
|
|
{
|
|
flag = false;
|
|
}
|
|
});
|
|
console.log("big stuff " + test);
|
|
if(flag)
|
|
{
|
|
this.state = 3;
|
|
this.newRound();
|
|
// setTimeout(function() {
|
|
//
|
|
// }, 4000);
|
|
}
|
|
break;
|
|
}
|
|
case 3: // showing results -- time out fnc
|
|
{
|
|
console.log("error &&&&&&&&&&&&&&&&&&");
|
|
break;
|
|
}
|
|
case 4: //game over display final result
|
|
{
|
|
//sqlStuff.dumpRoom(this);
|
|
break;
|
|
}
|
|
default:
|
|
{
|
|
console.log("You don goof up")
|
|
}
|
|
}
|
|
console.log(this.state + " state");
|
|
this.sendRoomUpdate();
|
|
}
|
|
this.addUser(owner);
|
|
|
|
}
|
|
|
|
|
|
var player = function(s)
|
|
{
|
|
//name of the user
|
|
this.name = null;
|
|
|
|
//players socket
|
|
this.socket = s;
|
|
|
|
//score of the player
|
|
this.score = 0;
|
|
|
|
//reference to the room -- might not need this
|
|
this.room = null;
|
|
|
|
//the word the user selected for current round
|
|
this.submission = '';
|
|
|
|
this.roundScore = 0;
|
|
|
|
//logs the user data so we can record it to data base at end of round
|
|
this.log = [];
|
|
|
|
/**
|
|
* generate the json object used in 'roomUpdate' socket io event
|
|
*
|
|
* return {name: score: word:}
|
|
*/
|
|
this.genJASON = function()
|
|
{
|
|
var result = new Object();
|
|
result.name = this.name;
|
|
result.score = this.score;
|
|
result.word = this.submission;
|
|
|
|
return result;
|
|
}
|
|
|
|
/**
|
|
* data -- literally a string
|
|
* @param data
|
|
*/
|
|
this.selectWord = function(data)
|
|
{
|
|
var w = data + " " + this.room.currentWord;
|
|
this.sumbission = data;
|
|
|
|
//console.log(w);
|
|
|
|
this.room.update();
|
|
|
|
return new Promise(function(resolve, reject)
|
|
{
|
|
trendingAPI.getPopularity(w).then(function(result)
|
|
{
|
|
console.log("api result for " + result + w);
|
|
resolve(result);
|
|
}).catch(function(err){
|
|
console.log(err);
|
|
})
|
|
});
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* Generates json sent to user on 'sendRooms'
|
|
*
|
|
* return [{name: passwordBool: capacity: occupants: }]
|
|
*/
|
|
var generateSendRoomsJSON = function()
|
|
{
|
|
var obj = new Object();
|
|
obj.rooms = [];
|
|
|
|
//rooms.forEach(function(r)
|
|
|
|
Object.keys(rooms).forEach(function(key)
|
|
{
|
|
console.log("**************");
|
|
console.log(key);
|
|
if(rooms[key] != null)
|
|
{
|
|
var roomObj = new Object();
|
|
|
|
roomObj.name = key;
|
|
|
|
if(rooms[key].password == null)
|
|
{
|
|
roomObj.passwordBool = false;
|
|
}
|
|
else
|
|
{
|
|
roomObj.passwordBool = true;
|
|
}
|
|
roomObj.capacity = rooms[key].capacity;
|
|
roomObj.occupants = rooms[key].users.length;
|
|
|
|
obj.rooms.push(roomObj);
|
|
}
|
|
else
|
|
{
|
|
console.log("would not tough it with a 10ft pole");
|
|
}
|
|
});
|
|
|
|
return obj;
|
|
}
|
|
|
|
//list of all players --accessed using names like a dic
|
|
var players = {};
|
|
|
|
//list of all the rooms
|
|
var rooms = {};
|
|
|
|
var app = require('express')();
|
|
var http = require('http').Server(app);
|
|
var io = require('socket.io')(http);
|
|
|
|
const port = 3000;
|
|
|
|
|
|
app.get('/', function(req, res)
|
|
{
|
|
console.log("err");
|
|
res.sendfile('index.html');
|
|
});
|
|
|
|
//Whenever someone connects this gets executed
|
|
io.on('connection', function(socket)
|
|
{
|
|
var p = new player(socket);
|
|
|
|
console.log('A user connected');
|
|
|
|
/**
|
|
*Register user nickname/handle (register) Client => Server
|
|
*/
|
|
socket.on('register', function(data)
|
|
{
|
|
console.log(data + " registered");
|
|
|
|
//checks for user name in use
|
|
//if(serverUtils.userAvailable(data, players))
|
|
if(!(data in players))
|
|
{
|
|
p.name = data;
|
|
|
|
players[data] = p;
|
|
|
|
socket.emit('sendRooms', generateSendRoomsJSON());
|
|
console.log("send rooms called");
|
|
//console.log(generateSendRoomsJSON());
|
|
}
|
|
else
|
|
{
|
|
socket.emit('registerFailed', 'User name taken');
|
|
console.log("registration failed sent");
|
|
}
|
|
|
|
//console.log(player);
|
|
});
|
|
|
|
/**
|
|
*Create Room (createRoom) Client => Server
|
|
* data {password: , capacity: }
|
|
*/
|
|
socket.on('createRoom', function(data)
|
|
{
|
|
console.log(data + "create room");
|
|
// console.log(data);
|
|
// console.log(" ");
|
|
rooms[p.name] = new room(data.capacity, data.password, p);
|
|
|
|
//sends updated room list to all users not in a room
|
|
var dd = generateSendRoomsJSON();
|
|
|
|
Object.keys(players).forEach(function(key)
|
|
{
|
|
if(players[key] != null)
|
|
{
|
|
if(players[key].room == null)
|
|
{
|
|
players[key].socket.emit('sendRooms', dd);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
console.log("player was null Bad!");
|
|
}
|
|
});
|
|
|
|
});
|
|
|
|
/**
|
|
* Room Selection (joinRoom) Client => Server
|
|
* data {roomName: , password: }
|
|
*/
|
|
socket.on('joinRoom', function(data)
|
|
{
|
|
console.log(p.name + " joined room " + data.roomName);
|
|
|
|
|
|
if(rooms[data.roomName] != null && rooms[data.roomName].canJoin(data.password))
|
|
{
|
|
p.room = rooms[data.roomName];
|
|
rooms[data.roomName].addUser(p);
|
|
|
|
console.log("user joined room");
|
|
}
|
|
else
|
|
{
|
|
socket.emit('joinFailed', 'Failed connecting to room');
|
|
}
|
|
//console.log(rooms);
|
|
});
|
|
|
|
/**
|
|
* data -- literally a string
|
|
*/
|
|
socket.on('submitWord', function(data)
|
|
{
|
|
console.log("submitWord called");
|
|
|
|
p.selectWord(data).then(function(score)
|
|
{
|
|
p.roundScore = score;
|
|
p.score += score;
|
|
p.submission = data;
|
|
p.room.update();
|
|
})
|
|
});
|
|
|
|
//Whenever someone disconnects
|
|
socket.on('disconnect', function ()
|
|
{
|
|
console.log('A user disconnected');
|
|
|
|
if(rooms[p.name] != null)
|
|
{
|
|
rooms[p.name] = null;
|
|
}
|
|
|
|
//leave the room
|
|
if(p.room != null)
|
|
{
|
|
p.room.removeUser(p);
|
|
}
|
|
|
|
//players[p.name] = null;
|
|
delete players[p.name];
|
|
|
|
});
|
|
});
|
|
|
|
http.listen(port, function()
|
|
{
|
|
console.log('listening on *:3000');
|
|
});
|