mirror of
https://github.com/xtr-dev/rondevu-client.git
synced 2025-12-15 21:33:23 +00:00
Revert to v0.18.3 answer processing logic
Reverted pollInternal to exactly match v0.18.3 which was the last working version. The changes in v0.18.5 and v0.18.6 that moved the answered flag and timestamp updates were causing issues. v0.18.3 working logic restored: - Check !activeOffer.answered - Call setRemoteDescription (no try/catch) - Set answered = true AFTER - Update lastPollTimestamp AFTER - No pre-emptive timestamp updates The only difference from v0.18.3 is the eventemitter3 import which should not affect answer processing behavior. 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
This commit is contained in:
@@ -645,37 +645,23 @@ export class Rondevu extends EventEmitter {
|
|||||||
try {
|
try {
|
||||||
const result = await this.api.poll(this.lastPollTimestamp)
|
const result = await this.api.poll(this.lastPollTimestamp)
|
||||||
|
|
||||||
// Update timestamp FIRST to prevent re-fetching same answers if processing fails
|
|
||||||
if (result.answers.length > 0) {
|
|
||||||
const maxAnswerTimestamp = Math.max(...result.answers.map(a => a.answeredAt))
|
|
||||||
this.lastPollTimestamp = Math.max(this.lastPollTimestamp, maxAnswerTimestamp)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Process answers
|
// Process answers
|
||||||
for (const answer of result.answers) {
|
for (const answer of result.answers) {
|
||||||
const activeOffer = this.activeOffers.get(answer.offerId)
|
const activeOffer = this.activeOffers.get(answer.offerId)
|
||||||
if (activeOffer && !activeOffer.answered) {
|
if (activeOffer && !activeOffer.answered) {
|
||||||
this.debug(`Received answer for offer ${answer.offerId}`)
|
this.debug(`Received answer for offer ${answer.offerId}`)
|
||||||
|
|
||||||
// Mark as answered BEFORE setRemoteDescription to prevent race condition
|
await activeOffer.pc.setRemoteDescription({
|
||||||
|
type: 'answer',
|
||||||
|
sdp: answer.sdp
|
||||||
|
})
|
||||||
|
|
||||||
activeOffer.answered = true
|
activeOffer.answered = true
|
||||||
|
this.lastPollTimestamp = answer.answeredAt
|
||||||
|
this.emit('offer:answered', answer.offerId, answer.answererId)
|
||||||
|
|
||||||
try {
|
// Create replacement offer
|
||||||
await activeOffer.pc.setRemoteDescription({
|
this.fillOffers()
|
||||||
type: 'answer',
|
|
||||||
sdp: answer.sdp
|
|
||||||
})
|
|
||||||
|
|
||||||
this.emit('offer:answered', answer.offerId, answer.answererId)
|
|
||||||
|
|
||||||
// Create replacement offer
|
|
||||||
this.fillOffers()
|
|
||||||
} catch (err) {
|
|
||||||
// If setRemoteDescription fails, reset the answered flag
|
|
||||||
activeOffer.answered = false
|
|
||||||
this.debug(`Failed to set remote description for offer ${answer.offerId}:`, err)
|
|
||||||
// Don't throw - continue processing other answers
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user