Skip to content

채팅 연결 (사용자 이름 확인) #70

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 2 commits into from
Mar 11, 2025
Merged

채팅 연결 (사용자 이름 확인) #70

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
fbfc607
Merge pull request #69 from CommitField/dev
whale22 Mar 11, 2025
eb65639
채팅 연결결
skyeong42 Mar 11, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
82 changes: 32 additions & 50 deletions src/components/ChatRoom.jsx
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -166,14 +166,15 @@ const ChatRoom = ({ roomId: propRoomId, onLeaveRoom, refreshRooms }) => {
});
const userData = await userResponse.json();

if (!userData || !userData.username) {
if (!userData || !userData.id) {
throw new Error('사용자 정보를 가져올 수 없습니다.');
}

// 새 메시지 객체 생성
const newMsg = {
chatMsgId: `local-${Date.now()}`,
userId: userData.username,
userId: userData.id,
username: userData.username,
nickname: userData.nickname || userData.username,
message: messageText,
sendAt: new Date().toISOString()
Expand All @@ -186,6 +187,7 @@ const ChatRoom = ({ roomId: propRoomId, onLeaveRoom, refreshRooms }) => {
const wsSuccess = await webSocketService.sendMessage(
roomIdInt,
messageText,
userData.id,
userData.username,
userData.nickname || userData.username
);
Expand Down Expand Up @@ -289,12 +291,12 @@ const ChatRoom = ({ roomId: propRoomId, onLeaveRoom, refreshRooms }) => {
});
const userData = await response.json();

if (!userData || !userData.username) {
if (!userData || !userData.id) {
throw new Error('사용자 정보를 가져올 수 없습니다.');
}

setUserInfo({
id: userData.username,
id: userData.id,
nickname: userData.nickname || userData.username
});
} catch (err) {
Expand All @@ -304,73 +306,53 @@ const ChatRoom = ({ roomId: propRoomId, onLeaveRoom, refreshRooms }) => {
}
};

// 웹소켓 메시지 핸들러 - 일반 웹소켓용
// 웹소켓 메시지 핸들러 수정
const handleWebSocketMessage = (message) => {
console.log('WebSocket message received:', message);

// 시스템 메시지 처리
if (message.type === 'SYSTEM' || message.type === 'SUBSCRIBE_ACK' || message.type === 'UNSUBSCRIBE_ACK') {
// 시스템 메시지는 상태 표시만 하고 채팅에 추가하지 않음
console.log('System/Control message:', message.message);
return;
}

// 에러 메시지 처리
if (message.type === 'ERROR') {
console.error('WebSocket error message:', message.message);
// alert(message.message || '채팅 오류가 발생했습니다.');
return;
}

// 채팅방 ID 확인
const messageRoomId = message.roomId ? parseInt(message.roomId) : null;
if (messageRoomId && messageRoomId !== roomIdInt) {
console.log('Message for different room ignored:', messageRoomId);
const messageRoomId = parseInt(message.roomId);
if (messageRoomId !== roomIdInt) {
return;
}

// 메시지 형식 처리
const newMessage = {
chatMsgId: message.id || message.chatMsgId || Date.now(),
userId: message.userId,
nickname: message.from || message.nickname || '알 수 없는 사용자',
message: message.message || message.content || '',
sendAt: message.sendAt || new Date().toISOString()
};
// 현재 사용자가 보낸 메시지인지 확인
if (message.isLocalMessage || parseInt(message.userId) === parseInt(userInfo.id)) {
console.log('Ignoring own message:', message);
return;
}

// 중복 메시지 방지
setMessages(prevMessages => {
// 로컬 메시지 ID (local-*)로 시작하는 임시 메시지 대체
const isLocalMessage = prevMessages.some(msg =>
msg.chatMsgId?.toString().startsWith('local-') &&
msg.message === newMessage.message &&
msg.userId === newMessage.userId
// 중복 메시지 확인
const isDuplicate = prevMessages.some(msg =>
msg.chatMsgId === message.id ||
(msg.message === message.message &&
parseInt(msg.userId) === parseInt(message.userId) &&
Math.abs(new Date(msg.sendAt) - new Date(message.sendAt)) < 1000)
);

let updatedMessages;
if (isLocalMessage) {
// 임시 메시지를 서버 메시지로 대체
updatedMessages = prevMessages.map(msg =>
(msg.chatMsgId?.toString().startsWith('local-') &&
msg.message === newMessage.message &&
msg.userId === newMessage.userId)
? newMessage
: msg
);
} else {
// 이미 동일한 ID의 메시지가 있는지 확인
const exists = prevMessages.some(msg =>
msg.chatMsgId === newMessage.chatMsgId &&
!msg.chatMsgId?.toString().startsWith('local-')
);

if (exists) return prevMessages;
updatedMessages = [...prevMessages, newMessage];
if (isDuplicate) {
console.log('Duplicate message ignored:', message);
return prevMessages;
}

// 로컬 스토리지에 업데이트된 메시지 저장
saveChatMessages(roomId, updatedMessages);
const newMessage = {
chatMsgId: message.id || Date.now(),
userId: parseInt(message.userId),
nickname: message.nickname || message.from || '알 수 없는 사용자',
message: message.message,
sendAt: message.sendAt || new Date().toISOString()
};

const updatedMessages = [...prevMessages, newMessage];
saveChatMessages(roomId, updatedMessages);
return updatedMessages;
});
};
Expand Down
13 changes: 6 additions & 7 deletions src/services/WebSocketService.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -326,26 +326,25 @@ class WebSocketService {
return false;
}

// 사용자 정보 가져오기
const userResponse = await fetch(`${API_BACKEND_URL}/api/user/chatinfo`, {
credentials: 'include'
});
const userData = await userResponse.json();

if (!userData || !userData.id) {
if (!userData) {
console.error('Failed to get user info');
return false;
}

const chatMessage = {
type: 'CHAT',
roomId: parseInt(roomId),
userId: userData.id,
from: userData.nickname,
username: userData.username,
email: userData.email,
userId: parseInt(userData.id), // userId를 숫자로 변환
nickname: userData.username,
from: userData.username,
message: message,
sendAt: new Date().toISOString()
sendAt: new Date().toISOString(),
isLocalMessage: true // 로컬에서 보낸 메시지 표시
};

console.log('Sending message with user info:', chatMessage);
Expand Down