xtr.dev/rondevu-demo
1
0
Fork 0
mirror of https://github.com/xtr-dev/rondevu-demo.git synced 2025-12-15 20:43:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

Filter ICE candidates by role in offerer polling

Browse Source 
- Offerer now filters for answerer ICE candidates only
- Ignores own candidates returned from server
- Uses role field to distinguish between offerer and answerer candidates
- Improves logging to show answerer candidate count
This commit is contained in:
Bas van den Aakster
2025-12-10 19:51:54 +01:00
parent a6329c8708
commit db651d4193
1 changed files with 16 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
src/App.jsx
View File

@@ -253,17 +253,22 @@ export default function App() {
const pc = offerIdToPeerConnection[offerId];
if (pc && candidates.length > 0) {
console.log(`[Host Polling] Processing ${candidates.length} ICE candidate(s) for offer ${offerId}`);
// Filter for answerer candidates only (offerer doesn't need their own candidates back)
const answererCandidates = candidates.filter(item => item.role === 'answerer');
for (const item of candidates) {
if (item.candidate) {
try {
await pc.addIceCandidate(new RTCIceCandidate(item.candidate));
totalIceCandidates++;
// Update timestamp
setLastAnswerTimestamp(prev => Math.max(prev, item.createdAt));
} catch (err) {
console.warn(`[Host Polling] Failed to add ICE candidate for offer ${offerId}:`, err);
if (answererCandidates.length > 0) {
console.log(`[Host Polling] Processing ${answererCandidates.length} answerer ICE candidate(s) for offer ${offerId}`);
for (const item of answererCandidates) {
if (item.candidate) {
try {
await pc.addIceCandidate(new RTCIceCandidate(item.candidate));
totalIceCandidates++;
// Update timestamp
setLastAnswerTimestamp(prev => Math.max(prev, item.createdAt));
} catch (err) {
console.warn(`[Host Polling] Failed to add ICE candidate for offer ${offerId}:`, err);
}
}
}
}
@@ -271,7 +276,7 @@ export default function App() {
}
if (totalIceCandidates > 0) {
console.log(`✅ [Host Polling] Added ${totalIceCandidates} ICE candidate(s)`);
console.log(`✅ [Host Polling] Added ${totalIceCandidates} answerer ICE candidate(s)`);
}
} catch (err) {
console.error('[Host Polling] Error polling:', err);