Pion rtpdump to disk

main.go

	peerConnection, err := webrtc.NewPeerConnection(webrtc.Configuration{})
	if err != nil {
		panic(err)
	}

	// Allow us to receive 1 audio track, and 1 video track
	if _, err = peerConnection.AddTransceiverFromKind(webrtc.RTPCodecTypeAudio, webrtc.RTPTransceiverInit{Direction: webrtc.RTPTransceiverDirectionRecvonly}); err != nil {
		panic(err)
	} else if _, err = peerConnection.AddTransceiverFromKind(webrtc.RTPCodecTypeVideo, webrtc.RTPTransceiverInit{Direction: webrtc.RTPTransceiverDirectionRecvonly}); err != nil {
		panic(err)
	}

	f, err := os.OpenFile(rtpdumpFilename, os.O_WRONLY|os.O_CREATE|os.O_TRUNC, 0600)
	if err != nil {
		panic(err)
	}

	writer, err := rtpdump.NewWriter(f, rtpdump.Header{
		Start:  time.Unix(9, 0),
		Source: net.IPv4(2, 2, 2, 2),
		Port:   2222,
	})
	if err != nil {
		panic(err)
	}

	startTime := time.Now()
	peerConnection.OnTrack(func(track *webrtc.TrackRemote, receiver *webrtc.RTPReceiver) {

		for {
			rtpPacket, _, err := track.ReadRTP()
			if err != nil {
				panic(err)
			}

			rtpPacket.Header.PayloadType = 96
			rtpPacket.Header.SSRC = 96

			buff, err := rtpPacket.Marshal()
			if err != nil {
				panic(err)
			}

			if err := writer.WritePacket(rtpdump.Packet{
				Offset:  time.Since(startTime),
				IsRTCP:  false,
				Payload: buff,
			}); err != nil {
				panic(err)
			}
		}
	})