We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent df2a3aa commit e199d51Copy full SHA for e199d51
examples/private-messaging/server/messageStore.js
@@ -30,10 +30,16 @@ class RedisMessageStore extends MessageStore {
30
31
saveMessage(message) {
32
const value = JSON.stringify(message);
33
- this.redisClient
34
- .multi()
35
- .rpush(`messages:${message.from}`, value)
36
- .rpush(`messages:${message.to}`, value)
+ const multi = this.redisClient.multi();
+
+ multi.rpush(`messages:${message.from}`, value);
37
+ // Only push to recipient if different from sender
38
+ if (message.from !== message.to) {
39
+ multi.rpush(`messages:${message.to}`, value);
40
+ }
41
42
+ multi
43
.expire(`messages:${message.from}`, CONVERSATION_TTL)
44
.expire(`messages:${message.to}`, CONVERSATION_TTL)
45
.exec();
0 commit comments