diff --git a/internal/op/client.go b/internal/op/client.go index f2c22b5..69fef61 100644 --- a/internal/op/client.go +++ b/internal/op/client.go @@ -44,7 +44,7 @@ func (c *Client) Broadcast(msg Message, conf ...BroadcastConf) error { } func (c *Client) SendChatMessage(message string) error { - if c.u.HasRoomPermission(c.r, model.PermissionSendChatMessage) { + if !c.u.HasRoomPermission(c.r, model.PermissionSendChatMessage) { return model.ErrNoPermission } return c.Broadcast(&pb.ElementMessage{ diff --git a/server/handlers/websocket.go b/server/handlers/websocket.go index 091bd92..c227143 100644 --- a/server/handlers/websocket.go +++ b/server/handlers/websocket.go @@ -173,7 +173,7 @@ func handleElementMsg(cli *op.Client, msg *pb.ElementMessage) error { Error: fmt.Sprintf("send chat message error: %v", err), }) } - return nil + return err case pb.ElementMessageType_PLAY, pb.ElementMessageType_PAUSE, pb.ElementMessageType_CHANGE_RATE: