mirror of
https://github.com/xtr-dev/rondevu-client.git
synced 2025-12-16 22:03:24 +00:00
Compare commits
1 Commits
claude/fix
...
v0.18.2
| Author | SHA1 | Date | |
|---|---|---|---|
| 0f469e234d |
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.1",
|
"version": "0.18.2",
|
||||||
"lockfileVersion": 3,
|
"lockfileVersion": 3,
|
||||||
"requires": true,
|
"requires": true,
|
||||||
"packages": {
|
"packages": {
|
||||||
"": {
|
"": {
|
||||||
"name": "@xtr-dev/rondevu-client",
|
"name": "@xtr-dev/rondevu-client",
|
||||||
"version": "0.18.1",
|
"version": "0.18.2",
|
||||||
"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.1",
|
"version": "0.18.2",
|
||||||
"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",
|
||||||
|
|||||||
@@ -259,7 +259,6 @@ export class Rondevu extends EventEmitter {
|
|||||||
private filling = false
|
private filling = false
|
||||||
private pollingInterval: ReturnType<typeof setInterval> | null = null
|
private pollingInterval: ReturnType<typeof setInterval> | null = null
|
||||||
private lastPollTimestamp = 0
|
private lastPollTimestamp = 0
|
||||||
private isPolling = false // Guard against concurrent poll execution
|
|
||||||
|
|
||||||
private constructor(
|
private constructor(
|
||||||
apiUrl: string,
|
apiUrl: string,
|
||||||
@@ -635,13 +634,6 @@ export class Rondevu extends EventEmitter {
|
|||||||
private async pollInternal(): Promise<void> {
|
private async pollInternal(): Promise<void> {
|
||||||
if (!this.filling) return
|
if (!this.filling) return
|
||||||
|
|
||||||
// Prevent concurrent poll execution to avoid duplicate answer processing
|
|
||||||
if (this.isPolling) {
|
|
||||||
this.debug('Poll already in progress, skipping')
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
this.isPolling = true
|
|
||||||
try {
|
try {
|
||||||
const result = await this.api.poll(this.lastPollTimestamp)
|
const result = await this.api.poll(this.lastPollTimestamp)
|
||||||
|
|
||||||
@@ -682,8 +674,6 @@ export class Rondevu extends EventEmitter {
|
|||||||
}
|
}
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
console.error('[Rondevu] Polling error:', err)
|
console.error('[Rondevu] Polling error:', err)
|
||||||
} finally {
|
|
||||||
this.isPolling = false
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -720,7 +710,6 @@ export class Rondevu extends EventEmitter {
|
|||||||
stopFilling(): void {
|
stopFilling(): void {
|
||||||
this.debug('Stopping offer filling and polling')
|
this.debug('Stopping offer filling and polling')
|
||||||
this.filling = false
|
this.filling = false
|
||||||
this.isPolling = false // Reset polling guard
|
|
||||||
|
|
||||||
// Stop polling
|
// Stop polling
|
||||||
if (this.pollingInterval) {
|
if (this.pollingInterval) {
|
||||||
|
|||||||
Reference in New Issue
Block a user