Big News: Socket raises $60M Series C at a $1B valuation to secure software supply chains for AI-driven development.Announcement →
@napi-rs/wasm-runtime
Advanced tools
@napi-rs/wasm-runtime - npm Package Compare versions
+259
| // @ts-check | ||
| /** | ||
| * @param {unknown} value | ||
| */ | ||
| const getType = (value) => { | ||
| if (value === undefined) return 0 | ||
| if (value === null) return 1 | ||
| const t = typeof value | ||
| if (t === 'boolean') return 2 | ||
| if (t === 'number') return 3 | ||
| if (t === 'string') return 4 | ||
| if (t === 'object') return 6 | ||
| if (t === 'bigint') return 9 | ||
| return -1 | ||
| } | ||
| /** | ||
| * @param {import('memfs').IFs} memfs | ||
| * @param {any} value | ||
| * @param {ReturnType<typeof getType>} type | ||
| * @returns {Uint8Array} | ||
| */ | ||
| const encodeValue = (memfs, value, type) => { | ||
| switch (type) { | ||
| case 0: | ||
| case 1: | ||
| return new Uint8Array(0) | ||
| case 2: { | ||
| const view = new Int32Array(1) | ||
| view[0] = value ? 1 : 0 | ||
| return new Uint8Array(view.buffer) | ||
| } | ||
| case 3: { | ||
| const view = new Float64Array(1) | ||
| view[0] = value | ||
| return new Uint8Array(view.buffer) | ||
| } | ||
| case 4: { | ||
| const view = new TextEncoder().encode(value) | ||
| return view | ||
| } | ||
| case 6: { | ||
| function storeConstructor(obj, memfs, processed = new WeakSet()) { | ||
| if (!obj || typeof obj !== 'object') { | ||
| return | ||
| } | ||
| if (processed.has(obj)) { | ||
| return | ||
| } | ||
| processed.add(obj) | ||
| const [entry] = | ||
| Object.entries(memfs).filter(([_, v]) => v === obj.constructor)[0] ?? | ||
| [] | ||
| if (entry) { | ||
| Object.defineProperty(obj, '__constructor__', { | ||
| configurable: true, | ||
| writable: true, | ||
| enumerable: true, | ||
| value: entry, | ||
| }) | ||
| } | ||
| for (const value of Object.values(obj)) { | ||
| storeConstructor(value, memfs, processed) | ||
| } | ||
| } | ||
| storeConstructor(value, memfs) | ||
| const json = JSON.stringify(value, (_, value) => { | ||
| if (typeof value === 'bigint') { | ||
| return `BigInt(${String(value)})` | ||
| } | ||
| if (value instanceof Error) { | ||
| return { | ||
| ...value, | ||
| message: value.message, | ||
| stack: value.stack, | ||
| __error__: value.constructor.name, | ||
| } | ||
| } | ||
| return value | ||
| }) | ||
| const view = new TextEncoder().encode(json) | ||
| return view | ||
| } | ||
| case 9: { | ||
| const view = new BigInt64Array(1) | ||
| view[0] = value | ||
| return new Uint8Array(view.buffer) | ||
| } | ||
| case -1: | ||
| default: | ||
| throw new Error('unsupported data') | ||
| } | ||
| } | ||
| /** | ||
| * @param {typeof import('memfs')} memfs | ||
| * @param {Uint8Array} payload | ||
| * @param {number} type | ||
| * @returns {any} | ||
| */ | ||
| const decodeValue = (memfs, payload, type) => { | ||
| if (type === 0) return undefined | ||
| if (type === 1) return null | ||
| if (type === 2) | ||
| return Boolean(new Int32Array(payload.buffer, payload.byteOffset, 1)[0]) | ||
| if (type === 3) | ||
| return new Float64Array(payload.buffer, payload.byteOffset, 1)[0] | ||
| if (type === 4) return new TextDecoder().decode(payload.slice()) | ||
| if (type === 6) { | ||
| const obj = JSON.parse( | ||
| new TextDecoder().decode(payload.slice()), | ||
| (_key, value) => { | ||
| if (typeof value === 'string') { | ||
| const matched = value.match(/^BigInt\((-?\d+)\)$/) | ||
| if (matched && matched[1]) { | ||
| return BigInt(matched[1]) | ||
| } | ||
| } | ||
| return value | ||
| }, | ||
| ) | ||
| function loadConstructor(obj, memfs, processed = new WeakSet()) { | ||
| if (!obj || typeof obj !== 'object') { | ||
| return | ||
| } | ||
| if (processed.has(obj)) { | ||
| return | ||
| } | ||
| processed.add(obj) | ||
| if (obj.__constructor__) { | ||
| const ctor = obj.__constructor__ | ||
| delete obj.__constructor__ | ||
| Object.setPrototypeOf(obj, memfs[ctor].prototype) | ||
| } | ||
| for (const value of Object.values(obj)) { | ||
| loadConstructor(value, memfs, processed) | ||
| } | ||
| } | ||
| loadConstructor(obj, memfs) | ||
| if (obj.__error__) { | ||
| const name = obj.__error__ | ||
| const ErrorConstructor = globalThis[name] || Error | ||
| delete obj.__error__ | ||
| const err = new ErrorConstructor(obj.message) | ||
| Object.defineProperty(err, 'stack', { | ||
| configurable: true, | ||
| enumerable: false, | ||
| writable: true, | ||
| value: err.stack, | ||
| }) | ||
| Object.defineProperty(err, Symbol.toStringTag, { | ||
| configurable: true, | ||
| enumerable: false, | ||
| writable: true, | ||
| value: name, | ||
| }) | ||
| for (const [k, v] of Object.entries(obj)) { | ||
| if (k === 'message' || k === 'stack') continue | ||
| err[k] = v | ||
| } | ||
| return err | ||
| } | ||
| return obj | ||
| } | ||
| if (type === 9) | ||
| return new BigInt64Array(payload.buffer, payload.byteOffset, 1)[0] | ||
| throw new Error('unsupported data') | ||
| } | ||
| /** | ||
| * @param {import('memfs').IFs} fs | ||
| * @returns {(e: { data: { __fs__: { sab: Int32Array, type: keyof import('memfs').IFs, payload: any[] } } }) => void} | ||
| */ | ||
| // oxlint-disable-next-line no-unused-vars -- fixed in an upcoming release | ||
| export const createOnMessage = (fs) => | ||
| function onMessage(e) { | ||
| if (e.data.__fs__) { | ||
| /** | ||
| * 0..4 status(int32_t): 21(waiting) 0(success) 1(error) | ||
| * 5..8 type(napi_valuetype): 0(undefined) 1(null) 2(boolean) 3(number) 4(string) 6(jsonstring) 9(bigint) -1(unsupported) | ||
| * 9..16 payload_size(uint32_t) <= 1024 | ||
| * 16..16 + payload_size payload_content | ||
| */ | ||
| const { sab, type, payload } = e.data.__fs__ | ||
| const fn = fs[type] | ||
| try { | ||
| const ret = fn.apply(fs, payload) | ||
| const t = getType(ret) | ||
| Atomics.store(sab, 1, t) | ||
| const v = encodeValue(fs, ret, t) | ||
| Atomics.store(sab, 2, v.length) | ||
| new Uint8Array(sab.buffer).set(v, 16) | ||
| Atomics.store(sab, 0, 0) // success | ||
| } catch (/** @type {any} */ err) { | ||
| const t = getType(err) | ||
| Atomics.store(sab, 1, t) | ||
| const v = encodeValue(fs, err, t) | ||
| Atomics.store(sab, 2, v.length) | ||
| new Uint8Array(sab.buffer).set(v, 16) | ||
| Atomics.store(sab, 0, 1) // error | ||
| } finally { | ||
| Atomics.notify(sab, 0) | ||
| } | ||
| } | ||
| } | ||
| /** | ||
| * @param {typeof import('memfs')} memfs | ||
| */ | ||
| export const createFsProxy = (memfs) => | ||
| new Proxy( | ||
| {}, | ||
| { | ||
| get(_target, p, _receiver) { | ||
| /** | ||
| * @param {any[]} args | ||
| */ | ||
| return function (...args) { | ||
| const sab = new SharedArrayBuffer(16 + 10240) | ||
| const i32arr = new Int32Array(sab) | ||
| Atomics.store(i32arr, 0, 21) | ||
| postMessage({ | ||
| __fs__: { | ||
| sab: i32arr, | ||
| type: p, | ||
| payload: args, | ||
| }, | ||
| }) | ||
| Atomics.wait(i32arr, 0, 21) | ||
| const status = Atomics.load(i32arr, 0) | ||
| const type = Atomics.load(i32arr, 1) | ||
| const size = Atomics.load(i32arr, 2) | ||
| const content = new Uint8Array(sab, 16, size) | ||
| const value = decodeValue(memfs, content, type) | ||
| if (status === 1) { | ||
| throw value | ||
| } | ||
| return value | ||
| } | ||
| }, | ||
| }, | ||
| ) |
| export { | ||
| instantiateNapiModuleSync, | ||
| instantiateNapiModule, | ||
| MessageHandler, | ||
| } from '@emnapi/core' | ||
| export { getDefaultContext } from '@emnapi/runtime' | ||
| export * from '@tybys/wasm-util' | ||
| export { createOnMessage, createFsProxy } from './fs-proxy.js' |
+5
-5
| { | ||
| "name": "@napi-rs/wasm-runtime", | ||
| "version": "1.0.1", | ||
| "version": "1.0.2", | ||
| "type": "module", | ||
@@ -22,3 +22,4 @@ "description": "Runtime and polyfill for wasm targets", | ||
| "runtime.cjs", | ||
| "fs-proxy.cjs", | ||
| "runtime.js", | ||
| "fs-proxy.js", | ||
| "dist/*.js" | ||
@@ -54,3 +55,3 @@ ], | ||
| ".": { | ||
| "import": "./dist/runtime.js", | ||
| "import": "./runtime.js", | ||
| "require": "./runtime.cjs" | ||
@@ -61,4 +62,3 @@ }, | ||
| } | ||
| }, | ||
| "gitHead": "739b091a71f27d04893784ea5e1d6d9a53d3913b" | ||
| } | ||
| } |
+1
-1
@@ -5,3 +5,3 @@ const { MessageHandler, instantiateNapiModuleSync, instantiateNapiModule } = require('@emnapi/core') | ||
| const { createFsProxy, createOnMessage } = require('./fs-proxy.cjs') | ||
| const { createFsProxy, createOnMessage } = require('./dist/fs-proxy.cjs') | ||
@@ -8,0 +8,0 @@ module.exports = { |
Sorry, the diff of this file is too big to display
-209
| // @ts-check | ||
| /** | ||
| * @param {unknown} value | ||
| */ | ||
| const getType = (value) => { | ||
| if (value === undefined) return 0 | ||
| if (value === null) return 1 | ||
| const t = typeof value | ||
| if (t === 'boolean') return 2 | ||
| if (t === 'number') return 3 | ||
| if (t === 'string') return 4 | ||
| if (t === 'object') return 6 | ||
| if (t === 'bigint') return 9 | ||
| return -1 | ||
| } | ||
| /** | ||
| * @param {import('memfs').IFs} memfs | ||
| * @param {any} value | ||
| * @param {ReturnType<typeof getType>} type | ||
| * @returns {Uint8Array} | ||
| */ | ||
| const encodeValue = (memfs, value, type) => { | ||
| switch (type) { | ||
| case 0: | ||
| case 1: | ||
| return new Uint8Array(0) | ||
| case 2: { | ||
| const view = new Int32Array(1) | ||
| view[0] = value ? 1 : 0 | ||
| return new Uint8Array(view.buffer) | ||
| } | ||
| case 3: { | ||
| const view = new Float64Array(1) | ||
| view[0] = value | ||
| return new Uint8Array(view.buffer) | ||
| } | ||
| case 4: { | ||
| const view = new TextEncoder().encode(value) | ||
| return view | ||
| } | ||
| case 6: { | ||
| const [entry] = Object.entries(memfs).filter(([_, v]) => v === value.constructor)[0] ?? [] | ||
| if (entry) { | ||
| Object.defineProperty(value, '__constructor__', { | ||
| configurable: true, | ||
| writable: true, | ||
| enumerable: true, | ||
| value: entry | ||
| }) | ||
| } | ||
| const json = JSON.stringify(value, (_, value) => { | ||
| if (typeof value === 'bigint') { | ||
| return `BigInt(${String(value)})` | ||
| } | ||
| if (value instanceof Error) { | ||
| return { | ||
| ...value, | ||
| message: value.message, | ||
| stack: value.stack, | ||
| __error__: value.constructor.name, | ||
| } | ||
| } | ||
| return value | ||
| }) | ||
| const view = new TextEncoder().encode(json) | ||
| return view | ||
| } | ||
| case 9: { | ||
| const view = new BigInt64Array(1) | ||
| view[0] = value | ||
| return new Uint8Array(view.buffer) | ||
| } | ||
| case -1: | ||
| default: | ||
| throw new Error('unsupported data') | ||
| } | ||
| } | ||
| /** | ||
| * @param {typeof import('memfs')} memfs | ||
| * @param {Uint8Array} payload | ||
| * @param {number} type | ||
| * @returns {any} | ||
| */ | ||
| const decodeValue = (memfs, payload, type) => { | ||
| if (type === 0) return undefined | ||
| if (type === 1) return null | ||
| if (type === 2) return Boolean(new Int32Array(payload.buffer, payload.byteOffset, 1)[0]) | ||
| if (type === 3) return new Float64Array(payload.buffer, payload.byteOffset, 1)[0] | ||
| if (type === 4) return new TextDecoder().decode(payload.slice()) | ||
| if (type === 6) { | ||
| const obj = JSON.parse(new TextDecoder().decode(payload.slice()), (_key, value) => { | ||
| if (typeof value === 'string') { | ||
| const matched = value.match(/^BigInt\((-?\d+)\)$/) | ||
| if (matched && matched[1]) { | ||
| return BigInt(matched[1]) | ||
| } | ||
| } | ||
| return value | ||
| }) | ||
| if (obj.__constructor__) { | ||
| const ctor = obj.__constructor__ | ||
| delete obj.__constructor__ | ||
| Object.setPrototypeOf(obj, memfs[ctor].prototype) | ||
| } | ||
| if (obj.__error__) { | ||
| const name = obj.__error__ | ||
| const ErrorConstructor = globalThis[name] || Error | ||
| delete obj.__error__ | ||
| const err = new ErrorConstructor(obj.message) | ||
| Object.defineProperty(err, 'stack', { | ||
| configurable: true, | ||
| enumerable: false, | ||
| writable: true, | ||
| value: err.stack | ||
| }) | ||
| Object.defineProperty(err, Symbol.toStringTag, { | ||
| configurable: true, | ||
| enumerable: false, | ||
| writable: true, | ||
| value: name | ||
| }) | ||
| for (const [k, v] of Object.entries(obj)) { | ||
| if (k === 'message' || k === 'stack') continue | ||
| err[k] = v | ||
| } | ||
| return err | ||
| } | ||
| return obj | ||
| } | ||
| if (type === 9) return new BigInt64Array(payload.buffer, payload.byteOffset, 1)[0] | ||
| throw new Error('unsupported data') | ||
| } | ||
| /** | ||
| * @param {import('memfs').IFs} fs | ||
| * @returns {(e: { data: { __fs__: { sab: Int32Array, type: keyof import('memfs').IFs, payload: any[] } } }) => void} | ||
| */ | ||
| // oxlint-disable-next-line no-unused-vars -- fixed in an upcoming release | ||
| module.exports.createOnMessage = (fs) => function onMessage(e) { | ||
| if (e.data.__fs__) { | ||
| /** | ||
| * 0..4 status(int32_t): 21(waiting) 0(success) 1(error) | ||
| * 5..8 type(napi_valuetype): 0(undefined) 1(null) 2(boolean) 3(number) 4(string) 6(jsonstring) 9(bigint) -1(unsupported) | ||
| * 9..16 payload_size(uint32_t) <= 1024 | ||
| * 16..16 + payload_size payload_content | ||
| */ | ||
| const { sab, type, payload } = e.data.__fs__ | ||
| const fn = fs[type] | ||
| try { | ||
| const ret = fn.apply(fs, payload) | ||
| const t = getType(ret) | ||
| Atomics.store(sab, 1, t) | ||
| const v = encodeValue(fs, ret, t) | ||
| Atomics.store(sab, 2, v.length) | ||
| new Uint8Array(sab.buffer).set(v, 16) | ||
| Atomics.store(sab, 0, 0) // success | ||
| } catch (/** @type {any} */ err) { | ||
| const t = getType(err) | ||
| Atomics.store(sab, 1, t) | ||
| const v = encodeValue(fs, err, t) | ||
| Atomics.store(sab, 2, v.length) | ||
| new Uint8Array(sab.buffer).set(v, 16) | ||
| Atomics.store(sab, 0, 1) // error | ||
| } finally { | ||
| Atomics.notify(sab, 0) | ||
| } | ||
| } | ||
| } | ||
| /** | ||
| * @param {typeof import('memfs')} memfs | ||
| */ | ||
| module.exports.createFsProxy = (memfs) => new Proxy({}, { | ||
| get (_target, p, _receiver) { | ||
| /** | ||
| * @param {any[]} args | ||
| */ | ||
| return function (...args) { | ||
| const sab = new SharedArrayBuffer(16 + 10240) | ||
| const i32arr = new Int32Array(sab) | ||
| Atomics.store(i32arr, 0, 21) | ||
| postMessage({ | ||
| __fs__: { | ||
| sab: i32arr, | ||
| type: p, | ||
| payload: args | ||
| } | ||
| }) | ||
| Atomics.wait(i32arr, 0, 21) | ||
| const status = Atomics.load(i32arr, 0) | ||
| const type = Atomics.load(i32arr, 1) | ||
| const size = Atomics.load(i32arr, 2) | ||
| const content = new Uint8Array(sab, 16, size) | ||
| const value = decodeValue(memfs, content, type) | ||
| if (status === 1) { | ||
| throw value | ||
| } | ||
| return value | ||
| } | ||
| } | ||
| }) |
-43
| MIT License | ||
| Copyright (c) 2020-present LongYinan | ||
| Permission is hereby granted, free of charge, to any person obtaining a copy | ||
| of this software and associated documentation files (the "Software"), to deal | ||
| in the Software without restriction, including without limitation the rights | ||
| to use, copy, modify, merge, publish, distribute, sublicense, and/or sell | ||
| copies of the Software, and to permit persons to whom the Software is | ||
| furnished to do so, subject to the following conditions: | ||
| The above copyright notice and this permission notice shall be included in all | ||
| copies or substantial portions of the Software. | ||
| THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR | ||
| IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, | ||
| FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE | ||
| AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER | ||
| LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, | ||
| OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE | ||
| SOFTWARE. | ||
| MIT License | ||
| Copyright (c) 2018 GitHub | ||
| Permission is hereby granted, free of charge, to any person obtaining a copy | ||
| of this software and associated documentation files (the "Software"), to deal | ||
| in the Software without restriction, including without limitation the rights | ||
| to use, copy, modify, merge, publish, distribute, sublicense, and/or sell | ||
| copies of the Software, and to permit persons to whom the Software is | ||
| furnished to do so, subject to the following conditions: | ||
| The above copyright notice and this permission notice shall be included in all | ||
| copies or substantial portions of the Software. | ||
| THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR | ||
| IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, | ||
| FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE | ||
| AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER | ||
| LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, | ||
| OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE | ||
| SOFTWARE. |
Sorry, the diff of this file is too big to display
New alerts
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
Worsened metrics
- Total package byte prevSize
6095497
-22.51%- Number of package files
5
-16.67%- Lines of code
1259
-93.37%- Number of medium supply chain risk alerts
1
Infinity%No dependency changes