Method setupWebrtcConnection

overlay/receive.go:454–574

(src key.NodePublic, res *overlayMessage, offer webrtc.SessionDescription)

}

func (r *Receive) setupWebrtcConnection(src key.NodePublic, res *overlayMessage, offer webrtc.SessionDescription) {
	// Configure larger buffer sizes
	settingEngine := webrtc.SettingEngine{}
	// Set maximum message size to 16MB
	settingEngine.SetSCTPMaxReceiveBufferSize(64 * 1024 * 1024)

	api := webrtc.NewAPI(webrtc.WithSettingEngine(settingEngine))

	// Use the custom API to create the peer connection
	peerConnection, err := api.NewPeerConnection(getWebRTCConfig())
	if err != nil {
		panic(err)
	}

	peerConnection.OnConnectionStateChange(func(s webrtc.PeerConnectionState) {
		switch s {
		case webrtc.PeerConnectionStateConnected:
		case webrtc.PeerConnectionStateDisconnected:
		case webrtc.PeerConnectionStateFailed:
		case webrtc.PeerConnectionStateClosed:
		}
	})

	peerConnection.OnDataChannel(func(d *webrtc.DataChannel) {
		// Increase buffer sizes
		d.SetBufferedAmountLowThreshold(65535)

		var (
			fi     *os.File
			bar    *progressbar.ProgressBar
			mw     io.Writer
			fiSize int
			read   int
		)

		d.OnMessage(func(msg webrtc.DataChannelMessage) {
			if msg.IsString {
				meta := RtcMetadata{}

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

				if meta.Type == RtcMetadataTypeFileMetadata {
					fiSize = meta.FileMetadata.FileSize
					fi, err = os.OpenFile(meta.FileMetadata.FileName, os.O_CREATE|os.O_RDWR|os.O_TRUNC, 0644)
					if err != nil {
						fmt.Println("failed to open file", err)
					}

					bar = progressbar.DefaultBytes(
						int64(fiSize),
						fmt.Sprintf("Downloading %q", meta.FileMetadata.FileName),
					)
					mw = io.MultiWriter(fi, bar)