Verify if the exist the channel before
This commit is contained in:
+4
-4
@@ -186,15 +186,15 @@ func onMessage(conn *websocket.Conn, w http.ResponseWriter, r *http.Request, ses
|
|||||||
|
|
||||||
channel, err := app.FindChannelByChannelID(clientEvent.Channel)
|
channel, err := app.FindChannelByChannelID(clientEvent.Channel)
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
emitWSError(newGenericError(fmt.Sprintf("Could not find a channel with the id %s", clientEvent.Channel)), conn)
|
||||||
|
}
|
||||||
|
|
||||||
if !channel.IsPresenceOrPrivate() {
|
if !channel.IsPresenceOrPrivate() {
|
||||||
emitWSError(newGenericError("Client event rejected - only supported on private and presence channels"), conn)
|
emitWSError(newGenericError("Client event rejected - only supported on private and presence channels"), conn)
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
|
|
||||||
if err != nil {
|
|
||||||
emitWSError(newGenericError(fmt.Sprintf("Could not find a channel with the id %s", clientEvent.Channel)), conn)
|
|
||||||
}
|
|
||||||
|
|
||||||
if err := app.Publish(channel, clientEvent, sessionID); err != nil {
|
if err := app.Publish(channel, clientEvent, sessionID); err != nil {
|
||||||
log.Error(err)
|
log.Error(err)
|
||||||
emitWSError(newGenericReconnectImmediatelyError(), conn)
|
emitWSError(newGenericReconnectImmediatelyError(), conn)
|
||||||
|
|||||||
Reference in New Issue
Block a user