Я работаю в приложении чата. Я хочу хранить сообщения в таком объекте:
{
'room1': ['msg1', 'msg2', ...]
'room2': ['msg3', 'msg4', ...]
...
}
Я определил переменную на своем сервере socket.io roomMessages
проблема в том, что когда я хочу добавить сообщение в определенную комнату, используя roomMessages[room].push(data);
, он показывает мне эту ошибку: TypeError: Cannot read properties of undefined (reading 'push')
это мой код socket.io:
const roomMessages = {};
roomsNamespace.use((socket, next) => {
const token = socket.handshake.query.token;
console.info(token);
if (!token) return next(new Error("not auth"));
next();
});
roomsNamespace.on("connection", (socket) => {
const token = socket.handshake.query.token;
const apiService = new ApiService(process.env.BE_URL, token);
const room = socket.handshake.query.room;
socket.on("join-room", async () => {
socket.join(room);
await apiService.joinRoom(room);
const usersInThisRoom = await apiService.getUsersInRoom(room);
roomsNamespace.in(room).emit("all-users", usersInThisRoom);
socket.emit("room-messages", roomMessages[room]);
});
socket.on("chat-message", (data) => {
// console.info(data);
if (roomMessages[room]) roomMessages[room].push(data);
roomsNamespace.in(room).emit("chat-message", data);
});
в основном, я хочу отправлять предыдущие сообщения, когда пользователь присоединяется к чату Как исправить эту ошибку?
как это сделать?
const roomMessages = [];
вы можете сделать что-то вроде этого
const roomMessages = {};
const getMessages = (room) => roomMessages[room] || []
const addMessage = (room, message) => {
roomMessages[room] = [...getMessages(room), message]
}
roomsNamespace.use((socket, next) => {
const token = socket.handshake.query.token;
console.info(token);
if (!token) return next(new Error("not auth"));
next();
});
roomsNamespace.on("connection", (socket) => {
const token = socket.handshake.query.token;
const apiService = new ApiService(process.env.BE_URL, token);
const room = socket.handshake.query.room;
socket.on("join-room", async () => {
socket.join(room);
await apiService.joinRoom(room);
const usersInThisRoom = await apiService.getUsersInRoom(room);
roomsNamespace.in(room).emit("all-users", usersInThisRoom);
socket.emit("room-messages", getMessages(room));
});
socket.on("chat-message", (data) => {
// console.info(data);
addMessage(room, data)
roomsNamespace.in(room).emit("chat-message", data);
});
таким образом, если вы хотите позже, вы можете изменить свою реализацию messageRepository
хранения данных в Redis или где угодно
Вы пытаетесь вставить данные в объект, вы должны использовать массив. Посмотрите на скобки.