Unify workers and wasm

Author: tolyo

@types/core/di/ng-module.d.ts

@@ -155,9 +155,24 @@ export class NgModule {
     ctlFn: import("../../interface.ts").Injectable<any>,
   ): NgModule;
   /**
+   * Register a named worker that will be instantiated via $provide.
+   *
    * @param {string} name
    * @param {string} src
    * @returns {NgModule}
    */
   wasm(name: string, src: string): NgModule;
+  /**
+   * Register a named worker that will be instantiated via $provide.
+   *
+   * @param {string} name
+   * @param {string | URL} scriptPath
+   * @param {ng.WorkerConfig} [config]
+   * @returns {NgModule}
+   */
+  worker(
+    name: string,
+    scriptPath: string | URL,
+    config?: ng.WorkerConfig,
+  ): NgModule;
 }

@types/services/worker/interface.d.ts @types/directive/worker/interface.d.ts@types/services/worker/interface.d.ts renamed to @types/directive/worker/interface.d.ts

@@ -9,4 +9,5 @@ export interface WorkerConnection {
   post(data: any): void;
   terminate(): void;
   restart(): void;
+  config: WorkerConfig;
 }

@types/directive/worker/worker.d.ts

@@ -1,15 +1,25 @@
 /**
- * ngWorker directive factory
  * Usage: <div ng-worker="workerName" data-params="{{ expression }}" data-on-result="callback($result)"></div>
+ *
+ * @param {ng.ParseService} $parse
+ * @param {ng.LogService} $log
+ * @returns {ng.Directive}
  */
 export function ngWorkerDirective(
-  $worker: any,
-  $parse: any,
-  $log: any,
-): {
-  restrict: string;
-  link(scope: any, element: any, attrs: any): void;
-};
+  $parse: ng.ParseService,
+  $log: ng.LogService,
+): ng.Directive;
 export namespace ngWorkerDirective {
   let $inject: string[];
 }
+/**
+ * Creates a managed Web Worker connection.
+ *
+ * @param {string | URL} scriptPath
+ * @param {ng.WorkerConfig} [config]
+ * @returns {ng.WorkerConnection}
+ */
+export function createWorkerConnection(
+  scriptPath: string | URL,
+  config?: ng.WorkerConfig,
+): ng.WorkerConnection;

@types/namespace.d.ts

@@ -59,7 +59,7 @@ import {
 import {
   WorkerConnection as TWorkerConnection,
   WorkerConfig as TWorkerConfig,
-} from "./services/worker/interface.ts";
+} from "./directive/worker/interface.ts";
 import { Provider as TProvideService } from "./interface.ts";
 import { Location as TLocationService } from "./services/location/location.js";
 import { AnimateService as TAnimateService } from "./animations/interface.ts";

@types/services/worker/worker.d.ts

@@ -583,7 +583,7 @@ export function wait(t?: number): Promise<void>;
  */
 export function startsWith(str: string, search: string): boolean;
 /**
- * Loads and instantiates a WebAssembly module with proper error handling.
+ * Loads and instantiates a WebAssembly module
  *
  * @param {string} src - URL to the wasm file
  * @returns {Promise<Object>} - Resolves to wasm exports

@types/shared/utils.d.ts

@@ -39,7 +39,6 @@ export function createInjector(modulesToLoad, strictDi = false) {
       service: supportObject(service),
       value: supportObject(value),
       constant: supportObject(constant),
-      wasm: supportObject(wasm),
       decorator,
     },
   };
@@ -155,17 +154,6 @@ export function createInjector(modulesToLoad, strictDi = false) {
     protoInstanceInjector.cache[name] = value;
   }
 
-  /**
-   * Register a wasm module (available during config).
-   * @param {string} name
-   * @param {string} value
-   * @returns {void}
-   */
-  function wasm(name, value) {
-    providerInjector.cache[name] = value;
-    protoInstanceInjector.cache[name] = value;
-  }
-
   /**
    * Register a decorator function to modify or replace an existing service.
    * @param name - The name of the service to decorate.

docs/static/typedoc/interfaces/Directive.html

@@ -1,4 +1,5 @@
 import { $injectTokens as $t } from "../../injection-tokens.js";
+import { createWorkerConnection } from "../../directive/worker/worker.js";
 import {
   isFunction,
   isString,
@@ -235,15 +236,49 @@ export class NgModule {
   }
 
   /**
+   * Register a named worker that will be instantiated via $provide.
+   *
    * @param {string} name
    * @param {string} src
    * @returns {NgModule}
    */
   wasm(name, src) {
     this.invokeQueue.push([
       $t.$provide,
-      "wasm",
-      [name, (() => instantiateWasm(src))()],
+      "provider",
+      [
+        name,
+        function () {
+          this.$get = function () {
+            return instantiateWasm(src);
+          };
+        },
+      ],
+    ]);
+
+    return this;
+  }
+
+  /**
+   * Register a named worker that will be instantiated via $provide.
+   *
+   * @param {string} name
+   * @param {string | URL} scriptPath
+   * @param {ng.WorkerConfig} [config]
+   * @returns {NgModule}
+   */
+  worker(name, scriptPath, config = {}) {
+    this.invokeQueue.push([
+      $t.$provide,
+      "provider",
+      [
+        name,
+        function () {
+          this.$get = function () {
+            return createWorkerConnection(scriptPath, config);
+          };
+        },
+      ],
     ]);
     return this;
   }

src/core/di/injector.js

@@ -7,7 +7,6 @@ import {
   toKeyValue,
   wait,
 } from "../../shared/utils.js";
-import { createElementFromHTML } from "../../shared/dom.js";
 
 /**
  * @param {"get" | "delete" | "post" | "put"} method - HTTP method applied to request