Compare commits
No commits in common. "master" and "master" have entirely different histories.
22
src/index.js
22
src/index.js
@ -21,7 +21,6 @@ const traffic = {
|
|||||||
};
|
};
|
||||||
|
|
||||||
var players = {};
|
var players = {};
|
||||||
var rooms = {};
|
|
||||||
|
|
||||||
// Send players json object
|
// Send players json object
|
||||||
app.get("/", (req, res) => {
|
app.get("/", (req, res) => {
|
||||||
@ -36,10 +35,10 @@ io.on("connection", (socket) => {
|
|||||||
const room = players[socket.id].room;
|
const room = players[socket.id].room;
|
||||||
|
|
||||||
var playerUpdate = {};
|
var playerUpdate = {};
|
||||||
if (io.sockets.adapter.rooms.get(room)) {
|
if (io.sockets.adapter.rooms[room]) {
|
||||||
io.sockets.adapter.rooms.get(room).forEach((id) => {
|
for (const id in io.sockets.adapter.rooms[room].sockets) {
|
||||||
playerUpdate[id] = players[id];
|
playerUpdate[id] = players[id];
|
||||||
});
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
io.in(room).emit("roomUpdate", playerUpdate);
|
io.in(room).emit("roomUpdate", playerUpdate);
|
||||||
@ -48,7 +47,6 @@ io.on("connection", (socket) => {
|
|||||||
|
|
||||||
if (io.sockets.adapter.rooms.get(room) == undefined) {
|
if (io.sockets.adapter.rooms.get(room) == undefined) {
|
||||||
console.log(traffic.int + colours.room(`Room ${room} has been deleted due to a lack of players`));
|
console.log(traffic.int + colours.room(`Room ${room} has been deleted due to a lack of players`));
|
||||||
delete rooms[room];
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -75,11 +73,7 @@ io.on("connection", (socket) => {
|
|||||||
if (roomId[0] == data.gameID) {
|
if (roomId[0] == data.gameID) {
|
||||||
if (roomId[1] == data.playersMax) {
|
if (roomId[1] == data.playersMax) {
|
||||||
if (io.sockets.adapter.rooms.get(room).size < data.playersMax) {
|
if (io.sockets.adapter.rooms.get(room).size < data.playersMax) {
|
||||||
if (!rooms[room].started) {
|
join += room;
|
||||||
join += room;
|
|
||||||
} else {
|
|
||||||
console.log(traffic.int + colours.room(`Room ${room} has already started, skipping.`));
|
|
||||||
}
|
|
||||||
} else {
|
} else {
|
||||||
console.log(traffic.int + colours.room(`Room ${room} is full, skipping.`));
|
console.log(traffic.int + colours.room(`Room ${room} is full, skipping.`));
|
||||||
}
|
}
|
||||||
@ -99,11 +93,6 @@ io.on("connection", (socket) => {
|
|||||||
});
|
});
|
||||||
|
|
||||||
join = data.gameID + "_" + data.playersMax + "_" + count;
|
join = data.gameID + "_" + data.playersMax + "_" + count;
|
||||||
|
|
||||||
rooms[join] = {
|
|
||||||
started: false
|
|
||||||
};
|
|
||||||
|
|
||||||
console.log(traffic.int + colours.room(`There is no room available for the requested game, making room ${join}`));
|
console.log(traffic.int + colours.room(`There is no room available for the requested game, making room ${join}`));
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -113,7 +102,6 @@ io.on("connection", (socket) => {
|
|||||||
if (io.sockets.adapter.rooms.get(join).size == data.playersMax) {
|
if (io.sockets.adapter.rooms.get(join).size == data.playersMax) {
|
||||||
console.log(traffic.int + colours.room(`Room ${join} has reached the maximum amount of players, starting game`));
|
console.log(traffic.int + colours.room(`Room ${join} has reached the maximum amount of players, starting game`));
|
||||||
io.in(join).emit("gameStart");
|
io.in(join).emit("gameStart");
|
||||||
rooms[join].started = true;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
players[socket.id] = {
|
players[socket.id] = {
|
||||||
@ -121,6 +109,8 @@ io.on("connection", (socket) => {
|
|||||||
room: join
|
room: join
|
||||||
};
|
};
|
||||||
|
|
||||||
|
console.log(players);
|
||||||
|
|
||||||
var playerUpdate = {};
|
var playerUpdate = {};
|
||||||
io.sockets.adapter.rooms.get(join).forEach((id) => {
|
io.sockets.adapter.rooms.get(join).forEach((id) => {
|
||||||
playerUpdate[id] = players[id];
|
playerUpdate[id] = players[id];
|
||||||
|
Loading…
Reference in New Issue
Block a user