···

       
205
       
 
       


     

       
206
       
 
       
		eventSource.onmessage = (event) => {

     

       
207
       
 
       
			const update = JSON.parse(event.data);

     

       
208
       
-
       
			console.log(`[Client received] Job ${jobId}:`, update);

     

       
209
       
 
       


     

       
210
       
 
       
			// Update the job in our list efficiently (mutate in place for Lit)

     

       
211
       
 
       
			const job = this.jobs.find((j) => j.id === jobId);

     

···

       
205
       
 
       


     

       
206
       
 
       
		eventSource.onmessage = (event) => {

     

       
207
       
 
       
			const update = JSON.parse(event.data);

     

       
0
       
 
       

     

       
208
       
 
       


     

       
209
       
 
       
			// Update the job in our list efficiently (mutate in place for Lit)

     

       
210
       
 
       
			const job = this.jobs.find((j) => j.id === jobId);

     

···

       
429
       
 
       
						}

     

       
430
       
 
       
						// Subscribe to EventEmitter for live updates

     

       
431
       
 
       
						const updateHandler = (data: TranscriptionUpdate) => {

     

       
432
       
-
       
							console.log(`[SSE to client] Job ${transcriptionId}:`, data);

     

       
433
       
 
       
							// Only send changed fields to save bandwidth

     

       
434
       
 
       
							const payload: Partial<TranscriptionUpdate> = {

     

       
435
       
 
       
								status: data.status,

     

···

       
429
       
 
       
						}

     

       
430
       
 
       
						// Subscribe to EventEmitter for live updates

     

       
431
       
 
       
						const updateHandler = (data: TranscriptionUpdate) => {

     

       
0
       
 
       

     

       
432
       
 
       
							// Only send changed fields to save bandwidth

     

       
433
       
 
       
							const payload: Partial<TranscriptionUpdate> = {

     

       
434
       
 
       
								status: data.status,

     

···

       
141
       
 
       
			}

     

       
142
       
 
       


     

       
143
       
 
       
			const { job_id } = await response.json();

     

       
144
       
-
       
			console.log(

     

       
145
       
-
       
				`[Transcription] Created Whisper job ${job_id} for ${transcriptionId}`,

     

       
146
       
-
       
			);

     

       
147
       
 
       


     

       
148
       
 
       
			// Connect to SSE stream from Whisper

     

       
149
       
 
       
			this.streamWhisperJob(transcriptionId, job_id, filePath);

     
···

       
180
       
 
       
	) {

     

       
181
       
 
       
		// Prevent duplicate streams using locks

     

       
182
       
 
       
		if (this.streamLocks.has(transcriptionId)) {

     

       
183
       
-
       
			console.log(`[Stream] Already streaming ${transcriptionId}, skipping`);

     

       
184
       
 
       
			return;

     

       
185
       
 
       
		}

     

       
186
       
 
       


     
···

       
499
       
 
       
				const filePath = `./uploads/${filename}`;

     

       
500
       
 
       
				await Bun.write(filePath, "").catch(() => {});

     

       
501
       
 
       
			}

     

       
502
       
-
       


     

       
503
       
-
       
			console.log(

     

       
504
       
-
       
				`[Cleanup] Removed ${staleTranscriptions.length} stale files`,

     

       
505
       
-
       
			);

     

       
506
       
 
       
		} catch (error) {

     

       
507
       
 
       
			console.error("[Cleanup] Failed:", error);

     

       
508
       
 
       
		}

     

···

       
141
       
 
       
			}

     

       
142
       
 
       


     

       
143
       
 
       
			const { job_id } = await response.json();

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
144
       
 
       


     

       
145
       
 
       
			// Connect to SSE stream from Whisper

     

       
146
       
 
       
			this.streamWhisperJob(transcriptionId, job_id, filePath);

     
···

       
177
       
 
       
	) {

     

       
178
       
 
       
		// Prevent duplicate streams using locks

     

       
179
       
 
       
		if (this.streamLocks.has(transcriptionId)) {

     

       
0
       
 
       

     

       
180
       
 
       
			return;

     

       
181
       
 
       
		}

     

       
182
       
 
       


     
···

       
495
       
 
       
				const filePath = `./uploads/${filename}`;

     

       
496
       
 
       
				await Bun.write(filePath, "").catch(() => {});

     

       
497
       
 
       
			}

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
498
       
 
       
		} catch (error) {

     

       
499
       
 
       
			console.error("[Cleanup] Failed:", error);

     

       
500
       
 
       
		}