From 70177202bf80c7716114b1f510fae269fb45f862 Mon Sep 17 00:00:00 2001 From: Alix von Schirp Date: Fri, 27 Feb 2026 02:02:56 +0100 Subject: [PATCH] fix?: possible fix to #1 Signed-off-by: Alix von Schirp --- build.sh | 3 --- package.json | 5 +++-- src/worker-node.mts | 25 ++++++++++++++----------- 3 files changed, 17 insertions(+), 16 deletions(-) diff --git a/build.sh b/build.sh index 8240ce5..bc18d8d 100755 --- a/build.sh +++ b/build.sh @@ -17,8 +17,5 @@ cp src/*.d.* dist # Build browser/node workers npm run build -# Remove unnecessary files -rm dist/browser-vite.* dist/worker-browser.* - # Copy files for npm publish cp package.json LICENSE README.md dist diff --git a/package.json b/package.json index 037d172..5b7e802 100644 --- a/package.json +++ b/package.json @@ -1,10 +1,10 @@ { "name": "@cis-oss/avprobe-wasm", - "version": "0.3.2", + "version": "0.3.3-rc1", "description": "ffprobe-like for browser and node, powered by WebAssembly", "repository": { "type": "git", - "url": "https://git.cislabs.de/cis-oss/ffprobe-wasm-npm" + "url": "https://git.cislabs.de/cis-oss/avprobe-wasm" }, "keywords": [ "ffprobe", @@ -17,6 +17,7 @@ "url": "https://b00tload.space", "email": "hi@b00tload.space" }, + "type": "module", "license": "MIT", "exports": { "node": "./node.mjs", diff --git a/src/worker-node.mts b/src/worker-node.mts index 6957cf7..587398f 100644 --- a/src/worker-node.mts +++ b/src/worker-node.mts @@ -1,19 +1,22 @@ -import { createRequire } from "module"; import { parentPort } from "worker_threads"; -import type { FFprobe } from "./ffprobe-wasm.js"; import { createListener } from "./worker.mjs"; if (!parentPort) { - throw new Error("parentPort must be defined. Are you sure you are in a worker context?"); + throw new Error("parentPort must be defined."); } -const require = createRequire(import.meta.url); +const listenerPromise = (async () => { + const { default: initFFprobe } = await import("./ffprobe-wasm.mjs"); -const listener = createListener(new Promise((resolve) => { - const ffprobe: FFprobe = require('./ffprobe-wasm.js') - ffprobe.onRuntimeInitialized = () => { - resolve(ffprobe); - } -}), "NODEFS"); + return createListener(new Promise(async (resolve) => { + const ffprobe = await initFFprobe(); + ffprobe.onRuntimeInitialized = () => { + resolve(ffprobe); + }; + }), "NODEFS"); +})(); -parentPort.on("message", listener); +parentPort.on("message", async (data) => { + const listener = await listenerPromise; + await listener(data); +});