Override undici version

This commit is contained in:
Shivam Mathur committed 2026-01-17 03:15:23 +05:30
1 parent 5efa2a774e
commit f89a301251
3 files changed
+9 -20

No files matched your search

+3 -3
View File
@@ -1,3 +1,3 @@
(()=>{var A={6472:function(A,e,t){"use strict";var r=this&&this.__createBinding||(Object.create?function(A,e,t,r){if(r===undefined)r=t;var s=Object.getOwnPropertyDescriptor(e,t);if(!s||("get"in s?!e.__esModule:s.writable||s.configurable)){s={enumerable:true,get:function(){return e[t]}}}Object.defineProperty(A,r,s)}:function(A,e,t,r){if(r===undefined)r=t;A[r]=e[t]});var s=this&&this.__setModuleDefault||(Object.create?function(A,e){Object.defineProperty(A,"default",{enumerable:true,value:e})}:function(A,e){A["default"]=e});var n=this&&this.__importStar||function(){var ownKeys=function(A){ownKeys=Object.getOwnPropertyNames||function(A){var e=[];for(var t in A)if(Object.prototype.hasOwnProperty.call(A,t))e[e.length]=t;return e};return ownKeys(A)};return function(A){if(A&&A.__esModule)return A;var e={};if(A!=null)for(var t=ownKeys(A),n=0;n<t.length;n++)if(t[n]!=="default")r(e,A,t[n]);s(e,A);return e}}();Object.defineProperty(e,"__esModule",{value:true});e.addINIValuesUnix=addINIValuesUnix;e.addINIValuesWindows=addINIValuesWindows;e.addINIValues=addINIValues;const o=n(t(9277));async function addINIValuesUnix(A){const e=await o.CSVArray(A);let t="";await o.asyncForEach(e,(async function(A){t+="\n"+await o.addLog("$tick",A,"Added to php.ini","linux")}));return'echo "'+e.join("\n")+'" | sudo tee -a "${pecl_file:-${ini_file[@]}}" >/dev/null 2>&1'+t}async function addINIValuesWindows(A){const e=await o.CSVArray(A);let t="\n";await o.asyncForEach(e,(async function(A){t+=await o.addLog("$tick",A,"Added to php.ini","win32")+"\n"}));return'Add-Content "$php_dir\\php.ini" "'+e.join("\n")+'"'+t}async function addINIValues(A,e,t=false){let r="\n";switch(t){case true:r+=await o.stepLog("Add php.ini values",e)+await o.suppressOutput(e)+"\n";break;case false:default:r+=await o.stepLog("Add php.ini values",e)+"\n";break}switch(e){case"win32":return r+await addINIValuesWindows(A);case"darwin":case"linux":return r+await addINIValuesUnix(A);default:return await o.log("Platform "+e+" is not supported",e,"error")}}},9524:function(A,e,t){"use strict";var r=this&&this.__createBinding||(Object.create?function(A,e,t,r){if(r===undefined)r=t;var s=Object.getOwnPropertyDescriptor(e,t);if(!s||("get"in s?!e.__esModule:s.writable||s.configurable)){s={enumerable:true,get:function(){return e[t]}}}Object.defineProperty(A,r,s)}:function(A,e,t,r){if(r===undefined)r=t;A[r]=e[t]});var s=this&&this.__setModuleDefault||(Object.create?function(A,e){Object.defineProperty(A,"default",{enumerable:true,value:e})}:function(A,e){A["default"]=e});var n=this&&this.__importStar||function(){var ownKeys=function(A){ownKeys=Object.getOwnPropertyNames||function(A){var e=[];for(var t in A)if(Object.prototype.hasOwnProperty.call(A,t))e[e.length]=t;return e};return ownKeys(A)};return function(A){if(A&&A.__esModule)return A;var e={};if(A!=null)for(var t=ownKeys(A),n=0;n<t.length;n++)if(t[n]!=="default")r(e,A,t[n]);s(e,A);return e}}();Object.defineProperty(e,"__esModule",{value:true});e.checkXdebugError=checkXdebugError;e.addCoverageXdebug=addCoverageXdebug;e.addCoveragePCOV=addCoveragePCOV;e.disableCoverage=disableCoverage;e.addCoverage=addCoverage;const o=n(t(9277));const i=n(t(3252));const a=n(t(6472));async function checkXdebugError(A,e){if(/^5\.[3-6]$|^7\.[0-1]$/.test(e)&&A=="xdebug3"||/^8\.[0-9]$/.test(e)&&A=="xdebug2"){return A+" is not supported on PHP "+e}return""}async function addCoverageXdebug(A,e,t,r){let s="\n";const n=await checkXdebugError(A,e);if(!n){s+=await i.addExtension(":pcov:false",e,t,true)+r;A=A=="xdebug3"?"xdebug":A;s+=await i.addExtension(A,e,t,true)+r;s+=await o.setVariable("xdebug_version","php -r \"echo phpversion('xdebug');\"",t);s+=await o.getCommand(t,"extension_log")+'xdebug "Xdebug $xdebug_version enabled as coverage driver"'}else{s+=await o.addLog("$cross",A,n,t)}return s}async function addCoveragePCOV(A,e,t){let r="\n";switch(true){default:r+=await i.addExtension(":xdebug:false",A,e,true)+t;r+=await i.addExtension("pcov",A,e,true)+t;r+=await a.addINIValues("pcov.enabled=1",e,true)+"\n";r+=await o.setVariable("pcov_version","php -r \"echo phpversion('pcov');\"",e);r+=await o.getCommand(e,"extension_log")+'pcov "PCOV $pcov_version enabled as coverage driver"';break;case/5\.[3-6]|7\.0/.test(A):r+=await o.addLog("$cross","pcov","PHP 7.1 or newer is required",e);break}return r}async function disableCoverage(A,e,t){let r="\n";r+=await i.addExtension(":pcov:false",A,e,true)+t;r+=await i.addExtension(":xdebug:false",A,e,true)+t;r+=await o.addLog("$tick","none","Disabled Xdebug and PCOV",e);return r}async function addCoverage(A,e,t){A=A.toLowerCase();const r="\n"+await o.stepLog("Setup Coverage",t);const s=await o.suppressOutput(t)+"\n";switch(A){case"pcov":return r+await addCoveragePCOV(e,t,s);case"xdebug":case"xdebug2":case"xdebug3":return r+await addCoverageXdebug(A,e,t,s);case"none":return r+await disableCoverage(e,t,s);default:return""}}},3252:function(A,e,t){"use strict";var r=this&&this.__createBinding||(Object.create?function(A,e,t,r)Line truncated (()=>{var e={6472:function(e,A,t){"use strict";var r=this&&this.__createBinding||(Object.create?function(e,A,t,r){if(r===undefined)r=t;var s=Object.getOwnPropertyDescriptor(A,t);if(!s||("get"in s?!A.__esModule:s.writable||s.configurable)){s={enumerable:true,get:function(){return A[t]}}}Object.defineProperty(e,r,s)}:function(e,A,t,r){if(r===undefined)r=t;e[r]=A[t]});var s=this&&this.__setModuleDefault||(Object.create?function(e,A){Object.defineProperty(e,"default",{enumerable:true,value:A})}:function(e,A){e["default"]=A});var n=this&&this.__importStar||function(){var ownKeys=function(e){ownKeys=Object.getOwnPropertyNames||function(e){var A=[];for(var t in e)if(Object.prototype.hasOwnProperty.call(e,t))A[A.length]=t;return A};return ownKeys(e)};return function(e){if(e&&e.__esModule)return e;var A={};if(e!=null)for(var t=ownKeys(e),n=0;n<t.length;n++)if(t[n]!=="default")r(A,e,t[n]);s(A,e);return A}}();Object.defineProperty(A,"__esModule",{value:true});A.addINIValuesUnix=addINIValuesUnix;A.addINIValuesWindows=addINIValuesWindows;A.addINIValues=addINIValues;const o=n(t(9277));async function addINIValuesUnix(e){const A=await o.CSVArray(e);let t="";await o.asyncForEach(A,(async function(e){t+="\n"+await o.addLog("$tick",e,"Added to php.ini","linux")}));return'echo "'+A.join("\n")+'" | sudo tee -a "${pecl_file:-${ini_file[@]}}" >/dev/null 2>&1'+t}async function addINIValuesWindows(e){const A=await o.CSVArray(e);let t="\n";await o.asyncForEach(A,(async function(e){t+=await o.addLog("$tick",e,"Added to php.ini","win32")+"\n"}));return'Add-Content "$php_dir\\php.ini" "'+A.join("\n")+'"'+t}async function addINIValues(e,A,t=false){let r="\n";switch(t){case true:r+=await o.stepLog("Add php.ini values",A)+await o.suppressOutput(A)+"\n";break;case false:default:r+=await o.stepLog("Add php.ini values",A)+"\n";break}switch(A){case"win32":return r+await addINIValuesWindows(e);case"darwin":case"linux":return r+await addINIValuesUnix(e);default:return await o.log("Platform "+A+" is not supported",A,"error")}}},9524:function(e,A,t){"use strict";var r=this&&this.__createBinding||(Object.create?function(e,A,t,r){if(r===undefined)r=t;var s=Object.getOwnPropertyDescriptor(A,t);if(!s||("get"in s?!A.__esModule:s.writable||s.configurable)){s={enumerable:true,get:function(){return A[t]}}}Object.defineProperty(e,r,s)}:function(e,A,t,r){if(r===undefined)r=t;e[r]=A[t]});var s=this&&this.__setModuleDefault||(Object.create?function(e,A){Object.defineProperty(e,"default",{enumerable:true,value:A})}:function(e,A){e["default"]=A});var n=this&&this.__importStar||function(){var ownKeys=function(e){ownKeys=Object.getOwnPropertyNames||function(e){var A=[];for(var t in e)if(Object.prototype.hasOwnProperty.call(e,t))A[A.length]=t;return A};return ownKeys(e)};return function(e){if(e&&e.__esModule)return e;var A={};if(e!=null)for(var t=ownKeys(e),n=0;n<t.length;n++)if(t[n]!=="default")r(A,e,t[n]);s(A,e);return A}}();Object.defineProperty(A,"__esModule",{value:true});A.checkXdebugError=checkXdebugError;A.addCoverageXdebug=addCoverageXdebug;A.addCoveragePCOV=addCoveragePCOV;A.disableCoverage=disableCoverage;A.addCoverage=addCoverage;const o=n(t(9277));const i=n(t(3252));const a=n(t(6472));async function checkXdebugError(e,A){if(/^5\.[3-6]$|^7\.[0-1]$/.test(A)&&e=="xdebug3"||/^8\.[0-9]$/.test(A)&&e=="xdebug2"){return e+" is not supported on PHP "+A}return""}async function addCoverageXdebug(e,A,t,r){let s="\n";const n=await checkXdebugError(e,A);if(!n){s+=await i.addExtension(":pcov:false",A,t,true)+r;e=e=="xdebug3"?"xdebug":e;s+=await i.addExtension(e,A,t,true)+r;s+=await o.setVariable("xdebug_version","php -r \"echo phpversion('xdebug');\"",t);s+=await o.getCommand(t,"extension_log")+'xdebug "Xdebug $xdebug_version enabled as coverage driver"'}else{s+=await o.addLog("$cross",e,n,t)}return s}async function addCoveragePCOV(e,A,t){let r="\n";switch(true){default:r+=await i.addExtension(":xdebug:false",e,A,true)+t;r+=await i.addExtension("pcov",e,A,true)+t;r+=await a.addINIValues("pcov.enabled=1",A,true)+"\n";r+=await o.setVariable("pcov_version","php -r \"echo phpversion('pcov');\"",A);r+=await o.getCommand(A,"extension_log")+'pcov "PCOV $pcov_version enabled as coverage driver"';break;case/5\.[3-6]|7\.0/.test(e):r+=await o.addLog("$cross","pcov","PHP 7.1 or newer is required",A);break}return r}async function disableCoverage(e,A,t){let r="\n";r+=await i.addExtension(":pcov:false",e,A,true)+t;r+=await i.addExtension(":xdebug:false",e,A,true)+t;r+=await o.addLog("$tick","none","Disabled Xdebug and PCOV",A);return r}async function addCoverage(e,A,t){e=e.toLowerCase();const r="\n"+await o.stepLog("Setup Coverage",t);const s=await o.suppressOutput(t)+"\n";switch(e){case"pcov":return r+await addCoveragePCOV(A,t,s);case"xdebug":case"xdebug2":case"xdebug3":return r+await addCoverageXdebug(e,A,t,s);case"none":return r+await disableCoverage(A,t,s);default:return""}}},3252:function(e,A,t){"use strict";var r=this&&this.__createBinding||(Object.create?function(e,A,t,r)Line truncated
/*! formdata-polyfill. MIT License. Jimmy Wärting <https://jimmy.warting.se/opensource> */;const escape=A=>A.replace(/\n/g,"%0A").replace(/\r/g,"%0D").replace(/"/g,"%22");const normalizeLinefeeds=A=>A.replace(/\r?\n|\r/g,"\r\n");const r=[];const s=new Uint8Array([13,10]);E=0;let n=false;for(const[e,o]of A){if(typeof o==="string"){const A=F.encode(t+`; name="${escape(normalizeLinefeeds(e))}"`+`\r\n\r\n${normalizeLinefeeds(o)}\r\n`);r.push(A);E+=A.byteLength}else{const A=F.encode(`${t}; name="${escape(normalizeLinefeeds(e))}"`+(o.name?`; filename="${escape(o.name)}"`:"")+"\r\n"+`Content-Type: ${o.type||"application/octet-stream"}\r\n\r\n`);r.push(A,o,s);if(typeof o.size==="number"){E+=A.byteLength+o.size+s.byteLength}else{n=true}}}const o=F.encode(`--${e}--`);r.push(o);E+=o.byteLength;if(n){E=null}g=A;c=async function*(){for(const A of r){if(A.stream){yield*A.stream()}else{yield A}}};Q="multipart/form-data; boundary="+e}else if(o(A)){g=A;E=A.size;if(A.type){Q=A.type}}else if(typeof A[Symbol.asyncIterator]==="function"){if(e){throw new TypeError("keepalive")}if(s.isDisturbed(A)||A.locked){throw new TypeError("Response body object should not be disturbed or locked")}r=A instanceof k?A:n(A)}if(typeof g==="string"||s.isBuffer(g)){E=Buffer.byteLength(g)}if(c!=null){let e;r=new k({async start(){e=c(A)[Symbol.asyncIterator]()},async pull(A){const{value:t,done:s}=await e.next();if(s){queueMicrotask((()=>{A.close()}))}else{if(!f(r)){A.enqueue(new Uint8Array(t))}}return A.desiredSize>0},async cancel(A){await e.return()},type:undefined})}const C={stream:r,source:g,length:E};return[C,Q]}function safelyExtractBody(A,e=false){if(!k){k=t(3774).ReadableStream}if(A instanceof k){d(!s.isDisturbed(A),"The body has already been consumed.");d(!A.locked,"The stream is locked.")}return extractBody(A,e)}function cloneBody(A){const[e,t]=A.stream.tee();const r=l(t,{transfer:[t]});const[,s]=r.tee();A.stream=e;return{stream:s,length:A.length,source:A.source}}async function*consumeBody(A){if(A){if(p(A)){yield A}else{const e=A.stream;if(s.isDisturbed(e)){throw new TypeError("The body has already been consumed.")}if(e.locked){throw new TypeError("The stream is locked.")}e[u]=true;yield*e}}}function throwIfAborted(A){if(A.aborted){throw new B("The operation was aborted.","AbortError")}}function bodyMixinMethods(A){const e={blob(){return specConsumeBody(this,(A=>{let e=bodyMimeType(this);if(e==="failure"){e=""}else if(e){e=D(e)}return new I([A],{type:e})}),A)},arrayBuffer(){return specConsumeBody(this,(A=>new Uint8Array(A).buffer),A)},text(){return specConsumeBody(this,utf8DecodeBytes,A)},json(){return specConsumeBody(this,parseJSONFromBytes,A)},async formData(){C.brandCheck(this,A);throwIfAborted(this[Q]);const e=this.headers.get("Content-Type");if(/multipart\/form-data/.test(e)){const A={};for(const[e,t]of this.headers)A[e.toLowerCase()]=t;const e=new E;let t;try{t=new r({headers:A,preservePath:true})}catch(A){throw new B(`${A}`,"AbortError")}t.on("field",((A,t)=>{e.append(A,t)}));t.on("file",((A,t,r,s,n)=>{const o=[];if(s==="base64"||s.toLowerCase()==="base64"){let s="";t.on("data",(A=>{s+=A.toString().replace(/[\r\n]/gm,"");const e=s.length-s.length%4;o.push(Buffer.from(s.slice(0,e),"base64"));s=s.slice(e)}));t.on("end",(()=>{o.push(Buffer.from(s,"base64"));e.append(A,new b(o,r,{type:n}))}))}else{t.on("data",(A=>{o.push(A)}));t.on("end",(()=>{e.append(A,new b(o,r,{type:n}))}))}}));const s=new Promise(((A,e)=>{t.on("finish",A);t.on("error",(A=>e(new TypeError(A))))}));if(this.body!==null)for await(const A of consumeBody(this[Q].body))t.write(A);t.end();await s;return e}else if(/application\/x-www-form-urlencoded/.test(e)){let A;try{let e="";const t=new TextDecoder("utf-8",{ignoreBOM:true});for await(const A of consumeBody(this[Q].body)){if(!p(A)){throw new TypeError("Expected Uint8Array chunk")}e+=t.decode(A,{stream:true})}e+=t.decode();A=new URLSearchParams(e)}catch(A){throw Object.assign(new TypeError,{cause:A})}const e=new E;for(const[t,r]of A){e.append(t,r)}return e}else{await Promise.resolve();throwIfAborted(this[Q]);throw C.errors.exception({header:`${A.name}.formData`,message:"Could not parse content as FormData."})}}};return e}function mixinBody(A){Object.assign(A.prototype,bodyMixinMethods(A))}async function specConsumeBody(A,e,t){C.brandCheck(A,t);throwIfAborted(A[Q]);if(bodyUnusable(A[Q].body)){throw new TypeError("Body is unusable")}const r=c();const errorSteps=A=>r.reject(A);const successSteps=A=>{try{r.resolve(e(A))}catch(A){errorSteps(A)}};if(A[Q].body==null){successSteps(new Uint8Array);return r.promise}await g(A[Q].body,successSteps,errorSteps);return r.promise}function bodyUnusable(A){return A!=null&&(A.stream.locked||s.isDisturbed(A.stream))}function utf8DecodeBytes(A){if(A.length===0){return""}if(A[0]===239&&A[1]===187&&A[2]===191){A=A.subarray(3)}const e=S.decode(A);return e}function parseJSONFromBytes(A){return JSON.parse(utf8DecodeBytes(A))}function bodyMimeType(A){const{headersList:e}=A[Q];const t=e.get("content-Line truncated /*! formdata-polyfill. MIT License. Jimmy Wärting <https://jimmy.warting.se/opensource> */;const escape=e=>e.replace(/\n/g,"%0A").replace(/\r/g,"%0D").replace(/"/g,"%22");const normalizeLinefeeds=e=>e.replace(/\r?\n|\r/g,"\r\n");const r=[];const s=new Uint8Array([13,10]);l=0;let n=false;for(const[A,o]of e){if(typeof o==="string"){const e=y.encode(t+`; name="${escape(normalizeLinefeeds(A))}"`+`\r\n\r\n${normalizeLinefeeds(o)}\r\n`);r.push(e);l+=e.byteLength}else{const e=y.encode(`${t}; name="${escape(normalizeLinefeeds(A))}"`+(o.name?`; filename="${escape(o.name)}"`:"")+"\r\n"+`Content-Type: ${o.type||"application/octet-stream"}\r\n\r\n`);r.push(e,o,s);if(typeof o.size==="number"){l+=e.byteLength+o.size+s.byteLength}else{n=true}}}const o=y.encode(`--${A}--\r\n`);r.push(o);l+=o.byteLength;if(n){l=null}c=e;a=async function*(){for(const e of r){if(e.stream){yield*e.stream()}else{yield e}}};g=`multipart/form-data; boundary=${A}`}else if(n(e)){c=e;l=e.size;if(e.type){g=e.type}}else if(typeof e[Symbol.asyncIterator]==="function"){if(A){throw new TypeError("keepalive")}if(r.isDisturbed(e)||e.locked){throw new TypeError("Response body object should not be disturbed or locked")}t=e instanceof ReadableStream?e:s(e)}if(typeof c==="string"||r.isBuffer(c)){l=Buffer.byteLength(c)}if(a!=null){let A;t=new ReadableStream({async start(){A=a(e)[Symbol.asyncIterator]()},async pull(e){const{value:r,done:s}=await A.next();if(s){queueMicrotask((()=>{e.close();e.byobRequest?.respond(0)}))}else{if(!C(t)){const A=new Uint8Array(r);if(A.byteLength){e.enqueue(A)}}}return e.desiredSize>0},async cancel(e){await A.return()},type:"bytes"})}const u={stream:t,source:c,length:l};return[u,g]}function safelyExtractBody(e,A=false){if(e instanceof ReadableStream){B(!r.isDisturbed(e),"The body has already been consumed.");B(!e.locked,"The stream is locked.")}return extractBody(e,A)}function cloneBody(e,A){const[t,r]=A.stream.tee();A.stream=t;return{stream:r,length:A.length,source:A.source}}function throwIfAborted(e){if(e.aborted){throw new DOMException("The operation was aborted.","AbortError")}}function bodyMixinMethods(e){const A={blob(){return consumeBody(this,(e=>{let A=bodyMimeType(this);if(A===null){A=""}else if(A){A=f(A)}return new h([e],{type:A})}),e)},arrayBuffer(){return consumeBody(this,(e=>new Uint8Array(e).buffer),e)},text(){return consumeBody(this,g,e)},json(){return consumeBody(this,parseJSONFromBytes,e)},formData(){return consumeBody(this,(e=>{const A=bodyMimeType(this);if(A!==null){switch(A.essence){case"multipart/form-data":{const t=p(e,A);if(t==="failure"){throw new TypeError("Failed to parse body as FormData.")}const r=new u;r[Q]=t;return r}case"application/x-www-form-urlencoded":{const A=new URLSearchParams(e.toString());const t=new u;for(const[e,r]of A){t.append(e,r)}return t}}}throw new TypeError('Content-Type was not one of "multipart/form-data" or "application/x-www-form-urlencoded".')}),e)},bytes(){return consumeBody(this,(e=>new Uint8Array(e)),e)}};return A}function mixinBody(e){Object.assign(e.prototype,bodyMixinMethods(e))}async function consumeBody(e,A,t){E.brandCheck(e,t);if(bodyUnusable(e)){throw new TypeError("Body is unusable: Body has already been read")}throwIfAborted(e[Q]);const r=a();const errorSteps=e=>r.reject(e);const successSteps=e=>{try{r.resolve(A(e))}catch(e){errorSteps(e)}};if(e[Q].body==null){successSteps(Buffer.allocUnsafe(0));return r.promise}await c(e[Q].body,successSteps,errorSteps);return r.promise}function bodyUnusable(e){const A=e[Q].body;return A!=null&&(A.stream.locked||r.isDisturbed(A.stream))}function parseJSONFromBytes(e){return JSON.parse(g(e))}function bodyMimeType(e){const A=e[Q].headersList;const t=l(A);if(t==="failure"){return null}return t}e.exports={extractBody:extractBody,safelyExtractBody:safelyExtractBody,cloneBody:cloneBody,mixinBody:mixinBody,streamRegistry:D,hasFinalizationRegistry:m,bodyUnusable:bodyUnusable}},4495:e=>{"use strict";const A=["GET","HEAD","POST"];const t=new Set(A);const r=[101,204,205,304];const s=[301,302,303,307,308];const n=new Set(s);const o=["1","7","9","11","13","15","17","19","20","21","22","23","25","37","42","43","53","69","77","79","87","95","101","102","103","104","109","110","111","113","115","117","119","123","135","137","139","143","161","179","389","427","465","512","513","514","515","526","530","531","532","540","548","554","556","563","587","601","636","989","990","993","995","1719","1720","1723","2049","3659","4045","4190","5060","5061","6000","6566","6665","6666","6667","6668","6669","6679","6697","10080"];const i=new Set(o);const a=["","no-referrer","no-referrer-when-downgrade","same-origin","origin","strict-origin","origin-when-cross-origin","strict-origin-when-cross-origin","unsafe-url"];const c=new Set(a);const l=["follow","manual","error"];const g=["GET","HEAD","OPTIONS","TRACE"];const u=new Set(g);const Q=["navigate","same-origin","no-cors","cors"];const E=["omit","same-origin","include"];const h=["default","no-store","reload","no-caLine truncated
/*! ws. MIT License. Einar Otto Stangvik <einaros@gmail.com> */n[s-4]=this.maskKey[0];n[s-3]=this.maskKey[1];n[s-2]=this.maskKey[2];n[s-1]=this.maskKey[3];n[1]=t;if(t===126){n.writeUInt16BE(e,2)}else if(t===127){n[2]=n[3]=0;n.writeUIntBE(e,4,6)}n[1]|=128;for(let A=0;A<e;A++){n[s+A]=this.frameData[A]^this.maskKey[A%4]}return n}}A.exports={WebsocketFrameSend:WebsocketFrameSend}},3171:(A,e,t)=>{"use strict";const{Writable:r}=t(2203);const s=t(1637);const{parserStates:n,opcodes:o,states:i,emptyBuffer:a}=t(5913);const{kReadyState:c,kSentClose:g,kResponse:E,kReceivedClose:Q}=t(2933);const{isValidStatusCode:C,failWebsocketConnection:B,websocketMessageReceived:l}=t(3574);const{WebsocketFrameSend:I}=t(1237);const h={};h.ping=s.channel("undici:websocket:ping");h.pong=s.channel("undici:websocket:pong");class ByteParser extends r{#o=[];#i=0;#a=n.INFO;#c={};#g=[];constructor(A){super();this.ws=A}_write(A,e,t){this.#o.push(A);this.#i+=A.length;this.run(t)}run(A){while(true){if(this.#a===n.INFO){if(this.#i<2){return A()}const e=this.consume(2);this.#c.fin=(e[0]&128)!==0;this.#c.opcode=e[0]&15;this.#c.originalOpcode??=this.#c.opcode;this.#c.fragmented=!this.#c.fin&&this.#c.opcode!==o.CONTINUATION;if(this.#c.fragmented&&this.#c.opcode!==o.BINARY&&this.#c.opcode!==o.TEXT){B(this.ws,"Invalid frame type was fragmented.");return}const t=e[1]&127;if(t<=125){this.#c.payloadLength=t;this.#a=n.READ_DATA}else if(t===126){this.#a=n.PAYLOADLENGTH_16}else if(t===127){this.#a=n.PAYLOADLENGTH_64}if(this.#c.fragmented&&t>125){B(this.ws,"Fragmented frame exceeded 125 bytes.");return}else if((this.#c.opcode===o.PING||this.#c.opcode===o.PONG||this.#c.opcode===o.CLOSE)&&t>125){B(this.ws,"Payload length for control frame exceeded 125 bytes.");return}else if(this.#c.opcode===o.CLOSE){if(t===1){B(this.ws,"Received close frame with a 1-byte body.");return}const A=this.consume(t);this.#c.closeInfo=this.parseCloseBody(false,A);if(!this.ws[g]){const A=Buffer.allocUnsafe(2);A.writeUInt16BE(this.#c.closeInfo.code,0);const e=new I(A);this.ws[E].socket.write(e.createFrame(o.CLOSE),(A=>{if(!A){this.ws[g]=true}}))}this.ws[c]=i.CLOSING;this.ws[Q]=true;this.end();return}else if(this.#c.opcode===o.PING){const e=this.consume(t);if(!this.ws[Q]){const A=new I(e);this.ws[E].socket.write(A.createFrame(o.PONG));if(h.ping.hasSubscribers){h.ping.publish({payload:e})}}this.#a=n.INFO;if(this.#i>0){continue}else{A();return}}else if(this.#c.opcode===o.PONG){const e=this.consume(t);if(h.pong.hasSubscribers){h.pong.publish({payload:e})}if(this.#i>0){continue}else{A();return}}}else if(this.#a===n.PAYLOADLENGTH_16){if(this.#i<2){return A()}const e=this.consume(2);this.#c.payloadLength=e.readUInt16BE(0);this.#a=n.READ_DATA}else if(this.#a===n.PAYLOADLENGTH_64){if(this.#i<8){return A()}const e=this.consume(8);const t=e.readUInt32BE(0);if(t>2**31-1){B(this.ws,"Received payload length > 2^31 bytes.");return}const r=e.readUInt32BE(4);this.#c.payloadLength=(t<<8)+r;this.#a=n.READ_DATA}else if(this.#a===n.READ_DATA){if(this.#i<this.#c.payloadLength){return A()}else if(this.#i>=this.#c.payloadLength){const A=this.consume(this.#c.payloadLength);this.#g.push(A);if(!this.#c.fragmented||this.#c.fin&&this.#c.opcode===o.CONTINUATION){const A=Buffer.concat(this.#g);l(this.ws,this.#c.originalOpcode,A);this.#c={};this.#g.length=0}this.#a=n.INFO}}if(this.#i>0){continue}else{A();break}}}consume(A){if(A>this.#i){return null}else if(A===0){return a}if(this.#o[0].length===A){this.#i-=this.#o[0].length;return this.#o.shift()}const e=Buffer.allocUnsafe(A);let t=0;while(t!==A){const r=this.#o[0];const{length:s}=r;if(s+t===A){e.set(this.#o.shift(),t);break}else if(s+t>A){e.set(r.subarray(0,A-t),t);this.#o[0]=r.subarray(A-t);break}else{e.set(this.#o.shift(),t);t+=r.length}}this.#i-=A;return e}parseCloseBody(A,e){let t;if(e.length>=2){t=e.readUInt16BE(0)}if(A){if(!C(t)){return null}return{code:t}}let r=e.subarray(2);if(r[0]===239&&r[1]===187&&r[2]===191){r=r.subarray(3)}if(t!==undefined&&!C(t)){return null}try{r=new TextDecoder("utf-8",{fatal:true}).decode(r)}catch{return null}return{code:t,reason:r}}get closingInfo(){return this.#c.closeInfo}}A.exports={ByteParser:ByteParser}},2933:A=>{"use strict";A.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")}},3574:(A,e,t)=>{"use strict";const{kReadyState:r,kController:s,kResponse:n,kBinaryType:o,kWebSocketURL:i}=t(2933);const{states:a,opcodes:c}=t(5913);const{MessageEvent:g,ErrorEvent:E}=t(6255);function isEstablished(A){return A[r]===a.OPEN}function isClosing(A){return A[r]===a.CLOSING}function isClosed(A){return A[r]===a.CLOSED}function fireEvent(A,e,t=Event,r){const s=new t(A,r);e.dispatchEvent(s)}function websocketMessageReceived(A,e,t){if(A[r]!==a.OPEN){return}let s;if(e===c.TEXT){try{s=new TextDecoder("utf-8",{fatal:true}).decode(t)Line truncated /*! ws. MIT License. Einar Otto Stangvik <einaros@gmail.com> */i[o-4]=t[0];i[o-3]=t[1];i[o-2]=t[2];i[o-1]=t[3];i[1]=n;if(n===126){i.writeUInt16BE(s,2)}else if(n===127){i[2]=i[3]=0;i.writeUIntBE(s,4,6)}i[1]|=128;for(let e=0;e<s;++e){i[o+e]=A[e]^t[e&3]}return i}}e.exports={WebsocketFrameSend:WebsocketFrameSend}},9469:(e,A,t)=>{"use strict";const{createInflateRaw:r,Z_DEFAULT_WINDOWBITS:s}=t(8522);const{isValidClientWindowBits:n}=t(8625);const o=Buffer.from([0,0,255,255]);const i=Symbol("kBuffer");const a=Symbol("kLength");class PerMessageDeflate{#z;#Q={};constructor(e){this.#Q.serverNoContextTakeover=e.has("server_no_context_takeover");this.#Q.serverMaxWindowBits=e.get("server_max_window_bits")}decompress(e,A,t){if(!this.#z){let e=s;if(this.#Q.serverMaxWindowBits){if(!n(this.#Q.serverMaxWindowBits)){t(new Error("Invalid server_max_window_bits"));return}e=Number.parseInt(this.#Q.serverMaxWindowBits)}this.#z=r({windowBits:e});this.#z[i]=[];this.#z[a]=0;this.#z.on("data",(e=>{this.#z[i].push(e);this.#z[a]+=e.length}));this.#z.on("error",(e=>{this.#z=null;t(e)}))}this.#z.write(e);if(A){this.#z.write(o)}this.#z.flush((()=>{const e=Buffer.concat(this.#z[i],this.#z[a]);this.#z[i].length=0;this.#z[a]=0;t(null,e)}))}}e.exports={PerMessageDeflate:PerMessageDeflate}},1652:(e,A,t)=>{"use strict";const{Writable:r}=t(7075);const s=t(4589);const{parserStates:n,opcodes:o,states:i,emptyBuffer:a,sentCloseFrameState:c}=t(736);const{kReadyState:l,kSentClose:g,kResponse:u,kReceivedClose:Q}=t(1216);const{channels:E}=t(2414);const{isValidStatusCode:h,isValidOpcode:B,failWebsocketConnection:C,websocketMessageReceived:I,utf8Decode:d,isControlFrame:f,isTextBinaryFrame:p,isContinuationFrame:w}=t(8625);const{WebsocketFrameSend:y}=t(3264);const{closeWebSocketConnection:m}=t(6897);const{PerMessageDeflate:D}=t(9469);class ByteParser extends r{#K=[];#X=0;#$=false;#f=n.INFO;#ee={};#Ae=[];#te;constructor(e,A){super();this.ws=e;this.#te=A==null?new Map:A;if(this.#te.has("permessage-deflate")){this.#te.set("permessage-deflate",new D(A))}}_write(e,A,t){this.#K.push(e);this.#X+=e.length;this.#$=true;this.run(t)}run(e){while(this.#$){if(this.#f===n.INFO){if(this.#X<2){return e()}const A=this.consume(2);const t=(A[0]&128)!==0;const r=A[0]&15;const s=(A[1]&128)===128;const i=!t&&r!==o.CONTINUATION;const a=A[1]&127;const c=A[0]&64;const l=A[0]&32;const g=A[0]&16;if(!B(r)){C(this.ws,"Invalid opcode received");return e()}if(s){C(this.ws,"Frame cannot be masked");return e()}if(c!==0&&!this.#te.has("permessage-deflate")){C(this.ws,"Expected RSV1 to be clear.");return}if(l!==0||g!==0){C(this.ws,"RSV1, RSV2, RSV3 must be clear");return}if(i&&!p(r)){C(this.ws,"Invalid frame type was fragmented.");return}if(p(r)&&this.#Ae.length>0){C(this.ws,"Expected continuation frame");return}if(this.#ee.fragmented&&i){C(this.ws,"Fragmented frame exceeded 125 bytes.");return}if((a>125||i)&&f(r)){C(this.ws,"Control frame either too large or fragmented");return}if(w(r)&&this.#Ae.length===0&&!this.#ee.compressed){C(this.ws,"Unexpected continuation frame");return}if(a<=125){this.#ee.payloadLength=a;this.#f=n.READ_DATA}else if(a===126){this.#f=n.PAYLOADLENGTH_16}else if(a===127){this.#f=n.PAYLOADLENGTH_64}if(p(r)){this.#ee.binaryType=r;this.#ee.compressed=c!==0}this.#ee.opcode=r;this.#ee.masked=s;this.#ee.fin=t;this.#ee.fragmented=i}else if(this.#f===n.PAYLOADLENGTH_16){if(this.#X<2){return e()}const A=this.consume(2);this.#ee.payloadLength=A.readUInt16BE(0);this.#f=n.READ_DATA}else if(this.#f===n.PAYLOADLENGTH_64){if(this.#X<8){return e()}const A=this.consume(8);const t=A.readUInt32BE(0);if(t>2**31-1){C(this.ws,"Received payload length > 2^31 bytes.");return}const r=A.readUInt32BE(4);this.#ee.payloadLength=(t<<8)+r;this.#f=n.READ_DATA}else if(this.#f===n.READ_DATA){if(this.#X<this.#ee.payloadLength){return e()}const A=this.consume(this.#ee.payloadLength);if(f(this.#ee.opcode)){this.#$=this.parseControlFrame(A);this.#f=n.INFO}else{if(!this.#ee.compressed){this.#Ae.push(A);if(!this.#ee.fragmented&&this.#ee.fin){const e=Buffer.concat(this.#Ae);I(this.ws,this.#ee.binaryType,e);this.#Ae.length=0}this.#f=n.INFO}else{this.#te.get("permessage-deflate").decompress(A,this.#ee.fin,((A,t)=>{if(A){m(this.ws,1007,A.message,A.message.length);return}this.#Ae.push(t);if(!this.#ee.fin){this.#f=n.INFO;this.#$=true;this.run(e);return}I(this.ws,this.#ee.binaryType,Buffer.concat(this.#Ae));this.#$=true;this.#f=n.INFO;this.#Ae.length=0;this.run(e)}));this.#$=false;break}}}}}consume(e){if(e>this.#X){throw new Error("Called consume() before buffers satiated.")}else if(e===0){return a}if(this.#K[0].length===e){this.#X-=this.#K[0].length;return this.#K.shift()}const A=Buffer.allocUnsafe(e);let t=0;while(t!==e){const r=this.#K[0];const{length:s}=r;if(s+t===e){A.set(this.#K.shift(),t);break}else if(s+t>e){A.set(r.subarray(0,e-t),t);this.#K[0]=r.subarray(e-t);break}else{A.set(this.#K.shift(),t);t+=r.length}}this.#X-=e;return A}parseCloseBody(e){s(e.length!==1);let A;if(e.length>=2){A=e.readUInt16BE(0)}if(Line truncated
+4 -16
View File
@@ -882,15 +882,6 @@
"node": "^18.18.0 || ^20.9.0 || >=21.1.0" "node": "^18.18.0 || ^20.9.0 || >=21.1.0"
} }
}, },
"node_modules/@fastify/busboy": {
"version": "2.1.1",
"resolved": "https://registry.npmjs.org/@fastify/busboy/-/busboy-2.1.1.tgz",
"integrity": "sha512-vBZP4NlzfOlerQTnba4aqZoMhE/a9HY7HRqoOPaETQcSQuWEIyZMHGfVu6w9wGtGK5fED5qRs2DteVCjOH60sA==",
"license": "MIT",
"engines": {
"node": ">=14"
}
},
"node_modules/@humanfs/core": { "node_modules/@humanfs/core": {
"version": "0.19.1", "version": "0.19.1",
"resolved": "https://registry.npmjs.org/@humanfs/core/-/core-0.19.1.tgz", "resolved": "https://registry.npmjs.org/@humanfs/core/-/core-0.19.1.tgz",
@@ -7613,15 +7604,12 @@
} }
}, },
"node_modules/undici": { "node_modules/undici": {
"version": "5.29.0", "version": "6.23.0",
"resolved": "https://registry.npmjs.org/undici/-/undici-5.29.0.tgz", "resolved": "https://registry.npmjs.org/undici/-/undici-6.23.0.tgz",
"integrity": "sha512-raqeBD6NQK4SkWhQzeYKd1KmIG6dllBOTt55Rmkt4HtI9mwdWtJljnrXjAFUBLTSN67HWrOIZ3EPF4kjUw80Bg==", "integrity": "sha512-VfQPToRA5FZs/qJxLIinmU59u0r7LXqoJkCzinq3ckNJp3vKEh7jTWN589YQ5+aoAC/TGRLyJLCPKcLQbM8r9g==",
"license": "MIT", "license": "MIT",
"dependencies": {
"@fastify/busboy": "^2.0.0"
},
"engines": { "engines": {
"node": ">=14.0" "node": ">=18.17"
} }
}, },
"node_modules/undici-types": { "node_modules/undici-types": {
+2 -1
View File
@@ -63,7 +63,8 @@
}, },
"overrides": { "overrides": {
"test-exclude": "^7.0.1", "test-exclude": "^7.0.1",
"glob": "^11.1.0" "glob": "^11.1.0",
"undici": "^6.23.0"
}, },
"bugs": { "bugs": {
"url": "https://github.com/shivammathur/setup-php/issues" "url": "https://github.com/shivammathur/setup-php/issues"