mirror of
https://github.com/pnpm/action-setup
synced 2026-11-10 06:07:57 +01:00
refactor: replace fs-extra with Node.js built-in fs methods (#120)
This commit is contained in:
Sukka authored and 
GitHub committed
1 parent
2ab6dce4f5
commit
ce859e384f
4 files changed
+9
-54
No files matched your search
Vendored
+4
-4
@@ -1,10 +1,10 @@
|
||||
(()=>{var e={276:function(e,t,A){"use strict";var s=this&&this.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(t,"__esModule",{value:true});const r=A(9093);const n=s(A(1784));const i=s(A(2960));const o=s(A(7650));const a=s(A(9462));const c=s(A(8307));async function main(){const e=(0,n.default)();const t=(0,r.getState)("is_post");if(t==="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,t,A){"use strict";var s=this&&this.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(t,"__esModule",{value:true});t.getInputs=void 0;const r=A(9093);const n=s(A(1791));const i=A(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")});t.getInputs=getInputs;t["default"]=t.getInputs},7090:function(e,t,A){"use strict";var s=this&&this.__createBinding||(Object.create?function(e,t,A,s){if(s===undefined)s=A;var r=Object.getOwnPropertyDescriptor(t,A);if(!r||("get"in r?!t.__esModule:r.writable||r.configurable)){r={enumerable:true,get:function(){return t[A]}}}Object.defineProperty(e,s,r)}:function(e,t,A,s){if(s===undefined)s=A;e[s]=t[A]});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 n=this&&this.__importStar||function(e){if(e&&e.__esModule)return e;var t={};if(e!=null)for(var A in e)if(A!=="default"&&Object.prototype.hasOwnProperty.call(e,A))s(t,e,A);r(t,e);return t};Object.defineProperty(t,"__esModule",{value:true});t.parseRunInstall=void 0;const i=A(9093);const o=n(A(2825));const a=A(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 t=(0,i.getInput)(e,{required:true});const A=o.parse(t);try{const e=l.parse(A);if(!e)return[];if(e===true)return[{recursive:true}];if(Array.isArray(e))return e;return[e]}catch(A){(0,i.error)(`Error for input "${e}" = ${t}`);if(A instanceof a.ZodError){(0,i.error)(`Errors: ${A.errors}`)}else{(0,i.error)(`Exception: ${A}`)}process.exit(1)}}t.parseRunInstall=parseRunInstall},2960:function(e,t,A){"use strict";var s=this&&this.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(t,"__esModule",{value:true});t.install=t.runSelfInstaller=void 0;const r=A(9093);const n=s(A(9530));t.runSelfInstaller=n.default;async function install(e){(0,r.startGroup)("Running self-installer...");const t=await(0,n.default)(e);(0,r.endGroup)();if(t){return(0,r.setFailed)(`Something went wrong, self-installer exits with code ${t}`)}}t.install=install;t["default"]=install},9530:function(e,t,A){"use strict";var s=this&&this.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(t,"__esModule",{value:true});t.runSelfInstaller=void 0;const r=A(9093);const n=A(2081);const i=A(3175);const o=s(A(1017));const a=A(7282);async function runSelfInstaller(e){const{version:t,dest:A,packageJsonFile:s,standalone:c}=e;await(0,i.remove)(A);const l=o.default.join(A,"package.json");await(0,i.ensureFile)(l);await(0,i.writeFile)(l,JSON.stringify({private:true}));const u=await readTarget({version:t,packageJsonFile:s,standalone:c});const g=(0,n.spawn)(a.execPath,[o.default.join(__dirname,"pnpm.cjs"),"install",u,"--no-lockfile"],{cwd:A,stdio:["pipe","inherit","inherit"]});const h=await new Promise(((e,t)=>{g.on("error",t);g.on("close",e)}));if(h===0){const e=o.default.join(A,"node_modules/.bin");(0,r.addPath)(e);(0,r.exportVariable)("PNPM_HOME",e)}return h}t.runSelfInstaller=runSelfInstaller;async function readTarget(e){const{version:t,packageJsonFile:A,standalone:s}=e;if(t)return`${s?"@pnpm/exe":"pnpm"}@${t}`;const{GITHUB_WORKSPACE:r}=process.env;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 the package.json file,\nplease run the actions/checkout before pnpm/action-setup.\nOtherwise, please specify the pnpm version in the action configuration.`)}const{packageManager:n}=JSON.parse(await(0,i.readFile)(o.default.join(r,A),"utf8"));if(typeof n!=="string"){throw new Error(`No pnpm version is specified.\nPlease specify it by one of the following ways:\n - in the GitHub Action config with the key "version"\n - in the package.json with the key "packageManager"`)}if(!n.startsWith("pnpm@")){throw new Error("Invalid packageManager field in package.json")}if(s){return n.replace("pnpm@Line truncated
|
||||
(()=>{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=s(t(1017));const a=t(7282);async function runSelfInstaller(e){const{version:A,dest:t,packageJsonFile:s,standalone:c}=e;await(0,i.rm)(t,{recursive:true,force:true});await(0,i.mkdir)(t,{recursive:true});const l=o.default.join(t,"package.json");await(0,i.writeFile)(l,JSON.stringify({private:true}));const g=await readTarget({version:A,packageJsonFile:s,standalone:c});const u=(0,n.spawn)(a.execPath,[o.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=o.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;if(A)return`${s?"@pnpm/exe":"pnpm"}@${A}`;const{GITHUB_WORKSPACE:r}=process.env;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 the package.json file,\nplease run the actions/checkout before pnpm/action-setup.\nOtherwise, please specify the pnpm version in the action configuration.`)}const{packageManager:n}=JSON.parse(await(0,i.readFile)(o.default.join(r,t),"utf8"));if(typeof n!=="string"){throw new Error(`No pnpm version is specified.\nPlease specify it by one of the following ways:\n - in the GitHub Action config with the key "version"\n - in the package.json with the key "packageManager"`)}if(!n.startsWith("pnpm@")){throw new Error("Invalid packageManager field in package.Line truncated
|
||||
/*!
|
||||
* expand-tilde <https://github.com/jonschlinkert/expand-tilde>
|
||||
*
|
||||
* Copyright (c) 2015 Jon Schlinkert.
|
||||
* Licensed under the MIT license.
|
||||
*/
|
||||
var s=A(9171);var r=A(1017);e.exports=function expandTilde(e){var t=s();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}},5524:(e,t,A)=>{"use strict";const s=A(7804);const r=A(1017);const n=A(8516).mkdirsSync;const i=A(7227).utimesMillisSync;const o=A(8826);function copySync(e,t,A){if(typeof A==="function"){A={filter:A}}A=A||{};A.clobber="clobber"in A?!!A.clobber:true;A.overwrite="overwrite"in A?!!A.overwrite:A.clobber;if(A.preserveTimestamps&&process.arch==="ia32"){process.emitWarning("Using the preserveTimestamps option in 32-bit node is not recommended;\n\n"+"\tsee https://github.com/jprichardson/node-fs-extra/issues/269","Warning","fs-extra-WARN0002")}const{srcStat:i,destStat:a}=o.checkPathsSync(e,t,"copy",A);o.checkParentPathsSync(e,i,t,"copy");if(A.filter&&!A.filter(e,t))return;const c=r.dirname(t);if(!s.existsSync(c))n(c);return getStats(a,e,t,A)}function getStats(e,t,A,r){const n=r.dereference?s.statSync:s.lstatSync;const i=n(t);if(i.isDirectory())return onDir(i,e,t,A,r);else if(i.isFile()||i.isCharacterDevice()||i.isBlockDevice())return onFile(i,e,t,A,r);else if(i.isSymbolicLink())return onLink(e,t,A,r);else if(i.isSocket())throw new Error(`Cannot copy a socket file: ${t}`);else if(i.isFIFO())throw new Error(`Cannot copy a FIFO pipe: ${t}`);throw new Error(`Unknown file: ${t}`)}function onFile(e,t,A,s,r){if(!t)return copyFile(e,A,s,r);return mayCopyFile(e,A,s,r)}function mayCopyFile(e,t,A,r){if(r.overwrite){s.unlinkSync(A);return copyFile(e,t,A,r)}else if(r.errorOnExist){throw new Error(`'${A}' already exists`)}}function copyFile(e,t,A,r){s.copyFileSync(t,A);if(r.preserveTimestamps)handleTimestamps(e.mode,t,A);return setDestMode(A,e.mode)}function handleTimestamps(e,t,A){if(fileIsNotWritable(e))makeFileWritable(A,e);return setDestTimestamps(t,A)}function fileIsNotWritable(e){return(e&128)===0}function makeFileWritable(e,t){return setDestMode(e,t|128)}function setDestMode(e,t){return s.chmodSync(e,t)}function setDestTimestamps(e,t){const A=s.statSync(e);return i(t,A.atime,A.mtime)}function onDir(e,t,A,s,r){if(!t)return mkDirAndCopy(e.mode,A,s,r);return copyDir(A,s,r)}function mkDirAndCopy(e,t,A,r){s.mkdirSync(A);copyDir(t,A,r);return setDestMode(A,e)}function copyDir(e,t,A){s.readdirSync(e).forEach((s=>copyDirItem(s,e,t,A)))}function copyDirItem(e,t,A,s){const n=r.join(t,e);const i=r.join(A,e);if(s.filter&&!s.filter(n,i))return;const{destStat:a}=o.checkPathsSync(n,i,"copy",s);return getStats(a,n,i,s)}function onLink(e,t,A,n){let i=s.readlinkSync(t);if(n.dereference){i=r.resolve(process.cwd(),i)}if(!e){return s.symlinkSync(i,A)}else{let e;try{e=s.readlinkSync(A)}catch(e){if(e.code==="EINVAL"||e.code==="UNKNOWN")return s.symlinkSync(i,A);throw e}if(n.dereference){e=r.resolve(process.cwd(),e)}if(o.isSrcSubdir(i,e)){throw new Error(`Cannot copy '${i}' to a subdirectory of itself, '${e}'.`)}if(o.isSrcSubdir(e,i)){throw new Error(`Cannot overwrite '${e}' with '${i}'.`)}return copyLink(i,A)}}function copyLink(e,t){s.unlinkSync(t);return s.symlinkSync(e,t)}e.exports=copySync},5770:(e,t,A)=>{"use strict";const s=A(5845);const r=A(1017);const{mkdirs:n}=A(8516);const{pathExists:i}=A(9667);const{utimesMillis:o}=A(7227);const a=A(8826);async function copy(e,t,A={}){if(typeof A==="function"){A={filter:A}}A.clobber="clobber"in A?!!A.clobber:true;A.overwrite="overwrite"in A?!!A.overwrite:A.clobber;if(A.preserveTimestamps&&process.arch==="ia32"){process.emitWarning("Using the preserveTimestamps option in 32-bit node is not recommended;\n\n"+"\tsee https://github.com/jprichardson/node-fs-extra/issues/269","Warning","fs-extra-WARN0001")}const{srcStat:s,destStat:o}=await a.checkPaths(e,t,"copy",A);await a.checkParentPaths(e,s,t,"copy");const c=await runFilter(e,t,A);if(!c)return;const l=r.dirname(t);const u=await i(l);if(!u){await n(l)}await getStatsAndPerformCopy(o,e,t,A)}async function runFilter(e,t,A){if(!A.filter)return true;return A.filter(e,t)}async function getStatsAndPerformCopy(e,t,A,r){const n=r.dereference?s.stat:s.lstat;const i=await n(t);if(i.isDirectory())return onDir(i,e,t,A,r);if(i.isFile()||i.isCharacterDevice()||i.isBlockDevice())return onFile(i,e,t,A,r);if(i.isSymbolicLink())return onLink(e,t,A,r);if(i.isSocket())throw new Error(`Cannot copy a socket file: ${t}`);if(i.isFIFO())throw new Error(`Cannot copy a FIFO pipe: ${t}`);throw new Error(`Unknown file: ${t}`)}async function onFile(e,t,A,r,n){if(!t)return copyFile(e,A,r,n);if(n.overwrite){await s.unlink(r);return copyFile(e,A,r,n)}if(n.errorOnExist){throw new Error(`'${r}' already exists`)}}async function copyFile(e,t,A,r){await s.copyFile(t,A);if(r.preserveTimestamps){if(fileIsNotWritable(e.mode)){await makeFileWritable(A,e.mode)}const r=await s.stat(t);await o(A,r.atime,r.mtime)}return s.chmod(A,e.mode)}function fileIsNotWritable(e){return(e&128)===0}function makeFileWritable(e,t){return s.chmod(e,t|128)}async function onDir(e,t,A,n,i){if(!t){await s.mkdir(n)}conLine 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]);u=0;let n=false;for(const[t,i]of e){if(typeof i==="string"){const e=R.encode(A+`; name="${escape(normalizeLinefeeds(t))}"`+`\r\n\r\n${normalizeLinefeeds(i)}\r\n`);s.push(e);u+=e.byteLength}else{const e=R.encode(`${A}; name="${escape(normalizeLinefeeds(t))}"`+(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"){u+=e.byteLength+i.size+r.byteLength}else{n=true}}}const i=R.encode(`--${t}--`);s.push(i);u+=i.byteLength;if(n){u=null}l=e;c=async function*(){for(const e of s){if(e.stream){yield*e.stream()}else{yield e}}};g="multipart/form-data; boundary="+t}else if(i(e)){l=e;u=e.size;if(e.type){g=e.type}}else if(typeof e[Symbol.asyncIterator]==="function"){if(t){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 b?e:n(e)}if(typeof l==="string"||r.isBuffer(l)){u=Buffer.byteLength(l)}if(c!=null){let t;s=new b({async start(){t=c(e)[Symbol.asyncIterator]()},async pull(e){const{value:A,done:r}=await t.next();if(r){queueMicrotask((()=>{e.close()}))}else{if(!B(s)){e.enqueue(new Uint8Array(A))}}return e.desiredSize>0},async cancel(e){await t.return()},type:undefined})}const h={stream:s,source:l,length:u};return[h,g]}function safelyExtractBody(e,t=false){if(!b){b=A(5356).ReadableStream}if(e instanceof b){I(!r.isDisturbed(e),"The body has already been consumed.");I(!e.locked,"The stream is locked.")}return extractBody(e,t)}function cloneBody(e){const[t,A]=e.stream.tee();const s=E(A,{transfer:[A]});const[,r]=s.tee();e.stream=t;return{stream:r,length:e.length,source:e.source}}async function*consumeBody(e){if(e){if(p(e)){yield e}else{const t=e.stream;if(r.isDisturbed(t)){throw new TypeError("The body has already been consumed.")}if(t.locked){throw new TypeError("The stream is locked.")}t[Q]=true;yield*t}}}function throwIfAborted(e){if(e.aborted){throw new d("The operation was aborted.","AbortError")}}function bodyMixinMethods(e){const t={blob(){return specConsumeBody(this,(e=>{let t=bodyMimeType(this);if(t==="failure"){t=""}else if(t){t=k(t)}return new f([e],{type:t})}),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(){h.brandCheck(this,e);throwIfAborted(this[g]);const t=this.headers.get("Content-Type");if(/multipart\/form-data/.test(t)){const e={};for(const[t,A]of this.headers)e[t.toLowerCase()]=A;const t=new u;let A;try{A=new s({headers:e,preservePath:true})}catch(e){throw new d(`${e}`,"AbortError")}A.on("field",((e,A)=>{t.append(e,A)}));A.on("file",((e,A,s,r,n)=>{const i=[];if(r==="base64"||r.toLowerCase()==="base64"){let r="";A.on("data",(e=>{r+=e.toString().replace(/[\r\n]/gm,"");const t=r.length-r.length%4;i.push(Buffer.from(r.slice(0,t),"base64"));r=r.slice(t)}));A.on("end",(()=>{i.push(Buffer.from(r,"base64"));t.append(e,new D(i,s,{type:n}))}))}else{A.on("data",(e=>{i.push(e)}));A.on("end",(()=>{t.append(e,new D(i,s,{type:n}))}))}}));const r=new Promise(((e,t)=>{A.on("finish",e);A.on("error",(e=>t(new TypeError(e))))}));if(this.body!==null)for await(const e of consumeBody(this[g].body))A.write(e);A.end();await r;return t}else if(/application\/x-www-form-urlencoded/.test(t)){let e;try{let t="";const A=new TextDecoder("utf-8",{ignoreBOM:true});for await(const e of consumeBody(this[g].body)){if(!p(e)){throw new TypeError("Expected Uint8Array chunk")}t+=A.decode(e,{stream:true})}t+=A.decode();e=new URLSearchParams(t)}catch(e){throw Object.assign(new TypeError,{cause:e})}const t=new u;for(const[A,s]of e){t.append(A,s)}return t}else{await Promise.resolve();throwIfAborted(this[g]);throw h.errors.exception({header:`${e.name}.formData`,message:"Could not parse content as FormData."})}}};return t}function mixinBody(e){Object.assign(e.prototype,bodyMixinMethods(e))}async function specConsumeBody(e,t,A){h.brandCheck(e,A);throwIfAborted(e[g]);if(bodyUnusable(e[g].body)){throw new TypeError("Body is unusable")}const s=c();const errorSteps=e=>s.reject(e);const successSteps=e=>{try{s.resolve(t(e))}catch(e){errorSteps(e)}};if(e[g].body==null){successSteps(new Uint8Array);return s.promise}await l(e[g].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 t=S.decode(e);return t}function parseJSONFromBytes(e){return JSON.parse(utf8DecodeBytes(e))}function bodyMimeType(e){const{headersList:t}=e[g];const A=t.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]=A;if(A===126){n.writeUInt16BE(t,2)}else if(A===127){n[2]=n[3]=0;n.writeUIntBE(t,4,6)}n[1]|=128;for(let e=0;e<t;e++){n[r+e]=this.frameData[e]^this.maskKey[e%4]}return n}}e.exports={WebsocketFrameSend:WebsocketFrameSend}},8634:(e,t,A)=>{"use strict";const{Writable:s}=A(2781);const r=A(7643);const{parserStates:n,opcodes:i,states:o,emptyBuffer:a}=A(1937);const{kReadyState:c,kSentClose:l,kResponse:u,kReceivedClose:g}=A(2319);const{isValidStatusCode:h,failWebsocketConnection:d,websocketMessageReceived:E}=A(865);const{WebsocketFrameSend:f}=A(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,t,A){this.#i.push(e);this.#o+=e.length;this.run(A)}run(e){while(true){if(this.#a===n.INFO){if(this.#o<2){return e()}const t=this.consume(2);this.#c.fin=(t[0]&128)!==0;this.#c.opcode=t[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){d(this.ws,"Invalid frame type was fragmented.");return}const A=t[1]&127;if(A<=125){this.#c.payloadLength=A;this.#a=n.READ_DATA}else if(A===126){this.#a=n.PAYLOADLENGTH_16}else if(A===127){this.#a=n.PAYLOADLENGTH_64}if(this.#c.fragmented&&A>125){d(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)&&A>125){d(this.ws,"Payload length for control frame exceeded 125 bytes.");return}else if(this.#c.opcode===i.CLOSE){if(A===1){d(this.ws,"Received close frame with a 1-byte body.");return}const e=this.consume(A);this.#c.closeInfo=this.parseCloseBody(false,e);if(!this.ws[l]){const e=Buffer.allocUnsafe(2);e.writeUInt16BE(this.#c.closeInfo.code,0);const t=new f(e);this.ws[u].socket.write(t.createFrame(i.CLOSE),(e=>{if(!e){this.ws[l]=true}}))}this.ws[c]=o.CLOSING;this.ws[g]=true;this.end();return}else if(this.#c.opcode===i.PING){const t=this.consume(A);if(!this.ws[g]){const e=new f(t);this.ws[u].socket.write(e.createFrame(i.PONG));if(C.ping.hasSubscribers){C.ping.publish({payload:t})}}this.#a=n.INFO;if(this.#o>0){continue}else{e();return}}else if(this.#c.opcode===i.PONG){const t=this.consume(A);if(C.pong.hasSubscribers){C.pong.publish({payload:t})}if(this.#o>0){continue}else{e();return}}}else if(this.#a===n.PAYLOADLENGTH_16){if(this.#o<2){return e()}const t=this.consume(2);this.#c.payloadLength=t.readUInt16BE(0);this.#a=n.READ_DATA}else if(this.#a===n.PAYLOADLENGTH_64){if(this.#o<8){return e()}const t=this.consume(8);const A=t.readUInt32BE(0);if(A>2**31-1){d(this.ws,"Received payload length > 2^31 bytes.");return}const s=t.readUInt32BE(4);this.#c.payloadLength=(A<<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);E(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 t=Buffer.allocUnsafe(e);let A=0;while(A!==e){const s=this.#i[0];const{length:r}=s;if(r+A===e){t.set(this.#i.shift(),A);break}else if(r+A>e){t.set(s.subarray(0,e-A),A);this.#i[0]=s.subarray(e-A);break}else{t.set(this.#i.shift(),A);A+=s.length}}this.#o-=e;return t}parseCloseBody(e,t){let A;if(t.length>=2){A=t.readUInt16BE(0)}if(e){if(!h(A)){return null}return{code:A}}let s=t.subarray(2);if(s[0]===239&&s[1]===187&&s[2]===191){s=s.subarray(3)}if(A!==undefined&&!h(A)){return null}try{s=new TextDecoder("utf-8",{fatal:true}).decode(s)}catch{return null}return{code:A,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,t,A)=>{"use strict";const{kReadyState:s,kController:r,kResponse:n,kBinaryType:i,kWebSocketURL:o}=A(2319);const{states:a,opcodes:c}=A(1937);const{MessageEvent:l,ErrorEvent:u}=A(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,t,A=Event,s){const r=new A(e,s);t.dispatchEvent(r)}function websocketMessageReceived(e,t,A){if(e[s]!==a.OPEN){return}let r;if(t===c.TEXT){try{r=new TextDecoder("utf-8",{fatal:true}).decode(A)}cLine truncated
|
||||
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}},4657:(e,A,t)=>{"use strict";const{Writable:s}=t(2781);const r=t(7643);const{parserStates:n,opcodes:i,states:o,emptyBuffer:a}=t(1974);const{kReadyState:c,kSentClose:l,kResponse:g,kReceivedClose:u}=t(2605);const{isValidStatusCode:E,failWebsocketConnection:h,websocketMessageReceived:d}=t(1744);const{WebsocketFrameSend:Q}=t(2052);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}},2605: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")}},1744:(e,A,t)=>{"use strict";const{kReadyState:s,kController:r,kResponse:n,kBinaryType:i,kWebSocketURL:o}=t(2605);const{states:a,opcodes:c}=t(1974);const{MessageEvent:l,ErrorEvent:g}=t(9382);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)Line truncated
|
||||
@@ -9,11 +9,9 @@
|
||||
"dependencies": {
|
||||
"@actions/core": "^1.10.1",
|
||||
"@types/expand-tilde": "^2.0.2",
|
||||
"@types/fs-extra": "^11.0.4",
|
||||
"@types/node": "^20.11.5",
|
||||
"@types/node-fetch": "^2.6.11",
|
||||
"expand-tilde": "^2.0.2",
|
||||
"fs-extra": "^11.2.0",
|
||||
"yaml": "^2.3.4",
|
||||
"zod": "^3.22.4"
|
||||
},
|
||||
|
||||
Generated
-45
@@ -11,9 +11,6 @@ dependencies:
|
||||
'@types/expand-tilde':
|
||||
specifier: ^2.0.2
|
||||
version: 2.0.2
|
||||
'@types/fs-extra':
|
||||
specifier: ^11.0.4
|
||||
version: 11.0.4
|
||||
'@types/node':
|
||||
specifier: ^20.11.5
|
||||
version: 20.11.5
|
||||
@@ -23,9 +20,6 @@ dependencies:
|
||||
expand-tilde:
|
||||
specifier: ^2.0.2
|
||||
version: 2.0.2
|
||||
fs-extra:
|
||||
specifier: ^11.2.0
|
||||
version: 11.2.0
|
||||
yaml:
|
||||
specifier: ^2.3.4
|
||||
version: 2.3.4
|
||||
@@ -69,19 +63,6 @@ packages:
|
||||
resolution: {integrity: sha512-wlsMYiapmIR4Eq/Z0qysN8xaDMjSkO6AIDNFx9oxgWGeKVA1jU+NzwPRZErBNP5z6/dx6QNkNpKglBGPO9OkTA==}
|
||||
dev: false
|
||||
|
||||
/@types/fs-extra@11.0.4:
|
||||
resolution: {integrity: sha512-yTbItCNreRooED33qjunPthRcSjERP1r4MqCZc7wv0u2sUkzTFp45tgUfS5+r7FrZPdmCCNflLhVSP/o+SemsQ==}
|
||||
dependencies:
|
||||
'@types/jsonfile': 6.1.4
|
||||
'@types/node': 20.11.5
|
||||
dev: false
|
||||
|
||||
/@types/jsonfile@6.1.4:
|
||||
resolution: {integrity: sha512-D5qGUYwjvnNNextdU59/+fI+spnwtTFmyQP0h+PfIOSkNfpU6AOICUOkm4i0OnSk+NyjdPJrxCDro0sJsWlRpQ==}
|
||||
dependencies:
|
||||
'@types/node': 20.11.5
|
||||
dev: false
|
||||
|
||||
/@types/node-fetch@2.6.11:
|
||||
resolution: {integrity: sha512-24xFj9R5+rfQJLRyM56qh+wnVSYhyXC2tkoBndtY0U+vubqNsYXGjufB2nn8Q6gt0LrARwL6UBtMCSVCwl4B1g==}
|
||||
dependencies:
|
||||
@@ -132,19 +113,6 @@ packages:
|
||||
mime-types: 2.1.35
|
||||
dev: false
|
||||
|
||||
/fs-extra@11.2.0:
|
||||
resolution: {integrity: sha512-PmDi3uwK5nFuXh7XDTlVnS17xJS7vW36is2+w3xcv8SVxiB4NyATf4ctkVY5bkSjX0Y4nbvZCq1/EjtEyr9ktw==}
|
||||
engines: {node: '>=14.14'}
|
||||
dependencies:
|
||||
graceful-fs: 4.2.11
|
||||
jsonfile: 6.1.0
|
||||
universalify: 2.0.1
|
||||
dev: false
|
||||
|
||||
/graceful-fs@4.2.11:
|
||||
resolution: {integrity: sha512-RbJ5/jmFcNNCcDV5o9eTnBLJ/HszWV0P73bc+Ff4nS/rJj+YaS6IGyiOL0VoBYX+l1Wrl3k63h/KrH+nhJ0XvQ==}
|
||||
dev: false
|
||||
|
||||
/homedir-polyfill@1.0.3:
|
||||
resolution: {integrity: sha512-eSmmWE5bZTK2Nou4g0AI3zZ9rswp7GRKoKXS1BLUkvPviOqs4YTN1djQIqrXy9k5gEtdLPy86JjRwsNM9tnDcA==}
|
||||
engines: {node: '>=0.10.0'}
|
||||
@@ -152,14 +120,6 @@ packages:
|
||||
parse-passwd: 1.0.0
|
||||
dev: false
|
||||
|
||||
/jsonfile@6.1.0:
|
||||
resolution: {integrity: sha512-5dgndWOriYSm5cnYaJNhalLNDKOqFwyDB/rr1E9ZsGciGvKPs8R2xYGCacuf3z6K1YKDz182fd+fY3cn3pMqXQ==}
|
||||
dependencies:
|
||||
universalify: 2.0.1
|
||||
optionalDependencies:
|
||||
graceful-fs: 4.2.11
|
||||
dev: false
|
||||
|
||||
/mime-db@1.52.0:
|
||||
resolution: {integrity: sha512-sPU4uV7dYlvtWJxwwxHD0PuihVNiE7TyAbQ5SWxDCB9mUYvOgroQOwYQQOKPJ8CIbE+1ETVlOoK1UC2nU3gYvg==}
|
||||
engines: {node: '>= 0.6'}
|
||||
@@ -205,11 +165,6 @@ packages:
|
||||
'@fastify/busboy': 2.1.0
|
||||
dev: false
|
||||
|
||||
/universalify@2.0.1:
|
||||
resolution: {integrity: sha512-gptHNQghINnc/vTGIk0SOFGFNXw7JVrlRUtConJRlvaw6DuX0wO5Jeko9sWrMBhh+PsYAZ7oXAiOnf/UKogyiw==}
|
||||
engines: {node: '>= 10.0.0'}
|
||||
dev: false
|
||||
|
||||
/uuid@8.3.2:
|
||||
resolution: {integrity: sha512-+NYs2QeMWy+GWFOEm9xnn6HCDp0l7QBD7ml8zLUmJ+93Q5NF0NocErnwkTkXVFNiX3/fpC6afS8Dhb/gz7R7eg==}
|
||||
hasBin: true
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
import { addPath, exportVariable } from '@actions/core'
|
||||
import { spawn } from 'child_process'
|
||||
import { remove, ensureFile, writeFile, readFile } from 'fs-extra'
|
||||
import { rm, writeFile, readFile, mkdir } from 'fs/promises'
|
||||
import path from 'path'
|
||||
import { execPath } from 'process'
|
||||
import { Inputs } from '../inputs'
|
||||
@@ -9,9 +9,11 @@ export async function runSelfInstaller(inputs: Inputs): Promise<number> {
|
||||
const { version, dest, packageJsonFile, standalone } = inputs
|
||||
|
||||
// prepare self install
|
||||
await remove(dest)
|
||||
await rm(dest, { recursive: true, force: true })
|
||||
// create dest directory after removal
|
||||
await mkdir(dest, { recursive: true })
|
||||
const pkgJson = path.join(dest, 'package.json')
|
||||
await ensureFile(pkgJson)
|
||||
// we have ensured the dest directory exists, we can write the file directly
|
||||
await writeFile(pkgJson, JSON.stringify({ private: true }))
|
||||
|
||||
// prepare target pnpm
|
||||
|
||||
Reference in new issue
Block a user