-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathserver.js
54 lines (51 loc) · 1.89 KB
/
server.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
const http = require("http");
const express = require("express");
const socketio = require("socket.io");
const path = require("path");
const roomOf = require("./server_modules/socket/roomOf");
const listUsersInRoom = require("./server_modules/socket/listUsersInRoom");
const usersInRoom = require("./server_modules/socket/usersInRoom");
const app = express();
const server = http.createServer(app);
const io = socketio(server);
let roomAcceptingEntry = false;
const playerLimit = 5;
app.use(express.static(path.join(__dirname, "public")));
io.on("connection", (socket) => {
console.log('room of socket is ',roomOf(socket))
console.log(`a user connected with id = ${socket.id}`);
socket.on("userName", (userName) =>
socket.broadcast.to(roomOf(socket)).emit("userName", socket.id, userName)
);
socket.on("scoreUpdate", (score) =>
socket.broadcast
.to(roomOf(socket))
.emit("scoreUpdateToClient", socket.id, score)
);
socket.on("startGame", () =>
io.to(roomOf(socket)).emit("startGame")
);
addToRandomRoom();
async function addToRandomRoom() {
usersInRoom(roomAcceptingEntry, io)
.then((numberOfUsers) => {
console.log("users in this room: ", numberOfUsers);
if (numberOfUsers < playerLimit&&roomAcceptingEntry) {
listUsersInRoom(roomAcceptingEntry, io)
.then((idSet) => socket.emit("existingUsers", [...idSet.keys()]))
.then(socket.join(roomAcceptingEntry));
} else {
socket.emit('youAreFirstUserInRoom')
socket.join('room_' + socket.id);
roomAcceptingEntry = 'room_' + socket.id;
}
console.log(roomOf(socket),'room of socket')
socket.broadcast.to(roomOf(socket)).emit("userJoined", socket.id);
})
.catch((e) => console.log(e));
}
});
const PORT = process.env.PORT || 3000;
server.listen(PORT, () => {
console.log(`Server running on port ${PORT}`);
});