From d15f1ec8f2631993506a5e6d4b4a73ebe0c09583 Mon Sep 17 00:00:00 2001 From: wukko Date: Thu, 30 Jan 2025 18:58:02 +0600 Subject: [PATCH] web/workers/remux: differentiate remux worker file event --- web/src/lib/queen-bee/run-worker.ts | 6 +++++- web/src/lib/workers/remux.ts | 4 ++-- 2 files changed, 7 insertions(+), 3 deletions(-) diff --git a/web/src/lib/queen-bee/run-worker.ts b/web/src/lib/queen-bee/run-worker.ts index f6fc276b..7605d7ae 100644 --- a/web/src/lib/queen-bee/run-worker.ts +++ b/web/src/lib/queen-bee/run-worker.ts @@ -40,7 +40,11 @@ export const runRemuxWorker = async (workerId: string, parentId: string, file: F } }); - worker.postMessage({ file }); + worker.postMessage({ + cobaltRemuxWorker: { + file + } + }); worker.onerror = (e) => { console.error("remux worker exploded:", e); diff --git a/web/src/lib/workers/remux.ts b/web/src/lib/workers/remux.ts index a718c778..81a6dab8 100644 --- a/web/src/lib/workers/remux.ts +++ b/web/src/lib/workers/remux.ts @@ -97,7 +97,7 @@ const remux = async (file: File) => { self.onmessage = async (event: MessageEvent) => { console.log(event.data); - if (event.data.file) { - await remux(event.data.file); + if (event.data.cobaltRemuxWorker.file) { + await remux(event.data.cobaltRemuxWorker.file); } }