From 647cf553890e90139bcaea6926a79fe82c430f44 Mon Sep 17 00:00:00 2001
From: ZGaetano <zgaetano@wilddragon.net>
Date: Sat, 16 May 2026 00:29:50 -0400
Subject: [PATCH] fix(infra+workers): S3 creds, ffprobe, BullMQ awaits,
 thumbnail seek, bin optional, docker-compose vars, jobs Redis, recorders stop
 codes: proxy.js

---
 services/worker/src/workers/proxy.js | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/services/worker/src/workers/proxy.js b/services/worker/src/workers/proxy.js
index 25fb144..9ca85d3 100644
--- a/services/worker/src/workers/proxy.js
+++ b/services/worker/src/workers/proxy.js
@@ -27,12 +27,12 @@ export const proxyWorker = async (job) => {
 
   try {
     // Download original from S3
-    job.updateProgress(10);
+    await job.updateProgress(10);
     console.log(`[proxy] Downloading ${inputKey} for asset ${assetId}`);
     await downloadFromS3(S3_BUCKET, inputKey, inputPath);
 
     // Transcode to H.264 proxy
-    job.updateProgress(30);
+    await job.updateProgress(30);
     console.log(`[proxy] Transcoding asset ${assetId}`);
     await transcodeVideo(inputPath, outputPath, {
       videoCodec:   'libx264',
@@ -43,12 +43,12 @@ export const proxyWorker = async (job) => {
     });
 
     // Upload proxy to S3
-    job.updateProgress(70);
+    await job.updateProgress(70);
     console.log(`[proxy] Uploading to ${outputKey}`);
     await uploadToS3(S3_BUCKET, outputKey, outputPath);
 
-    // Update asset record — proxy ready, status processing until thumbnail done
-    job.updateProgress(90);
+    // Update asset record — proxy ready, status stays processing until thumbnail done
+    await job.updateProgress(90);
     await query(
       `UPDATE assets SET proxy_s3_key = $1, updated_at = NOW() WHERE id = $2`,
       [outputKey, assetId]
@@ -63,7 +63,7 @@ export const proxyWorker = async (job) => {
     });
 
     console.log(`[proxy] Asset ${assetId} proxy complete, thumbnail job queued`);
-    job.updateProgress(100);
+    await job.updateProgress(100);
 
     return { assetId, outputKey };
   } catch (error) {