diff --git a/src/modules/api/submodules/chat.ts b/src/modules/api/submodules/chat.ts index 47e6140..dbc138a 100644 --- a/src/modules/api/submodules/chat.ts +++ b/src/modules/api/submodules/chat.ts @@ -146,39 +146,42 @@ function setup(data: SubmoduleData): void { chatMessageRead({ sender: chatPartner, reciever: userid }) }) - socket.on('chat message', (message) => { - const { reciever, msg, type } = message - if (!reciever || !msg || !type) { - return - } - const recieverUser = dbtools.Select(userDB, 'users', { - id: reciever, - })[0] - if (!recieverUser) { - socket.emit('chat message', { - success: false, - date: new Date().getTime(), - sender: reciever, - reciever: userid, - type: 'text', - msg: `A #${reciever} számú felhasználó nem létezik`, - }) - return - } + socket.on( + 'chat message', + (message: { reciever: string; msg: string; type: string }) => { + const { reciever, msg, type } = message + if (!reciever || !msg || !msg.trim() || !type) { + return + } + const recieverUser = dbtools.Select(userDB, 'users', { + id: reciever, + })[0] + if (!recieverUser) { + socket.emit('chat message', { + success: false, + date: new Date().getTime(), + sender: reciever, + reciever: userid, + type: 'text', + msg: `A #${reciever} számú felhasználó nem létezik`, + }) + return + } - const msgObj = { - sender: userid, - reciever: parseInt(reciever), - msg: dbtools.sanitizeQuery(msg), - type: type || 'text', - date: new Date().getTime(), - unread: 1, + const msgObj = { + sender: userid, + reciever: parseInt(reciever), + msg: dbtools.sanitizeQuery(msg), + type: type || 'text', + date: new Date().getTime(), + unread: 1, + } + dbtools.Insert(msgDB, 'msgs', msgObj) + if (userid !== parseInt(reciever)) { + io.sockets.in(reciever.toString()).emit('chat message', msgObj) + } } - dbtools.Insert(msgDB, 'msgs', msgObj) - if (userid !== reciever) { - io.sockets.in(reciever.toString()).emit('chat message', msgObj) - } - }) + ) }) // socket.on('disconnect', () => {})