unknown

request module install -> to call weather api

...@@ -8,62 +8,13 @@ module.exports = (server, app) => { ...@@ -8,62 +8,13 @@ module.exports = (server, app) => {
8 transports: ['websocket'] 8 transports: ['websocket']
9 }); 9 });
10 10
11 - io.use(passportSocketIo.authorize(passport_IO)); //passport와 socketIO 연동 미들웨어 사용
12 - app.set('io', io); //io를 app.get("io")로 다른 라우터에서 접근 가능하게함
13 - const chat = io.of('/chat'); //chat namespace
14 11
15 - chat.on('connection', (socket) => { //네임스페이스 연결시 루프 동작 12 + io.on('connection', (socket) => { //네임스페이스 연결시 루프 동작
16 - let room;
17 - socket.to(room).emit('chat_sended_to_client', "LALALALALAL");
18 socket.on('disconnecting', (reason) => { 13 socket.on('disconnecting', (reason) => {
19 14
20 - const sql = "DELETE FROM participants WHERE id=?"
21 - console.log(socket.request.user.nickname, room, '번방 퇴장');
22 - db.query(sql, [socket.request.user.id], (err, result) => { //퇴장할때 참가자 목록에서 뺌
23 - socket.leave(room);
24 -
25 - const msg = {};
26 - const user=socket.request.user;
27 - msg.time = socket.handshake.time.slice(0, 24);
28 - msg.sended = user.id;
29 - msg.sended_Nickname = user.nickname;
30 - msg.profile_image=user.profile_image;
31 - msg.description = `${msg.sended_Nickname}님이 퇴장하셨습니다.`;
32 -
33 - socket.to(room).emit("other_leaved_room", msg);
34 - room = 0;
35 - })
36 }) 15 })
37 socket.on("connection", (roomnum) => { //방 접속시에 현재 방번호 room에 저장 16 socket.on("connection", (roomnum) => { //방 접속시에 현재 방번호 room에 저장
38 - room = roomnum;
39 - console.log(socket.request.user.nickname, room, '번방 입장');
40 - socket.join(room); // x번 room에 join시킴
41 - const msg = {};
42 - const user= socket.request.user;
43 - msg.time = socket.handshake.time.slice(0, 24);
44 - msg.sended = `${user.id}`;
45 - msg.sended_Nickname = user.nickname;
46 - msg.profile_image = user.profile_image;
47 - msg.description = `${user.nickname}님이 들어오셨습니다.`
48 -
49 - const sql = 'INSERT INTO participants (room,id,name,nickname,profile_image) VALUES (?,?,?,?,?)'; //add user in room
50 - db.query(sql, [roomnum, user.id, user.name, user.nickname, user.profile_image], (err, result) => {
51 - chat.to(room).emit("new_user_in", msg); //방에 속한 모든 사람들에게 내가 들어왔음을 알림
52 - })
53 }) 17 })
54 - socket.on('chat_sended_to_server', (data) => { //
55 - console.log('chat received', socket.request.user.id, data);
56 - const msg = {};
57 - msg.time = socket.handshake.time.slice(0, 24);
58 - msg.sended = `${socket.request.user.id}`;
59 - msg.sended_Nickname = socket.request.user.nickname;
60 - msg.profile_image = socket.request.user.profile_image;
61 - msg.description = data;
62 - console.log(room);
63 - const sql = 'INSERT INTO chat (room, description,sended,sended_nickname,time,profile_image) VALUES (?,?,?,?,?,?)';
64 - db.query(sql, [room, msg.description, msg.sended, msg.sended_Nickname, msg.time, msg.profile_image]); //채팅한 말 객체들의 배열 [ { room : 10 "sended":"YOUT","sended_NickName":"YOU" , time : "now" , description : "lala", profile_image : "!@#@!#"} , ... ]
65 - chat.to(room).emit('chat_sended_to_client', msg);
66 - });
67 }) 18 })
68 19
69 20
......
This diff is collapsed. Click to expand it.
...@@ -12,9 +12,10 @@ ...@@ -12,9 +12,10 @@
12 "debug": "~2.6.9", 12 "debug": "~2.6.9",
13 "ejs": "~2.5.7", 13 "ejs": "~2.5.7",
14 "express": "~4.16.0", 14 "express": "~4.16.0",
15 + "helmet": "^3.13.0",
15 "http-errors": "~1.6.2", 16 "http-errors": "~1.6.2",
16 "morgan": "~1.9.0", 17 "morgan": "~1.9.0",
17 - "helmet": "^3.13.0", 18 + "request": "^2.88.0",
18 "socket.io": "^2.1.1" 19 "socket.io": "^2.1.1"
19 } 20 }
20 } 21 }
......