Function TestFlushOnSetLocalDescription

peerconnection_test.go:706–786

Assert that candidates are flushed by calling SetLocalDescription if ICECandidatePoolSize > 0.

(t *testing.T)

// Assert that candidates are flushed by calling SetLocalDescription if ICECandidatePoolSize > 0.
func TestFlushOnSetLocalDescription(t *testing.T) {
	if runtime.GOARCH == "wasm" {
		t.Skip("Skipping ICECandidatePool test on WASM")
	}

	lim := test.TimeOut(time.Second * 30)
	defer lim.Stop()

	report := test.CheckRoutines(t)
	defer report()

	pcOfferFlushStarted := make(chan SessionDescription)
	pcAnswerFlushStarted := make(chan SessionDescription)

	var offerOnce sync.Once
	var answerOnce sync.Once

	pcOffer, err := NewPeerConnection(Configuration{
		ICECandidatePoolSize: 1,
	})
	assert.NoError(t, err)

	// We need to create a data channel in order to set mid
	_, err = pcOffer.CreateDataChannel("initial_data_channel", nil)
	assert.NoError(t, err)

	pcOffer.OnICECandidate(func(i *ICECandidate) {
		offerOnce.Do(func() {
			close(pcOfferFlushStarted)
		})
	})

	// Assert that ICEGatheringState changes immediately
	assert.Eventually(t, func() bool {
		return pcOffer.ICEGatheringState() != ICEGatheringStateNew
	}, time.Second, 10*time.Millisecond, "ICEGatheringState should switch to Gathering or Complete immediately")

	// Assert that no events are fired before SetLocalDescription
	select {
	case <-pcOfferFlushStarted:
		assert.Fail(t, "Flush started before SetLocalDescription")
	case <-time.After(time.Second):
	}

	// Verify that candidates are flushed immediately after SetLocalDescription
	offer, err := pcOffer.CreateOffer(nil)
	assert.NoError(t, err)
	assert.NoError(t, pcOffer.SetLocalDescription(offer))
	<-pcOfferFlushStarted

	// Create Answer PeerConnection
	pcAnswer, err := NewPeerConnection(Configuration{
		ICECandidatePoolSize: 1,
	})
	assert.NoError(t, err)

	pcAnswer.OnICECandidate(func(i *ICECandidate) {
		answerOnce.Do(func() {