signaling.go

package main

import (
	"encoding/base64"
	"encoding/json"

	"fyne.io/fyne"
	"fyne.io/fyne/widget"
	inRtmp "github.com/pion/obs-wormhole/internal/rtmp"
	"github.com/pion/webrtc/v3"
	"github.com/yutopp/go-rtmp"
)

const (
	StatusNew          = "Status: New"
	StatusConnecting   = "Status: Connecting"
	StatusConnected    = "Status: Connected"
	StatusDisconnected = "Status: Disconnected"
)

type SignalingPageContext struct {
	IsOffer bool
}

type SignalingPage struct {
	fyne.Widget
	rtmpServer     *rtmp.Server
	peerConnection *webrtc.PeerConnection
}

func NewSignalingPage(navigator Navigator, ctx SignalingPageContext) (Page, error) {
	remoteSDPInput := widget.NewMultiLineEntry()
	remoteSDPInput.Wrapping = fyne.TextWrapBreak

	localSDPInput := widget.NewMultiLineEntry()
	localSDPInput.Wrapping = fyne.TextWrapBreak
	localSDPInput.Disable()

	form := widget.NewAccordionContainer(
		widget.NewAccordionItem("Local SDP", localSDPInput),
		widget.NewAccordionItem("Remote SDP", remoteSDPInput),
	)

	errLabel := widget.NewLabel("")

	peerConnection, videoTrack, audioTrack := createPeerConnection()
	rtmpServer := inRtmp.StartServer(peerConnection, videoTrack, audioTrack)

	statusLabel := widget.NewLabelWithStyle(StatusNew, fyne.TextAlignCenter, fyne.TextStyle{Bold: true})
	peerConnection.OnICEConnectionStateChange(func(status webrtc.ICEConnectionState) {
		switch status {
		case webrtc.ICEConnectionStateChecking:
			statusLabel.SetText(StatusConnecting)
		case webrtc.ICEConnectionStateConnected:
			statusLabel.SetText(StatusConnected)
		case webrtc.ICEConnectionStateClosed:
			fallthrough
		case webrtc.ICEConnectionStateDisconnected:
			fallthrough
		case webrtc.ICEConnectionStateFailed:
			statusLabel.SetText(StatusDisconnected)
		}
	})

	submitButton := widget.NewButton("Submit", func() {
		sdp := remoteSDPInput.Text
		if sdp == "" {
			errLabel.SetText("SDP can't be empty")
			return
		}

		decoded, err := base64.StdEncoding.DecodeString(sdp)
		panicIfErr(err)

		remoteDescription := &webrtc.SessionDescription{}
		panicIfErr(json.Unmarshal(decoded, remoteDescription))

		panicIfErr(peerConnection.SetRemoteDescription(*remoteDescription))

		if !ctx.IsOffer {
			answer, err := peerConnection.CreateAnswer(nil)
			panicIfErr(err)

			peerConnection.SetLocalDescription(answer)
			raw, err := json.Marshal(peerConnection.LocalDescription())
			panicIfErr(err)
			localSDPInput.SetText(base64.StdEncoding.EncodeToString(raw))
			form.Open(0)
		}
		form.Close(1)
	})

	disconnectButton := widget.NewButton("Disconnect", func() {
		navigator.Reset()
	})

	if ctx.IsOffer {
		offer, err := peerConnection.CreateOffer(nil)
		panicIfErr(err)

		gatherPromise := webrtc.GatheringCompletePromise(peerConnection)
		panicIfErr(peerConnection.SetLocalDescription(offer))
		<-gatherPromise

		raw, err := json.Marshal(peerConnection.LocalDescription())
		panicIfErr(err)
		localSDPInput.SetText(base64.StdEncoding.EncodeToString(raw))
		form.Open(0)
	} else {
		form.Open(1)
	}

	content := widget.NewScrollContainer(widget.NewVBox(
		form,
		submitButton,
		disconnectButton,
		statusLabel,
		errLabel,
	))
	return &SignalingPage{
		Widget:         content,
		peerConnection: peerConnection,
		rtmpServer:     rtmpServer,
	}, nil
}

func (page *SignalingPage) BeforeDestroy() {
	page.rtmpServer.Close()
	page.peerConnection.Close()
}

func createPeerConnection() (*webrtc.PeerConnection, *webrtc.TrackLocalStaticSample, *webrtc.TrackLocalStaticSample) {
	// Only support PCMA + H264
	m := webrtc.MediaEngine{}
	err := m.RegisterCodec(webrtc.RTPCodecParameters{
		RTPCodecCapability: webrtc.RTPCodecCapability{MimeType: webrtc.MimeTypeH264, ClockRate: 90000, Channels: 0, SDPFmtpLine: "", RTCPFeedback: nil},
		PayloadType:        102,
	}, webrtc.RTPCodecTypeVideo)
	panicIfErr(err)
	err = m.RegisterCodec(webrtc.RTPCodecParameters{
		RTPCodecCapability: webrtc.RTPCodecCapability{MimeType: webrtc.MimeTypePCMA, ClockRate: 8000, Channels: 0, SDPFmtpLine: "", RTCPFeedback: nil},
		PayloadType:        8,
	}, webrtc.RTPCodecTypeAudio)

	panicIfErr(err)

	// Create a PeerConnection
	peerConnection, err := webrtc.NewAPI(webrtc.WithMediaEngine(&m)).NewPeerConnection(webrtc.Configuration{
		ICEServers: []webrtc.ICEServer{
			{
				URLs: []string{"stun:stun.l.google.com:19302"},
			},
		},
	})
	panicIfErr(err)

	videoTrack, err := webrtc.NewTrackLocalStaticSample(webrtc.RTPCodecCapability{MimeType: webrtc.MimeTypeH264}, "video", "pion")
	panicIfErr(err)

	_, err = peerConnection.AddTrack(videoTrack)
	panicIfErr(err)

	audioTrack, err := webrtc.NewTrackLocalStaticSample(webrtc.RTPCodecCapability{MimeType: webrtc.MimeTypePCMA}, "audio", "pion")
	panicIfErr(err)

	_, err = peerConnection.AddTrack(audioTrack)
	panicIfErr(err)

	return peerConnection, videoTrack, audioTrack
}