webrtc: fix 'duplicate payload type' error in read page (#3543)

bluenviron · Aug 22, 2024 · 8b8edf0 · 8b8edf0
1 parent 7da91a7
commit 8b8edf0
Showing 1 changed file with 67 additions and 44 deletions.
diff --git a/internal/servers/webrtc/read_index.html b/internal/servers/webrtc/read_index.html
@@ -108,70 +108,93 @@
 	return ret;
 };
 
+const findFreePayloadType = (firstLine) => {
+	const payloadTypes = firstLine.split(' ').slice(3);
+
+	for (let i = 96; i <= 127; i++) {
+		if (!payloadTypes.includes(i.toString())) {
+			return i.toString();
+		}
+	}
+
+	return 96;
+};
+
 const enableStereoPcmau = (section) => {
 	let lines = section.split('\r\n');
 
-	lines[0] += ' 118';
-	lines.splice(lines.length - 1, 0, 'a=rtpmap:118 PCMU/8000/2');
-	lines.splice(lines.length - 1, 0, 'a=rtcp-fb:118 transport-cc');
+	let payloadType = findFreePayloadType(lines[0]);
+	lines[0] += ` ${payloadType}`;
+	lines.splice(lines.length - 1, 0, `a=rtpmap:${payloadType} PCMU/8000/2`);
+	lines.splice(lines.length - 1, 0, `a=rtcp-fb:${payloadType} transport-cc`);
 
-	lines[0] += ' 119';
-	lines.splice(lines.length - 1, 0, 'a=rtpmap:119 PCMA/8000/2');
-	lines.splice(lines.length - 1, 0, 'a=rtcp-fb:119 transport-cc');
+	payloadType = findFreePayloadType(lines[0]);
+	lines[0] += ` ${payloadType}`;
+	lines.splice(lines.length - 1, 0, `a=rtpmap:${payloadType} PCMA/8000/2`);
+	lines.splice(lines.length - 1, 0, `a=rtcp-fb:${payloadType} transport-cc`);
 
 	return lines.join('\r\n');
 };
 
 const enableMultichannelOpus = (section) => {
 	let lines = section.split('\r\n');
 
-	lines[0] += " 112";
-	lines.splice(lines.length - 1, 0, "a=rtpmap:112 multiopus/48000/3");
-	lines.splice(lines.length - 1, 0, "a=fmtp:112 channel_mapping=0,2,1;num_streams=2;coupled_streams=1");
-	lines.splice(lines.length - 1, 0, "a=rtcp-fb:112 transport-cc");
-
-	lines[0] += " 113";
-	lines.splice(lines.length - 1, 0, "a=rtpmap:113 multiopus/48000/4");
-	lines.splice(lines.length - 1, 0, "a=fmtp:113 channel_mapping=0,1,2,3;num_streams=2;coupled_streams=2");
-	lines.splice(lines.length - 1, 0, "a=rtcp-fb:113 transport-cc");
-
-	lines[0] += " 114";
-	lines.splice(lines.length - 1, 0, "a=rtpmap:114 multiopus/48000/5");
-	lines.splice(lines.length - 1, 0, "a=fmtp:114 channel_mapping=0,4,1,2,3;num_streams=3;coupled_streams=2");
-	lines.splice(lines.length - 1, 0, "a=rtcp-fb:114 transport-cc");
-
-	lines[0] += " 115";
-	lines.splice(lines.length - 1, 0, "a=rtpmap:115 multiopus/48000/6");
-	lines.splice(lines.length - 1, 0, "a=fmtp:115 channel_mapping=0,4,1,2,3,5;num_streams=4;coupled_streams=2");
-	lines.splice(lines.length - 1, 0, "a=rtcp-fb:115 transport-cc");
-
-	lines[0] += " 116";
-	lines.splice(lines.length - 1, 0, "a=rtpmap:116 multiopus/48000/7");
-	lines.splice(lines.length - 1, 0, "a=fmtp:116 channel_mapping=0,4,1,2,3,5,6;num_streams=4;coupled_streams=4");
-	lines.splice(lines.length - 1, 0, "a=rtcp-fb:116 transport-cc");
-
-	lines[0] += " 117";
-	lines.splice(lines.length - 1, 0, "a=rtpmap:117 multiopus/48000/8");
-	lines.splice(lines.length - 1, 0, "a=fmtp:117 channel_mapping=0,6,1,4,5,2,3,7;num_streams=5;coupled_streams=4");
-	lines.splice(lines.length - 1, 0, "a=rtcp-fb:117 transport-cc");
+	let payloadType = findFreePayloadType(lines[0]);
+	lines[0] += ` ${payloadType}`;
+	lines.splice(lines.length - 1, 0, `a=rtpmap:${payloadType} multiopus/48000/3`);
+	lines.splice(lines.length - 1, 0, `a=fmtp:${payloadType} channel_mapping=0,2,1;num_streams=2;coupled_streams=1`);
+	lines.splice(lines.length - 1, 0, `a=rtcp-fb:${payloadType} transport-cc`);
+
+	payloadType = findFreePayloadType(lines[0]);
+	lines[0] += ` ${payloadType}`;
+	lines.splice(lines.length - 1, 0, `a=rtpmap:${payloadType} multiopus/48000/4`);
+	lines.splice(lines.length - 1, 0, `a=fmtp:${payloadType} channel_mapping=0,1,2,3;num_streams=2;coupled_streams=2`);
+	lines.splice(lines.length - 1, 0, `a=rtcp-fb:${payloadType} transport-cc`);
+
+	payloadType = findFreePayloadType(lines[0]);
+	lines[0] += ` ${payloadType}`;
+	lines.splice(lines.length - 1, 0, `a=rtpmap:${payloadType} multiopus/48000/5`);
+	lines.splice(lines.length - 1, 0, `a=fmtp:${payloadType} channel_mapping=0,4,1,2,3;num_streams=3;coupled_streams=2`);
+	lines.splice(lines.length - 1, 0, `a=rtcp-fb:${payloadType} transport-cc`);
+
+	payloadType = findFreePayloadType(lines[0]);
+	lines[0] += ` ${payloadType}`;
+	lines.splice(lines.length - 1, 0, `a=rtpmap:${payloadType} multiopus/48000/6`);
+	lines.splice(lines.length - 1, 0, `a=fmtp:${payloadType} channel_mapping=0,4,1,2,3,5;num_streams=4;coupled_streams=2`);
+	lines.splice(lines.length - 1, 0, `a=rtcp-fb:${payloadType} transport-cc`);
+
+	payloadType = findFreePayloadType(lines[0]);
+	lines[0] += ` ${payloadType}`;
+	lines.splice(lines.length - 1, 0, `a=rtpmap:${payloadType} multiopus/48000/7`);
+	lines.splice(lines.length - 1, 0, `a=fmtp:${payloadType} channel_mapping=0,4,1,2,3,5,6;num_streams=4;coupled_streams=4`);
+	lines.splice(lines.length - 1, 0, `a=rtcp-fb:${payloadType} transport-cc`);
+
+	payloadType = findFreePayloadType(lines[0]);
+	lines[0] += ` ${payloadType}`;
+	lines.splice(lines.length - 1, 0, `a=rtpmap:${payloadType} multiopus/48000/8`);
+	lines.splice(lines.length - 1, 0, `a=fmtp:${payloadType} channel_mapping=0,6,1,4,5,2,3,7;num_streams=5;coupled_streams=4`);
+	lines.splice(lines.length - 1, 0, `a=rtcp-fb:${payloadType} transport-cc`);
 
 	return lines.join('\r\n');
 };
 
 const enableL16 = (section) => {
 	let lines = section.split('\r\n');
 
-	lines[0] += " 120";
-	lines.splice(lines.length - 1, 0, "a=rtpmap:120 L16/8000/2");
-	lines.splice(lines.length - 1, 0, "a=rtcp-fb:120 transport-cc");
+	let payloadType = findFreePayloadType(lines[0]);
+	lines[0] += ` ${payloadType}`;
+	lines.splice(lines.length - 1, 0, `a=rtpmap:${payloadType} L16/8000/2`);
+	lines.splice(lines.length - 1, 0, `a=rtcp-fb:${payloadType} transport-cc`);
 
-	lines[0] += " 121";
-	lines.splice(lines.length - 1, 0, "a=rtpmap:121 L16/16000/2");
-	lines.splice(lines.length - 1, 0, "a=rtcp-fb:121 transport-cc");
+	payloadType = findFreePayloadType(lines[0]);
+	lines[0] += ` ${payloadType}`;
+	lines.splice(lines.length - 1, 0, `a=rtpmap:${payloadType} L16/16000/2`);
+	lines.splice(lines.length - 1, 0, `a=rtcp-fb:${payloadType} transport-cc`);
 
-	lines[0] += " 122";
-	lines.splice(lines.length - 1, 0, "a=rtpmap:122 L16/48000/2");
-	lines.splice(lines.length - 1, 0, "a=rtcp-fb:122 transport-cc");
+	payloadType = findFreePayloadType(lines[0]);
+	lines[0] += ` ${payloadType}`;
+	lines.splice(lines.length - 1, 0, `a=rtpmap:${payloadType} L16/48000/2`);
+	lines.splice(lines.length - 1, 0, `a=rtcp-fb:${payloadType} transport-cc`);
 
 	return lines.join('\r\n');
 };