xtr.dev/rondevu-demo
1
0
Fork 0
mirror of https://github.com/xtr-dev/rondevu-demo.git synced 2025-12-16 13:03:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add detailed logging for answerer ICE candidate exchange

Browse Source 
- Log when answerer starts polling for offerer ICE candidates
- Log count of candidates received from offerer
- Log each candidate being added with details
- Log success/failure of adding each candidate
- Log when answerer sends their own ICE candidates to server
- Helps debug ICE candidate exchange on answerer side
This commit is contained in:
Bas van den Aakster
2025-12-10 20:06:11 +01:00
parent db651d4193
commit 91b845aa1c
1 changed files with 16 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
src/App.jsx
View File

@@ -594,6 +594,8 @@ export default function App() {
// Poll for ICE candidates // Poll for ICE candidates
const lastIceTimestamp = { current: 0 }; const lastIceTimestamp = { current: 0 };
console.log(`[Answerer] Starting ICE candidate polling for offer ${serviceData.offerId}`);
const icePolling = setInterval(async () => { const icePolling = setInterval(async () => {
try { try {
const result = await rondevu.getOfferIceCandidates( const result = await rondevu.getOfferIceCandidates(
@@ -602,14 +604,20 @@ export default function App() {
lastIceTimestamp.current lastIceTimestamp.current
); );
if (result.candidates.length > 0) {
console.log(`[Answerer] Received ${result.candidates.length} ICE candidate(s) from offerer`);
}
for (const item of result.candidates) { for (const item of result.candidates) {
if (item.candidate && item.candidate.candidate) { if (item.candidate && item.candidate.candidate) {
try { try {
console.log(`[Answerer] Adding offerer ICE candidate:`, item.candidate);
const rtcCandidate = new RTCIceCandidate(item.candidate); const rtcCandidate = new RTCIceCandidate(item.candidate);
await pc.addIceCandidate(rtcCandidate); await pc.addIceCandidate(rtcCandidate);
lastIceTimestamp.current = item.createdAt; lastIceTimestamp.current = item.createdAt;
console.log(`✅ [Answerer] Successfully added offerer ICE candidate`);
} catch (err) { } catch (err) {
console.warn('Failed to process ICE candidate:', err); console.warn('[Answerer] Failed to process ICE candidate:', err);
lastIceTimestamp.current = item.createdAt; lastIceTimestamp.current = item.createdAt;
} }
} else { } else {
@@ -618,8 +626,10 @@ export default function App() {
} }
} catch (err) { } catch (err) {
if (err.message?.includes('404') || err.message?.includes('410')) { if (err.message?.includes('404') || err.message?.includes('410')) {
console.warn('Offer expired, stopping ICE polling'); console.warn('[Answerer] Offer expired, stopping ICE polling');
clearInterval(icePolling); clearInterval(icePolling);
} else {
console.error('[Answerer] Error polling ICE candidates:', err);
} }
} }
}, 1000); }, 1000);
@@ -627,11 +637,14 @@ export default function App() {
// Send local ICE candidates // Send local ICE candidates
pc.onicecandidate = (event) => { pc.onicecandidate = (event) => {
if (event.candidate) { if (event.candidate) {
console.log(`[Answerer] Sending ICE candidate to server:`, event.candidate);
rondevu.addOfferIceCandidates( rondevu.addOfferIceCandidates(
fqn, fqn,
serviceData.offerId, serviceData.offerId,
[event.candidate.toJSON()] [event.candidate.toJSON()]
).catch(err => console.error('Failed to send ICE candidate:', err)); ).then(() => {
console.log(`✅ [Answerer] Successfully sent ICE candidate to server`);
}).catch(err => console.error('[Answerer] Failed to send ICE candidate:', err));
} }
}; };