prettyer fixes (#214)

Author: AaronGBoswell

packages/data-sdk/CHANGELOG.md

@@ -1,3 +1,7 @@
+## [1.80.0] - 2025-05-22
+
+- Fix Asset loading
+
 ## [1.79.0] - 2025-05-09
 
 - Command fixes

packages/data-sdk/package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@formant/data-sdk",
-  "version": "1.79.0",
+  "version": "1.80.0",
   "description": "A library for getting data from Formant",
   "repository": {
     "type": "git",

packages/data-sdk/package.json

@@ -46,6 +46,7 @@ export class AudioPlayer {
     }
 
     const AudioContext =
+      // eslint-disable-next-line @typescript-eslint/no-explicit-any
       window.AudioContext || (window as any).webkitAudioContext;
 
     this.audioContext = new AudioContext();
@@ -76,7 +77,7 @@ export class AudioPlayer {
     const arrayBuffer = stringToArrayBuffer(data);
     try {
       await audioContext.decodeAudioData(
-        arrayBuffer.buffer,
+        toArrayBuffer(arrayBuffer.buffer),
         this.scheduleChunk
       );
     } catch (error) {
@@ -127,6 +128,7 @@ export class AudioPlayer {
     source.buffer = buffer;
     source.connect(audioContext.destination);
     source.loop = false;
+    // eslint-disable-next-line @typescript-eslint/no-unused-vars
     source.onended = (_: Event) => {
       this.chunks.splice(this.chunks.indexOf(source), 1);
       if (this.chunks.length === 0) {
@@ -146,3 +148,27 @@ export class AudioPlayer {
     );
   }
 }
+
+function toArrayBuffer(data: ArrayBufferLike): ArrayBuffer {
+  // (1) If it’s already an ArrayBuffer, just return it.
+  if (data instanceof ArrayBuffer) {
+    return data;
+  }
+
+  // (2) If it’s a TypedArray or DataView, pull out the exact bytes.
+  if (ArrayBuffer.isView(data)) {
+    const view = data as ArrayBufferView;
+    const buffer = view.buffer.slice(
+      view.byteOffset,
+      view.byteOffset + view.byteLength
+    );
+    if (buffer instanceof SharedArrayBuffer) {
+      return new Uint8Array(data as SharedArrayBuffer).slice().buffer;
+    }
+    return buffer;
+  }
+
+  // (3) Otherwise it must be a SharedArrayBuffer — copy it into a new ArrayBuffer.
+  //     We do this by wrapping in a Uint8Array and slicing.
+  return new Uint8Array(data as SharedArrayBuffer).slice().buffer;
+}

packages/data-sdk/src/AudioPlayer.ts

@@ -10,7 +10,7 @@ export class LruCache<K, V> {
   private cache!: BaseLruCache<string, V>;
   private stringify: (_: K) => string;
 
-  constructor(private options: CacheOptions<V>) {
+  constructor(options: CacheOptions<V>) {
     this.cache = new BaseLruCache<string, V>({
       // if using the dispose callback,
       // by default automatically prune expired entries so

packages/data-sdk/src/connector/common/LruCache.ts

@@ -8,5 +8,5 @@ import stringify from "fast-json-stable-stringify";
  * Warning: output is not guaranteed to be a valid JSON string.
  */
 export function toStringSafe(input: unknown): string {
-    return stringify(input, { cycles: true });
+  return stringify(input, { cycles: true });
 }

packages/data-sdk/src/connector/common/toStringSafe.ts

@@ -1,31 +1,30 @@
 import { errorToString } from "../../common/errorToString";
 
-
 // eslint-disable-next-line @typescript-eslint/no-explicit-any
 const context: Worker = self as any;
 const previewLength = 1000;
 
-addEventListener("message", async event => {
-    try {
-        const url: string = event.data;
+addEventListener("message", async (event) => {
+  try {
+    const url: string = event.data;
 
-        try {
-            const response = await fetch(url, { mode: "cors" });
-            const payload = await response.text();
+    try {
+      const response = await fetch(url, { mode: "cors" });
+      const payload = await response.text();
 
-            context.postMessage({
-                json: JSON.parse(payload),
-                preview: payload.substring(0, previewLength),
-                length: payload.length,
-                url,
-            });
-        } catch (error) {
-            throw new Error(`Load failed ${errorToString(error)}`);
-        }
+      context.postMessage({
+        json: JSON.parse(payload),
+        preview: payload.substring(0, previewLength),
+        length: payload.length,
+        url,
+      });
     } catch (error) {
-        context.postMessage({
-            error: errorToString(error),
-            url: event?.data?.url,
-        });
+      throw new Error(`Load failed ${errorToString(error)}`);
     }
+  } catch (error) {
+    context.postMessage({
+      error: errorToString(error),
+      url: event?.data?.url,
+    });
+  }
 });

packages/data-sdk/src/connector/data/loader/data-loader.worker.ts

@@ -3,5 +3,5 @@ import { ITransform } from "./ITransform";
 export interface IPath {
   worldToLocal: ITransform;
   poses: ITransform[];
-  url?: string
+  url?: string;
 }