20230912 웹소켓(Csocket.js) 백업용

[fun1ty]

const models = require("../models/index");
const jwt = require("jsonwebtoken");
const vt = require("../utils/JwtVerifyToken");
const S3 = require("../utils/S3upload");
const randomBytes = require("crypto").randomBytes(2);
const number = parseInt(randomBytes.toString("hex"), 16);
// const roomList = [];
const user = [];
let roomName;
// let roomFind;
let msg;
let roomDBInsert;

console.log(user);
const generateRandomString = (num) => {
const characters = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz";
let result = "";
const charactersLength = characters.length;
for (let i = 0; i < num; i++) {
result += characters.charAt(Math.floor(Math.random() * charactersLength));
}
return result;
};

exports.connection = (io, socket) => {
console.log("접속");

socket.on("jwt", async ({ token }) => {
// console.log(클라이언트로부터 JWT 토큰을 수신: ${token});
//jwt토큰 확인
try {
let userId = await vt.verifyToken(token);
console.log("userId: ", userId);
const resultValue = await models.User.findOne({
where: { id: userId },
}); //회원이 있는지 검증
userId = console.log("resultValue", resultValue);
if (!user.includes(resultValue.id)) {
user.push(resultValue.id);
console.log("user", user[0], user[1]);
}
socket.emit("jwt", resultValue);
} catch (error) {
console.error("토큰 검증 에러:", error);
}
});

//채팅방 만들기 생성
socket.on("create", async (userId, usernick) => {
//join(방이름) 해당 방이름으로 없다면 생성. 존재하면 입장
console.log(userId, usernick);
try {
if (!roomName) {
roomName = "room" + number + generateRandomString(10) + userId;
socket.join(roomName);
console.log("roomName", roomName);
roomDBInsert = await models.ChatRoom.create({
roomname: roomName,
});
}

  roomFind = await models.ChatRoom.findOne({
    where: { roomname: roomName },
  });
  console.log("roomFind", roomFind);

  if (user.length > 1) {
    await chatUserDBInsert();
  }
  socket.room = roomName;
  socket.user = usernick;

  io.to(socket.room).emit("notice", `${socket.user}님이 입장하셨습니다`);

  //채팅방 목록 갱신
  // if (!roomList.includes(roomFind.id)) {
  //   roomList.push(roomFind.id);
  //   // //갱신된 목록은 전체가 봐야함
  // }
  // const usersInRoom = getUsersInRoom(chatRoomId);
  // io.to(roomFind.id).emit("userList", usersInRoom);
} catch (error) {
  console.log(error);
}

});

socket.on("sendMessage", async (message) => {
try {
const FILE = message.file;
msg = message.message;
console.log("sendMessage", message);
await chatDBInsert(FILE, msg);
io.to(socket.room).emit("newMessage", message.message, message.nick);
} catch (error) {
console.log("newMessage에러: ", error);
}
});

socket.on("disconnect", () => {
if (socket.room) {
socket.leave(socket.room);
}
});

//채팅 유저DB 삽입
function chatUserDBInsert() {
if (roomDBInsert) {
models.ChatUser.create({
roomid: roomFind.id,
userid: user[0],
joinuser: user[user.length - 1],
}).then((result) => {
console.log("chatUserDBInsert", result);
});
} else {
console.log("chatUserDBInsert null");
}
}

//채팅대화 DB 삽입
function chatDBInsert(FILE, msg) {
if (roomDBInsert) {
models.Chat.create({
userid: user[0],
roomid: roomFind.id,
CONTENT: msg,
FILE: FILE,
joinuser: user[user.length - 1],
}).then((result) => {
console.log("chatDBInsert", result);
});
} else {
console.log("chatDBInsert null");
}
}

function getUsersInRoom(room) {
const users = [];
//채팅룸에 접속한 socket.id값을 찾아야함
const clients = io.sockets.adapter.rooms.get(room);
//console.log(clients);
if (clients) {
clients.forEach((socketId) => {
//io.sockets.sockets: socket.id가 할당한 변수들의 객체값
const userSocket = io.sockets.sockets.get(socketId);
//개별 사용자에게 메세지를 보내기 위해서 객체형태로 변경
//key: 소켓아이디, name:이름
const info = { name: userSocket.user, key: socketId };
users.push(info);
});
}
return users;
}
};