iridium/neko
2
2
Fork 0
mirror of https://github.com/m1k1o/neko.git synced 2024-07-24 14:40:50 +12:00
Code Issues Packages Projects Releases Wiki Activity

fix typo.

Browse Source
This commit is contained in:
Miroslav Šedivý 2024-06-17 23:16:48 +02:00
parent 57596315e9
commit c78d797fe7
4 changed files with 17 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
server/internal/types/event/events.go
View File

@ -46,9 +46,9 @@ const (
) )
const ( const (
BORADCAST_STATUS = "broadcast/status" BROADCAST_STATUS = "broadcast/status"
BORADCAST_CREATE = "broadcast/create" BROADCAST_CREATE = "broadcast/create"
BORADCAST_DESTROY = "broadcast/destroy" BROADCAST_DESTROY = "broadcast/destroy"
) )
const ( const (

16
server/internal/websocket/handler/broadcast.go
View File

@ -6,7 +6,7 @@ import (
"m1k1o/neko/internal/types/message" "m1k1o/neko/internal/types/message"
) )
func (h *MessageHandler) boradcastCreate(session types.Session, payload *message.BroadcastCreate) error { func (h *MessageHandler) broadcastCreate(session types.Session, payload *message.BroadcastCreate) error {
broadcast := h.capture.Broadcast() broadcast := h.capture.Broadcast()
if !session.Admin() { if !session.Admin() {
@ -44,14 +44,14 @@ func (h *MessageHandler) boradcastCreate(session types.Session, payload *message
} }
} }
if err := h.boradcastStatus(nil); err != nil { if err := h.broadcastStatus(nil); err != nil {
return err return err
} }
return nil return nil
} }
func (h *MessageHandler) boradcastDestroy(session types.Session) error { func (h *MessageHandler) broadcastDestroy(session types.Session) error {
broadcast := h.capture.Broadcast() broadcast := h.capture.Broadcast()
if !session.Admin() { if !session.Admin() {
@ -70,18 +70,18 @@ func (h *MessageHandler) boradcastDestroy(session types.Session) error {
broadcast.Stop() broadcast.Stop()
if err := h.boradcastStatus(nil); err != nil { if err := h.broadcastStatus(nil); err != nil {
return err return err
} }
return nil return nil
} }
func (h *MessageHandler) boradcastStatus(session types.Session) error { func (h *MessageHandler) broadcastStatus(session types.Session) error {
broadcast := h.capture.Broadcast() broadcast := h.capture.Broadcast()
msg := message.BroadcastStatus{ msg := message.BroadcastStatus{
Event: event.BORADCAST_STATUS, Event: event.BROADCAST_STATUS,
IsActive: broadcast.Started(), IsActive: broadcast.Started(),
URL: broadcast.Url(), URL: broadcast.Url(),
} }
@ -89,7 +89,7 @@ func (h *MessageHandler) boradcastStatus(session types.Session) error {
// if no session, broadcast change // if no session, broadcast change
if session == nil { if session == nil {
if err := h.sessions.AdminBroadcast(msg, nil); err != nil { if err := h.sessions.AdminBroadcast(msg, nil); err != nil {
h.logger.Warn().Err(err).Msgf("broadcasting event %s has failed", event.BORADCAST_STATUS) h.logger.Warn().Err(err).Msgf("broadcasting event %s has failed", event.BROADCAST_STATUS)
return err return err
} }
@ -102,7 +102,7 @@ func (h *MessageHandler) boradcastStatus(session types.Session) error {
} }
if err := session.Send(msg); err != nil { if err := session.Send(msg); err != nil {
h.logger.Warn().Err(err).Msgf("sending event %s has failed", event.BORADCAST_STATUS) h.logger.Warn().Err(err).Msgf("sending event %s has failed", event.BROADCAST_STATUS)
return err return err
} }

10
server/internal/websocket/handler/handler.go
View File

@ -148,15 +148,15 @@ func (h *MessageHandler) Message(id string, raw []byte) error {
return h.screenSet(id, session, payload) return h.screenSet(id, session, payload)
}), "%s failed", header.Event) }), "%s failed", header.Event)
// Boradcast Events // Broadcast Events
case event.BORADCAST_CREATE: case event.BROADCAST_CREATE:
payload := &message.BroadcastCreate{} payload := &message.BroadcastCreate{}
return errors.Wrapf( return errors.Wrapf(
utils.Unmarshal(payload, raw, func() error { utils.Unmarshal(payload, raw, func() error {
return h.boradcastCreate(session, payload) return h.broadcastCreate(session, payload)
}), "%s failed", header.Event) }), "%s failed", header.Event)
case event.BORADCAST_DESTROY: case event.BROADCAST_DESTROY:
return errors.Wrapf(h.boradcastDestroy(session), "%s failed", header.Event) return errors.Wrapf(h.broadcastDestroy(session), "%s failed", header.Event)
// Admin Events // Admin Events
case event.ADMIN_LOCK: case event.ADMIN_LOCK:

2
server/internal/websocket/handler/session.go
View File

@ -30,7 +30,7 @@ func (h *MessageHandler) SessionCreated(id string, session types.Session) error
} }
// send broadcast status if admin // send broadcast status if admin
if err := h.boradcastStatus(session); err != nil { if err := h.broadcastStatus(session); err != nil {
return err return err
} }
} }