🪻 distributed transcription service
thistle.dunkirk.sh
feat: handle murmur going down
+12
-2
+10
-1
src/index.ts
+10
-1
src/index.ts
···
62
62
}
63
63
64
64
// Periodic sync every 5 minutes as backup (SSE handles real-time updates)
65
-
setInterval(() => whisperService.syncWithWhisper(), 5 * 60 * 1000);
65
+
setInterval(async () => {
66
+
try {
67
+
await whisperService.syncWithWhisper();
68
+
} catch (error) {
69
+
console.warn(
70
+
"[Sync] Failed to sync with Murmur:",
71
+
error instanceof Error ? error.message : "Unknown error",
72
+
);
73
+
}
74
+
}, 5 * 60 * 1000);
66
75
67
76
// Clean up stale files daily
68
77
setInterval(() => whisperService.cleanupStaleFiles(), 24 * 60 * 60 * 1000);
+2
-1
src/lib/transcription.ts
+2
-1
src/lib/transcription.ts
···
396
396
async syncWithWhisper(): Promise<void> {
397
397
const whisperJobs = await this.fetchWhisperJobs();
398
398
if (!whisperJobs) {
399
-
throw new Error("Murmur service unavailable");
399
+
console.warn("[Sync] Murmur service unavailable");
400
+
return;
400
401
}
401
402
402
403
const activeDbJobs = this.getActiveDbJobs();