doesitarm/helpers/scanner/client.mjs

import AppScanWorker from './worker.mjs?worker'

const noop = () => {}

function getArrayBufferFromFileData ( file ) {
    return new Promise( ( resolve, reject ) => {

        // If it has a .arrayBuffer function
        // then return that
        // (Likely a browser File blob)
        if ( typeof file.arrayBuffer === 'function' ) {
            file.arrayBuffer().then( resolve )

            return
        }

        // If it has a truthy .arrayBuffer property
        // then return that
        // (Likely a node File object)
        if ( !!file?.arrayBuffer ) {
            resolve( file.arrayBuffer )
            return
        }

        // Assume it's a Node Buffer from fs.readFile


        resolve( file.buffer )

        // const hasFileReader = typeof FileReader !== 'undefined'
        // const reader = hasFileReader ? new FileReader() : new FileApi.FileReader()

        // reader.onerror = function onerror ( readerEvent ) {
        //     reject( readerEvent.target.error )
        // }

        // reader.onload = function onload ( readerEvent ) {
        //     resolve( readerEvent.target.result )
        // }

        // reader.readAsArrayBuffer( file )
    })
}

export async function runScanWorker ( file, messageReceiver = noop ) {
    // console.log( 'file', file )

    const appScanWorker = new AppScanWorker()

    const fileArrayBuffer = ( typeof file.arrayBuffer === 'function' ) ? (await file.arrayBuffer()) : file.arrayBuffer

    if ( !fileArrayBuffer ) {
        throw new Error( 'No fileArrayBuffer' )
    }

    const scan = await new Promise( ( resolve, reject ) => {
        // Set up the worker message handler
        appScanWorker.onmessage = async (event) => {
            // console.log( 'Main received message', event )

            const { status } = event.data

            messageReceiver( event.data )

            // Resolves promise on finished status
            if ( status === 'finished' ) {
                const { scan } = event.data
                resolve( scan )
            }
        }

        // Set up the worker error handler
        appScanWorker.onerror = async ( errorEvent ) => {
            console.error( 'Error received from App Scan Worker', errorEvent )
            reject()
        }


        // Start the worker
        // https://developer.mozilla.org/en-US/docs/Web/API/Worker/postMessage
        appScanWorker.postMessage( {
            status: 'start',
            options: {
                file: {
                    ...file,
                    // We put it into an array
                    // so that it's iterable for Blob
                    arrayBuffer: [ fileArrayBuffer ]
                }
            }
        }, [
            // This array is our transferrable objects
            // so that the App Scan Worker is allowed
            // to use existing data from the main thread
            // and we don't have to clone the data from scratch
            fileArrayBuffer
        ] )
    })

    return {
        scan,
        appScanWorker
    }
}