fix(ReadImagePipelines): Check for SharedArrayBuffer in read image pi…

…pelines

adds getTransferables everywhere worker postmessage is used, specifically the read image pipelines,
where it was missing

src/io/meshToPolyData.ts

@@ -5,6 +5,7 @@ import PolyData from '../core/PolyData.js'
 import meshTransferables from '../core/internal/meshTransferables.js'
 import PipelineInput from '../pipeline/PipelineInput.js'
 import config from '../itkConfig.js'
+import getTransferables from '../core/getTransferables.js'
 
 async function meshToPolyData (webWorker: Worker | null, mesh: Mesh): Promise<{ polyData: PolyData, webWorker: Worker }> {
   let worker = webWorker
@@ -33,7 +34,7 @@ async function meshToPolyData (webWorker: Worker | null, mesh: Mesh): Promise<{
       outputs,
       inputs
     },
-    transferables
+    getTransferables(transferables)
   )
   return { polyData: result.outputs[0].data as PolyData, webWorker: worker }
 }

src/io/polyDataToMesh.ts

@@ -5,6 +5,7 @@ import PolyData from '../core/PolyData.js'
 import polyDataTransferables from '../core/internal/polyDataTransferables.js'
 import PipelineInput from '../pipeline/PipelineInput.js'
 import config from '../itkConfig.js'
+import getTransferables from '../core/getTransferables.js'
 
 async function polyDataToMesh (webWorker: Worker | null, polyData: PolyData): Promise<{ mesh: Mesh, webWorker: Worker }> {
   let worker = webWorker
@@ -33,7 +34,7 @@ async function polyDataToMesh (webWorker: Worker | null, polyData: PolyData): Pr
       outputs,
       inputs
     },
-    transferables
+    getTransferables(transferables)
   )
   return { mesh: result.outputs[0].data as Mesh, webWorker: worker }
 }

src/io/readDICOMTagsArrayBuffer.ts

@@ -1,3 +1,4 @@
+import getTransferables from '../core/getTransferables.js'
 import createWebWorkerPromise from '../core/createWebWorkerPromise.js'
 import PipelineInput from '../pipeline/PipelineInput.js'
 import TextStream from '../core/TextStream.js'
@@ -30,6 +31,7 @@ async function readDICOMTagsArrayBuffer (webWorker: Worker | null, arrayBuffer:
     { type: InterfaceTypes.TextStream }
   ]
 
+  const transferables: ArrayBuffer[] = [arrayBuffer]
   interface PipelineResult {
     stdout: string
     stderr: string
@@ -45,7 +47,7 @@ async function readDICOMTagsArrayBuffer (webWorker: Worker | null, arrayBuffer:
       outputs,
       inputs
     },
-    [arrayBuffer]
+    getTransferables(transferables)
   )
   const tagsJSON = (result.outputs[0].data as TextStream).data
   const tagsResult = JSON.parse(tagsJSON)

src/io/readImageArrayBuffer.ts

@@ -1,3 +1,4 @@
+import getTransferables from '../core/getTransferables.js'
 import createWebWorkerPromise from '../core/createWebWorkerPromise.js'
 import Image from '../core/Image.js'
 import InterfaceTypes from '../core/InterfaceTypes.js'
@@ -49,7 +50,7 @@ async function readImageArrayBuffer (webWorker: Worker | null, arrayBuffer: Arra
       outputs,
       inputs
     },
-    transferables
+    getTransferables(transferables)
   )
   let image = result.outputs[0].data as Image
   if (typeof options === 'object' && (typeof options.componentType !== 'undefined' || typeof options.pixelType !== 'undefined')) {

src/io/readImageDICOMArrayBufferSeries.ts

@@ -1,3 +1,4 @@
+import getTransferables from '../core/getTransferables.js'
 import createWebWorkerPromise from '../core/createWebWorkerPromise.js'
 import WorkerPool from '../core/WorkerPool.js'
 import Metadata from '../core/Metadata.js'
@@ -57,7 +58,10 @@ const workerFunction = async (
     outputs,
     inputs
   }
-  const result: PipelineResult = await webworkerPromise.postMessage(message, transferables)
+  const result: PipelineResult = await webworkerPromise.postMessage(
+    message,
+    getTransferables(transferables)
+  )
   const image: Image = result.outputs[0].data
   const filenames: string[] = result.outputs[1].data.data.split('\0')
   // remove the last element since we expect it to be empty

src/io/readMeshArrayBuffer.ts

@@ -1,3 +1,4 @@
+import getTransferables from '../core/getTransferables.js'
 import createWebWorkerPromise from '../core/createWebWorkerPromise.js'
 import Mesh from '../core/Mesh.js'
 import InterfaceTypes from '../core/InterfaceTypes.js'
@@ -39,7 +40,7 @@ async function readMeshArrayBuffer (webWorker: Worker | null, arrayBuffer: Array
       outputs,
       inputs
     },
-    transferables
+    getTransferables(transferables)
   )
   return { mesh: result.outputs[0].data as Mesh, webWorker: worker }
 }

src/io/writeMeshArrayBuffer.ts

@@ -9,6 +9,7 @@ import PipelineInput from '../pipeline/PipelineInput.js'
 import PipelineOutput from '../pipeline/PipelineOutput.js'
 import InterfaceTypes from '../core/InterfaceTypes.js'
 import meshTransferables from '../core/internal/meshTransferables.js'
+import getTransferables from '../core/getTransferables.js'
 
 async function writeMeshArrayBuffer (webWorker: Worker | null, mesh: Mesh, fileName: string, mimeType: string, options: WriteMeshOptions): Promise<WriteArrayBufferResult> {
   if ('useCompression' in (mesh as any) || 'binaryFileType' in (mesh as any)) {
@@ -52,7 +53,7 @@ async function writeMeshArrayBuffer (webWorker: Worker | null, mesh: Mesh, fileN
       outputs,
       inputs
     },
-    transferables
+    getTransferables(transferables)
   )
   return { arrayBuffer: result.outputs[0].data.data.buffer as ArrayBuffer, webWorker: worker }
 }