mirror of
https://github.com/xtr-dev/rondevu-client.git
synced 2025-12-15 21:33:23 +00:00
Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| e48b3bb17a | |||
| 8f7e15e633 |
4
package-lock.json
generated
4
package-lock.json
generated
@@ -1,12 +1,12 @@
|
|||||||
{
|
{
|
||||||
"name": "@xtr-dev/rondevu-client",
|
"name": "@xtr-dev/rondevu-client",
|
||||||
"version": "0.18.4",
|
"version": "0.18.5",
|
||||||
"lockfileVersion": 3,
|
"lockfileVersion": 3,
|
||||||
"requires": true,
|
"requires": true,
|
||||||
"packages": {
|
"packages": {
|
||||||
"": {
|
"": {
|
||||||
"name": "@xtr-dev/rondevu-client",
|
"name": "@xtr-dev/rondevu-client",
|
||||||
"version": "0.18.4",
|
"version": "0.18.5",
|
||||||
"license": "MIT",
|
"license": "MIT",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@noble/ed25519": "^3.0.0",
|
"@noble/ed25519": "^3.0.0",
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@xtr-dev/rondevu-client",
|
"name": "@xtr-dev/rondevu-client",
|
||||||
"version": "0.18.4",
|
"version": "0.18.5",
|
||||||
"description": "TypeScript client for Rondevu with durable WebRTC connections, automatic reconnection, and message queuing",
|
"description": "TypeScript client for Rondevu with durable WebRTC connections, automatic reconnection, and message queuing",
|
||||||
"type": "module",
|
"type": "module",
|
||||||
"main": "dist/index.js",
|
"main": "dist/index.js",
|
||||||
|
|||||||
@@ -651,17 +651,25 @@ export class Rondevu extends EventEmitter {
|
|||||||
if (activeOffer && !activeOffer.answered) {
|
if (activeOffer && !activeOffer.answered) {
|
||||||
this.debug(`Received answer for offer ${answer.offerId}`)
|
this.debug(`Received answer for offer ${answer.offerId}`)
|
||||||
|
|
||||||
await activeOffer.pc.setRemoteDescription({
|
// Mark as answered BEFORE setRemoteDescription to prevent race condition
|
||||||
type: 'answer',
|
|
||||||
sdp: answer.sdp
|
|
||||||
})
|
|
||||||
|
|
||||||
activeOffer.answered = true
|
activeOffer.answered = true
|
||||||
this.lastPollTimestamp = answer.answeredAt
|
|
||||||
this.emit('offer:answered', answer.offerId, answer.answererId)
|
|
||||||
|
|
||||||
// Create replacement offer
|
try {
|
||||||
this.fillOffers()
|
await activeOffer.pc.setRemoteDescription({
|
||||||
|
type: 'answer',
|
||||||
|
sdp: answer.sdp
|
||||||
|
})
|
||||||
|
|
||||||
|
this.lastPollTimestamp = answer.answeredAt
|
||||||
|
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
|
||||||
|
throw err
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user