Send initialization message inside the remote executor.

Author: bobsingor

packages/engines/src/lib/orchestrator/remote-executor.ts

@@ -33,10 +33,25 @@ import {
   TaskError,
   PdfErrorCode,
   SearchResult,
+  serializeLogger,
 } from '@embedpdf/models';
 import type { IPdfExecutor, ImageDataLike } from './pdf-engine';
 import type { WorkerRequest, WorkerResponse } from './pdfium-native-runner';
 
+/**
+ * Options for creating a RemoteExecutor
+ */
+export interface RemoteExecutorOptions {
+  /**
+   * URL to the pdfium.wasm file (required)
+   */
+  wasmUrl: string;
+  /**
+   * Logger instance for debugging
+   */
+  logger?: Logger;
+}
+
 const LOG_SOURCE = 'RemoteExecutor';
 const LOG_CATEGORY = 'Worker';
 
@@ -102,10 +117,19 @@ export class RemoteExecutor implements IPdfExecutor {
 
   constructor(
     private worker: Worker,
-    logger?: Logger,
+    options: RemoteExecutorOptions,
   ) {
-    this.logger = logger ?? new NoopLogger();
+    this.logger = options.logger ?? new NoopLogger();
     this.worker.addEventListener('message', this.handleMessage);
+
+    // Send initialization message with WASM URL
+    this.worker.postMessage({
+      id: '0',
+      type: 'wasmInit',
+      wasmUrl: options.wasmUrl,
+      logger: options.logger ? serializeLogger(options.logger) : undefined,
+    });
+
     this.logger.debug(LOG_SOURCE, LOG_CATEGORY, 'RemoteExecutor created');
   }
 

packages/engines/src/lib/pdfium/web/worker-engine.ts

@@ -1,4 +1,4 @@
-import { Logger, serializeLogger } from '@embedpdf/models';
+import { Logger } from '@embedpdf/models';
 import { PdfEngine } from '../../orchestrator/pdf-engine';
 import { RemoteExecutor } from '../../orchestrator/remote-executor';
 import { ImageEncoderWorkerPool } from '../../image-encoder';
@@ -71,16 +71,8 @@ export function createPdfiumEngine(
     },
   );
 
-  // Send initialization message with WASM URL
-  worker.postMessage({
-    id: '0',
-    type: 'wasmInit',
-    wasmUrl,
-    logger: logger ? serializeLogger(logger) : undefined,
-  });
-
-  // Create RemoteExecutor (proxy to worker)
-  const remoteExecutor = new RemoteExecutor(worker, logger);
+  // Create RemoteExecutor (proxy to worker) - handles wasmInit internally
+  const remoteExecutor = new RemoteExecutor(worker, { wasmUrl, logger });
 
   const finalEncoderWorkerUrl = URL.createObjectURL(
     new Blob([__ENCODER_WORKER_BODY__], { type: 'application/javascript' }),