Method setupWebrtcConnection

overlay/send.go:313–368

()

}

func (s *Send) setupWebrtcConnection() {
	var err error
	s.RtcConn, err = webrtc.NewPeerConnection(getWebRTCConfig())
	if err != nil {
		panic("failed to create webrtc connection: " + err.Error())
	}

	s.RtcConn.OnICECandidate(func(i *webrtc.ICECandidate) {
		if i == nil {
			return
		}
		ic := i.ToJSON()

		<-s.waitIce
		s.out <- &overlayMessage{
			Typ:             messageTypeWebRTCCandidate,
			WebrtcCandidate: &ic,
		}
	})

	s.RtcDc, err = s.RtcConn.CreateDataChannel("fileTransfer", nil)
	if err != nil {
		fmt.Println("failed to create dc:", err)
	}

	// Add message handler to our created data channel
	s.RtcDc.OnMessage(func(msg webrtc.DataChannelMessage) {
		if msg.IsString {
			meta := RtcMetadata{}

			err := json.Unmarshal(msg.Data, &meta)
			if err != nil {
				fmt.Println("failed to unmarshal metadata:", err)
				return
			}

			if meta.Type == RtcMetadataTypeFileAck {
				close(s.WaitTransferDone)
				return
			}
			return
		}
	})

	answer, err := s.RtcConn.CreateOffer(nil)
	if err != nil {
		fmt.Println("failed to create answer:", err)
	}

	err = s.RtcConn.SetLocalDescription(answer)
	if err != nil {
		fmt.Println("failed to set local description:", err)
	}

	s.offer = answer
}