ocelot-Social-Community/Ocelot-Social
1
0
Fork 0
mirror of https://github.com/Ocelot-Social-Community/Ocelot-Social.git synced 2025-12-13 07:46:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix recipient selection

Browse Source
This commit is contained in:
Ulf Gebhardt 2023-07-18 10:52:18 +02:00
parent d7aba44fbe
commit ae2d6c7ad5
Signed by: ulfgebhardt
GPG Key ID: DA6B843E748679C9
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
backend/src/schema/resolvers/messages.ts
View File

@ -26,7 +26,7 @@ export default {
subscribe: withFilter( subscribe: withFilter(
() => pubsub.asyncIterator(CHAT_MESSAGE_ADDED), () => pubsub.asyncIterator(CHAT_MESSAGE_ADDED),
(payload, variables) => { (payload, variables) => {
return true // payload.user.id === variables.userId return payload.userId === variables.userId
}, },
), ),
}, },
@ -114,13 +114,13 @@ export default {
const roomCountUpdated = await getUnreadRoomsCount(message.recipientId, session) const roomCountUpdated = await getUnreadRoomsCount(message.recipientId, session)
// send subscriptions // send subscriptions
await pubsub.publish(ROOM_COUNT_UPDATED, { void pubsub.publish(ROOM_COUNT_UPDATED, {
roomCountUpdated, roomCountUpdated,
userId: message.recipientId, userId: message.recipientId,
}) })
await pubsub.publish(CHAT_MESSAGE_ADDED, { void pubsub.publish(CHAT_MESSAGE_ADDED, {
chatMessageAdded: message, chatMessageAdded: message,
user: message.recipientId, userId: message.recipientId,
}) })
} }