diff options
Diffstat (limited to 'src/js/node')
| -rw-r--r-- | src/js/node/crypto.js | 36 | ||||
| -rw-r--r-- | src/js/node/stream.js | 12 |
2 files changed, 42 insertions, 6 deletions
diff --git a/src/js/node/crypto.js b/src/js/node/crypto.js index e75182429..20e052e3e 100644 --- a/src/js/node/crypto.js +++ b/src/js/node/crypto.js @@ -23802,12 +23802,35 @@ timingSafeEqual && Object.defineProperty(scryptSync, "name", { value: "::bunternal::", })); + +const harcoded_curves = [ + "p192", + "p224", + "p256", + "p384", + "p521", + "curve25519", + "ed25519", + "secp256k1", + "secp224r1", + "prime256v1", + "prime192v1", + "ed25519", + "secp384r1", + "secp521r1", +]; + +function getCurves() { + return harcoded_curves; +} + var webcrypto = crypto; __export(crypto_exports, { DEFAULT_ENCODING: () => DEFAULT_ENCODING, getRandomValues: () => getRandomValues, randomUUID: () => randomUUID, randomInt: () => randomInt, + getCurves: () => getCurves, scrypt: () => scrypt, scryptSync: () => scryptSync, timingSafeEqual: () => timingSafeEqual, @@ -23856,6 +23879,17 @@ export const { createCredentials, constants, } = crypto_exports; -export { DEFAULT_ENCODING, getRandomValues, randomUUID, randomInt, scrypt, scryptSync, timingSafeEqual, webcrypto }; + +export { + DEFAULT_ENCODING, + getRandomValues, + getCurves, + randomUUID, + randomInt, + scrypt, + scryptSync, + timingSafeEqual, + webcrypto, +}; export default crypto_exports; /*! safe-buffer. MIT License. Feross Aboukhadijeh <https://feross.org/opensource> */ diff --git a/src/js/node/stream.js b/src/js/node/stream.js index 741b2f65c..30c76d797 100644 --- a/src/js/node/stream.js +++ b/src/js/node/stream.js @@ -5356,10 +5356,10 @@ function createNativeStreamReadable(nativeType, Readable) { return chunk; } - push(result, encoding) { - __DEBUG__ && debug("NativeReadable push -- result, encoding", result, encoding, this.__id); - return super.push(...arguments); - } + // push(result, encoding) { + // __DEBUG__ && debug("NativeReadable push -- result, encoding", result, encoding, this.__id); + // return super.push(...arguments); + // } #handleResult(result, view, isClosed) { __DEBUG__ && debug("result, isClosed @ #handleResult", result, isClosed, this.__id); @@ -5372,7 +5372,9 @@ function createNativeStreamReadable(nativeType, Readable) { return handleNumberResult(this, result, view, isClosed); } else if (typeof result === "boolean") { - this.push(null); + process.nextTick(() => { + this.push(null); + }); return view?.byteLength ?? 0 > 0 ? view : undefined; } else if (ArrayBuffer.isView(result)) { if (result.byteLength >= this.#highWaterMark && !this.#hasResized && !isClosed) { |