diff --git a/backend/server.js b/backend/server.js index 42d3246..75f8969 100644 --- a/backend/server.js +++ b/backend/server.js @@ -34,6 +34,9 @@ const io = new Server(server, { // <--- Инициализация socket.io } }); +// Сделать экземпляр io доступным в запросах +app.set('io', io); + // Подключение к базе данных - проверяем, что импортировали функцию if (typeof connectDBModule === 'function') { try { @@ -95,6 +98,16 @@ io.on("connection", (socket) => { return activeUsers.find(u => u.userId === userId); }; + socket.on("joinConversationRoom", (roomId) => { + socket.join(roomId); + console.log(`[Socket.IO] User ${socket.id} joined room ${roomId}`); + }); + + socket.on("leaveConversationRoom", (roomId) => { + socket.leave(roomId); + console.log(`[Socket.IO] User ${socket.id} left room ${roomId}`); + }); + // Отправка сообщения socket.on("sendMessage", async ({ senderId, receiverId, text, clientConversationId }) => { // Добавлен clientConversationId, async console.log(`"[Socket.IO] Получено сообщение от ${senderId} для ${receiverId}: "${text}" (попытка для диалога: ${clientConversationId})"`); diff --git a/src/views/ChatView.vue b/src/views/ChatView.vue index 273a839..636daf3 100644 --- a/src/views/ChatView.vue +++ b/src/views/ChatView.vue @@ -33,7 +33,7 @@
{{ item.data.text }}
{{ formatMessageTimestamp(item.data.createdAt) }} - (изменено) + (изменено) (отправка...)