neko/internal/websocket/handler/signal.go

package handler

import (
	"demodesk/neko/internal/types"
	"demodesk/neko/internal/types/event"
	"demodesk/neko/internal/types/message"
)

func (h *MessageHandlerCtx) signalRequest(session types.Session) error {
	if !session.CanWatch() {
		return nil
	}

	sdp, lite, ice, err := h.webrtc.CreatePeer(session)
	if err != nil {
		return err
	}

	return session.Send(
		message.SignalProvide{
			Event: event.SIGNAL_PROVIDE,
			SDP:   sdp,
			Lite:  lite,
			ICE:   ice,
		})
}

func (h *MessageHandlerCtx) signalAnswer(session types.Session, payload *message.SignalAnswer) error {
	return session.SignalAnswer(payload.SDP)
}