Cleanup: Manager, reorganise the socketio code a bit
This commit is contained in:
parent
c07d2e3249
commit
8d69bfe069
17
internal/manager/webupdates/chat.go
Normal file
17
internal/manager/webupdates/chat.go
Normal file
@ -0,0 +1,17 @@
|
|||||||
|
// SPDX-License-Identifier: GPL-3.0-or-later
|
||||||
|
package webupdates
|
||||||
|
|
||||||
|
import gosocketio "github.com/graarh/golang-socketio"
|
||||||
|
|
||||||
|
func (b *BiDirComms) registerChatEventHandlers() {
|
||||||
|
_ = b.sockserv.On(string(SIOEventChatMessageRcv),
|
||||||
|
func(c *gosocketio.Channel, message Message) string {
|
||||||
|
logger := sioLogger(c)
|
||||||
|
logger.Info().
|
||||||
|
Str("text", message.Text).
|
||||||
|
Str("name", message.Name).
|
||||||
|
Msg("socketIO: message received")
|
||||||
|
b.BroadcastTo(SocketIORoomChat, SIOEventChatMessageSend, message)
|
||||||
|
return "message sent successfully."
|
||||||
|
})
|
||||||
|
}
|
@ -58,16 +58,7 @@ func (b *BiDirComms) registerSIOEventHandlers() {
|
|||||||
logger.Warn().Msg("socketIO: socketio error")
|
logger.Warn().Msg("socketIO: socketio error")
|
||||||
})
|
})
|
||||||
|
|
||||||
// chat socket
|
b.registerChatEventHandlers()
|
||||||
_ = sio.On(string(SIOEventChatMessageRcv), func(c *gosocketio.Channel, message Message) string {
|
|
||||||
logger := sioLogger(c)
|
|
||||||
logger.Info().
|
|
||||||
Str("text", message.Text).
|
|
||||||
Str("name", message.Name).
|
|
||||||
Msg("socketIO: message received")
|
|
||||||
b.BroadcastTo(SocketIORoomChat, SIOEventChatMessageSend, message)
|
|
||||||
return "message sent successfully."
|
|
||||||
})
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func sioLogger(c *gosocketio.Channel) zerolog.Logger {
|
func sioLogger(c *gosocketio.Channel) zerolog.Logger {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user