/
githubmirror
/
socket.io
Обзор
Документация
Войти
/
githubmirror
/
socket.io
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
main
examples/private-messaging/server/messageStore.js
60 строк
1 KB
Meet Shah
docs(examples): fix duplicate self messages (#5341)
29 май 2026, 12:22
Не верифицирован
29 май 2026, 12:22
fad463c
Код
Авторство
О чём код?
/* abstract */ class MessageStore { saveMessage(message) {} findMessagesForUser(userID) {} } class InMemoryMessageStore extends MessageStore { constructor() { super(); this.messages = []; } saveMessage(message) { this.messages.push(message); } findMessagesForUser(userID) { return this.messages.filter( ({ from, to }) => from === userID || to === userID ); } } const CONVERSATION_TTL = 24 * 60 * 60; class RedisMessageStore extends MessageStore { constructor(redisClient) { super(); this.redisClient = redisClient; } saveMessage(message) { const value = JSON.stringify(message); const multi = this.redisClient.multi(); multi.rpush(`messages:${message.from}`, value); // Only push to recipient if different from sender if (message.from !== message.to) { multi.rpush(`messages:${message.to}`, value); } multi .expire(`messages:${message.from}`, CONVERSATION_TTL) .expire(`messages:${message.to}`, CONVERSATION_TTL) .exec(); } findMessagesForUser(userID) { return this.redisClient .lrange(`messages:${userID}`, 0, -1) .then((results) => { return results.map((result) => JSON.parse(result)); }); } } module.exports = { InMemoryMessageStore, RedisMessageStore, };