From db651d4193c3426f6d847459c689f8bc80047502 Mon Sep 17 00:00:00 2001
From: Bas van den Aakster <bvdaakster@gmail.com>
Date: Wed, 10 Dec 2025 19:51:54 +0100
Subject: [PATCH] Filter ICE candidates by role in offerer polling

- 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
---
 src/App.jsx | 27 ++++++++++++++++-----------
 1 file changed, 16 insertions(+), 11 deletions(-)

diff --git a/src/App.jsx b/src/App.jsx
index 510ae9a..35156b4 100644
--- a/src/App.jsx
+++ b/src/App.jsx
@@ -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);