add-sse-entity

This commit is contained in:
Untone 2023-11-16 18:34:37 +03:00
parent 93c4c3d308
commit 4f7702a77f
2 changed files with 5 additions and 5 deletions

View File

@ -32,12 +32,12 @@ export const InboxProvider = (props: { children: JSX.Element }) => {
const handleMessage = (sseMessage) => { const handleMessage = (sseMessage) => {
console.log('[context.inbox]:', sseMessage) console.log('[context.inbox]:', sseMessage)
// TODO: handle all action types: create update delete join left // TODO: handle all action types: create update delete join left
if (['create', 'update', 'delete'].includes(sseMessage.action)) { if (sseMessage.entity == 'message') {
const relivedMessage = sseMessage.payload const relivedMessage = sseMessage.payload
setMessages((prev) => [...prev, relivedMessage]) setMessages((prev) => [...prev, relivedMessage])
} else if (['left', 'join'].includes(sseMessage.action)) { } else if (sseMessage.entity == 'chat') {
// TODO: set chat members const relivedChat = sseMessage.payload
console.debug(sseMessage) setChats((prev) => [...prev, relivedChat])
} }
} }

View File

@ -104,7 +104,7 @@ export const NotificationsProvider = (props: { children: JSX.Element }) => {
}, },
onmessage(event) { onmessage(event) {
const m: SSEMessage = JSON.parse(event.data) const m: SSEMessage = JSON.parse(event.data)
if (m.entity === 'chat') { if (m.entity === 'chat' || m.entity == 'message') {
console.log('[context.notifications] Received message:', m) console.log('[context.notifications] Received message:', m)
messageHandler()(m) messageHandler()(m)
} else { } else {