v0.0.8

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@flemist/ffmpeg-encode-decode",
-  "version": "0.0.7",
+  "version": "0.0.8",
   "description": "WASM (WebAssembly) encode/decode mp3/ogg/opus/vorbis from/to Float32Array. Well tested @ffmpeg/ffmpeg wrapper.",
   "main": "dist/index.cjs",
   "module": "dist/index.mjs",

src/ffmpeg/FFmpegTransformClient.ts

@@ -1,8 +1,8 @@
 import {Worker} from 'worker_threads'
 import {
+  FFmpegClientOptions,
   FFmpegInitEvent,
   FFmpegInitOptions,
-  FFmpegOptions,
   FFmpegTransformArgs,
   IFFmpegTransformClient,
 } from './contracts'
@@ -16,6 +16,7 @@ import {
 } from '@flemist/worker-server'
 import {CreateFFmpegOptions} from '@flemist/ffmpeg.wasm-st'
 import path from 'path'
+import {ffmpegTransformWorkerPath} from './paths.cjs'
 
 function getWorkerFFmpegInit(
   workerEventBus: WorkerFunctionClientEventBus<Omit<CreateFFmpegOptions, 'logger'>, void, FFmpegInitEvent>,
@@ -37,14 +38,14 @@ function getWorkerFFmpegTransform(
 
 export class FFmpegTransformClient implements IFFmpegTransformClient {
   private readonly _workerFilePath: string
-  options?: FFmpegOptions
+  options?: FFmpegClientOptions
   private _worker: Worker = null
   private _workerEventBus: IWorkerEventBus = null
   private _ffmpegInit: WorkerFunctionClient<FFmpegInitOptions, void, FFmpegInitEvent>
   private _ffmpegTransform: WorkerFunctionClient<FFmpegTransformArgs, Uint8Array, void>
 
-  constructor(workerFilePath: string, options?: FFmpegOptions) {
-    this._workerFilePath = workerFilePath
+  constructor(options?: FFmpegClientOptions) {
+    this._workerFilePath = ffmpegTransformWorkerPath
     this.options = options || {}
     if (this.options.preload) {
       void this.init()

src/ffmpeg/FFmpegTransformClientMT.ts

@@ -1,4 +1,4 @@
-import {FFmpegOptions, FFmpegTransformArgs, IFFmpegTransformClient} from './contracts'
+import {FFmpegClientOptions, FFmpegTransformArgs, IFFmpegTransformClient} from './contracts'
 import {FFmpegTransformClient} from './FFmpegTransformClient'
 import {WorkerData} from '@flemist/worker-server'
 import {
@@ -7,11 +7,9 @@ import {
 } from '@flemist/async-utils'
 
 export class FFmpegTransformClientMT implements IFFmpegTransformClient {
-  private readonly _workerFilePath: string
-  options?: FFmpegOptions
+  options?: FFmpegClientOptions
   private readonly _clientPool: IObjectPool<IFFmpegTransformClient>
-  constructor(workerFilePath: string, options?: FFmpegOptions & { threads: number }) {
-    this._workerFilePath = workerFilePath
+  constructor(options?: FFmpegClientOptions & { threads: number }) {
     this.options = options || {}
     this._clientPool = new ObjectPool<IFFmpegTransformClient>({
       maxSize    : options.threads || 1,
@@ -29,7 +27,7 @@ export class FFmpegTransformClientMT implements IFFmpegTransformClient {
   }
 
   private _createClient(): FFmpegTransformClient {
-    return new FFmpegTransformClient(this._workerFilePath, this.options)
+    return new FFmpegTransformClient(this.options)
   }
 
   ffmpegTransform(...args: FFmpegTransformArgs): Promise<WorkerData<Uint8Array>> {

src/ffmpeg/contracts.ts

@@ -16,6 +16,10 @@ export type FFmpegOptions = Omit<CreateFFmpegOptionsExt, 'logger'> & {
   logger?: (event: WorkerData<FFmpegInitEvent>) => void
 }
 
+export type FFmpegClientOptions = FFmpegOptions & {
+
+}
+
 export type FFmpegInitOptions = Omit<FFmpegOptions, 'logger'> & { logger?: boolean }
 
 export type FFmpegTransformArgs = [

src/ffmpeg/paths.cjs

@@ -0,0 +1,8 @@
+'use strict'
+
+const path = require('path')
+const ffmpegTransformWorkerPath = path.resolve(__dirname, '../../dist/ffmpeg/ffmpegTransformWorker.cjs')
+
+module.exports = {
+  ffmpegTransformWorkerPath,
+}

src/ffmpeg/test/ffmpegTest.ts

@@ -10,7 +10,6 @@ import {FFmpegTransformClientMT} from '../FFmpegTransformClientMT'
 
 let logSize = 0
 export const ffmpegTransformClient = new FFmpegTransformClientMT(
-  './dist/ffmpeg/ffmpegTransformWorker.cjs',
   {
     threads : 3,
     preload : true,