-
Notifications
You must be signed in to change notification settings - Fork 0
/
socket.js
70 lines (65 loc) · 2.43 KB
/
socket.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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
const onlineUsers = {};
const RoomModel = require("./models/RoomSchema");
const UserModel = require("./models/UserSchema");
function disconnectionHandling(socket, io) {
if (onlineUsers[socket.id] !== null && onlineUsers[socket.id] !== undefined) {
console.log(`user ${socket.id} out`);
const leftroom = onlineUsers[socket.id].roomId;
const leftuser = onlineUsers[socket.id].username;
delete onlineUsers[socket.id];
io.sockets.in(leftroom).emit("roombye", `${leftuser} leaved this room`);
io.sockets.in(leftroom).emit("userout", socket.id);
// room의 인원 감소시키기
RoomModel.findOne({ _id: leftroom }, (err, r) => {
if (r === null || r === undefined) {} else {
const mems = r.members;
r.members = mems - 1;
r.save();
}
});
}
}
function connectionHandling(socket, io) {
let loginID = [];
console.log(`+ connection to socket.io : user ${socket.id} in`);
console.log(`=> ${io.engine.clientsCount} socket(s) connected`);
loginID.concat(socket.id);
//첫 페이지에 접속한 유저에게 방 정보를 보내자 -> 일단 하지 말자
socket.on("disconnect", () => disconnectionHandling(socket, io));
socket.on("roomenter", (data) => {
const user = data.username;
const roomID = data.roomID;
socket.join(roomID);
// room의 인원 증가시키기
RoomModel.findOne({ _id: roomID }, (err, r) => {
const mems = r.members;
r.members = mems + 1;
r.save();
});
onlineUsers[socket.id] = { roomId: roomID, username: user };
io.sockets.in(roomID).emit("roomgreet", `${user} joined this room`);
io.sockets.in(roomID).emit("usersList", getUsersByRoomId(roomID));
});
socket.on("messageInput", (data) => {
io.sockets
.in(data.roomID)
.emit("messagePrint", `${data.username} said : ${data.message}`);
});
}
module.exports = (io) => {
io.on("connection", (socket) => {
connectionHandling(socket, io);
});
};
const getUsersByRoomId = (roomId) => {
let userstemp = [];
Object.keys(onlineUsers).forEach((sid) => {
if (onlineUsers[sid].roomId === roomId) {
userstemp.push({
socketId: sid,
name: onlineUsers[sid].username,
});
}
});
return userstemp;
};