| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 | - - - - - -1x -12x - - - - - - -1x -16x -4x - - - - - - - -12x -12x - - | import { argumentError, isValid } from './utils'
-import { post } from './post'
-import { postAll } from './postAll'
-import { register } from './register'
-import { unregister } from './unregister'
-
-const options = actions => {
- return {
- expected: 'an array of objects',
- received: actions,
- extraInfo: 'Every action should be an object containing two fields:\n* message\n* func'
- }
-}
-
-export const create = (actions = []) => {
- if (isValid(actions)('actionsArray')) {
- return {
- actions: actions,
- postMessage: post(actions),
- postAll: postAll,
- register: register(actions),
- unregister: unregister(actions)
- }
- }
- console.error(argumentError(options(actions)))
- return null
-}
- |
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 | 3x - - - - - - - - - - - - - - - - - - - | export const createDisposableWorker = response => { - const URL = window.URL || window.webkitURL - const blob = new Blob([response], { type: 'application/javascript' }) // eslint-disable-line - const objectURL = URL.createObjectURL(blob) - const worker = new Worker(objectURL) // eslint-disable-line - worker.post = message => - new Promise((resolve, reject) => { - worker.onmessage = event => { - URL.revokeObjectURL(objectURL) - resolve(event.data) - } - worker.onerror = e => { - console.error(`Error: Line ${e.lineno} in ${e.filename}: ${e.message}`) - reject(e) - } - worker.postMessage({ message }) - }) - return worker -} - |
| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| create.js | -100% | -7/7 | -100% | -3/3 | -100% | -2/2 | -100% | -7/7 | -|
| createDisposableWorker.js | -6.67% | -1/15 | -0% | -0/2 | -0% | -0/5 | -6.67% | -1/15 | -|
| index.js | -0% | -0/13 | -0% | -0/6 | -0% | -0/1 | -0% | -0/11 | -|
| post.js | -100% | -21/21 | -100% | -13/13 | -100% | -5/5 | -100% | -16/16 | -|
| postAll.js | -100% | -20/20 | -100% | -15/15 | -100% | -9/9 | -100% | -12/12 | -|
| register.js | -100% | -24/24 | -100% | -7/7 | -100% | -10/10 | -100% | -20/20 | -|
| run.js | -100% | -11/11 | -100% | -9/9 | -100% | -1/1 | -100% | -9/9 | -|
| unregister.js | -100% | -18/18 | -100% | -7/7 | -100% | -7/7 | -100% | -15/15 | -|
| utils.js | -98.21% | -55/56 | -94.29% | -33/35 | -100% | -23/23 | -97.3% | -36/37 | -
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 | - - - - - - - - - - - - - - - - - - | import { create } from './create'
-import { run } from './run'
-
-const createWrapper = () => {
- if (!window.Worker) {
- console.error('This browser does not support Workers.')
- return null
- }
- if (!(window.URL.createObjectURL || window.webkitURL.createObjectURL)) {
- console.error('This browser does not have URL.createObjectURL method.')
- return null
- }
- return { create, run }
-}
-
-const WorkerWrapper = createWrapper()
-
-export default WorkerWrapper
- |
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 | - - -2x -2x -2x - - -5x -41x -41x -41x -14x -56x -12x - - -14x -12x -6x - - -27x -27x -27x - - | import { argumentError, isValid } from './utils'
-import { run } from './run'
-
-const warnWork = msg => {
- console.warn(`WARN! ${msg} is not a registered action for this worker`)
- return `${msg} is not a registered action for this worker`
-}
-
-export const post = actions => (msg = null, args) => {
- const validMessage = isValid(msg)('string')
- const validArgs = isValid(args)(['array', 'undefined'])
- if (validMessage && validArgs) {
- const work = actions
- .filter(({ message }) => JSON.stringify(message) === JSON.stringify(msg))
- .map(action => action.func)
- .pop()
-
- if (!work) return run(warnWork, [JSON.stringify(msg)])
- if (args) return run(work, args)
- return run(work)
- }
-
- if (!validMessage) console.error(argumentError({ expected: 'a string', received: msg }))
- if (!validArgs) console.error(argumentError({ expected: 'an array', received: args }))
- return null
-}
- |
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 | - - -2x -30x - - - - - - - - -38x -10x - -10x -3x - - -8x -3x - - -14x -12x - - - -30x -30x - - | // import { invalidObjectsArray, isArrayOf, notArray, returnNull, wrongLength, wrongObjects } from './utils'
-import { isValid, argumentError } from './utils'
-
-const makeOptionsFor = arr => {
- return {
- expected: 'an array of arrays, an array of objects, or an array of strings',
- received: arr,
- extraInfo: 'If an array of arrays, ' +
- 'it must have the same length as the actions registered for this worker.\n' +
- 'If an array of objects, every object must containing two fields:\n* message\n* args'
- }
-}
-export function postAll (arr = []) {
- if (isValid(arr)(['arraysArray', 'postParamsArray', 'stringsArray'])) {
- if (arr.length === 0) return Promise.all(this.actions.map(({ message }) => this.postMessage(message)))
-
- if (arr.every(item => typeof item === 'string')) {
- return Promise.all(arr.map(msg => this.postMessage(msg)))
- }
-
- if (arr.every(item => typeof item === 'object' && !Array.isArray(item))) {
- return Promise.all(arr.map(({ message, args }) => this.postMessage(message, args)))
- }
-
- if (arr.every(item => Array.isArray(item)) && arr.length === this.actions.length) {
- return Promise.all(arr.map((args, index) => this.postMessage(this.actions[index].message, args)))
- }
- }
-
- console.error(argumentError(makeOptionsFor(arr)))
- return null
-}
- |
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 | - -24x -32x - -2x -10x - -24x -24x -10x -10x - -14x - - -2x -10x - - - - - - -28x -24x -14x -8x -18x -18x - - - -6x - -10x -10x - - | import { argumentError, isValid } from './utils'
-
-const isActionOf = actions => newAction =>
- actions.some(action => action.message === newAction.message)
-
-const warnMsg = action =>
- `WARN! An action with message "${action.message}" is already registered for this worker`
-
-const pushInto = actions => action => {
- if (isActionOf(actions)(action)) {
- console.warn(warnMsg(action))
- return actions.length
- }
- return actions.push(action)
-}
-
-const makeOptionsFor = action => {
- return {
- expected: 'an array of actions or an action',
- received: action,
- extraInfo: 'Every action should be an object containing two fields:\n* message\n* func'
- }
-}
-
-export const register = actions => (action = null) => {
- if (isValid(action)(['action', 'actionsArray'])) {
- if (Array.isArray(action)) {
- return action.reduce((actions, action) => {
- pushInto(actions)(action)
- return actions
- }, actions).length
- }
-
- return pushInto(actions)(action)
- }
- console.error((argumentError(makeOptionsFor(action))))
- return null
-}
- |
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 | - - -3x -36x -36x -36x -22x -22x - -14x -14x -14x - - | import { argumentError, isValid, makeResponse } from './utils'
-import { createDisposableWorker } from './createDisposableWorker'
-
-export const run = (work = null, args) => {
- const validWork = isValid(work)('function')
- const validArgs = isValid(args)(['array', 'undefined'])
- if (validWork && validArgs) {
- const worker = createDisposableWorker(makeResponse(work))
- return worker.post({ args })
- }
- if (!validWork) console.error(argumentError({ expected: 'a function', received: work }))
- if (!validArgs) console.error(argumentError({ expected: 'an array', received: args }))
- return null
-}
- |
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 | - -16x -20x -16x - - -16x - - -2x -10x - - - - - -24x -20x -10x -6x -12x -12x - - -4x - - -10x -10x - - | import { argumentError, isValid } from './utils'
-
-const removeFrom = actions => msg => {
- const index = actions.findIndex(({ message }) => message === msg)
- index === -1
- ? console.warn(`WARN! Impossible to unregister action with message "${msg}".\nIt is not a registered action for this worker.`)
- : actions.splice(index, 1)
- return actions
-}
-
-const makeOptions = msg => {
- return {
- expected: 'an array of strings or a string',
- received: msg
- }
-}
-
-export const unregister = actions => (msg = null) => {
- if (isValid(msg)(['string', 'stringsArray'])) {
- if (Array.isArray(msg)) {
- return msg.reduce((actions, message) => {
- removeFrom(actions)(message)
- return actions
- }, actions).length
- }
- return removeFrom(actions)(msg).length
- }
-
- console.error(argumentError(makeOptions(msg)))
- return null
-}
- |
| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 -78 -79 | -99x -119x - -7x -65x - - - -23x - -7x -32x - - - -28x - -7x -2x - -7x -23x -48x -2x -28x -55x - - -458x -458x -456x -388x -356x -149x -136x -122x - -207x -83x - - -291x -335x -123x -52x - - - -7x -108x -108x - -1x -1x - - - - - - -7x - - - - - - - - - - - - - - - - - | // Argument validation
-const isValidObjectWith = fields => obj =>
- !!obj && !Array.isArray(obj) && fields.every(field => obj.hasOwnProperty(field))
-
-const isValidAction = obj => {
- return isValidObjectWith(['message', 'func'])(obj) &&
- typeof obj.func === 'function' && typeof obj.message === 'string'
-}
-
-const isValidActionsArray = arr => arr.every(isValidAction)
-
-const isValidPostParams = obj => {
- return isValidObjectWith(['message', 'args'])(obj) &&
- Array.isArray(obj.args) && typeof obj.message === 'string'
-}
-
-const isValidPostParamsArray = arr => arr.every(isValidPostParams)
-
-const isValidObjectsArray = arr => (fields = []) =>
- arr.every(isValidObjectWith(fields))
-
-const testArray = {
- 'actionsArray': arr => isValidActionsArray(arr),
- 'arraysArray': arr => arr.every(item => Array.isArray(item)),
- 'objectsArray': arr => isValidObjectsArray(arr)(),
- 'postParamsArray': arr => isValidPostParamsArray(arr),
- 'stringsArray': arr => arr.every(item => typeof item === 'string')
-}
-
-const isValidArg = arg => type => {
- if (type === 'null') return arg === null
- if (type === 'undefined') return arg === undefined
- if (type === 'action') return isValidAction(arg)
- if (Array.isArray(arg)) {
- if (type !== 'array' && !testArray[type]) return false
- if (type === 'array') return true
- return testArray[type](arg)
- }
- if (arg) return typeof arg === type.toString() // eslint-disable-line
- return false
-}
-
-const isValid = argument => (types = null) => {
- if (Array.isArray(types)) return types.some(type => isValidArg(argument)(type))
- if (isValidArg(argument)(types)) return true
- return false
-}
-
-// Argument error builder
-const argumentError = ({ expected = '', received, extraInfo = '' }) => {
- try {
- return new TypeError(`${'You should provide ' + expected}${'\n' + extraInfo}${'\nReceived: ' + JSON.stringify(received)}`)
- } catch (err) {
- Eif (err.message === 'Converting circular structure to JSON') {
- return new TypeError(`${'You should provide ' + expected}${'\n' + extraInfo}${'\nReceived a circular structure: ' + received}`)
- }
- throw err
- }
-}
-
-// Response builder
-const makeResponse = work => `
- self.onmessage = event => {
- const args = event.data.message.args
- if (args) {
- self.postMessage((${work}).apply(null, args))
- return close()
- }
- self.postMessage((${work})())
- return close()
- }
-`
-
-export {
- makeResponse,
- argumentError,
- isValid
-}
- |