Fix FlexFEC negotiation with libwebrtc publishers

pkg/rtc/mediaengine.go

@@ -26,8 +26,9 @@ import (
 )
 
 // flexFECRepairWindow is the flexfec-03 "repair-window" fmtp value in
-// microseconds (2 s).
-const flexFECRepairWindow = 2_000_000
+// microseconds (10 s), matching libwebrtc and pion's fixed advertised value.
+// A different value prevents those publishers from negotiating FlexFEC.
+const flexFECRepairWindow = 10_000_000
 
 // flexFECCodecParameters returns the flexfec-03 codec registered/offered when
 // FlexFEC is enabled for a direction. Mirrors pion's ConfigureFlexFEC03 codec

pkg/rtc/transport_fec_test.go

@@ -40,7 +40,7 @@ a=rtpmap:96 VP8/90000
 a=rtpmap:97 rtx/90000
 a=fmtp:97 apt=96
 a=rtpmap:115 flexfec-03/90000
-a=fmtp:115 repair-window=2000000
+a=fmtp:115 repair-window=10000000
 a=ssrc-group:FID 1111 2222
 a=ssrc-group:FEC-FR 1111 3333
 a=ssrc:1111 cname:test
@@ -156,7 +156,7 @@ func TestMediaEngineRegistersFlexFEC(t *testing.T) {
 			require.NoError(t, err)
 
 			flexFECParams := flexFECCodecParameters(115)
-			assert.Equal(t, "repair-window=2000000", flexFECParams.SDPFmtpLine)
+			assert.Equal(t, "repair-window=10000000", flexFECParams.SDPFmtpLine)
 			filtered := filterCodecs(
 				[]webrtc.RTPCodecParameters{flexFECParams},
 				enabledCodecs,
@@ -168,7 +168,7 @@ func TestMediaEngineRegistersFlexFEC(t *testing.T) {
 				require.Len(t, filtered, 1)
 				assert.Equal(t, webrtc.MimeTypeFlexFEC03, filtered[0].MimeType)
 				assert.Contains(t, offer.SDP, "a=rtpmap:115 flexfec-03/90000")
-				assert.Contains(t, offer.SDP, "a=fmtp:115 repair-window=2000000")
+				assert.Contains(t, offer.SDP, "a=fmtp:115 repair-window=10000000")
 			} else {
 				assert.Empty(t, filtered)
 				assert.NotContains(t, offer.SDP, "flexfec-03")

pkg/sfu/buffer/buffer_fec_test.go

@@ -42,7 +42,7 @@ var flexFECCodec = webrtc.RTPCodecParameters{
 	RTPCodecCapability: webrtc.RTPCodecCapability{
 		MimeType:    webrtc.MimeTypeFlexFEC03,
 		ClockRate:   90000,
-		SDPFmtpLine: "repair-window=2000000",
+		SDPFmtpLine: "repair-window=10000000",
 	},
 	PayloadType: webrtc.PayloadType(fecTestFECPT),
 }

test/flexfec_upstream_test.go

@@ -78,7 +78,7 @@ func TestFlexFECUpstreamNegotiation(t *testing.T) {
 		if !strings.Contains(sd.SDP, "flexfec-03") {
 			return "SFU answer does not contain flexfec-03"
 		}
-		if !strings.Contains(sd.SDP, "repair-window=2000000") {
+		if !strings.Contains(sd.SDP, "repair-window=10000000") {
 			return "SFU answer does not contain the configured FlexFEC repair window"
 		}
 		return ""