lib: use validateArray for array arguments

Replace manual ArrayIsArray checks that throw ERR_INVALID_ARG_TYPE with
the shared validateArray helper. The error code, argument name and
expected type are unchanged, so the thrown error stays identical.
Signed-off-by: greenhead <shren0812@gmail.com>
PR-URL: #64959
Reviewed-By: Aviv Keller <me@aviv.sh>
Reviewed-By: Filip Skokan <panva.ip@gmail.com>
Reviewed-By: Mattias Buelens <mattias@buelens.com>

Author: greenheadHQ

lib/internal/streams/iter/broadcast.js

@@ -33,6 +33,7 @@ const {
 }=require('internal/errors');
 const{
  validateAbortSignal,
+ validateArray,
  validateInteger,
  validateObject,
 }=require('internal/validators');
@@ -559,9 +560,7 @@ class BroadcastWriter {
 }
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constsignal=getWriterSignal(options);
 // Fast path: no signal, writer open, buffer has space
 if(this.#canUseWriteFastPath(signal)){
@@ -620,9 +619,7 @@ class BroadcastWriter {
 }
 
 writevSync(chunks){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 if(this.#isClosedOrAborted())returnfalse;
 if(!this.#broadcast[kCanWrite]())returnfalse;
 constconverted=convertChunks(chunks);

lib/internal/streams/iter/classic.js

@@ -12,7 +12,6 @@
 // toWritable(writer) -- stream/iter Writer -> classic Writable
 
 const{
- ArrayIsArray,
  ArrayPrototypePush,
  NumberMAX_SAFE_INTEGER,
  Promise,
@@ -41,6 +40,7 @@ const {
 }=require('internal/errors');
 
 const{
+ validateArray,
  validateInteger,
  validateObject,
 }=require('internal/validators');
@@ -619,9 +619,7 @@ function fromWritable(writable, options = kNullPrototype) {
 },
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 getWriterSignal(options);
 if(!isWritable()){
 returnPromiseReject(newERR_STREAM_WRITE_AFTER_END());

lib/internal/streams/iter/push.js

@@ -6,7 +6,6 @@
 // with built-in backpressure.
 
 const{
- ArrayIsArray,
  ArrayPrototypePush,
  PromisePrototypeThen,
  PromiseReject,
@@ -21,13 +20,13 @@ const {
 
 const{
 codes: {
-ERR_INVALID_ARG_TYPE,
 ERR_INVALID_STATE,
 },
 }=require('internal/errors');
 const{ lazyDOMException }=require('internal/util');
 const{
  validateAbortSignal,
+ validateArray,
  validateInteger,
 }=require('internal/validators');
 
@@ -629,9 +628,7 @@ class PushWriter {
 }
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constsignal=getWriterSignal(options);
 if(!signal&&this.#queue.canWriteSync()){
 constbytes=convertChunks(chunks);
@@ -648,9 +645,7 @@ class PushWriter {
 }
 
 writevSync(chunks){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constbytes=convertChunks(chunks);
 returnthis.#queue.writeSync(bytes);
 }

lib/internal/tls/secure-context.js

@@ -26,6 +26,7 @@ const {
 }=require('internal/util/types');
 
 const{
+ validateArray,
  validateBuffer,
  validateInt32,
  validateObject,
@@ -212,10 +213,7 @@ function configSecureContext(context, options = kEmptyObject, name = 'options')
 }
 
 if(certificateCompression!=null){
-if(!ArrayIsArray(certificateCompression)){
-thrownewERR_INVALID_ARG_TYPE(
-`${name}.certificateCompression`,'Array',certificateCompression);
-}
+validateArray(certificateCompression,`${name}.certificateCompression`);
 
 if(certificateCompression.length>0){
 // Pack length + algorithm IDs into a single Uint32 for a cheap

lib/tls.js

@@ -70,7 +70,7 @@ const { canonicalizeIP } = internalBinding('cares_wrap');
 consttlsCommon=require('internal/tls/common');
 consttlsWrap=require('internal/tls/wrap');
 const{ domainToASCII }=require('internal/url');
-const{ validateString }=require('internal/validators');
+const{validateArray,validateString }=require('internal/validators');
 
 const{
 namespace: {
@@ -206,9 +206,7 @@ function getCACertificates(type = 'default') {
 exports.getCACertificates=getCACertificates;
 
 functionsetDefaultCACertificates(certs){
-if(!ArrayIsArray(certs)){
-thrownewERR_INVALID_ARG_TYPE('certs','Array',certs);
-}
+validateArray(certs,'certs');
 
 // Verify that all elements in the array are strings
 for(leti=0;i<certs.length;i++){

lib/internal/streams/iter/broadcast.js

@@ -33,6 +33,7 @@ const {
 }=require('internal/errors');
 const{
  validateAbortSignal,
+ validateArray,
  validateInteger,
  validateObject,
 }=require('internal/validators');
@@ -559,9 +560,7 @@ class BroadcastWriter {
 }
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constsignal=getWriterSignal(options);
 // Fast path: no signal, writer open, buffer has space
 if(this.#canUseWriteFastPath(signal)){
@@ -620,9 +619,7 @@ class BroadcastWriter {
 }
 
 writevSync(chunks){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 if(this.#isClosedOrAborted())returnfalse;
 if(!this.#broadcast[kCanWrite]())returnfalse;
 constconverted=convertChunks(chunks);

lib/internal/streams/iter/classic.js

@@ -12,7 +12,6 @@
 // toWritable(writer) -- stream/iter Writer -> classic Writable
 
 const{
- ArrayIsArray,
  ArrayPrototypePush,
  NumberMAX_SAFE_INTEGER,
  Promise,
@@ -41,6 +40,7 @@ const {
 }=require('internal/errors');
 
 const{
+ validateArray,
  validateInteger,
  validateObject,
 }=require('internal/validators');
@@ -619,9 +619,7 @@ function fromWritable(writable, options = kNullPrototype) {
 },
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 getWriterSignal(options);
 if(!isWritable()){
 returnPromiseReject(newERR_STREAM_WRITE_AFTER_END());

lib/internal/streams/iter/push.js

@@ -6,7 +6,6 @@
 // with built-in backpressure.
 
 const{
- ArrayIsArray,
  ArrayPrototypePush,
  PromisePrototypeThen,
  PromiseReject,
@@ -21,13 +20,13 @@ const {
 
 const{
 codes: {
-ERR_INVALID_ARG_TYPE,
 ERR_INVALID_STATE,
 },
 }=require('internal/errors');
 const{ lazyDOMException }=require('internal/util');
 const{
  validateAbortSignal,
+ validateArray,
  validateInteger,
 }=require('internal/validators');
 
@@ -629,9 +628,7 @@ class PushWriter {
 }
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constsignal=getWriterSignal(options);
 if(!signal&&this.#queue.canWriteSync()){
 constbytes=convertChunks(chunks);
@@ -648,9 +645,7 @@ class PushWriter {
 }
 
 writevSync(chunks){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constbytes=convertChunks(chunks);
 returnthis.#queue.writeSync(bytes);
 }

lib/internal/tls/secure-context.js

@@ -26,6 +26,7 @@ const {
 }=require('internal/util/types');
 
 const{
+ validateArray,
  validateBuffer,
  validateInt32,
  validateObject,
@@ -212,10 +213,7 @@ function configSecureContext(context, options = kEmptyObject, name = 'options')
 }
 
 if(certificateCompression!=null){
-if(!ArrayIsArray(certificateCompression)){
-thrownewERR_INVALID_ARG_TYPE(
-`${name}.certificateCompression`,'Array',certificateCompression);
-}
+validateArray(certificateCompression,`${name}.certificateCompression`);
 
 if(certificateCompression.length>0){
 // Pack length + algorithm IDs into a single Uint32 for a cheap

lib/tls.js

@@ -70,7 +70,7 @@ const { canonicalizeIP } = internalBinding('cares_wrap');
 consttlsCommon=require('internal/tls/common');
 consttlsWrap=require('internal/tls/wrap');
 const{ domainToASCII }=require('internal/url');
-const{ validateString }=require('internal/validators');
+const{validateArray,validateString }=require('internal/validators');
 
 const{
 namespace: {
@@ -206,9 +206,7 @@ function getCACertificates(type = 'default') {
 exports.getCACertificates=getCACertificates;
 
 functionsetDefaultCACertificates(certs){
-if(!ArrayIsArray(certs)){
-thrownewERR_INVALID_ARG_TYPE('certs','Array',certs);
-}
+validateArray(certs,'certs');
 
 // Verify that all elements in the array are strings
 for(leti=0;i<certs.length;i++){

lib/internal/streams/iter/broadcast.js

@@ -33,6 +33,7 @@ const {
 }=require('internal/errors');
 const{
  validateAbortSignal,
+ validateArray,
  validateInteger,
  validateObject,
 }=require('internal/validators');
@@ -559,9 +560,7 @@ class BroadcastWriter {
 }
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constsignal=getWriterSignal(options);
 // Fast path: no signal, writer open, buffer has space
 if(this.#canUseWriteFastPath(signal)){
@@ -620,9 +619,7 @@ class BroadcastWriter {
 }
 
 writevSync(chunks){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 if(this.#isClosedOrAborted())returnfalse;
 if(!this.#broadcast[kCanWrite]())returnfalse;
 constconverted=convertChunks(chunks);

lib/internal/streams/iter/classic.js

@@ -12,7 +12,6 @@
 // toWritable(writer) -- stream/iter Writer -> classic Writable
 
 const{
- ArrayIsArray,
  ArrayPrototypePush,
  NumberMAX_SAFE_INTEGER,
  Promise,
@@ -41,6 +40,7 @@ const {
 }=require('internal/errors');
 
 const{
+ validateArray,
  validateInteger,
  validateObject,
 }=require('internal/validators');
@@ -619,9 +619,7 @@ function fromWritable(writable, options = kNullPrototype) {
 },
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 getWriterSignal(options);
 if(!isWritable()){
 returnPromiseReject(newERR_STREAM_WRITE_AFTER_END());

lib/internal/streams/iter/push.js

@@ -6,7 +6,6 @@
 // with built-in backpressure.
 
 const{
- ArrayIsArray,
  ArrayPrototypePush,
  PromisePrototypeThen,
  PromiseReject,
@@ -21,13 +20,13 @@ const {
 
 const{
 codes: {
-ERR_INVALID_ARG_TYPE,
 ERR_INVALID_STATE,
 },
 }=require('internal/errors');
 const{ lazyDOMException }=require('internal/util');
 const{
  validateAbortSignal,
+ validateArray,
  validateInteger,
 }=require('internal/validators');
 
@@ -629,9 +628,7 @@ class PushWriter {
 }
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constsignal=getWriterSignal(options);
 if(!signal&&this.#queue.canWriteSync()){
 constbytes=convertChunks(chunks);
@@ -648,9 +645,7 @@ class PushWriter {
 }
 
 writevSync(chunks){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constbytes=convertChunks(chunks);
 returnthis.#queue.writeSync(bytes);
 }

lib/internal/tls/secure-context.js

@@ -26,6 +26,7 @@ const {
 }=require('internal/util/types');
 
 const{
+ validateArray,
  validateBuffer,
  validateInt32,
  validateObject,
@@ -212,10 +213,7 @@ function configSecureContext(context, options = kEmptyObject, name = 'options')
 }
 
 if(certificateCompression!=null){
-if(!ArrayIsArray(certificateCompression)){
-thrownewERR_INVALID_ARG_TYPE(
-`${name}.certificateCompression`,'Array',certificateCompression);
-}
+validateArray(certificateCompression,`${name}.certificateCompression`);
 
 if(certificateCompression.length>0){
 // Pack length + algorithm IDs into a single Uint32 for a cheap

lib/tls.js

@@ -70,7 +70,7 @@ const { canonicalizeIP } = internalBinding('cares_wrap');
 consttlsCommon=require('internal/tls/common');
 consttlsWrap=require('internal/tls/wrap');
 const{ domainToASCII }=require('internal/url');
-const{ validateString }=require('internal/validators');
+const{validateArray,validateString }=require('internal/validators');
 
 const{
 namespace: {
@@ -206,9 +206,7 @@ function getCACertificates(type = 'default') {
 exports.getCACertificates=getCACertificates;
 
 functionsetDefaultCACertificates(certs){
-if(!ArrayIsArray(certs)){
-thrownewERR_INVALID_ARG_TYPE('certs','Array',certs);
-}
+validateArray(certs,'certs');
 
 // Verify that all elements in the array are strings
 for(leti=0;i<certs.length;i++){

lib/internal/streams/iter/broadcast.js

@@ -33,6 +33,7 @@ const {
 }=require('internal/errors');
 const{
  validateAbortSignal,
+ validateArray,
  validateInteger,
  validateObject,
 }=require('internal/validators');
@@ -559,9 +560,7 @@ class BroadcastWriter {
 }
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constsignal=getWriterSignal(options);
 // Fast path: no signal, writer open, buffer has space
 if(this.#canUseWriteFastPath(signal)){
@@ -620,9 +619,7 @@ class BroadcastWriter {
 }
 
 writevSync(chunks){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 if(this.#isClosedOrAborted())returnfalse;
 if(!this.#broadcast[kCanWrite]())returnfalse;
 constconverted=convertChunks(chunks);

lib/internal/streams/iter/classic.js

@@ -12,7 +12,6 @@
 // toWritable(writer) -- stream/iter Writer -> classic Writable
 
 const{
- ArrayIsArray,
  ArrayPrototypePush,
  NumberMAX_SAFE_INTEGER,
  Promise,
@@ -41,6 +40,7 @@ const {
 }=require('internal/errors');
 
 const{
+ validateArray,
  validateInteger,
  validateObject,
 }=require('internal/validators');
@@ -619,9 +619,7 @@ function fromWritable(writable, options = kNullPrototype) {
 },
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 getWriterSignal(options);
 if(!isWritable()){
 returnPromiseReject(newERR_STREAM_WRITE_AFTER_END());

lib/internal/streams/iter/push.js

@@ -6,7 +6,6 @@
 // with built-in backpressure.
 
 const{
- ArrayIsArray,
  ArrayPrototypePush,
  PromisePrototypeThen,
  PromiseReject,
@@ -21,13 +20,13 @@ const {
 
 const{
 codes: {
-ERR_INVALID_ARG_TYPE,
 ERR_INVALID_STATE,
 },
 }=require('internal/errors');
 const{ lazyDOMException }=require('internal/util');
 const{
  validateAbortSignal,
+ validateArray,
  validateInteger,
 }=require('internal/validators');
 
@@ -629,9 +628,7 @@ class PushWriter {
 }
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constsignal=getWriterSignal(options);
 if(!signal&&this.#queue.canWriteSync()){
 constbytes=convertChunks(chunks);
@@ -648,9 +645,7 @@ class PushWriter {
 }
 
 writevSync(chunks){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constbytes=convertChunks(chunks);
 returnthis.#queue.writeSync(bytes);
 }

lib/internal/tls/secure-context.js

@@ -26,6 +26,7 @@ const {
 }=require('internal/util/types');
 
 const{
+ validateArray,
  validateBuffer,
  validateInt32,
  validateObject,
@@ -212,10 +213,7 @@ function configSecureContext(context, options = kEmptyObject, name = 'options')
 }
 
 if(certificateCompression!=null){
-if(!ArrayIsArray(certificateCompression)){
-thrownewERR_INVALID_ARG_TYPE(
-`${name}.certificateCompression`,'Array',certificateCompression);
-}
+validateArray(certificateCompression,`${name}.certificateCompression`);
 
 if(certificateCompression.length>0){
 // Pack length + algorithm IDs into a single Uint32 for a cheap

lib/tls.js

@@ -70,7 +70,7 @@ const { canonicalizeIP } = internalBinding('cares_wrap');
 consttlsCommon=require('internal/tls/common');
 consttlsWrap=require('internal/tls/wrap');
 const{ domainToASCII }=require('internal/url');
-const{ validateString }=require('internal/validators');
+const{validateArray,validateString }=require('internal/validators');
 
 const{
 namespace: {
@@ -206,9 +206,7 @@ function getCACertificates(type = 'default') {
 exports.getCACertificates=getCACertificates;
 
 functionsetDefaultCACertificates(certs){
-if(!ArrayIsArray(certs)){
-thrownewERR_INVALID_ARG_TYPE('certs','Array',certs);
-}
+validateArray(certs,'certs');
 
 // Verify that all elements in the array are strings
 for(leti=0;i<certs.length;i++){

lib/internal/streams/iter/broadcast.js

@@ -33,6 +33,7 @@ const {
 }=require('internal/errors');
 const{
  validateAbortSignal,
+ validateArray,
  validateInteger,
  validateObject,
 }=require('internal/validators');
@@ -559,9 +560,7 @@ class BroadcastWriter {
 }
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constsignal=getWriterSignal(options);
 // Fast path: no signal, writer open, buffer has space
 if(this.#canUseWriteFastPath(signal)){
@@ -620,9 +619,7 @@ class BroadcastWriter {
 }
 
 writevSync(chunks){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 if(this.#isClosedOrAborted())returnfalse;
 if(!this.#broadcast[kCanWrite]())returnfalse;
 constconverted=convertChunks(chunks);

lib/internal/streams/iter/classic.js

@@ -12,7 +12,6 @@
 // toWritable(writer) -- stream/iter Writer -> classic Writable
 
 const{
- ArrayIsArray,
  ArrayPrototypePush,
  NumberMAX_SAFE_INTEGER,
  Promise,
@@ -41,6 +40,7 @@ const {
 }=require('internal/errors');
 
 const{
+ validateArray,
  validateInteger,
  validateObject,
 }=require('internal/validators');
@@ -619,9 +619,7 @@ function fromWritable(writable, options = kNullPrototype) {
 },
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 getWriterSignal(options);
 if(!isWritable()){
 returnPromiseReject(newERR_STREAM_WRITE_AFTER_END());

lib/internal/streams/iter/push.js

@@ -6,7 +6,6 @@
 // with built-in backpressure.
 
 const{
- ArrayIsArray,
  ArrayPrototypePush,
  PromisePrototypeThen,
  PromiseReject,
@@ -21,13 +20,13 @@ const {
 
 const{
 codes: {
-ERR_INVALID_ARG_TYPE,
 ERR_INVALID_STATE,
 },
 }=require('internal/errors');
 const{ lazyDOMException }=require('internal/util');
 const{
  validateAbortSignal,
+ validateArray,
  validateInteger,
 }=require('internal/validators');
 
@@ -629,9 +628,7 @@ class PushWriter {
 }
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constsignal=getWriterSignal(options);
 if(!signal&&this.#queue.canWriteSync()){
 constbytes=convertChunks(chunks);
@@ -648,9 +645,7 @@ class PushWriter {
 }
 
 writevSync(chunks){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constbytes=convertChunks(chunks);
 returnthis.#queue.writeSync(bytes);
 }

lib/internal/tls/secure-context.js

@@ -26,6 +26,7 @@ const {
 }=require('internal/util/types');
 
 const{
+ validateArray,
  validateBuffer,
  validateInt32,
  validateObject,
@@ -212,10 +213,7 @@ function configSecureContext(context, options = kEmptyObject, name = 'options')
 }
 
 if(certificateCompression!=null){
-if(!ArrayIsArray(certificateCompression)){
-thrownewERR_INVALID_ARG_TYPE(
-`${name}.certificateCompression`,'Array',certificateCompression);
-}
+validateArray(certificateCompression,`${name}.certificateCompression`);
 
 if(certificateCompression.length>0){
 // Pack length + algorithm IDs into a single Uint32 for a cheap

lib/tls.js

@@ -70,7 +70,7 @@ const { canonicalizeIP } = internalBinding('cares_wrap');
 consttlsCommon=require('internal/tls/common');
 consttlsWrap=require('internal/tls/wrap');
 const{ domainToASCII }=require('internal/url');
-const{ validateString }=require('internal/validators');
+const{validateArray,validateString }=require('internal/validators');
 
 const{
 namespace: {
@@ -206,9 +206,7 @@ function getCACertificates(type = 'default') {
 exports.getCACertificates=getCACertificates;
 
 functionsetDefaultCACertificates(certs){
-if(!ArrayIsArray(certs)){
-thrownewERR_INVALID_ARG_TYPE('certs','Array',certs);
-}
+validateArray(certs,'certs');
 
 // Verify that all elements in the array are strings
 for(leti=0;i<certs.length;i++){

lib/internal/streams/iter/broadcast.js

@@ -33,6 +33,7 @@ const {
 }=require('internal/errors');
 const{
  validateAbortSignal,
+ validateArray,
  validateInteger,
  validateObject,
 }=require('internal/validators');
@@ -559,9 +560,7 @@ class BroadcastWriter {
 }
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constsignal=getWriterSignal(options);
 // Fast path: no signal, writer open, buffer has space
 if(this.#canUseWriteFastPath(signal)){
@@ -620,9 +619,7 @@ class BroadcastWriter {
 }
 
 writevSync(chunks){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 if(this.#isClosedOrAborted())returnfalse;
 if(!this.#broadcast[kCanWrite]())returnfalse;
 constconverted=convertChunks(chunks);

lib/internal/streams/iter/classic.js

@@ -12,7 +12,6 @@
 // toWritable(writer) -- stream/iter Writer -> classic Writable
 
 const{
- ArrayIsArray,
  ArrayPrototypePush,
  NumberMAX_SAFE_INTEGER,
  Promise,
@@ -41,6 +40,7 @@ const {
 }=require('internal/errors');
 
 const{
+ validateArray,
  validateInteger,
  validateObject,
 }=require('internal/validators');
@@ -619,9 +619,7 @@ function fromWritable(writable, options = kNullPrototype) {
 },
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 getWriterSignal(options);
 if(!isWritable()){
 returnPromiseReject(newERR_STREAM_WRITE_AFTER_END());

lib/internal/streams/iter/push.js

@@ -6,7 +6,6 @@
 // with built-in backpressure.
 
 const{
- ArrayIsArray,
  ArrayPrototypePush,
  PromisePrototypeThen,
  PromiseReject,
@@ -21,13 +20,13 @@ const {
 
 const{
 codes: {
-ERR_INVALID_ARG_TYPE,
 ERR_INVALID_STATE,
 },
 }=require('internal/errors');
 const{ lazyDOMException }=require('internal/util');
 const{
  validateAbortSignal,
+ validateArray,
  validateInteger,
 }=require('internal/validators');
 
@@ -629,9 +628,7 @@ class PushWriter {
 }
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constsignal=getWriterSignal(options);
 if(!signal&&this.#queue.canWriteSync()){
 constbytes=convertChunks(chunks);
@@ -648,9 +645,7 @@ class PushWriter {
 }
 
 writevSync(chunks){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constbytes=convertChunks(chunks);
 returnthis.#queue.writeSync(bytes);
 }

lib/internal/tls/secure-context.js

@@ -26,6 +26,7 @@ const {
 }=require('internal/util/types');
 
 const{
+ validateArray,
  validateBuffer,
  validateInt32,
  validateObject,
@@ -212,10 +213,7 @@ function configSecureContext(context, options = kEmptyObject, name = 'options')
 }
 
 if(certificateCompression!=null){
-if(!ArrayIsArray(certificateCompression)){
-thrownewERR_INVALID_ARG_TYPE(
-`${name}.certificateCompression`,'Array',certificateCompression);
-}
+validateArray(certificateCompression,`${name}.certificateCompression`);
 
 if(certificateCompression.length>0){
 // Pack length + algorithm IDs into a single Uint32 for a cheap

lib/tls.js

@@ -70,7 +70,7 @@ const { canonicalizeIP } = internalBinding('cares_wrap');
 consttlsCommon=require('internal/tls/common');
 consttlsWrap=require('internal/tls/wrap');
 const{ domainToASCII }=require('internal/url');
-const{ validateString }=require('internal/validators');
+const{validateArray,validateString }=require('internal/validators');
 
 const{
 namespace: {
@@ -206,9 +206,7 @@ function getCACertificates(type = 'default') {
 exports.getCACertificates=getCACertificates;
 
 functionsetDefaultCACertificates(certs){
-if(!ArrayIsArray(certs)){
-thrownewERR_INVALID_ARG_TYPE('certs','Array',certs);
-}
+validateArray(certs,'certs');
 
 // Verify that all elements in the array are strings
 for(leti=0;i<certs.length;i++){

lib/internal/streams/iter/broadcast.js

@@ -33,6 +33,7 @@ const {
 }=require('internal/errors');
 const{
  validateAbortSignal,
+ validateArray,
  validateInteger,
  validateObject,
 }=require('internal/validators');
@@ -559,9 +560,7 @@ class BroadcastWriter {
 }
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constsignal=getWriterSignal(options);
 // Fast path: no signal, writer open, buffer has space
 if(this.#canUseWriteFastPath(signal)){
@@ -620,9 +619,7 @@ class BroadcastWriter {
 }
 
 writevSync(chunks){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 if(this.#isClosedOrAborted())returnfalse;
 if(!this.#broadcast[kCanWrite]())returnfalse;
 constconverted=convertChunks(chunks);

lib/internal/streams/iter/classic.js

@@ -12,7 +12,6 @@
 // toWritable(writer) -- stream/iter Writer -> classic Writable
 
 const{
- ArrayIsArray,
  ArrayPrototypePush,
  NumberMAX_SAFE_INTEGER,
  Promise,
@@ -41,6 +40,7 @@ const {
 }=require('internal/errors');
 
 const{
+ validateArray,
  validateInteger,
  validateObject,
 }=require('internal/validators');
@@ -619,9 +619,7 @@ function fromWritable(writable, options = kNullPrototype) {
 },
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 getWriterSignal(options);
 if(!isWritable()){
 returnPromiseReject(newERR_STREAM_WRITE_AFTER_END());

lib/internal/streams/iter/push.js

@@ -6,7 +6,6 @@
 // with built-in backpressure.
 
 const{
- ArrayIsArray,
  ArrayPrototypePush,
  PromisePrototypeThen,
  PromiseReject,
@@ -21,13 +20,13 @@ const {
 
 const{
 codes: {
-ERR_INVALID_ARG_TYPE,
 ERR_INVALID_STATE,
 },
 }=require('internal/errors');
 const{ lazyDOMException }=require('internal/util');
 const{
  validateAbortSignal,
+ validateArray,
  validateInteger,
 }=require('internal/validators');
 
@@ -629,9 +628,7 @@ class PushWriter {
 }
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constsignal=getWriterSignal(options);
 if(!signal&&this.#queue.canWriteSync()){
 constbytes=convertChunks(chunks);
@@ -648,9 +645,7 @@ class PushWriter {
 }
 
 writevSync(chunks){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constbytes=convertChunks(chunks);
 returnthis.#queue.writeSync(bytes);
 }

lib/internal/tls/secure-context.js

@@ -26,6 +26,7 @@ const {
 }=require('internal/util/types');
 
 const{
+ validateArray,
  validateBuffer,
  validateInt32,
  validateObject,
@@ -212,10 +213,7 @@ function configSecureContext(context, options = kEmptyObject, name = 'options')
 }
 
 if(certificateCompression!=null){
-if(!ArrayIsArray(certificateCompression)){
-thrownewERR_INVALID_ARG_TYPE(
-`${name}.certificateCompression`,'Array',certificateCompression);
-}
+validateArray(certificateCompression,`${name}.certificateCompression`);
 
 if(certificateCompression.length>0){
 // Pack length + algorithm IDs into a single Uint32 for a cheap

lib/tls.js

@@ -70,7 +70,7 @@ const { canonicalizeIP } = internalBinding('cares_wrap');
 consttlsCommon=require('internal/tls/common');
 consttlsWrap=require('internal/tls/wrap');
 const{ domainToASCII }=require('internal/url');
-const{ validateString }=require('internal/validators');
+const{validateArray,validateString }=require('internal/validators');
 
 const{
 namespace: {
@@ -206,9 +206,7 @@ function getCACertificates(type = 'default') {
 exports.getCACertificates=getCACertificates;
 
 functionsetDefaultCACertificates(certs){
-if(!ArrayIsArray(certs)){
-thrownewERR_INVALID_ARG_TYPE('certs','Array',certs);
-}
+validateArray(certs,'certs');
 
 // Verify that all elements in the array are strings
 for(leti=0;i<certs.length;i++){

lib/internal/streams/iter/broadcast.js

@@ -33,6 +33,7 @@ const {
 }=require('internal/errors');
 const{
  validateAbortSignal,
+ validateArray,
  validateInteger,
  validateObject,
 }=require('internal/validators');
@@ -559,9 +560,7 @@ class BroadcastWriter {
 }
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constsignal=getWriterSignal(options);
 // Fast path: no signal, writer open, buffer has space
 if(this.#canUseWriteFastPath(signal)){
@@ -620,9 +619,7 @@ class BroadcastWriter {
 }
 
 writevSync(chunks){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 if(this.#isClosedOrAborted())returnfalse;
 if(!this.#broadcast[kCanWrite]())returnfalse;
 constconverted=convertChunks(chunks);

lib/internal/streams/iter/classic.js

@@ -12,7 +12,6 @@
 // toWritable(writer) -- stream/iter Writer -> classic Writable
 
 const{
- ArrayIsArray,
  ArrayPrototypePush,
  NumberMAX_SAFE_INTEGER,
  Promise,
@@ -41,6 +40,7 @@ const {
 }=require('internal/errors');
 
 const{
+ validateArray,
  validateInteger,
  validateObject,
 }=require('internal/validators');
@@ -619,9 +619,7 @@ function fromWritable(writable, options = kNullPrototype) {
 },
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 getWriterSignal(options);
 if(!isWritable()){
 returnPromiseReject(newERR_STREAM_WRITE_AFTER_END());

lib/internal/streams/iter/push.js

@@ -6,7 +6,6 @@
 // with built-in backpressure.
 
 const{
- ArrayIsArray,
  ArrayPrototypePush,
  PromisePrototypeThen,
  PromiseReject,
@@ -21,13 +20,13 @@ const {
 
 const{
 codes: {
-ERR_INVALID_ARG_TYPE,
 ERR_INVALID_STATE,
 },
 }=require('internal/errors');
 const{ lazyDOMException }=require('internal/util');
 const{
  validateAbortSignal,
+ validateArray,
  validateInteger,
 }=require('internal/validators');
 
@@ -629,9 +628,7 @@ class PushWriter {
 }
 
 writev(chunks,options){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constsignal=getWriterSignal(options);
 if(!signal&&this.#queue.canWriteSync()){
 constbytes=convertChunks(chunks);
@@ -648,9 +645,7 @@ class PushWriter {
 }
 
 writevSync(chunks){
-if(!ArrayIsArray(chunks)){
-thrownewERR_INVALID_ARG_TYPE('chunks','Array',chunks);
-}
+validateArray(chunks,'chunks');
 constbytes=convertChunks(chunks);
 returnthis.#queue.writeSync(bytes);
 }

lib/internal/tls/secure-context.js

@@ -26,6 +26,7 @@ const {
 }=require('internal/util/types');
 
 const{
+ validateArray,
  validateBuffer,
  validateInt32,
  validateObject,
@@ -212,10 +213,7 @@ function configSecureContext(context, options = kEmptyObject, name = 'options')
 }
 
 if(certificateCompression!=null){
-if(!ArrayIsArray(certificateCompression)){
-thrownewERR_INVALID_ARG_TYPE(
-`${name}.certificateCompression`,'Array',certificateCompression);
-}
+validateArray(certificateCompression,`${name}.certificateCompression`);
 
 if(certificateCompression.length>0){
 // Pack length + algorithm IDs into a single Uint32 for a cheap

lib/tls.js

@@ -70,7 +70,7 @@ const { canonicalizeIP } = internalBinding('cares_wrap');
 consttlsCommon=require('internal/tls/common');
 consttlsWrap=require('internal/tls/wrap');
 const{ domainToASCII }=require('internal/url');
-const{ validateString }=require('internal/validators');
+const{validateArray,validateString }=require('internal/validators');
 
 const{
 namespace: {
@@ -206,9 +206,7 @@ function getCACertificates(type = 'default') {
 exports.getCACertificates=getCACertificates;
 
 functionsetDefaultCACertificates(certs){
-if(!ArrayIsArray(certs)){
-thrownewERR_INVALID_ARG_TYPE('certs','Array',certs);
-}
+validateArray(certs,'certs');
 
 // Verify that all elements in the array are strings
 for(leti=0;i<certs.length;i++){