Merge pull request #402 from docker/dependabot/npm_and_yarn/undici-5.28.4
chore(deps): Bump undici from 5.28.3 to 5.28.4
This commit is contained in:
3 files changed
+6
-6
No files matched your search
+2
-2
@@ -40,8 +40,8 @@ hooks.version="2.30.1";setHookCallback(createLocal);hooks.fn=Ye;hooks.min=min;ho
|
||||
*
|
||||
* MIT Licensed
|
||||
*/
|
||||
const a=o(57147);const i=o(22037);const p=o(71017);const c=o(6113);const d={fs:a.constants,os:i.constants};const A="0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz",l=/XXXXXX/,u=3,b=(d.O_CREAT||d.fs.O_CREAT)|(d.O_EXCL||d.fs.O_EXCL)|(d.O_RDWR||d.fs.O_RDWR),M=i.platform()==="win32",m=d.EBADF||d.os.errno.EBADF,z=d.ENOENT||d.os.errno.ENOENT,O=448,h=384,g="exit",E=[],q=a.rmdirSync.bind(a);let y=false;function rimraf(t,r){return a.rm(t,{recursive:true},r)}function FN_RIMRAF_SYNC(t){return a.rmSync(t,{recursive:true})}function tmpName(t,r){const o=_parseArguments(t,r),i=o[0],p=o[1];try{_assertAndSanitizeOptions(i)}catch(t){return p(t)}let c=i.tries;(function _getUniqueName(){try{const t=_generateTmpName(i);a.stat(t,(function(r){if(!r){if(c-- >0)return _getUniqueName();return p(new Error("Could not get a unique tmp filename, max tries reached "+t))}p(null,t)}))}catch(t){p(t)}})()}function tmpNameSync(t){const r=_parseArguments(t),o=r[0];_assertAndSanitizeOptions(o);let i=o.tries;do{const t=_generateTmpName(o);try{a.statSync(t)}catch(r){return t}}while(i-- >0);throw new Error("Could not get a unique tmp filename, max tries reached")}function file(t,r){const o=_parseArguments(t,r),i=o[0],p=o[1];tmpName(i,(function _tmpNameCreated(t,r){if(t)return p(t);a.open(r,b,i.mode||h,(function _fileCreated(t,o){if(t)return p(t);if(i.discardDescriptor){return a.close(o,(function _discardCallback(t){return p(t,r,undefined,_prepareTmpFileRemoveCallback(r,-1,i,false))}))}else{const t=i.discardDescriptor||i.detachDescriptor;p(null,r,o,_prepareTmpFileRemoveCallback(r,t?-1:o,i,false))}}))}))}function fileSync(t){const r=_parseArguments(t),o=r[0];const i=o.discardDescriptor||o.detachDescriptor;const p=tmpNameSync(o);var c=a.openSync(p,b,o.mode||h);if(o.discardDescriptor){a.closeSync(c);c=undefined}return{name:p,fd:c,removeCallback:_prepareTmpFileRemoveCallback(p,i?-1:c,o,true)}}function dir(t,r){const o=_parseArguments(t,r),i=o[0],p=o[1];tmpName(i,(function _tmpNameCreated(t,r){if(t)return p(t);a.mkdir(r,i.mode||O,(function _dirCreated(t){if(t)return p(t);p(null,r,_prepareTmpDirRemoveCallback(r,i,false))}))}))}function dirSync(t){const r=_parseArguments(t),o=r[0];const i=tmpNameSync(o);a.mkdirSync(i,o.mode||O);return{name:i,removeCallback:_prepareTmpDirRemoveCallback(i,o,true)}}function _removeFileAsync(t,r){const _handler=function(t){if(t&&!_isENOENT(t)){return r(t)}r()};if(0<=t[0])a.close(t[0],(function(){a.unlink(t[1],_handler)}));else a.unlink(t[1],_handler)}function _removeFileSync(t){let r=null;try{if(0<=t[0])a.closeSync(t[0])}catch(t){if(!_isEBADF(t)&&!_isENOENT(t))throw t}finally{try{a.unlinkSync(t[1])}catch(t){if(!_isENOENT(t))r=t}}if(r!==null){throw r}}function _prepareTmpFileRemoveCallback(t,r,o,a){const i=_prepareRemoveCallback(_removeFileSync,[r,t],a);const p=_prepareRemoveCallback(_removeFileAsync,[r,t],a,i);if(!o.keep)E.unshift(i);return a?i:p}function _prepareTmpDirRemoveCallback(t,r,o){const i=r.unsafeCleanup?rimraf:a.rmdir.bind(a);const p=r.unsafeCleanup?FN_RIMRAF_SYNC:q;const c=_prepareRemoveCallback(p,t,o);const d=_prepareRemoveCallback(i,t,o,c);if(!r.keep)E.unshift(c);return o?c:d}function _prepareRemoveCallback(t,r,o,a){let i=false;return function _cleanupCallback(p){if(!i){const c=a||_cleanupCallback;const d=E.indexOf(c);if(d>=0)E.splice(d,1);i=true;if(o||t===q||t===FN_RIMRAF_SYNC){return t(r)}else{return t(r,p||function(){})}}}}function _garbageCollector(){if(!y)return;while(E.length){try{E[0]()}catch(t){}}}function _randomChars(t){let r=[],o=null;try{o=c.randomBytes(t)}catch(r){o=c.pseudoRandomBytes(t)}for(var a=0;a<t;a++){r.push(A[o[a]%A.length])}return r.join("")}function _isBlank(t){return t===null||_isUndefined(t)||!t.trim()}function _isUndefined(t){return typeof t==="undefined"}function _parseArguments(t,r){if(typeof t==="function"){return[{},t]}if(_isUndefined(t)){return[{},r]}const o={};for(const r of Object.getOwnPropertyNames(t)){o[r]=t[r]}return[o,r]}function _generateTmpName(t){const r=t.tmpdir;if(!_isUndefined(t.name))return p.join(r,t.dir,t.name);if(!_isUndefined(t.template))return p.join(r,t.dir,t.template).replace(l,_randomChars(6));const o=[t.prefix?t.prefix:"tmp","-",process.pid,"-",_randomChars(12),t.postfix?"-"+t.postfix:""].join("");return p.join(r,t.dir,o)}function _assertAndSanitizeOptions(t){t.tmpdir=_getTmpDir(t);const r=t.tmpdir;if(!_isUndefined(t.name))_assertIsRelative(t.name,"name",r);if(!_isUndefined(t.dir))_assertIsRelative(t.dir,"dir",r);if(!_isUndefined(t.template)){_assertIsRelative(t.template,"template",r);if(!t.template.match(l))throw new Error(`Invalid template, found "${t.template}".`)}if(!_isUndefined(t.tries)&&isNaN(t.tries)||t.tries<0)throw new Error(`Invalid tries, found "${t.tries}".`);t.tries=_isUndefined(t.name)?t.tries||u:1;t.keep=!!t.keep;t.detachDescriptor=!!t.detachDescriptor;t.discardDescriptor=!!t.discardDescriptor;t.unsafeCleanup=!!t.unsafeCleanup;t.dir=_isUndefined(t.dir)?"":p.relative(r,_resolvePath(t.dir,r));t.template=_isUndefined(t.template)Line truncated
|
||||
/*! formdata-polyfill. MIT License. Jimmy Wärting <https://jimmy.warting.se/opensource> */;const escape=t=>t.replace(/\n/g,"%0A").replace(/\r/g,"%0D").replace(/"/g,"%22");const normalizeLinefeeds=t=>t.replace(/\r?\n|\r/g,"\r\n");const a=[];const i=new Uint8Array([13,10]);b=0;let p=false;for(const[r,c]of t){if(typeof c==="string"){const t=w.encode(o+`; name="${escape(normalizeLinefeeds(r))}"`+`\r\n\r\n${normalizeLinefeeds(c)}\r\n`);a.push(t);b+=t.byteLength}else{const t=w.encode(`${o}; name="${escape(normalizeLinefeeds(r))}"`+(c.name?`; filename="${escape(c.name)}"`:"")+"\r\n"+`Content-Type: ${c.type||"application/octet-stream"}\r\n\r\n`);a.push(t,c,i);if(typeof c.size==="number"){b+=t.byteLength+c.size+i.byteLength}else{p=true}}}const c=w.encode(`--${r}--`);a.push(c);b+=c.byteLength;if(p){b=null}u=t;l=async function*(){for(const t of a){if(t.stream){yield*t.stream()}else{yield t}}};M="multipart/form-data; boundary="+r}else if(c(t)){u=t;b=t.size;if(t.type){M=t.type}}else if(typeof t[Symbol.asyncIterator]==="function"){if(r){throw new TypeError("keepalive")}if(i.isDisturbed(t)||t.locked){throw new TypeError("Response body object should not be disturbed or locked")}a=t instanceof N?t:p(t)}if(typeof u==="string"||i.isBuffer(u)){b=Buffer.byteLength(u)}if(l!=null){let r;a=new N({async start(){r=l(t)[Symbol.asyncIterator]()},async pull(t){const{value:o,done:i}=await r.next();if(i){queueMicrotask((()=>{t.close()}))}else{if(!y(a)){t.enqueue(new Uint8Array(o))}}return t.desiredSize>0},async cancel(t){await r.return()},type:undefined})}const m={stream:a,source:u,length:b};return[m,M]}function safelyExtractBody(t,r=false){if(!N){N=o(35356).ReadableStream}if(t instanceof N){q(!i.isDisturbed(t),"The body has already been consumed.");q(!t.locked,"The stream is locked.")}return extractBody(t,r)}function cloneBody(t){const[r,o]=t.stream.tee();const a=O(o,{transfer:[o]});const[,i]=a.tee();t.stream=r;return{stream:i,length:t.length,source:t.source}}async function*consumeBody(t){if(t){if(C(t)){yield t}else{const r=t.stream;if(i.isDisturbed(r)){throw new TypeError("The body has already been consumed.")}if(r.locked){throw new TypeError("The stream is locked.")}r[E]=true;yield*r}}}function throwIfAborted(t){if(t.aborted){throw new z("The operation was aborted.","AbortError")}}function bodyMixinMethods(t){const r={blob(){return specConsumeBody(this,(t=>{let r=bodyMimeType(this);if(r==="failure"){r=""}else if(r){r=I(r)}return new h([t],{type:r})}),t)},arrayBuffer(){return specConsumeBody(this,(t=>new Uint8Array(t).buffer),t)},text(){return specConsumeBody(this,utf8DecodeBytes,t)},json(){return specConsumeBody(this,parseJSONFromBytes,t)},async formData(){m.brandCheck(this,t);throwIfAborted(this[M]);const r=this.headers.get("Content-Type");if(/multipart\/form-data/.test(r)){const t={};for(const[r,o]of this.headers)t[r.toLowerCase()]=o;const r=new b;let o;try{o=new a({headers:t,preservePath:true})}catch(t){throw new z(`${t}`,"AbortError")}o.on("field",((t,o)=>{r.append(t,o)}));o.on("file",((t,o,a,i,p)=>{const c=[];if(i==="base64"||i.toLowerCase()==="base64"){let i="";o.on("data",(t=>{i+=t.toString().replace(/[\r\n]/gm,"");const r=i.length-i.length%4;c.push(Buffer.from(i.slice(0,r),"base64"));i=i.slice(r)}));o.on("end",(()=>{c.push(Buffer.from(i,"base64"));r.append(t,new W(c,a,{type:p}))}))}else{o.on("data",(t=>{c.push(t)}));o.on("end",(()=>{r.append(t,new W(c,a,{type:p}))}))}}));const i=new Promise(((t,r)=>{o.on("finish",t);o.on("error",(t=>r(new TypeError(t))))}));if(this.body!==null)for await(const t of consumeBody(this[M].body))o.write(t);o.end();await i;return r}else if(/application\/x-www-form-urlencoded/.test(r)){let t;try{let r="";const o=new TextDecoder("utf-8",{ignoreBOM:true});for await(const t of consumeBody(this[M].body)){if(!C(t)){throw new TypeError("Expected Uint8Array chunk")}r+=o.decode(t,{stream:true})}r+=o.decode();t=new URLSearchParams(r)}catch(t){throw Object.assign(new TypeError,{cause:t})}const r=new b;for(const[o,a]of t){r.append(o,a)}return r}else{await Promise.resolve();throwIfAborted(this[M]);throw m.errors.exception({header:`${t.name}.formData`,message:"Could not parse content as FormData."})}}};return r}function mixinBody(t){Object.assign(t.prototype,bodyMixinMethods(t))}async function specConsumeBody(t,r,o){m.brandCheck(t,o);throwIfAborted(t[M]);if(bodyUnusable(t[M].body)){throw new TypeError("Body is unusable")}const a=l();const errorSteps=t=>a.reject(t);const successSteps=t=>{try{a.resolve(r(t))}catch(t){errorSteps(t)}};if(t[M].body==null){successSteps(new Uint8Array);return a.promise}await u(t[M].body,successSteps,errorSteps);return a.promise}function bodyUnusable(t){return t!=null&&(t.stream.locked||i.isDisturbed(t.stream))}function utf8DecodeBytes(t){if(t.length===0){return""}if(t[0]===239&&t[1]===187&&t[2]===191){t=t.subarray(3)}const r=S.decode(t);return r}function parseJSONFromBytes(t){return JSON.parse(utf8DecodeBytes(t))}function bodyMimeType(t){const{headersList:r}=t[M];const o=r.get("contentLine truncated
|
||||
const a=o(57147);const i=o(22037);const p=o(71017);const c=o(6113);const d={fs:a.constants,os:i.constants};const A="0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz",l=/XXXXXX/,u=3,b=(d.O_CREAT||d.fs.O_CREAT)|(d.O_EXCL||d.fs.O_EXCL)|(d.O_RDWR||d.fs.O_RDWR),M=i.platform()==="win32",m=d.EBADF||d.os.errno.EBADF,z=d.ENOENT||d.os.errno.ENOENT,O=448,h=384,g="exit",E=[],q=a.rmdirSync.bind(a);let y=false;function rimraf(t,r){return a.rm(t,{recursive:true},r)}function FN_RIMRAF_SYNC(t){return a.rmSync(t,{recursive:true})}function tmpName(t,r){const o=_parseArguments(t,r),i=o[0],p=o[1];try{_assertAndSanitizeOptions(i)}catch(t){return p(t)}let c=i.tries;(function _getUniqueName(){try{const t=_generateTmpName(i);a.stat(t,(function(r){if(!r){if(c-- >0)return _getUniqueName();return p(new Error("Could not get a unique tmp filename, max tries reached "+t))}p(null,t)}))}catch(t){p(t)}})()}function tmpNameSync(t){const r=_parseArguments(t),o=r[0];_assertAndSanitizeOptions(o);let i=o.tries;do{const t=_generateTmpName(o);try{a.statSync(t)}catch(r){return t}}while(i-- >0);throw new Error("Could not get a unique tmp filename, max tries reached")}function file(t,r){const o=_parseArguments(t,r),i=o[0],p=o[1];tmpName(i,(function _tmpNameCreated(t,r){if(t)return p(t);a.open(r,b,i.mode||h,(function _fileCreated(t,o){if(t)return p(t);if(i.discardDescriptor){return a.close(o,(function _discardCallback(t){return p(t,r,undefined,_prepareTmpFileRemoveCallback(r,-1,i,false))}))}else{const t=i.discardDescriptor||i.detachDescriptor;p(null,r,o,_prepareTmpFileRemoveCallback(r,t?-1:o,i,false))}}))}))}function fileSync(t){const r=_parseArguments(t),o=r[0];const i=o.discardDescriptor||o.detachDescriptor;const p=tmpNameSync(o);var c=a.openSync(p,b,o.mode||h);if(o.discardDescriptor){a.closeSync(c);c=undefined}return{name:p,fd:c,removeCallback:_prepareTmpFileRemoveCallback(p,i?-1:c,o,true)}}function dir(t,r){const o=_parseArguments(t,r),i=o[0],p=o[1];tmpName(i,(function _tmpNameCreated(t,r){if(t)return p(t);a.mkdir(r,i.mode||O,(function _dirCreated(t){if(t)return p(t);p(null,r,_prepareTmpDirRemoveCallback(r,i,false))}))}))}function dirSync(t){const r=_parseArguments(t),o=r[0];const i=tmpNameSync(o);a.mkdirSync(i,o.mode||O);return{name:i,removeCallback:_prepareTmpDirRemoveCallback(i,o,true)}}function _removeFileAsync(t,r){const _handler=function(t){if(t&&!_isENOENT(t)){return r(t)}r()};if(0<=t[0])a.close(t[0],(function(){a.unlink(t[1],_handler)}));else a.unlink(t[1],_handler)}function _removeFileSync(t){let r=null;try{if(0<=t[0])a.closeSync(t[0])}catch(t){if(!_isEBADF(t)&&!_isENOENT(t))throw t}finally{try{a.unlinkSync(t[1])}catch(t){if(!_isENOENT(t))r=t}}if(r!==null){throw r}}function _prepareTmpFileRemoveCallback(t,r,o,a){const i=_prepareRemoveCallback(_removeFileSync,[r,t],a);const p=_prepareRemoveCallback(_removeFileAsync,[r,t],a,i);if(!o.keep)E.unshift(i);return a?i:p}function _prepareTmpDirRemoveCallback(t,r,o){const i=r.unsafeCleanup?rimraf:a.rmdir.bind(a);const p=r.unsafeCleanup?FN_RIMRAF_SYNC:q;const c=_prepareRemoveCallback(p,t,o);const d=_prepareRemoveCallback(i,t,o,c);if(!r.keep)E.unshift(c);return o?c:d}function _prepareRemoveCallback(t,r,o,a){let i=false;return function _cleanupCallback(p){if(!i){const c=a||_cleanupCallback;const d=E.indexOf(c);if(d>=0)E.splice(d,1);i=true;if(o||t===q||t===FN_RIMRAF_SYNC){return t(r)}else{return t(r,p||function(){})}}}}function _garbageCollector(){if(!y)return;while(E.length){try{E[0]()}catch(t){}}}function _randomChars(t){let r=[],o=null;try{o=c.randomBytes(t)}catch(r){o=c.pseudoRandomBytes(t)}for(var a=0;a<t;a++){r.push(A[o[a]%A.length])}return r.join("")}function _isBlank(t){return t===null||_isUndefined(t)||!t.trim()}function _isUndefined(t){return typeof t==="undefined"}function _parseArguments(t,r){if(typeof t==="function"){return[{},t]}if(_isUndefined(t)){return[{},r]}const o={};for(const r of Object.getOwnPropertyNames(t)){o[r]=t[r]}return[o,r]}function _generateTmpName(t){const r=t.tmpdir;if(!_isUndefined(t.name))return p.join(r,t.dir,t.name);if(!_isUndefined(t.template))return p.join(r,t.dir,t.template).replace(l,_randomChars(6));const o=[t.prefix?t.prefix:"tmp","-",process.pid,"-",_randomChars(12),t.postfix?"-"+t.postfix:""].join("");return p.join(r,t.dir,o)}function _assertAndSanitizeOptions(t){t.tmpdir=_getTmpDir(t);const r=t.tmpdir;if(!_isUndefined(t.name))_assertIsRelative(t.name,"name",r);if(!_isUndefined(t.dir))_assertIsRelative(t.dir,"dir",r);if(!_isUndefined(t.template)){_assertIsRelative(t.template,"template",r);if(!t.template.match(l))throw new Error(`Invalid template, found "${t.template}".`)}if(!_isUndefined(t.tries)&&isNaN(t.tries)||t.tries<0)throw new Error(`Invalid tries, found "${t.tries}".`);t.tries=_isUndefined(t.name)?t.tries||u:1;t.keep=!!t.keep;t.detachDescriptor=!!t.detachDescriptor;t.discardDescriptor=!!t.discardDescriptor;t.unsafeCleanup=!!t.unsafeCleanup;t.dir=_isUndefined(t.dir)?"":p.relative(r,_resolvePath(t.dir,r));t.template=_isUndefined(t.template)Line truncated
|
||||
/*! formdata-polyfill. MIT License. Jimmy Wärting <https://jimmy.warting.se/opensource> */;const escape=t=>t.replace(/\n/g,"%0A").replace(/\r/g,"%0D").replace(/"/g,"%22");const normalizeLinefeeds=t=>t.replace(/\r?\n|\r/g,"\r\n");const a=[];const i=new Uint8Array([13,10]);b=0;let p=false;for(const[r,c]of t){if(typeof c==="string"){const t=w.encode(o+`; name="${escape(normalizeLinefeeds(r))}"`+`\r\n\r\n${normalizeLinefeeds(c)}\r\n`);a.push(t);b+=t.byteLength}else{const t=w.encode(`${o}; name="${escape(normalizeLinefeeds(r))}"`+(c.name?`; filename="${escape(c.name)}"`:"")+"\r\n"+`Content-Type: ${c.type||"application/octet-stream"}\r\n\r\n`);a.push(t,c,i);if(typeof c.size==="number"){b+=t.byteLength+c.size+i.byteLength}else{p=true}}}const c=w.encode(`--${r}--`);a.push(c);b+=c.byteLength;if(p){b=null}u=t;l=async function*(){for(const t of a){if(t.stream){yield*t.stream()}else{yield t}}};M="multipart/form-data; boundary="+r}else if(c(t)){u=t;b=t.size;if(t.type){M=t.type}}else if(typeof t[Symbol.asyncIterator]==="function"){if(r){throw new TypeError("keepalive")}if(i.isDisturbed(t)||t.locked){throw new TypeError("Response body object should not be disturbed or locked")}a=t instanceof N?t:p(t)}if(typeof u==="string"||i.isBuffer(u)){b=Buffer.byteLength(u)}if(l!=null){let r;a=new N({async start(){r=l(t)[Symbol.asyncIterator]()},async pull(t){const{value:o,done:i}=await r.next();if(i){queueMicrotask((()=>{t.close()}))}else{if(!y(a)){t.enqueue(new Uint8Array(o))}}return t.desiredSize>0},async cancel(t){await r.return()},type:undefined})}const m={stream:a,source:u,length:b};return[m,M]}function safelyExtractBody(t,r=false){if(!N){N=o(35356).ReadableStream}if(t instanceof N){q(!i.isDisturbed(t),"The body has already been consumed.");q(!t.locked,"The stream is locked.")}return extractBody(t,r)}function cloneBody(t){const[r,o]=t.stream.tee();const a=O(o,{transfer:[o]});const[,i]=a.tee();t.stream=r;return{stream:i,length:t.length,source:t.source}}async function*consumeBody(t){if(t){if(C(t)){yield t}else{const r=t.stream;if(i.isDisturbed(r)){throw new TypeError("The body has already been consumed.")}if(r.locked){throw new TypeError("The stream is locked.")}r[E]=true;yield*r}}}function throwIfAborted(t){if(t.aborted){throw new z("The operation was aborted.","AbortError")}}function bodyMixinMethods(t){const r={blob(){return specConsumeBody(this,(t=>{let r=bodyMimeType(this);if(r==="failure"){r=""}else if(r){r=I(r)}return new h([t],{type:r})}),t)},arrayBuffer(){return specConsumeBody(this,(t=>new Uint8Array(t).buffer),t)},text(){return specConsumeBody(this,utf8DecodeBytes,t)},json(){return specConsumeBody(this,parseJSONFromBytes,t)},async formData(){m.brandCheck(this,t);throwIfAborted(this[M]);const r=this.headers.get("Content-Type");if(/multipart\/form-data/.test(r)){const t={};for(const[r,o]of this.headers)t[r.toLowerCase()]=o;const r=new b;let o;try{o=new a({headers:t,preservePath:true})}catch(t){throw new z(`${t}`,"AbortError")}o.on("field",((t,o)=>{r.append(t,o)}));o.on("file",((t,o,a,i,p)=>{const c=[];if(i==="base64"||i.toLowerCase()==="base64"){let i="";o.on("data",(t=>{i+=t.toString().replace(/[\r\n]/gm,"");const r=i.length-i.length%4;c.push(Buffer.from(i.slice(0,r),"base64"));i=i.slice(r)}));o.on("end",(()=>{c.push(Buffer.from(i,"base64"));r.append(t,new W(c,a,{type:p}))}))}else{o.on("data",(t=>{c.push(t)}));o.on("end",(()=>{r.append(t,new W(c,a,{type:p}))}))}}));const i=new Promise(((t,r)=>{o.on("finish",t);o.on("error",(t=>r(new TypeError(t))))}));if(this.body!==null)for await(const t of consumeBody(this[M].body))o.write(t);o.end();await i;return r}else if(/application\/x-www-form-urlencoded/.test(r)){let t;try{let r="";const o=new TextDecoder("utf-8",{ignoreBOM:true});for await(const t of consumeBody(this[M].body)){if(!C(t)){throw new TypeError("Expected Uint8Array chunk")}r+=o.decode(t,{stream:true})}r+=o.decode();t=new URLSearchParams(r)}catch(t){throw Object.assign(new TypeError,{cause:t})}const r=new b;for(const[o,a]of t){r.append(o,a)}return r}else{await Promise.resolve();throwIfAborted(this[M]);throw m.errors.exception({header:`${t.name}.formData`,message:"Could not parse content as FormData."})}}};return r}function mixinBody(t){Object.assign(t.prototype,bodyMixinMethods(t))}async function specConsumeBody(t,r,o){m.brandCheck(t,o);throwIfAborted(t[M]);if(bodyUnusable(t[M].body)){throw new TypeError("Body is unusable")}const a=l();const errorSteps=t=>a.reject(t);const successSteps=t=>{try{a.resolve(r(t))}catch(t){errorSteps(t)}};if(t[M].body==null){successSteps(new Uint8Array);return a.promise}await u(t[M].body,successSteps,errorSteps);return a.promise}function bodyUnusable(t){return t!=null&&(t.stream.locked||i.isDisturbed(t.stream))}function utf8DecodeBytes(t){if(t.length===0){return""}if(t[0]===239&&t[1]===187&&t[2]===191){t=t.subarray(3)}const r=S.decode(t);return r}function parseJSONFromBytes(t){return JSON.parse(utf8DecodeBytes(t))}function bodyMimeType(t){const{headersList:r}=t[M];const o=r.get("contentLine truncated
|
||||
/*! ws. MIT License. Einar Otto Stangvik <einaros@gmail.com> */p[i-4]=this.maskKey[0];p[i-3]=this.maskKey[1];p[i-2]=this.maskKey[2];p[i-1]=this.maskKey[3];p[1]=o;if(o===126){p.writeUInt16BE(r,2)}else if(o===127){p[2]=p[3]=0;p.writeUIntBE(r,4,6)}p[1]|=128;for(let t=0;t<r;t++){p[i+t]=this.frameData[t]^this.maskKey[t%4]}return p}}t.exports={WebsocketFrameSend:WebsocketFrameSend}},11688:(t,r,o)=>{"use strict";const{Writable:a}=o(12781);const i=o(67643);const{parserStates:p,opcodes:c,states:d,emptyBuffer:A}=o(19188);const{kReadyState:l,kSentClose:u,kResponse:b,kReceivedClose:M}=o(37578);const{isValidStatusCode:m,failWebsocketConnection:z,websocketMessageReceived:O}=o(25515);const{WebsocketFrameSend:h}=o(25444);const g={};g.ping=i.channel("undici:websocket:ping");g.pong=i.channel("undici:websocket:pong");class ByteParser extends a{#i=[];#s=0;#p=p.INFO;#c={};#d=[];constructor(t){super();this.ws=t}_write(t,r,o){this.#i.push(t);this.#s+=t.length;this.run(o)}run(t){while(true){if(this.#p===p.INFO){if(this.#s<2){return t()}const r=this.consume(2);this.#c.fin=(r[0]&128)!==0;this.#c.opcode=r[0]&15;this.#c.originalOpcode??=this.#c.opcode;this.#c.fragmented=!this.#c.fin&&this.#c.opcode!==c.CONTINUATION;if(this.#c.fragmented&&this.#c.opcode!==c.BINARY&&this.#c.opcode!==c.TEXT){z(this.ws,"Invalid frame type was fragmented.");return}const o=r[1]&127;if(o<=125){this.#c.payloadLength=o;this.#p=p.READ_DATA}else if(o===126){this.#p=p.PAYLOADLENGTH_16}else if(o===127){this.#p=p.PAYLOADLENGTH_64}if(this.#c.fragmented&&o>125){z(this.ws,"Fragmented frame exceeded 125 bytes.");return}else if((this.#c.opcode===c.PING||this.#c.opcode===c.PONG||this.#c.opcode===c.CLOSE)&&o>125){z(this.ws,"Payload length for control frame exceeded 125 bytes.");return}else if(this.#c.opcode===c.CLOSE){if(o===1){z(this.ws,"Received close frame with a 1-byte body.");return}const t=this.consume(o);this.#c.closeInfo=this.parseCloseBody(false,t);if(!this.ws[u]){const t=Buffer.allocUnsafe(2);t.writeUInt16BE(this.#c.closeInfo.code,0);const r=new h(t);this.ws[b].socket.write(r.createFrame(c.CLOSE),(t=>{if(!t){this.ws[u]=true}}))}this.ws[l]=d.CLOSING;this.ws[M]=true;this.end();return}else if(this.#c.opcode===c.PING){const r=this.consume(o);if(!this.ws[M]){const t=new h(r);this.ws[b].socket.write(t.createFrame(c.PONG));if(g.ping.hasSubscribers){g.ping.publish({payload:r})}}this.#p=p.INFO;if(this.#s>0){continue}else{t();return}}else if(this.#c.opcode===c.PONG){const r=this.consume(o);if(g.pong.hasSubscribers){g.pong.publish({payload:r})}if(this.#s>0){continue}else{t();return}}}else if(this.#p===p.PAYLOADLENGTH_16){if(this.#s<2){return t()}const r=this.consume(2);this.#c.payloadLength=r.readUInt16BE(0);this.#p=p.READ_DATA}else if(this.#p===p.PAYLOADLENGTH_64){if(this.#s<8){return t()}const r=this.consume(8);const o=r.readUInt32BE(0);if(o>2**31-1){z(this.ws,"Received payload length > 2^31 bytes.");return}const a=r.readUInt32BE(4);this.#c.payloadLength=(o<<8)+a;this.#p=p.READ_DATA}else if(this.#p===p.READ_DATA){if(this.#s<this.#c.payloadLength){return t()}else if(this.#s>=this.#c.payloadLength){const t=this.consume(this.#c.payloadLength);this.#d.push(t);if(!this.#c.fragmented||this.#c.fin&&this.#c.opcode===c.CONTINUATION){const t=Buffer.concat(this.#d);O(this.ws,this.#c.originalOpcode,t);this.#c={};this.#d.length=0}this.#p=p.INFO}}if(this.#s>0){continue}else{t();break}}}consume(t){if(t>this.#s){return null}else if(t===0){return A}if(this.#i[0].length===t){this.#s-=this.#i[0].length;return this.#i.shift()}const r=Buffer.allocUnsafe(t);let o=0;while(o!==t){const a=this.#i[0];const{length:i}=a;if(i+o===t){r.set(this.#i.shift(),o);break}else if(i+o>t){r.set(a.subarray(0,t-o),o);this.#i[0]=a.subarray(t-o);break}else{r.set(this.#i.shift(),o);o+=a.length}}this.#s-=t;return r}parseCloseBody(t,r){let o;if(r.length>=2){o=r.readUInt16BE(0)}if(t){if(!m(o)){return null}return{code:o}}let a=r.subarray(2);if(a[0]===239&&a[1]===187&&a[2]===191){a=a.subarray(3)}if(o!==undefined&&!m(o)){return null}try{a=new TextDecoder("utf-8",{fatal:true}).decode(a)}catch{return null}return{code:o,reason:a}}get closingInfo(){return this.#c.closeInfo}}t.exports={ByteParser:ByteParser}},37578:t=>{"use strict";t.exports={kWebSocketURL:Symbol("url"),kReadyState:Symbol("ready state"),kController:Symbol("controller"),kResponse:Symbol("response"),kBinaryType:Symbol("binary type"),kSentClose:Symbol("sent close"),kReceivedClose:Symbol("received close"),kByteParser:Symbol("byte parser")}},25515:(t,r,o)=>{"use strict";const{kReadyState:a,kController:i,kResponse:p,kBinaryType:c,kWebSocketURL:d}=o(37578);const{states:A,opcodes:l}=o(19188);const{MessageEvent:u,ErrorEvent:b}=o(52611);function isEstablished(t){return t[a]===A.OPEN}function isClosing(t){return t[a]===A.CLOSING}function isClosed(t){return t[a]===A.CLOSED}function fireEvent(t,r,o=Event,a){const i=new o(t,a);r.dispatchEvent(i)}function websocketMessageReceived(t,r,o){if(t[a]!==A.OPEN){return}let i;if(r===l.TEXT){try{i=new TextDecoder("utf-8",{fatal:trueLine truncated
|
||||
/*!
|
||||
* XRegExp.build 4.4.1
|
||||
|
||||
+1
-1
@@ -1 +1 @@
|
||||
{"version":3,"file":"index.js","names":["__createBinding","this","Object","create","o","m","k","k2","undefined","desc","getOwnPropertyDescriptor","__esModule","writable","configurable","enumerable","get","defineProperty","__setModuleDefault","v","value","__importStar","mod","result","prototype","hasOwnProperty","call","__awaiter","thisArg","_arguments","P","generator","adopt","resolve","Promise","reject","fulfilled","step","next","e","rejected","done","then","apply","exports","saveCache","restoreCache","isFeatureAvailable","ReserveCacheError","ValidationError","core","__webpack_require__","path","utils","cacheHttpClient","tar_1","Error","constructor","message","super","name","setPrototypeOf","checkPaths","paths","length","checkKey","key","regex","test","process","env","primaryKey","restoreKeys","options","enableCrossOsArchive","keys","debug","JSON","stringify","compressionMethod","getCompressionMethod","archivePath","cacheEntry","getCacheEntry","archiveLocation","lookupOnly","info","cacheKey","join","createTempDirectory","getCacheFileName","downloadCache","isDebug","listTar","archiveFileSize","getArchiveFileSizeInBytes","Math","round","extractTar","error","typedError","warning","unlinkFile","_a","_b","_c","_d","_e","cacheId","cachePaths","resolvePaths","archiveFolder","createTar","fileSizeLimit","isGhes","reserveCacheResponse","reserveCache","cacheSize","statusCode","getCacheVersion","http_client_1","auth_1","crypto","fs","url_1","downloadUtils_1","options_1","requestUtils_1","versionSalt","getCacheApiUrl","resource","baseUrl","url","createAcceptHeader","type","apiVersion","getRequestOptions","requestOptions","headers","Accept","createHttpClient","token","bearerCredentialHandler","BearerCredentialHandler","HttpClient","components","slice","push","platform","createHash","update","digest","httpClient","version","encodeURIComponent","response","retryTypedResponse","getJson","printCachesListForDiagnostics","isSuccessStatusCode","cacheResult","cacheDownloadUrl","setSecret","cacheListResult","totalCount","artifactCaches","cacheVersion","scope","creationTime","archiveUrl","URL","downloadOptions","getDownloadOptions","hostname","endsWith","useAzureSdk","downloadCacheStorageSDK","concurrentBlobDownloads","downloadCacheHttpClientConcurrent","downloadCacheHttpClient","reserveCacheRequest","postJson","getContentRange","start","end","uploadChunk","resourceUrl","openStream","additionalHeaders","uploadChunkResponse","retryHttpClientResponse","sendStream","uploadFile","fileSize","toString","fd","openSync","uploadOptions","getUploadOptions","concurrency","assertDefined","uploadConcurrency","maxChunkSize","uploadChunkSize","parallelUploads","Array","offset","all","map","chunkSize","min","createReadStream","autoClose","on","closeSync","commitCache","filesize","commitCacheRequest","size","commitCacheResponse","__asyncValues","Symbol","asyncIterator","TypeError","i","__values","iterator","verb","n","settle","d","getGnuTarPathOnWindows","exec","glob","io","semver","util","uuid_1","constants_1","IS_WINDOWS","tempDirectory","baseLocation","dest","v4","mkdirP","filePath","statSync","patterns","e_1","workspace","cwd","globber","implicitDescendants","_f","globGenerator","_g","file","relativeFile","relative","replace","RegExp","sep","e_1_1","return","promisify","unlink","getVersion","app","additionalArgs","versionOutput","ignoreReturnCode","silent","listeners","stdout","data","stderr","err","trim","clean","CompressionMethod","Gzip","ZstdWithoutLong","CacheFilename","Zstd","existsSync","GnuTarPathOnWindows","toLowerCase","includes","which","ghUrl","trimEnd","toUpperCase","isGitHubHost","isGheHost","ManifestFilename","TarFilename","SystemTarPathOnWindows","SocketTimeout","DefaultRetryDelay","DefaultRetryAttempts","ArchiveToolType","DownloadProgress","storage_blob_1","buffer","stream","abort_controller_1","pipeResponseToStream","output","pipeline","contentLength","segmentIndex","segmentSize","segmentOffset","receivedBytes","displayedComplete","startTime","Date","now","nextSegment","setReceivedBytes","getTransferredBytes","isDone","display","transferredBytes","percentage","toFixed","elapsedTime","downloadSpeed","onProgress","progress","loadedBytes","startDisplayTimer","delayInMs","displayCallback","timeoutHandle","setTimeout","stopDisplayTimer","clearTimeout","writeStream","createWriteStream","downloadResponse","socket","destroy","contentLengthHeader","expectedLength","parseInt","actualLength","archiveDescriptor","promises","open","socketTimeout","timeoutInMs","keepAlive","res","request","lengthHeader","Number","isNaN","downloads","blockSize","count","promiseGetter","downloadSegmentRetry","reverse","actives","bytesDownloaded","progressFn","activeDownloads","nextDownload","waitAndWrite","segment","race","values","write","pop","downloadConcurrency","dispose","close","retries","failures","timeout","promiseWithTimeout","downloadSegment","partRes","Range","readBodyBuffer","client","BlockBlobClient","retryOptions","tryTimeoutInMs","properties"Line truncated
|
||||
{"version":3,"file":"index.js","names":["__createBinding","this","Object","create","o","m","k","k2","undefined","desc","getOwnPropertyDescriptor","__esModule","writable","configurable","enumerable","get","defineProperty","__setModuleDefault","v","value","__importStar","mod","result","prototype","hasOwnProperty","call","__awaiter","thisArg","_arguments","P","generator","adopt","resolve","Promise","reject","fulfilled","step","next","e","rejected","done","then","apply","exports","saveCache","restoreCache","isFeatureAvailable","ReserveCacheError","ValidationError","core","__webpack_require__","path","utils","cacheHttpClient","tar_1","Error","constructor","message","super","name","setPrototypeOf","checkPaths","paths","length","checkKey","key","regex","test","process","env","primaryKey","restoreKeys","options","enableCrossOsArchive","keys","debug","JSON","stringify","compressionMethod","getCompressionMethod","archivePath","cacheEntry","getCacheEntry","archiveLocation","lookupOnly","info","cacheKey","join","createTempDirectory","getCacheFileName","downloadCache","isDebug","listTar","archiveFileSize","getArchiveFileSizeInBytes","Math","round","extractTar","error","typedError","warning","unlinkFile","_a","_b","_c","_d","_e","cacheId","cachePaths","resolvePaths","archiveFolder","createTar","fileSizeLimit","isGhes","reserveCacheResponse","reserveCache","cacheSize","statusCode","getCacheVersion","http_client_1","auth_1","crypto","fs","url_1","downloadUtils_1","options_1","requestUtils_1","versionSalt","getCacheApiUrl","resource","baseUrl","url","createAcceptHeader","type","apiVersion","getRequestOptions","requestOptions","headers","Accept","createHttpClient","token","bearerCredentialHandler","BearerCredentialHandler","HttpClient","components","slice","push","platform","createHash","update","digest","httpClient","version","encodeURIComponent","response","retryTypedResponse","getJson","printCachesListForDiagnostics","isSuccessStatusCode","cacheResult","cacheDownloadUrl","setSecret","cacheListResult","totalCount","artifactCaches","cacheVersion","scope","creationTime","archiveUrl","URL","downloadOptions","getDownloadOptions","hostname","endsWith","useAzureSdk","downloadCacheStorageSDK","concurrentBlobDownloads","downloadCacheHttpClientConcurrent","downloadCacheHttpClient","reserveCacheRequest","postJson","getContentRange","start","end","uploadChunk","resourceUrl","openStream","additionalHeaders","uploadChunkResponse","retryHttpClientResponse","sendStream","uploadFile","fileSize","toString","fd","openSync","uploadOptions","getUploadOptions","concurrency","assertDefined","uploadConcurrency","maxChunkSize","uploadChunkSize","parallelUploads","Array","offset","all","map","chunkSize","min","createReadStream","autoClose","on","closeSync","commitCache","filesize","commitCacheRequest","size","commitCacheResponse","__asyncValues","Symbol","asyncIterator","TypeError","i","__values","iterator","verb","n","settle","d","getGnuTarPathOnWindows","exec","glob","io","semver","util","uuid_1","constants_1","IS_WINDOWS","tempDirectory","baseLocation","dest","v4","mkdirP","filePath","statSync","patterns","e_1","workspace","cwd","globber","implicitDescendants","_f","globGenerator","_g","file","relativeFile","relative","replace","RegExp","sep","e_1_1","return","promisify","unlink","getVersion","app","additionalArgs","versionOutput","ignoreReturnCode","silent","listeners","stdout","data","stderr","err","trim","clean","CompressionMethod","Gzip","ZstdWithoutLong","CacheFilename","Zstd","existsSync","GnuTarPathOnWindows","toLowerCase","includes","which","ghUrl","trimEnd","toUpperCase","isGitHubHost","isGheHost","ManifestFilename","TarFilename","SystemTarPathOnWindows","SocketTimeout","DefaultRetryDelay","DefaultRetryAttempts","ArchiveToolType","DownloadProgress","storage_blob_1","buffer","stream","abort_controller_1","pipeResponseToStream","output","pipeline","contentLength","segmentIndex","segmentSize","segmentOffset","receivedBytes","displayedComplete","startTime","Date","now","nextSegment","setReceivedBytes","getTransferredBytes","isDone","display","transferredBytes","percentage","toFixed","elapsedTime","downloadSpeed","onProgress","progress","loadedBytes","startDisplayTimer","delayInMs","displayCallback","timeoutHandle","setTimeout","stopDisplayTimer","clearTimeout","writeStream","createWriteStream","downloadResponse","socket","destroy","contentLengthHeader","expectedLength","parseInt","actualLength","archiveDescriptor","promises","open","socketTimeout","timeoutInMs","keepAlive","res","request","lengthHeader","Number","isNaN","downloads","blockSize","count","promiseGetter","downloadSegmentRetry","reverse","actives","bytesDownloaded","progressFn","activeDownloads","nextDownload","waitAndWrite","segment","race","values","write","pop","downloadConcurrency","dispose","close","retries","failures","timeout","promiseWithTimeout","downloadSegment","partRes","Range","readBodyBuffer","client","BlockBlobClient","retryOptions","tryTimeoutInMs","properties"Line truncated
|
||||
@@ -4009,9 +4009,9 @@ uglify-js@^3.1.4:
|
||||
integrity sha512-wDRziHG94mNj2n3R864CvYw/+pc9y/RNImiTyrrf8BzgWn75JgFSwYvXrtZQMnMnOp/4UTrf3iCSQxSStPiByA==
|
||||
|
||||
undici@^5.25.4:
|
||||
version "5.28.3"
|
||||
resolved "https://registry.yarnpkg.com/undici/-/undici-5.28.3.tgz#a731e0eff2c3fcfd41c1169a869062be222d1e5b"
|
||||
integrity sha512-3ItfzbrhDlINjaP0duwnNsKpDQk3acHI3gVJ1z4fmwMK31k5G9OVIAMLSIaP6w4FaGkaAkN6zaQO9LUvZ1t7VA==
|
||||
version "5.28.4"
|
||||
resolved "https://registry.yarnpkg.com/undici/-/undici-5.28.4.tgz#6b280408edb6a1a604a9b20340f45b422e373068"
|
||||
integrity sha512-72RFADWFqKmUb2hmmvNODKL3p9hcB6Gt2DOQMis1SEBaV6a4MH8soBvzg+95CYhCKPFedut2JY9bMfrDl9D23g==
|
||||
dependencies:
|
||||
"@fastify/busboy" "^2.0.0"
|
||||
|
||||
|
||||
Reference in new issue
Block a user