romtuck/openclaw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge c4ac0d2722 into 4583f88626

Browse Source
This commit is contained in:
Steve Rodriguez 2026-01-29 18:16:09 -08:00 committed by GitHub
commit 9e3d902336
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 25 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
extensions/voice-call/src/manager.ts
View File

@ -830,6 +830,10 @@ export class CallManager {
const logPath = path.join(this.storePath, "calls.jsonl"); const logPath = path.join(this.storePath, "calls.jsonl");
if (!fs.existsSync(logPath)) return; if (!fs.existsSync(logPath)) return;
// Calls older than maxDurationSeconds are definitely stale
const maxAgeMs = this.config.maxDurationSeconds * 1000;
const now = Date.now();
// Read file synchronously and parse lines // Read file synchronously and parse lines
const content = fs.readFileSync(logPath, "utf-8"); const content = fs.readFileSync(logPath, "utf-8");
const lines = content.split("\n"); const lines = content.split("\n");
@ -847,18 +851,28 @@ export class CallManager {
} }
} }
// Only keep non-terminal calls // Only keep non-terminal calls that aren't stale
for (const [callId, call] of callMap) { for (const [callId, call] of callMap) {
if (!TerminalStates.has(call.state)) { // Skip terminal states
this.activeCalls.set(callId, call); if (TerminalStates.has(call.state)) continue;
// Populate providerCallId mapping for lookups
if (call.providerCallId) { // Skip stale calls (older than max duration)
this.providerCallIdMap.set(call.providerCallId, callId); const callAge = now - call.startedAt;
} if (callAge > maxAgeMs) {
// Populate processed event IDs console.log(
for (const eventId of call.processedEventIds) { `[voice-call] Skipping stale call ${callId} (age: ${Math.round(callAge / 1000)}s, max: ${this.config.maxDurationSeconds}s)`,
this.processedEventIds.add(eventId); );
} continue;
}
this.activeCalls.set(callId, call);
// Populate providerCallId mapping for lookups
if (call.providerCallId) {
this.providerCallIdMap.set(call.providerCallId, callId);
}
// Populate processed event IDs
for (const eventId of call.processedEventIds) {
this.processedEventIds.add(eventId);
} }
} }
} }