Trabajo en una aplicación de chat. Quiero almacenar mensajes en un objeto como este:
{ 'room1': ['msg1', 'msg2', ...] 'room2': ['msg3', 'msg4', ...] ... } Definí una variable en mi servidor roomMessages , el problema es cuando quiero agregar un mensaje en una habitación específica usando roomMessages[room].push(data); me muestra este error: TypeError: Cannot read properties of undefined (reading 'push') este es mi código socket.io:
const roomMessages = {}; roomsNamespace.use((socket, next) => { const token = socket.handshake.query.token; console.log(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.log(data); if (roomMessages[room]) roomMessages[room].push(data); roomsNamespace.in(room).emit("chat-message", data); });Básicamente, quiero enviar mensajes anteriores cuando el usuario se une al chat. ¿Cómo solucionar este error?
puedes hacer algo como esto
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.log(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.log(data); addMessage(room, data) roomsNamespace.in(room).emit("chat-message", data); }); de esta forma si quieres más adelante puedes cambiar tu implementación de messageRepository almacenando datos en redis o donde quieras