sage
/
kafka-dance-api
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge branch 'main' of https://gitlab.com/kafka-dance/kafka-dance-api into main

This commit is contained in:
Sage Vaillancourt 2022-08-26 18:51:41 -04:00
parent cf21c56231 ac2d3504bd
commit 3f98892ddd
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
app.js
View File

@ -169,10 +169,14 @@ wsServer.on('connection', socket => {
})
socket.on('message', async message => {
console.log('socket message')
//socket.send('Loading...')
message = JSON.parse(message)
if (message.mode === 'kill') {
console.log('KILLING SOCKET')
await killConsumer(consumers.get(socket))
consumers.delete(socket)
return
}
const currentMode = message.mode === 'realTime' ? realTimeSearch : search
const cluster = clusters[message.cluster]
const run = async () => consumers.set(socket, await currentMode({