fix: Updates the add method to support Uint8Array

Author: thecodedrift

CHANGELOG.md

@@ -1,5 +1,11 @@
 # @taskless/loader
 
+## 0.0.37
+
+### Patch Changes
+
+- Switches pack add command to use Uint8Arrays instead of buffers
+
 ## 0.0.36
 
 ### Patch Changes

package.json

@@ -1,7 +1,7 @@
 {
   "name": "@taskless/loader",
   "description": "Taskless Loader - Take control of your third party APIs",
-  "version": "0.0.36",
+  "version": "0.0.37",
   "author": "Taskless",
   "license": "Apache-2.0",
   "repository": "taskless/loader-js",

src/lib/taskless.ts

@@ -21,6 +21,7 @@ import {
 import { createClient, type NormalizeOAS } from "fets";
 import { glob } from "glob";
 import { setupServer } from "msw/node";
+import { toUint8Array } from "uint8array-extras";
 import { createHandler } from "./msw.js";
 import { entriesToNetworkJson } from "./util/entriesToNetworkJson.js";
 import { createErrorAPI, InitializationError } from "./util/error.js";
@@ -30,6 +31,7 @@ import { makeSynchronousRequest } from "./workers/makeRequest.js";
 import type openapi from "../__generated__/openapi.js";
 
 export type * from "../types.js";
+export { toUint8Array } from "uint8array-extras";
 
 /** Autoloading interface for Taskless, hides manual pack loading and automatically initializes */
 export const autoload = (secret?: string, options?: InitOptions) => {
@@ -292,7 +294,7 @@ export const taskless = (
   /** Packs are added programatically or during the init step */
   const packs: Pack[] = [];
 
-  const moduleSource = new Map<string, MaybePromise<ArrayBuffer>>();
+  const moduleSource = new Map<string, MaybePromise<Uint8Array>>();
 
   /** WASM modules are added programatically or during the init step */
   const modules = new Map<string, Promise<Plugin>>();
@@ -384,7 +386,7 @@ export const taskless = (
                 configuration: Pack["configuration"];
                 url: Pack["url"];
               };
-              const wasmContents = readFile(wasmPath);
+              const wasmContents = readFile(wasmPath) as Promise<Uint8Array>;
               const pack: Pack = {
                 ...config,
                 ...manifest,
@@ -423,7 +425,8 @@ export const taskless = (
               },
             });
             logger.trace(`Fetched ${ident} from ${pack.url.source}`);
-            return data.arrayBuffer();
+            const buffer = await data.arrayBuffer();
+            return toUint8Array(buffer);
           })()
         );
       }
@@ -517,7 +520,7 @@ export const taskless = (
     logger,
 
     /** add additional local packs programatically */
-    add(manifest: Manifest, wasm: ArrayBuffer) {
+    add(manifest: Manifest, wasm: Uint8Array) {
       if (initialized) {
         throw new Error("A pack was added after Taskless was initialized");
       }

src/types.ts

@@ -78,7 +78,7 @@ export type InitOptions = {
 
 export type TasklessAPI = {
   logger: Logger;
-  add(pack: Pack, wasm: ArrayBuffer): void;
+  add(pack: Pack, wasm: Uint8Array): void;
   shutdown(waitMs?: number): Promise<void>;
   load(): Promise<{
     network: boolean;

test/pack_methods/chunk.spec.ts

@@ -4,6 +4,7 @@ import { type ConsolePayload, type Pack } from "@~/types.js";
 import { http } from "msw";
 import { setupServer } from "msw/node";
 import { packageDirectorySync } from "package-directory";
+import { toUint8Array } from "uint8array-extras";
 import { describe, test, vi } from "vitest";
 
 // hold a reference to this package's root for loading local WASM files
@@ -70,7 +71,7 @@ describe("Chunked encoding using SSE", () => {
       {
         ...(JSON.parse(manifest.toString()) as Pack),
       },
-      wasm
+      toUint8Array(wasm.buffer as ArrayBuffer)
     );
 
     // load taskless and init

test/packs.spec.ts

@@ -9,6 +9,7 @@ import {
 import { http } from "msw";
 import { setupServer } from "msw/node";
 import { packageDirectorySync } from "package-directory";
+import { toUint8Array } from "uint8array-extras";
 import { describe, test, vi } from "vitest";
 
 // hold a reference to this package's root for loading local WASM files
@@ -78,7 +79,7 @@ describe("Loading packs", () => {
       {
         ...(JSON.parse(manifest.toString()) as Pack),
       },
-      wasm
+      toUint8Array(wasm.buffer as ArrayBuffer)
     );
 
     // validate load