mirror of
https://github.com/pnpm/action-setup
synced 2026-11-06 20:47:58 +01:00
feat: update dist
This commit is contained in:
1 file changed
+2
-4
Vendored
+2
-4
@@ -1,10 +1,8 @@
|
||||
(()=>{var e={276:function(e,A,t){"use strict";var s=this&&this.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(A,"__esModule",{value:true});const r=t(9093);const n=s(t(1784));const i=s(t(2960));const o=s(t(7650));const a=s(t(9462));const c=s(t(8307));async function main(){const e=(0,n.default)();const A=(0,r.getState)("is_post");if(A==="true")return(0,c.default)(e);(0,r.saveState)("is_post","true");await(0,i.default)(e);console.log("Installation Completed!");(0,o.default)(e);(0,a.default)(e)}main().catch((e=>{console.error(e);(0,r.setFailed)(e)}))},1784:function(e,A,t){"use strict";var s=this&&this.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(A,"__esModule",{value:true});A.getInputs=void 0;const r=t(9093);const n=s(t(1791));const i=t(7090);const o={required:true};const parseInputPath=e=>(0,n.default)((0,r.getInput)(e,o));const getInputs=()=>({version:(0,r.getInput)("version"),dest:parseInputPath("dest"),runInstall:(0,i.parseRunInstall)("run_install"),packageJsonFile:parseInputPath("package_json_file"),standalone:(0,r.getBooleanInput)("standalone")});A.getInputs=getInputs;A["default"]=A.getInputs},7090:function(e,A,t){"use strict";var s=this&&this.__createBinding||(Object.create?function(e,A,t,s){if(s===undefined)s=t;var r=Object.getOwnPropertyDescriptor(A,t);if(!r||("get"in r?!A.__esModule:r.writable||r.configurable)){r={enumerable:true,get:function(){return A[t]}}}Object.defineProperty(e,s,r)}:function(e,A,t,s){if(s===undefined)s=t;e[s]=A[t]});var r=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(e){if(e&&e.__esModule)return e;var A={};if(e!=null)for(var t in e)if(t!=="default"&&Object.prototype.hasOwnProperty.call(e,t))s(A,e,t);r(A,e);return A};Object.defineProperty(A,"__esModule",{value:true});A.parseRunInstall=void 0;const i=t(9093);const o=n(t(2825));const a=t(8553);const c=a.z.object({recursive:a.z.boolean().optional(),cwd:a.z.string().optional(),args:a.z.array(a.z.string()).optional()});const l=a.z.union([a.z.null(),a.z.boolean(),c,a.z.array(c)]);function parseRunInstall(e){const A=(0,i.getInput)(e,{required:true});const t=o.parse(A);try{const e=l.parse(t);if(!e)return[];if(e===true)return[{recursive:true}];if(Array.isArray(e))return e;return[e]}catch(t){(0,i.error)(`Error for input "${e}" = ${A}`);if(t instanceof a.ZodError){(0,i.error)(`Errors: ${t.errors}`)}else{(0,i.error)(`Exception: ${t}`)}process.exit(1)}}A.parseRunInstall=parseRunInstall},2960:function(e,A,t){"use strict";var s=this&&this.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(A,"__esModule",{value:true});A.install=A.runSelfInstaller=void 0;const r=t(9093);const n=s(t(9530));A.runSelfInstaller=n.default;async function install(e){(0,r.startGroup)("Running self-installer...");const A=await(0,n.default)(e);(0,r.endGroup)();if(A){return(0,r.setFailed)(`Something went wrong, self-installer exits with code ${A}`)}}A.install=install;A["default"]=install},9530:function(e,A,t){"use strict";var s=this&&this.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(A,"__esModule",{value:true});A.runSelfInstaller=void 0;const r=t(9093);const n=t(2081);const i=t(3292);const o=t(7147);const a=s(t(1017));const c=t(7282);const l=s(t(3837));async function runSelfInstaller(e){const{version:A,dest:t,packageJsonFile:s,standalone:o}=e;await(0,i.rm)(t,{recursive:true,force:true});await(0,i.mkdir)(t,{recursive:true});const l=a.default.join(t,"package.json");await(0,i.writeFile)(l,JSON.stringify({private:true}));const g=await readTarget({version:A,packageJsonFile:s,standalone:o});const u=(0,n.spawn)(c.execPath,[a.default.join(__dirname,"pnpm.cjs"),"install",g,"--no-lockfile"],{cwd:t,stdio:["pipe","inherit","inherit"]});const E=await new Promise(((e,A)=>{u.on("error",A);u.on("close",e)}));if(E===0){const e=a.default.join(t,"node_modules/.bin");(0,r.addPath)(e);(0,r.exportVariable)("PNPM_HOME",e)}return E}A.runSelfInstaller=runSelfInstaller;async function readTarget(e){const{version:A,packageJsonFile:t,standalone:s}=e;const{GITHUB_WORKSPACE:r}=process.env;let n;if(r){try{({packageManager:n}=JSON.parse((0,o.readFileSync)(a.default.join(r,t),"utf8")))}catch(e){if(!l.default.types.isNativeError(e)||!("code"in e)||e.code!=="ENOENT")throw e}}if(A){if(typeof n==="string"&&n.replace("pnpm@","")!==A){throw new Error(`Multiple versions of pnpm specified:\n - version ${A} in the GitHub Action config with the key "version"\n - version ${n} in the package.json with the key "packageManager"\nRemove one of these versions to avoid version mismatch errors like ERR_PNPM_BAD_PM_VERSION`)}return`${s?"@pnpm/exe":"pnpm"}@${A}`}if(!r){throw new Error(`No workspace is found.\nIf you're intended to let pnpm/action-setup read preferred pnpm version from the "packageManager" field in t
Line truncated
|
||||
(()=>{var e={1046:function(e,t,s){"use strict";var n=this&&this.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(t,"__esModule",{value:true});const r=s(9999);const i=n(s(6414));const o=n(s(3144));const a=n(s(7215));const c=n(s(4728));const l=n(s(6879));async function main(){const e=(0,i.default)();const t=(0,r.getState)("is_post");if(t==="true")return(0,l.default)(e);(0,r.saveState)("is_post","true");await(0,o.default)(e);console.log("Installation Completed!");(0,a.default)(e);(0,c.default)(e)}main().catch((e=>{console.error(e);(0,r.setFailed)(e)}))},6414:function(e,t,s){"use strict";var n=this&&this.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(t,"__esModule",{value:true});t.getInputs=void 0;const r=s(9999);const i=n(s(6746));const o=s(9065);const a={required:true};const parseInputPath=e=>(0,i.default)((0,r.getInput)(e,a));const getInputs=()=>({version:(0,r.getInput)("version"),dest:parseInputPath("dest"),runInstall:(0,o.parseRunInstall)("run_install"),packageJsonFile:parseInputPath("package_json_file"),standalone:(0,r.getBooleanInput)("standalone")});t.getInputs=getInputs;t["default"]=t.getInputs},9065:function(e,t,s){"use strict";var n=this&&this.__createBinding||(Object.create?function(e,t,s,n){if(n===undefined)n=s;var r=Object.getOwnPropertyDescriptor(t,s);if(!r||("get"in r?!t.__esModule:r.writable||r.configurable)){r={enumerable:true,get:function(){return t[s]}}}Object.defineProperty(e,n,r)}:function(e,t,s,n){if(n===undefined)n=s;e[n]=t[s]});var r=this&&this.__setModuleDefault||(Object.create?function(e,t){Object.defineProperty(e,"default",{enumerable:true,value:t})}:function(e,t){e["default"]=t});var i=this&&this.__importStar||function(){var ownKeys=function(e){ownKeys=Object.getOwnPropertyNames||function(e){var t=[];for(var s in e)if(Object.prototype.hasOwnProperty.call(e,s))t[t.length]=s;return t};return ownKeys(e)};return function(e){if(e&&e.__esModule)return e;var t={};if(e!=null)for(var s=ownKeys(e),i=0;i<s.length;i++)if(s[i]!=="default")n(t,e,s[i]);r(t,e);return t}}();Object.defineProperty(t,"__esModule",{value:true});t.parseRunInstall=parseRunInstall;const o=s(9999);const a=i(s(7669));const c=s(6516);const l=c.z.object({recursive:c.z.boolean().optional(),cwd:c.z.string().optional(),args:c.z.array(c.z.string()).optional()});const u=c.z.union([c.z.null(),c.z.boolean(),l,c.z.array(l)]);function parseRunInstall(e){const t=(0,o.getInput)(e,{required:true});const s=a.parse(t);try{const e=u.parse(s);if(!e)return[];if(e===true)return[{recursive:true}];if(Array.isArray(e))return e;return[e]}catch(s){(0,o.error)(`Error for input "${e}" = ${t}`);if(s instanceof c.ZodError){(0,o.error)(`Errors: ${s.errors}`)}else{(0,o.error)(`Exception: ${s}`)}process.exit(1)}}},3144:function(e,t,s){"use strict";var n=this&&this.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(t,"__esModule",{value:true});t.runSelfInstaller=void 0;t.install=install;const r=s(9999);const i=n(s(7053));t.runSelfInstaller=i.default;async function install(e){(0,r.startGroup)("Running self-installer...");const t=await(0,i.default)(e);(0,r.endGroup)();if(t){return(0,r.setFailed)(`Something went wrong, self-installer exits with code ${t}`)}}t["default"]=install},7053:function(e,t,s){"use strict";var n=this&&this.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(t,"__esModule",{value:true});t.runSelfInstaller=runSelfInstaller;const r=s(9999);const i=s(5317);const o=s(1943);const a=s(9896);const c=n(s(6928));const l=s(932);const u=n(s(9023));const d=n(s(7669));async function runSelfInstaller(e){const{version:t,dest:s,packageJsonFile:n,standalone:a}=e;await(0,o.rm)(s,{recursive:true,force:true});await(0,o.mkdir)(s,{recursive:true});const u=c.default.join(s,"package.json");await(0,o.writeFile)(u,JSON.stringify({private:true}));const d=await readTarget({version:t,packageJsonFile:n,standalone:a});const f=(0,i.spawn)(l.execPath,[c.default.join(__dirname,"pnpm.cjs"),"install",d,"--no-lockfile"],{cwd:s,stdio:["pipe","inherit","inherit"]});const p=await new Promise(((e,t)=>{f.on("error",t);f.on("close",e)}));if(p===0){const e=c.default.join(s,"node_modules/.bin");(0,r.addPath)(e);(0,r.exportVariable)("PNPM_HOME",e)}return p}async function readTarget(e){const{version:t,packageJsonFile:s,standalone:n}=e;const{GITHUB_WORKSPACE:r}=process.env;let i;if(r){try{const e=(0,a.readFileSync)(c.default.join(r,s),"utf8");({packageManager:i}=s.endsWith(".yaml")?d.default.parse(e,{merge:true}):JSON.parse(e))}catch(e){if(!u.default.types.isNativeError(e)||!("code"in e)||e.code!=="ENOENT")throw e}}if(t){if(typeof i==="string"&&i.replace("pnpm@","")!==t){throw new Error(`Multiple versions of pnpm specified:\n - version ${t} in the GitHub Action config with the key "version"\n - version ${i} in the package.json with the key "packageManager"\nRemove one of these versions to avoid version mismatch errors like ERR_P
Line truncated
|
||||
/*!
|
||||
* expand-tilde <https://github.com/jonschlinkert/expand-tilde>
|
||||
*
|
||||
* Copyright (c) 2015 Jon Schlinkert.
|
||||
* Licensed under the MIT license.
|
||||
*/
|
||||
var s=t(9171);var r=t(1017);e.exports=function expandTilde(e){var A=s();if(e.charCodeAt(0)===126){if(e.charCodeAt(1)===43){return r.join(process.cwd(),e.slice(2))}return A?r.join(A,e.slice(1)):e}return e}},9171:(e,A,t)=>{"use strict";var s=t(2037);if(typeof s.homedir!=="undefined"){e.exports=s.homedir}else{e.exports=t(1952)}},1952:(e,A,t)=>{"use strict";var s=t(7147);var r=t(3794);function homedir(){if(process.platform==="win32"){if(process.env.USERPROFILE){return process.env.USERPROFILE}if(process.env.HOMEDRIVE&&process.env.HOMEPATH){return process.env.HOMEDRIVE+process.env.HOMEPATH}if(process.env.HOME){return process.env.HOME}return null}if(process.env.HOME){return process.env.HOME}var e=tryReadFileSync("/etc/passwd");var A=find(r(e),getuid());if(A){return A}var t=process.env.LOGNAME||process.env.USER||process.env.LNAME||process.env.USERNAME;if(!t){return null}if(process.platform==="darwin"){return"/Users/"+t}return"/home/"+t}function find(e,A){var t=e.length;for(var s=0;s<t;s++){if(+e[s].uid===A){return e[s].homedir}}}function getuid(){if(typeof process.geteuid==="function"){return process.geteuid()}return process.getuid()}function tryReadFileSync(e){try{return s.readFileSync(e,"utf8")}catch(e){return""}}e.exports=homedir},3794:e=>{"use strict";e.exports=function(e){if(typeof e!=="string"){throw new Error("expected a string")}return e.split("\n").map(user).filter(Boolean)};function user(e,A){if(!e||!e.length||e.charAt(0)==="#"){return null}var t=e.split(":");return{username:t[0],password:t[1],uid:t[2],gid:t[3],gecos:t[4],homedir:t[5],shell:t[6]}}},4225:(e,A,t)=>{e.exports=t(4030)},4030:(e,A,t)=>{"use strict";var s=t(1808);var r=t(4404);var n=t(3685);var i=t(5687);var o=t(2361);var a=t(9491);var c=t(3837);A.httpOverHttp=httpOverHttp;A.httpsOverHttp=httpsOverHttp;A.httpOverHttps=httpOverHttps;A.httpsOverHttps=httpsOverHttps;function httpOverHttp(e){var A=new TunnelingAgent(e);A.request=n.request;return A}function httpsOverHttp(e){var A=new TunnelingAgent(e);A.request=n.request;A.createSocket=createSecureSocket;A.defaultPort=443;return A}function httpOverHttps(e){var A=new TunnelingAgent(e);A.request=i.request;return A}function httpsOverHttps(e){var A=new TunnelingAgent(e);A.request=i.request;A.createSocket=createSecureSocket;A.defaultPort=443;return A}function TunnelingAgent(e){var A=this;A.options=e||{};A.proxyOptions=A.options.proxy||{};A.maxSockets=A.options.maxSockets||n.Agent.defaultMaxSockets;A.requests=[];A.sockets=[];A.on("free",(function onFree(e,t,s,r){var n=toOptions(t,s,r);for(var i=0,o=A.requests.length;i<o;++i){var a=A.requests[i];if(a.host===n.host&&a.port===n.port){A.requests.splice(i,1);a.request.onSocket(e);return}}e.destroy();A.removeSocket(e)}))}c.inherits(TunnelingAgent,o.EventEmitter);TunnelingAgent.prototype.addRequest=function addRequest(e,A,t,s){var r=this;var n=mergeOptions({request:e},r.options,toOptions(A,t,s));if(r.sockets.length>=this.maxSockets){r.requests.push(n);return}r.createSocket(n,(function(A){A.on("free",onFree);A.on("close",onCloseOrRemove);A.on("agentRemove",onCloseOrRemove);e.onSocket(A);function onFree(){r.emit("free",A,n)}function onCloseOrRemove(e){r.removeSocket(A);A.removeListener("free",onFree);A.removeListener("close",onCloseOrRemove);A.removeListener("agentRemove",onCloseOrRemove)}}))};TunnelingAgent.prototype.createSocket=function createSocket(e,A){var t=this;var s={};t.sockets.push(s);var r=mergeOptions({},t.proxyOptions,{method:"CONNECT",path:e.host+":"+e.port,agent:false,headers:{host:e.host+":"+e.port}});if(e.localAddress){r.localAddress=e.localAddress}if(r.proxyAuth){r.headers=r.headers||{};r.headers["Proxy-Authorization"]="Basic "+new Buffer(r.proxyAuth).toString("base64")}l("making CONNECT request");var n=t.request(r);n.useChunkedEncodingByDefault=false;n.once("response",onResponse);n.once("upgrade",onUpgrade);n.once("connect",onConnect);n.once("error",onError);n.end();function onResponse(e){e.upgrade=true}function onUpgrade(e,A,t){process.nextTick((function(){onConnect(e,A,t)}))}function onConnect(r,i,o){n.removeAllListeners();i.removeAllListeners();if(r.statusCode!==200){l("tunneling socket could not be established, statusCode=%d",r.statusCode);i.destroy();var a=new Error("tunneling socket could not be established, "+"statusCode="+r.statusCode);a.code="ECONNRESET";e.request.emit("error",a);t.removeSocket(s);return}if(o.length>0){l("got illegal response body from proxy");i.destroy();var a=new Error("got illegal response body from proxy");a.code="ECONNRESET";e.request.emit("error",a);t.removeSocket(s);return}l("tunneling connection has established");t.sockets[t.sockets.indexOf(s)]=i;return A(i)}function onError(A){n.removeAllListeners();l("tunneling socket could not be established, cause=%s\n",A.message,A.stack);var r=new Error("tunneling socket could not be established, "+"cause="+A.message);r.code="ECONNRESET";e.request.emit("error",r);t.removeSocket(s)}};TunnelingAgent.prototype.removeSocket=function removeSocket(e){var A=this.sockets.indexOf(e)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 s=[];const r=new Uint8Array([13,10]);g=0;let n=false;for(const[A,i]of e){if(typeof i==="string"){const e=R.encode(t+`; name="${escape(normalizeLinefeeds(A))}"`+`\r\n\r\n${normalizeLinefeeds(i)}\r\n`);s.push(e);g+=e.byteLength}else{const e=R.encode(`${t}; name="${escape(normalizeLinefeeds(A))}"`+(i.name?`; filename="${escape(i.name)}"`:"")+"\r\n"+`Content-Type: ${i.type||"application/octet-stream"}\r\n\r\n`);s.push(e,i,r);if(typeof i.size==="number"){g+=e.byteLength+i.size+r.byteLength}else{n=true}}}const i=R.encode(`--${A}--`);s.push(i);g+=i.byteLength;if(n){g=null}l=e;c=async function*(){for(const e of s){if(e.stream){yield*e.stream()}else{yield e}}};u="multipart/form-data; boundary="+A}else if(i(e)){l=e;g=e.size;if(e.type){u=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")}s=e instanceof D?e:n(e)}if(typeof l==="string"||r.isBuffer(l)){g=Buffer.byteLength(l)}if(c!=null){let A;s=new D({async start(){A=c(e)[Symbol.asyncIterator]()},async pull(e){const{value:t,done:r}=await A.next();if(r){queueMicrotask((()=>{e.close()}))}else{if(!B(s)){e.enqueue(new Uint8Array(t))}}return e.desiredSize>0},async cancel(e){await A.return()},type:undefined})}const E={stream:s,source:l,length:g};return[E,u]}function safelyExtractBody(e,A=false){if(!D){D=t(5356).ReadableStream}if(e instanceof D){f(!r.isDisturbed(e),"The body has already been consumed.");f(!e.locked,"The stream is locked.")}return extractBody(e,A)}function cloneBody(e){const[A,t]=e.stream.tee();const s=d(t,{transfer:[t]});const[,r]=s.tee();e.stream=A;return{stream:r,length:e.length,source:e.source}}async function*consumeBody(e){if(e){if(p(e)){yield e}else{const A=e.stream;if(r.isDisturbed(A)){throw new TypeError("The body has already been consumed.")}if(A.locked){throw new TypeError("The stream is locked.")}A[I]=true;yield*A}}}function throwIfAborted(e){if(e.aborted){throw new h("The operation was aborted.","AbortError")}}function bodyMixinMethods(e){const A={blob(){return specConsumeBody(this,(e=>{let A=bodyMimeType(this);if(A==="failure"){A=""}else if(A){A=k(A)}return new Q([e],{type:A})}),e)},arrayBuffer(){return specConsumeBody(this,(e=>new Uint8Array(e).buffer),e)},text(){return specConsumeBody(this,utf8DecodeBytes,e)},json(){return specConsumeBody(this,parseJSONFromBytes,e)},async formData(){E.brandCheck(this,e);throwIfAborted(this[u]);const A=this.headers.get("Content-Type");if(/multipart\/form-data/.test(A)){const e={};for(const[A,t]of this.headers)e[A.toLowerCase()]=t;const A=new g;let t;try{t=new s({headers:e,preservePath:true})}catch(e){throw new h(`${e}`,"AbortError")}t.on("field",((e,t)=>{A.append(e,t)}));t.on("file",((e,t,s,r,n)=>{const i=[];if(r==="base64"||r.toLowerCase()==="base64"){let r="";t.on("data",(e=>{r+=e.toString().replace(/[\r\n]/gm,"");const A=r.length-r.length%4;i.push(Buffer.from(r.slice(0,A),"base64"));r=r.slice(A)}));t.on("end",(()=>{i.push(Buffer.from(r,"base64"));A.append(e,new b(i,s,{type:n}))}))}else{t.on("data",(e=>{i.push(e)}));t.on("end",(()=>{A.append(e,new b(i,s,{type:n}))}))}}));const r=new Promise(((e,A)=>{t.on("finish",e);t.on("error",(e=>A(new TypeError(e))))}));if(this.body!==null)for await(const e of consumeBody(this[u].body))t.write(e);t.end();await r;return A}else if(/application\/x-www-form-urlencoded/.test(A)){let e;try{let A="";const t=new TextDecoder("utf-8",{ignoreBOM:true});for await(const e of consumeBody(this[u].body)){if(!p(e)){throw new TypeError("Expected Uint8Array chunk")}A+=t.decode(e,{stream:true})}A+=t.decode();e=new URLSearchParams(A)}catch(e){throw Object.assign(new TypeError,{cause:e})}const A=new g;for(const[t,s]of e){A.append(t,s)}return A}else{await Promise.resolve();throwIfAborted(this[u]);throw E.errors.exception({header:`${e.name}.formData`,message:"Could not parse content as FormData."})}}};return A}function mixinBody(e){Object.assign(e.prototype,bodyMixinMethods(e))}async function specConsumeBody(e,A,t){E.brandCheck(e,t);throwIfAborted(e[u]);if(bodyUnusable(e[u].body)){throw new TypeError("Body is unusable")}const s=c();const errorSteps=e=>s.reject(e);const successSteps=e=>{try{s.resolve(A(e))}catch(e){errorSteps(e)}};if(e[u].body==null){successSteps(new Uint8Array);return s.promise}await l(e[u].body,successSteps,errorSteps);return s.promise}function bodyUnusable(e){return e!=null&&(e.stream.locked||r.isDisturbed(e.stream))}function utf8DecodeBytes(e){if(e.length===0){return""}if(e[0]===239&&e[1]===187&&e[2]===191){e=e.subarray(3)}const A=S.decode(e);return A}function parseJSONFromBytes(e){return JSON.parse(utf8DecodeBytes(e))}function bodyMimeType(e){const{headersList:A}=e[u];const t=A.get("content-Line truncated
|
||||
/*! ws. MIT License. Einar Otto Stangvik <einaros@gmail.com> */n[r-4]=this.maskKey[0];n[r-3]=this.maskKey[1];n[r-2]=this.maskKey[2];n[r-1]=this.maskKey[3];n[1]=t;if(t===126){n.writeUInt16BE(A,2)}else if(t===127){n[2]=n[3]=0;n.writeUIntBE(A,4,6)}n[1]|=128;for(let e=0;e<A;e++){n[r+e]=this.frameData[e]^this.maskKey[e%4]}return n}}e.exports={WebsocketFrameSend:WebsocketFrameSend}},8634:(e,A,t)=>{"use strict";const{Writable:s}=t(2781);const r=t(7643);const{parserStates:n,opcodes:i,states:o,emptyBuffer:a}=t(1937);const{kReadyState:c,kSentClose:l,kResponse:g,kReceivedClose:u}=t(2319);const{isValidStatusCode:E,failWebsocketConnection:h,websocketMessageReceived:d}=t(865);const{WebsocketFrameSend:Q}=t(7825);const C={};C.ping=r.channel("undici:websocket:ping");C.pong=r.channel("undici:websocket:pong");class ByteParser extends s{#i=[];#o=0;#a=n.INFO;#c={};#l=[];constructor(e){super();this.ws=e}_write(e,A,t){this.#i.push(e);this.#o+=e.length;this.run(t)}run(e){while(true){if(this.#a===n.INFO){if(this.#o<2){return e()}const A=this.consume(2);this.#c.fin=(A[0]&128)!==0;this.#c.opcode=A[0]&15;this.#c.originalOpcode??=this.#c.opcode;this.#c.fragmented=!this.#c.fin&&this.#c.opcode!==i.CONTINUATION;if(this.#c.fragmented&&this.#c.opcode!==i.BINARY&&this.#c.opcode!==i.TEXT){h(this.ws,"Invalid frame type was fragmented.");return}const t=A[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){h(this.ws,"Fragmented frame exceeded 125 bytes.");return}else if((this.#c.opcode===i.PING||this.#c.opcode===i.PONG||this.#c.opcode===i.CLOSE)&&t>125){h(this.ws,"Payload length for control frame exceeded 125 bytes.");return}else if(this.#c.opcode===i.CLOSE){if(t===1){h(this.ws,"Received close frame with a 1-byte body.");return}const e=this.consume(t);this.#c.closeInfo=this.parseCloseBody(false,e);if(!this.ws[l]){const e=Buffer.allocUnsafe(2);e.writeUInt16BE(this.#c.closeInfo.code,0);const A=new Q(e);this.ws[g].socket.write(A.createFrame(i.CLOSE),(e=>{if(!e){this.ws[l]=true}}))}this.ws[c]=o.CLOSING;this.ws[u]=true;this.end();return}else if(this.#c.opcode===i.PING){const A=this.consume(t);if(!this.ws[u]){const e=new Q(A);this.ws[g].socket.write(e.createFrame(i.PONG));if(C.ping.hasSubscribers){C.ping.publish({payload:A})}}this.#a=n.INFO;if(this.#o>0){continue}else{e();return}}else if(this.#c.opcode===i.PONG){const A=this.consume(t);if(C.pong.hasSubscribers){C.pong.publish({payload:A})}if(this.#o>0){continue}else{e();return}}}else if(this.#a===n.PAYLOADLENGTH_16){if(this.#o<2){return e()}const A=this.consume(2);this.#c.payloadLength=A.readUInt16BE(0);this.#a=n.READ_DATA}else if(this.#a===n.PAYLOADLENGTH_64){if(this.#o<8){return e()}const A=this.consume(8);const t=A.readUInt32BE(0);if(t>2**31-1){h(this.ws,"Received payload length > 2^31 bytes.");return}const s=A.readUInt32BE(4);this.#c.payloadLength=(t<<8)+s;this.#a=n.READ_DATA}else if(this.#a===n.READ_DATA){if(this.#o<this.#c.payloadLength){return e()}else if(this.#o>=this.#c.payloadLength){const e=this.consume(this.#c.payloadLength);this.#l.push(e);if(!this.#c.fragmented||this.#c.fin&&this.#c.opcode===i.CONTINUATION){const e=Buffer.concat(this.#l);d(this.ws,this.#c.originalOpcode,e);this.#c={};this.#l.length=0}this.#a=n.INFO}}if(this.#o>0){continue}else{e();break}}}consume(e){if(e>this.#o){return null}else if(e===0){return a}if(this.#i[0].length===e){this.#o-=this.#i[0].length;return this.#i.shift()}const A=Buffer.allocUnsafe(e);let t=0;while(t!==e){const s=this.#i[0];const{length:r}=s;if(r+t===e){A.set(this.#i.shift(),t);break}else if(r+t>e){A.set(s.subarray(0,e-t),t);this.#i[0]=s.subarray(e-t);break}else{A.set(this.#i.shift(),t);t+=s.length}}this.#o-=e;return A}parseCloseBody(e,A){let t;if(A.length>=2){t=A.readUInt16BE(0)}if(e){if(!E(t)){return null}return{code:t}}let s=A.subarray(2);if(s[0]===239&&s[1]===187&&s[2]===191){s=s.subarray(3)}if(t!==undefined&&!E(t)){return null}try{s=new TextDecoder("utf-8",{fatal:true}).decode(s)}catch{return null}return{code:t,reason:s}}get closingInfo(){return this.#c.closeInfo}}e.exports={ByteParser:ByteParser}},2319:e=>{"use strict";e.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")}},865:(e,A,t)=>{"use strict";const{kReadyState:s,kController:r,kResponse:n,kBinaryType:i,kWebSocketURL:o}=t(2319);const{states:a,opcodes:c}=t(1937);const{MessageEvent:l,ErrorEvent:g}=t(5310);function isEstablished(e){return e[s]===a.OPEN}function isClosing(e){return e[s]===a.CLOSING}function isClosed(e){return e[s]===a.CLOSED}function fireEvent(e,A,t=Event,s){const r=new t(e,s);A.dispatchEvent(r)}function websocketMessageReceived(e,A,t){if(e[s]!==a.OPEN){return}let r;if(A===c.TEXT){try{r=new TextDecoder("utf-8",{fatal:true}).decode(t)}cLine truncated
|
||||
var n=s(9048);var r=s(6928);e.exports=function expandTilde(e){var t=n();if(e.charCodeAt(0)===126){if(e.charCodeAt(1)===43){return r.join(process.cwd(),e.slice(2))}return t?r.join(t,e.slice(1)):e}return e}},9048:(e,t,s)=>{"use strict";var n=s(857);if(typeof n.homedir!=="undefined"){e.exports=n.homedir}else{e.exports=s(8873)}},8873:(e,t,s)=>{"use strict";var n=s(9896);var r=s(7393);function homedir(){if(process.platform==="win32"){if(process.env.USERPROFILE){return process.env.USERPROFILE}if(process.env.HOMEDRIVE&&process.env.HOMEPATH){return process.env.HOMEDRIVE+process.env.HOMEPATH}if(process.env.HOME){return process.env.HOME}return null}if(process.env.HOME){return process.env.HOME}var e=tryReadFileSync("/etc/passwd");var t=find(r(e),getuid());if(t){return t}var s=process.env.LOGNAME||process.env.USER||process.env.LNAME||process.env.USERNAME;if(!s){return null}if(process.platform==="darwin"){return"/Users/"+s}return"/home/"+s}function find(e,t){var s=e.length;for(var n=0;n<s;n++){if(+e[n].uid===t){return e[n].homedir}}}function getuid(){if(typeof process.geteuid==="function"){return process.geteuid()}return process.getuid()}function tryReadFileSync(e){try{return n.readFileSync(e,"utf8")}catch(e){return""}}e.exports=homedir},7393:e=>{"use strict";e.exports=function(e){if(typeof e!=="string"){throw new Error("expected a string")}return e.split("\n").map(user).filter(Boolean)};function user(e,t){if(!e||!e.length||e.charAt(0)==="#"){return null}var s=e.split(":");return{username:s[0],password:s[1],uid:s[2],gid:s[3],gecos:s[4],homedir:s[5],shell:s[6]}}},6124:(e,t,s)=>{e.exports=s(3660)},3660:(e,t,s)=>{"use strict";var n=s(9278);var r=s(4756);var i=s(8611);var o=s(5692);var a=s(4434);var c=s(2613);var l=s(9023);t.httpOverHttp=httpOverHttp;t.httpsOverHttp=httpsOverHttp;t.httpOverHttps=httpOverHttps;t.httpsOverHttps=httpsOverHttps;function httpOverHttp(e){var t=new TunnelingAgent(e);t.request=i.request;return t}function httpsOverHttp(e){var t=new TunnelingAgent(e);t.request=i.request;t.createSocket=createSecureSocket;t.defaultPort=443;return t}function httpOverHttps(e){var t=new TunnelingAgent(e);t.request=o.request;return t}function httpsOverHttps(e){var t=new TunnelingAgent(e);t.request=o.request;t.createSocket=createSecureSocket;t.defaultPort=443;return t}function TunnelingAgent(e){var t=this;t.options=e||{};t.proxyOptions=t.options.proxy||{};t.maxSockets=t.options.maxSockets||i.Agent.defaultMaxSockets;t.requests=[];t.sockets=[];t.on("free",(function onFree(e,s,n,r){var i=toOptions(s,n,r);for(var o=0,a=t.requests.length;o<a;++o){var c=t.requests[o];if(c.host===i.host&&c.port===i.port){t.requests.splice(o,1);c.request.onSocket(e);return}}e.destroy();t.removeSocket(e)}))}l.inherits(TunnelingAgent,a.EventEmitter);TunnelingAgent.prototype.addRequest=function addRequest(e,t,s,n){var r=this;var i=mergeOptions({request:e},r.options,toOptions(t,s,n));if(r.sockets.length>=this.maxSockets){r.requests.push(i);return}r.createSocket(i,(function(t){t.on("free",onFree);t.on("close",onCloseOrRemove);t.on("agentRemove",onCloseOrRemove);e.onSocket(t);function onFree(){r.emit("free",t,i)}function onCloseOrRemove(e){r.removeSocket(t);t.removeListener("free",onFree);t.removeListener("close",onCloseOrRemove);t.removeListener("agentRemove",onCloseOrRemove)}}))};TunnelingAgent.prototype.createSocket=function createSocket(e,t){var s=this;var n={};s.sockets.push(n);var r=mergeOptions({},s.proxyOptions,{method:"CONNECT",path:e.host+":"+e.port,agent:false,headers:{host:e.host+":"+e.port}});if(e.localAddress){r.localAddress=e.localAddress}if(r.proxyAuth){r.headers=r.headers||{};r.headers["Proxy-Authorization"]="Basic "+new Buffer(r.proxyAuth).toString("base64")}u("making CONNECT request");var i=s.request(r);i.useChunkedEncodingByDefault=false;i.once("response",onResponse);i.once("upgrade",onUpgrade);i.once("connect",onConnect);i.once("error",onError);i.end();function onResponse(e){e.upgrade=true}function onUpgrade(e,t,s){process.nextTick((function(){onConnect(e,t,s)}))}function onConnect(r,o,a){i.removeAllListeners();o.removeAllListeners();if(r.statusCode!==200){u("tunneling socket could not be established, statusCode=%d",r.statusCode);o.destroy();var c=new Error("tunneling socket could not be established, "+"statusCode="+r.statusCode);c.code="ECONNRESET";e.request.emit("error",c);s.removeSocket(n);return}if(a.length>0){u("got illegal response body from proxy");o.destroy();var c=new Error("got illegal response body from proxy");c.code="ECONNRESET";e.request.emit("error",c);s.removeSocket(n);return}u("tunneling connection has established");s.sockets[s.sockets.indexOf(n)]=o;return t(o)}function onError(t){i.removeAllListeners();u("tunneling socket could not be established, cause=%s\n",t.message,t.stack);var r=new Error("tunneling socket could not be established, "+"cause="+t.message);r.code="ECONNRESET";e.request.emit("error",r);s.removeSocket(n)}};TunnelingAgent.prototype.removeSocket=function removeSocket(e){var t=this.sockets.indexOf(e);Line truncated
|
||||
Reference in new issue
Block a user