neko/internal/websocket/handler/handler.go

128 lines
3.3 KiB
Go
Raw Normal View History

2020-11-02 04:09:48 +13:00
package handler
import (
"github.com/rs/zerolog"
2020-11-02 04:09:48 +13:00
"github.com/rs/zerolog/log"
2020-10-29 07:15:48 +13:00
"demodesk/neko/internal/types"
"demodesk/neko/internal/types/event"
"demodesk/neko/internal/types/message"
"demodesk/neko/internal/utils"
)
2020-11-02 04:09:48 +13:00
func New(
sessions types.SessionManager,
desktop types.DesktopManager,
capture types.CaptureManager,
webrtc types.WebRTCManager,
) *MessageHandlerCtx {
return &MessageHandlerCtx{
2021-08-30 04:23:58 +12:00
logger: log.With().Str("module", "websocket").Str("submodule", "handler").Logger(),
2021-02-15 02:40:17 +13:00
sessions: sessions,
desktop: desktop,
capture: capture,
webrtc: webrtc,
2020-11-02 04:09:48 +13:00
}
}
type MessageHandlerCtx struct {
2021-02-15 02:40:17 +13:00
logger zerolog.Logger
sessions types.SessionManager
webrtc types.WebRTCManager
desktop types.DesktopManager
capture types.CaptureManager
}
2021-08-30 09:00:51 +12:00
func (h *MessageHandlerCtx) Message(session types.Session, data types.WebSocketMessage) bool {
logger := h.logger.With().
Str("event", data.Event).
Str("session_id", session.ID()).
Logger()
2020-11-17 04:56:03 +13:00
var err error
2021-08-30 09:00:51 +12:00
switch data.Event {
2021-09-10 08:08:39 +12:00
// System Events
case event.SYSTEM_LOGS:
payload := &message.SystemLogs{}
err = utils.Unmarshal(payload, data.Payload, func() error {
return h.systemLogs(session, payload)
})
// Signal Events
2020-12-01 06:27:25 +13:00
case event.SIGNAL_REQUEST:
2021-05-01 02:05:07 +12:00
payload := &message.SignalVideo{}
2021-08-30 09:00:51 +12:00
err = utils.Unmarshal(payload, data.Payload, func() error {
2021-05-01 02:05:07 +12:00
return h.signalRequest(session, payload)
})
2021-06-28 08:02:05 +12:00
case event.SIGNAL_RESTART:
err = h.signalRestart(session)
case event.SIGNAL_ANSWER:
payload := &message.SignalAnswer{}
2021-08-30 09:00:51 +12:00
err = utils.Unmarshal(payload, data.Payload, func() error {
2020-11-17 04:56:03 +13:00
return h.signalAnswer(session, payload)
})
2021-02-03 08:43:33 +13:00
case event.SIGNAL_CANDIDATE:
payload := &message.SignalCandidate{}
2021-08-30 09:00:51 +12:00
err = utils.Unmarshal(payload, data.Payload, func() error {
2021-02-03 08:43:33 +13:00
return h.signalCandidate(session, payload)
})
2021-02-06 08:35:30 +13:00
case event.SIGNAL_VIDEO:
payload := &message.SignalVideo{}
2021-08-30 09:00:51 +12:00
err = utils.Unmarshal(payload, data.Payload, func() error {
2021-02-06 08:35:30 +13:00
return h.signalVideo(session, payload)
})
// Control Events
case event.CONTROL_RELEASE:
2020-11-17 04:56:03 +13:00
err = h.controlRelease(session)
case event.CONTROL_REQUEST:
2020-11-17 04:56:03 +13:00
err = h.controlRequest(session)
2020-12-01 05:53:05 +13:00
// Screen Events
case event.SCREEN_SET:
payload := &message.ScreenSize{}
2021-08-30 09:00:51 +12:00
err = utils.Unmarshal(payload, data.Payload, func() error {
2020-12-01 05:53:05 +13:00
return h.screenSet(session, payload)
})
2020-12-01 05:40:38 +13:00
// Clipboard Events
case event.CLIPBOARD_SET:
payload := &message.ClipboardData{}
2021-08-30 09:00:51 +12:00
err = utils.Unmarshal(payload, data.Payload, func() error {
2020-12-01 05:40:38 +13:00
return h.clipboardSet(session, payload)
})
2020-12-01 05:45:53 +13:00
// Keyboard Events
2021-01-16 04:53:03 +13:00
case event.KEYBOARD_MAP:
payload := &message.KeyboardMap{}
2021-08-30 09:00:51 +12:00
err = utils.Unmarshal(payload, data.Payload, func() error {
2021-01-16 04:53:03 +13:00
return h.keyboardMap(session, payload)
2020-12-01 05:45:53 +13:00
})
2021-01-16 04:53:03 +13:00
case event.KEYBOARD_MODIFIERS:
2020-12-01 05:45:53 +13:00
payload := &message.KeyboardModifiers{}
2021-08-30 09:00:51 +12:00
err = utils.Unmarshal(payload, data.Payload, func() error {
2020-12-01 05:45:53 +13:00
return h.keyboardModifiers(session, payload)
})
2021-01-29 03:56:50 +13:00
// Send Events
case event.SEND_UNICAST:
payload := &message.SendUnicast{}
2021-08-30 09:00:51 +12:00
err = utils.Unmarshal(payload, data.Payload, func() error {
2021-01-29 03:56:50 +13:00
return h.sendUnicast(session, payload)
})
case event.SEND_BROADCAST:
payload := &message.SendBroadcast{}
2021-08-30 09:00:51 +12:00
err = utils.Unmarshal(payload, data.Payload, func() error {
2021-01-29 03:56:50 +13:00
return h.sendBroadcast(session, payload)
})
default:
2020-12-13 05:40:10 +13:00
return false
}
2020-11-17 04:56:03 +13:00
2020-12-13 05:40:10 +13:00
if err != nil {
2021-09-02 09:10:18 +12:00
logger.Warn().Err(err).Msg("message handler has failed")
2020-12-13 05:40:10 +13:00
}
return true
}