lage - npm Package Compare versions

Comparing version 2.12.6 to 2.12.7

dist/singleTargetWorker.js

@@ -7,5 +7,5 @@ "use strict";var Lt=Object.create;var Ke=Object.defineProperty;var $t=Object.getOwnPropertyDescriptor;var Bt=Object.getOwnPropertyNames;var Ft=Object.getPrototypeOf,Gt=Object.prototype.hasOwnProperty;var f=(r,e)=>()=>(e||r((e={exports:{}}).exports,e),e.exports);var Ut=(r,e,t,i)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of Bt(e))!Gt.call(r,s)&&s!==t&&Ke(r,s,{get:()=>e[s],enumerable:!(i=$t(e,s))||i.enumerable});return r};var zt=(r,e,t)=>(t=r!=null?Lt(Ft(r)):{},Ut(e||!r||!r.__esModule?Ke(t,"default",{value:r,enumerable:!0}):t,r));var A=f(X=>{"use strict";Object.defineProperty(X,"__esModule",{value:!0});function Kt(r,e){for(var t in e)Object.defineProperty(r,t,{enumerable:!0,get:e[t]})}Kt(X,{END_MARKER_PREFIX:function(){return Xe},START_MARKER_PREFIX:function(){return He},endMarker:function(){return Xt},startMarker:function(){return Ht}});var He="## WORKER:START:",Xe="## WORKER:END:";function Ht(r){return`${He}${r}`}function Xt(r){return`${Xe}${r}`}});var Je=f(J=>{"use strict";Object.defineProperty(J,"__esModule",{value:!0});Object.defineProperty(J,"registerWorker",{enumerable:!0,get:function(){return Jt}});var N=require("worker_threads"),C=A();function Jt(r){var i;(i=N.parentPort)==null||i.on("message",async s=>{let n;switch(s.type){case"start":return n=new AbortController,s.task&&await e(s.id,s.task,n.signal);case"abort":return n==null?void 0:n.abort();case"check-memory-usage":return t(N.parentPort)}});async function e(s,n,o){var u,c;try{process.stdout.write(`${(0,C.startMarker)(s)}
 `),"")),s.includes(j.END_MARKER_PREFIX)&&(s=s.replace(new RegExp(j.END_MARKER_PREFIX+`[0-9a-z]{64}
-`),"")),i(null,s)}})}});var Ve=f(Y=>{"use strict";Object.defineProperty(Y,"__esModule",{value:!0});Object.defineProperty(Y,"TaskInfo",{enumerable:!0,get:function(){return V}});var Yt=require("async_hooks");function Zt(r,e,t){return e in r?Object.defineProperty(r,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):r[e]=t,r}var V=class extends Yt.AsyncResource{get id(){return this.options.id}get weight(){return this.options.weight}get abortSignal(){return this.options.abortSignal}done(e,t){let{cleanup:i,worker:s,resolve:n,reject:o}=this.options;i&&this.runInAsyncScope(i,null,s),e?this.runInAsyncScope(o,null,e,s):this.runInAsyncScope(n,null,t,s),this.emitDestroy()}constructor(e){super("WorkerPoolTaskInfo"),Zt(this,"options",void 0),this.options=e,e.setup&&this.runInAsyncScope(e.setup,null,e.worker,e.worker.stdout,e.worker.stderr)}}});var ut=f(se=>{"use strict";Object.defineProperty(se,"__esModule",{value:!0});Object.defineProperty(se,"ThreadWorker",{enumerable:!0,get:function(){return te}});var Ye=Qe(),Ze=require("readline"),et=A(),er=require("events"),tt=require("stream"),tr=Ve(),rr=require("worker_threads"),sr=ot(require("crypto")),nr=ot(require("v8"));function nt(r,e){if(e.has(r))throw new TypeError("Cannot initialize the same private elements twice on an object")}function ir(r,e){return e.get?e.get.call(r):e.value}function or(r,e,t){if(e.set)e.set.call(r,t);else{if(!e.writable)throw new TypeError("attempted to set read only private field");e.value=t}}function it(r,e,t){if(!e.has(r))throw new TypeError("attempted to "+t+" private field on non-instance");return e.get(r)}function l(r,e){var t=it(r,e,"get");return ir(r,t)}function L(r,e,t){nt(r,e),e.set(r,t)}function T(r,e,t){var i=it(r,e,"set");return or(r,i,t),t}function b(r,e,t){if(!e.has(r))throw new TypeError("attempted to get private field on non-instance");return t}function $(r,e){nt(r,e),e.add(r)}function I(r,e,t){return e in r?Object.defineProperty(r,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):r[e]=t,r}function ot(r){return r&&r.__esModule?r:{default:r}}var ar="free",ur=nr.default.getHeapStatistics().total_available_size,y=new WeakMap,v=new WeakMap,P=new WeakMap,_=new WeakMap,Z=new WeakSet,ee=new WeakSet,at=new WeakSet,B=new WeakSet,te=class extends er.EventEmitter{start(e,t){this.status="busy";let{task:i,resolve:s,reject:n,cleanup:o,setup:u}=e;t==null||t.addEventListener("abort",b(this,B,re));let c=sr.default.randomBytes(32).toString("hex");T(this,y,new tr.TaskInfo({id:c,weight:e.weight,cleanup:o,resolve:s,reject:n,worker:this,setup:u,abortSignal:t})),l(this,v).promise=new Promise(a=>{l(this,v).resolve=a}),l(this,P).promise=new Promise(a=>{l(this,P).resolve=a}),l(this,_).postMessage({type:"start",task:{...i,weight:e.weight},id:c})}get weight(){var e;return((e=l(this,y))==null?void 0:e.weight)??1}get stdout(){return l(this,v).stream}get stderr(){return l(this,P).stream}get resourceLimits(){return l(this,_).resourceLimits}get threadId(){return l(this,_).threadId}terminate(){l(this,_).removeAllListeners(),l(this,_).terminate(),l(this,_).unref()}restart(){this.restarts++,this.status="busy",l(this,_).terminate(),b(this,Z,rt).call(this)}async checkMemoryUsage(){l(this,_).postMessage({type:"check-memory-usage"})}postMessage(e,t){l(this,_).postMessage(e,t)}constructor(e,t){super(),$(this,Z),$(this,ee),$(this,at),$(this,B),I(this,"script",void 0),I(this,"options",void 0),L(this,y,{writable:!0,value:void 0}),L(this,v,{writable:!0,value:void 0}),L(this,P,{writable:!0,value:void 0}),L(this,_,{writable:!0,value:void 0}),I(this,"status",void 0),I(this,"restarts",void 0),I(this,"maxWorkerMemoryUsage",void 0),this.script=e,this.options=t,T(this,v,{stream:new tt.Readable,promise:Promise.resolve(),resolve:()=>{}}),T(this,P,{stream:new tt.Readable,promise:Promise.resolve(),resolve:()=>{}}),this.status="busy",this.restarts=0,this.maxWorkerMemoryUsage=0,t.workerIdleMemoryLimitPercentage||(t.workerIdleMemoryLimitPercentage=80),b(this,Z,rt).call(this)}};function rt(){let{workerOptions:r}=this.options,e=this.script,t=new rr.Worker(e,{...r,stdout:!0,stderr:!0});b(this,at,cr).call(this,t);let i=t.stdout.pipe((0,Ye.createFilteredStreamTransform)()),s=t.stderr.pipe((0,Ye.createFilteredStreamTransform)()),n=()=>{},o=new Promise(d=>{n=d,d()}),u=()=>{},c=new Promise(d=>{u=d,d()}),a=d=>{var h;if(d.type==="status")Promise.all([l(this,v).promise,l(this,P).promise]).then(()=>{var w;let{err:g,results:m}=d;l(this,y)&&((w=l(this,y).abortSignal)==null||w.removeEventListener("abort",b(this,B,re)),l(this,y).done(g,m)),this.checkMemoryUsage()});else if(d.type==="report-memory-usage"){this.maxWorkerMemoryUsage=Math.max(this.maxWorkerMemoryUsage,d.memoryUsage);let g=(h=l(this,_).resourceLimits)==null?void 0:h.maxOldGenerationSizeMb,m=this.options.workerIdleMemoryLimit??(g?g*1024*1024:ur)*this.options.workerIdleMemoryLimitPercentage/100;m&&d.memoryUsage>m?this.restart():b(this,ee,st).call(this)}else this.emit("message",d)};t.on("message",a);let p=d=>{var h;l(this,v).resolve(),l(this,P).resolve(),l(this,y)?((h=l(this,y).abortSignal)==null||h.removeEventListener("abort",b(this,B,re)),l(this,y).done(d,null)):this.emit("error",d)};t.on("error",p),T(this,_,t),T(this,v,{stream:i,promise:o,resolve:n}),T(this,P,{stream:s,promise:c,resolve:u}),b(this,ee,st).call(this)}function st(){let r=1;l(this,y)&&(r=l(this,y).weight,T(this,y,void 0)),this.status="free",this.emit(ar,{weight:r})}function cr(r){let e=r.stdout,t=(0,Ze.createInterface)({input:e,crlfDelay:1/0}),i=r.stderr,s=(0,Ze.createInterface)({input:i,crlfDelay:1/0}),n=c=>{let a=[],p;return d=>{l(this,y)&&(d.includes((0,et.startMarker)(l(this,y).id))?(a=[],c==="stdout"?p=l(this,v).resolve:p=l(this,P).resolve):d.includes((0,et.endMarker)(l(this,y).id))?p():a.push(d))}},o=n("stdout"),u=n("stderr");t.on("line",o),s.on("line",u)}function re(){l(this,_)&&l(this,_).postMessage({type:"abort"})}});var oe=f(ie=>{"use strict";Object.defineProperty(ie,"__esModule",{value:!0});function dr(r,e){for(var t in e)Object.defineProperty(r,t,{enumerable:!0,get:e[t]})}dr(ie,{WorkerPool:function(){return ne},WorkerPoolEvents:function(){return x}});var pr=require("events"),lr=ut(),fr=hr(require("os"));function M(r,e,t){return e in r?Object.defineProperty(r,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):r[e]=t,r}function hr(r){return r&&r.__esModule?r:{default:r}}var x={freedWorker:"freedWorker",idle:"idle",busy:"busy",restarting:"restarting"},ne=class extends pr.EventEmitter{isIdle(){return this.workers.every(e=>e.status==="free")}get workerRestarts(){return this.workers.reduce((e,t)=>e+t.restarts,0)}get maxWorkerMemoryUsage(){return this.workers.reduce((e,t)=>Math.max(e,t.maxWorkerMemoryUsage),0)}stats(){return{maxWorkerMemoryUsage:this.maxWorkerMemoryUsage,workerRestarts:this.workerRestarts}}createInitialWorkers(){if(this.workers.length===0)for(let e=0;e<this.minWorkers;e++)this.addNewWorker()}addNewWorker(){if(this.workers.length<=this.maxWorkers){let{script:e,workerOptions:t}=this.options,i=new lr.ThreadWorker(e,{workerOptions:t,workerIdleMemoryLimit:this.options.workerIdleMemoryLimit});return i.on("free",s=>{let{weight:n}=s;this.availability+=n,this.emit(x.freedWorker)}),this.workers.push(i),i}}exec(e,t,i,s,n){return n!=null&&n.aborted?Promise.resolve():(t=Math.min(Math.max(1,t),this.maxWorkers),new Promise((o,u)=>{this.queue.push({task:{...e,weight:t},weight:t,resolve:o,reject:u,cleanup:s,setup:i}),this._exec(n)}))}_exec(e){let t=this.queue.findIndex(s=>s.weight<=this.availability);if(t===-1)return;let i=this.workers.find(s=>s.status==="free");if(i||(i=this.addNewWorker()),i){let s=this.queue[t];this.queue.splice(t,1),this.availability-=s.weight,i.start(s,e)}}async close(){await Promise.all(this.workers.map(e=>e.terminate()))}constructor(e){super(),M(this,"options",void 0),M(this,"workers",void 0),M(this,"freeWorkers",void 0),M(this,"queue",void 0),M(this,"minWorkers",void 0),M(this,"maxWorkers",void 0),M(this,"availability",void 0),this.options=e,this.workers=[],this.freeWorkers=[],this.queue=[],this.minWorkers=0,this.maxWorkers=0,this.availability=0,this.minWorkers=this.options.minWorkers??2,this.maxWorkers=this.options.maxWorkers??fr.default.cpus().length-1,this.availability=this.maxWorkers,this.workers=[],this.freeWorkers=[],this.queue=[],this.createInitialWorkers(),this.on(x.freedWorker,()=>{this.queue.length>0?(this._exec(),this.emit(x.busy)):this.isIdle()&&this.emit(x.idle)})}}});var ct=f(ce=>{"use strict";Object.defineProperty(ce,"__esModule",{value:!0});Object.defineProperty(ce,"AggregatedPool",{enumerable:!0,get:function(){return ue}});var F=oe(),gr=mr(require("events"));function ae(r,e,t){return e in r?Object.defineProperty(r,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):r[e]=t,r}function mr(r){return r&&r.__esModule?r:{default:r}}var ue=class extends gr.default{stats(){return[...this.groupedPools.values(),this.defaultPool].reduce((t,i)=>{if(i){let s=i.stats();t.maxWorkerMemoryUsage=Math.max(t.maxWorkerMemoryUsage,s.maxWorkerMemoryUsage),t.workerRestarts=t.workerRestarts+s.workerRestarts}return t},{maxWorkerMemoryUsage:0,workerRestarts:0})}async exec(e,t,i,s,n){let o=this.options.groupBy(e),u=this.groupedPools.get(o)??this.defaultPool;if(!u)throw new Error(`No pool found to be able to run ${o} tasks, try adjusting the maxWorkers & concurrency values`);return u.exec(e,t,i,s,n)}async close(){let e=[...this.groupedPools.values(),this.defaultPool].map(t=>t==null?void 0:t.close());return Promise.all(e)}constructor(e){super(),ae(this,"options",void 0),ae(this,"groupedPools",void 0),ae(this,"defaultPool",void 0),this.options=e,this.groupedPools=new Map;let{maxWorkers:t,maxWorkersByGroup:i,script:s,workerOptions:n}=e,o=0;for(let[a,p]of i.entries()){let d=new F.WorkerPool({maxWorkers:p,workerOptions:n,script:s,workerIdleMemoryLimit:e.workerIdleMemoryLimit});this.groupedPools.set(a,d),o+=p}if(o>t)throw new Error(`Total maxWorkers (${o}) configured across all groups exceeds concurrency (${t}). Try reducing the maxWorkers, or increasing the --concurrency CLI argument, or separate the tasks to be run`);let u=t-o;u>0&&(this.defaultPool=new F.WorkerPool({maxWorkers:u,workerOptions:n,script:s,workerIdleMemoryLimit:e.workerIdleMemoryLimit})),this.options.logger.verbose(`Workers pools created:  ${[...i.entries(),["default",u]].map(([a,p])=>`${a} (${p})`).join(", ")}`);let c=[...this.groupedPools.values(),this.defaultPool];c.forEach(a=>{a==null||a.on(F.WorkerPoolEvents.idle,()=>{c.every(p=>p==null?void 0:p.isIdle())&&this.emit(F.WorkerPoolEvents.idle)})})}}});var dt=f(de=>{"use strict";Object.defineProperty(de,"__esModule",{value:!0});function yr(r,e){for(var t in e)Object.defineProperty(r,t,{enumerable:!0,get:e[t]})}yr(de,{AggregatedPool:function(){return kr.AggregatedPool},WorkerPool:function(){return wr.WorkerPool},registerWorker:function(){return _r.registerWorker}});var _r=Je(),wr=oe(),kr=ct()});var lt=f(pe=>{"use strict";Object.defineProperty(pe,"__esModule",{value:!0});Object.defineProperty(pe,"NpmScriptRunner",{enumerable:!0,get:function(){return G}});var vr=require("path"),Pr=require("fs/promises"),br=require("child_process"),Tr=Mr(require("os"));function pt(r,e,t){return e in r?Object.defineProperty(r,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):r[e]=t,r}function Mr(r){return r&&r.__esModule?r:{default:r}}var G=class r{getNpmArgs(e,t){let i=t.length>0?["--",...t]:[];return["run",e,...i]}async hasNpmScript(e){var n,o;let t=((n=e.options)==null?void 0:n.script)??e.task,i=(0,vr.join)(e.cwd,"package.json");return!!((o=JSON.parse(await(0,Pr.readFile)(i,"utf8")).scripts)!=null&&o[t])}async shouldRun(e){return await this.hasNpmScript(e)&&(e.shouldRun??!0)}async run(e){var g,m,w;let{target:t,weight:i,abortSignal:s}=e,{nodeOptions:n,npmCmd:o,taskArgs:u}=this.options,c=((g=t.options)==null?void 0:g.script)??t.task,a;if(s){if(s.aborted)return{exitCode:1};let k=()=>{if(s.removeEventListener("abort",k),a&&!a.killed){let H=a.pid;process.stdout.write(`Abort signal detected, attempting to killing process id ${H}
-`),a.kill("SIGTERM");let R=setTimeout(()=>{a&&!a.killed&&a.kill("SIGKILL")},r.gracefulKillTimeout);R.unref&&R.unref()}};s.addEventListener("abort",k)}let p=[...u,...((m=t.options)==null?void 0:m.taskArgs)??[]],d=this.getNpmArgs(c,p),h=[n,(w=t.options)==null?void 0:w.nodeOptions].filter(k=>k).join(" ");return await new Promise((k,H)=>{a=(0,br.spawn)(o,d,{cwd:t.cwd,stdio:["inherit","pipe","pipe"],...Tr.default.platform()==="win32"&&{shell:!0},env:{...process.stdout.isTTY&&{FORCE_COLOR:"1"},...process.env,...h&&{NODE_OPTIONS:h},LAGE_PACKAGE_NAME:t.packageName,LAGE_TASK:t.task,LAGE_WEIGHT:String(i)}});let R=!1,E=D=>{var Ge,Ue,ze;if(a==null||a.off("exit",E),a==null||a.off("error",E),!R){if(R=!0,(Ge=a==null?void 0:a.stdout)==null||Ge.destroy(),(Ue=a==null?void 0:a.stderr)==null||Ue.destroy(),(ze=a==null?void 0:a.stdin)==null||ze.destroy(),D===0)return k({exitCode:D});H({exitCode:D,error:new Error(`NPM Script Runner: ${o} ${d.join(" ")} exited with code ${D}`)})}},{pid:Nt}=a;process.stdout.write(`Running ${[o,...d].join(" ")}, pid: ${Nt}
-`);let Ct=a.stdout,jt=a.stderr;Ct.pipe(process.stdout),jt.pipe(process.stderr),a.on("exit",E),a.on("error",()=>E(1))})}constructor(e){pt(this,"options",void 0),this.options=e}};pt(G,"gracefulKillTimeout",2500)});var ht=f(le=>{"use strict";Object.defineProperty(le,"__esModule",{value:!0});Object.defineProperty(le,"WorkerRunner",{enumerable:!0,get:function(){return U}});var Sr=require("url");function ft(r,e,t){return e in r?Object.defineProperty(r,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):r[e]=t,r}var U=class{async shouldRun(e){let t=await this.getScriptModule(e);return typeof t.shouldRun=="function"?await t.shouldRun(e)&&(e.shouldRun??!0):e.shouldRun??!0}async run(e){let{target:t,weight:i,abortSignal:s}=e,{taskArgs:n}=this.options,o=await this.getScriptModule(t),u=typeof o.run=="function"?o.run:typeof o.default=="function"?o.default:o;if(typeof u!="function")throw new Error("WorkerRunner: worker script must export a function; you likely need to use `module.exports = function() {...}`");return await u({target:t,weight:i,taskArgs:n,abortSignal:s})}async getScriptModule(e){var s,n;let t=((s=e.options)==null?void 0:s.worker)??((n=e.options)==null?void 0:n.script);if(!t)throw new Error('WorkerRunner: "script" configuration is required - e.g. { type: "worker", script: "./worker.js" }');let i=t;return i.startsWith("file://")||(i=(0,Sr.pathToFileURL)(i).toString()),await import(i)}constructor(e){ft(this,"options",void 0),this.options=e}};ft(U,"gracefulKillTimeout",2500)});var ge=f(he=>{"use strict";Object.defineProperty(he,"__esModule",{value:!0});Object.defineProperty(he,"NoOpRunner",{enumerable:!0,get:function(){return fe}});var fe=class{async shouldRun(){return!0}async run(){}}});var gt=f(me=>{"use strict";Object.defineProperty(me,"__esModule",{value:!0});Object.defineProperty(me,"sortTargetsByPriority",{enumerable:!0,get:function(){return Wr}});function Wr(r){return r.sort((e,t)=>(t.priority??0)-(e.priority??0))}});var W=f(ye=>{"use strict";Object.defineProperty(ye,"__esModule",{value:!0});function Or(r,e){for(var t in e)Object.defineProperty(r,t,{enumerable:!0,get:e[t]})}Or(ye,{getPackageAndTask:function(){return Ir},getStagedTargetId:function(){return Er},getStartTargetId:function(){return qr},getTargetId:function(){return Rr}});function Rr(r,e){return`${typeof r=="string"?r:""}#${e}`}function Ir(r){if(r.startsWith("\u0394"))return{packageName:void 0,task:r.slice(1)};if(r.includes("#")){let e=r.split("#");return r.startsWith("#")||e[0]==="//"?{packageName:void 0,task:e[1]}:{packageName:e[0],task:e[1]}}else return{packageName:void 0,task:r}}var xr="__start";function qr(){return xr}function Er(r){return`\u0394${r}`}});var we=f(_e=>{"use strict";Object.defineProperty(_e,"__esModule",{value:!0});Object.defineProperty(_e,"detectCycles",{enumerable:!0,get:function(){return Dr}});function Dr(r){let e=new Map;for(let[t]of r.entries())if(!e.has(t)){let i=Ar(r,e,t);if(i.length>0)return{hasCycle:!0,cycle:i}}return{hasCycle:!1}}var Ar=(r,e,t)=>{let i=[{node:t,traversing:!1}];for(;i.length>0;){let s=i[i.length-1];if(s.traversing)e.set(s.node,!1),i.pop();else{if(e.has(s.node))if(e.get(s.node)){let o=i.filter(u=>u.traversing).map(u=>u.node);return o.slice(o.indexOf(s.node))}else{i.pop();continue}e.set(s.node,!0),i[i.length-1]={...s,traversing:!0};let n=r.get(s.node);if(!n)throw new Error(`Could not find node "${s.node}" in the graph`);i.push(...[...n.dependents].map(o=>({node:o,traversing:!1})))}}return[]}});var mt=f(z=>{"use strict";Object.defineProperty(z,"__esModule",{value:!0});z.getPackageDependencies=void 0;function Nr(r,e){var i,s,n,o;let t=((i=r.dependencies)==null?void 0:i[e])||((s=r.devDependencies)==null?void 0:s[e])||((n=r.peerDependencies)==null?void 0:n[e])||((o=r.optionalDependencies)==null?void 0:o[e]);return t?!t.startsWith("npm:")&&!t.startsWith("file:"):!1}function Cr(r,e,t={withDevDependencies:!0}){let i=[];if(r.dependencies)for(let n of Object.keys(r.dependencies))n!==r.name&&e.has(n)&&i.push(n);if(r.devDependencies&&t.withDevDependencies)for(let n of Object.keys(r.devDependencies))n!==r.name&&e.has(n)&&i.push(n);if(r.peerDependencies&&t.withPeerDependencies)for(let n of Object.keys(r.peerDependencies))n!==r.name&&e.has(n)&&i.push(n);if(r.optionalDependencies&&t.withOptionalDependencies)for(let n of Object.keys(r.optionalDependencies))n!==r.name&&e.has(n)&&i.push(n);return i.filter(n=>Nr(r,n))}z.getPackageDependencies=Cr});var yt=f(K=>{"use strict";Object.defineProperty(K,"__esModule",{value:!0});K.createDependencyMap=void 0;var jr=mt();function Lr(r,e={withDevDependencies:!0,withPeerDependencies:!1}){let t={dependencies:new Map,dependents:new Map},i=new Set(Object.keys(r));for(let[s,n]of Object.entries(r)){let o=(0,jr.getPackageDependencies)(n,i,e);for(let u of o)t.dependencies.has(s)||t.dependencies.set(s,new Set),t.dependencies.get(s).add(u),t.dependents.has(u)||t.dependents.set(u,new Set),t.dependents.get(u).add(s)}return t}K.createDependencyMap=Lr});var wt=f(ve=>{"use strict";Object.defineProperty(ve,"__esModule",{value:!0});Object.defineProperty(ve,"expandDepSpecs",{enumerable:!0,get:function(){return $r}});var q=W();function $r(r,e){let t=[],i=(o,u)=>{t.push([o,u])},s=(o,u)=>u?n.filter(c=>{let{task:a,packageName:p}=c;return a===o&&u.some(d=>d===p)}).map(c=>c.id):n.filter(c=>c.task===o).map(c=>c.id),n=[...r.values()];for(let o of n){let{depSpecs:u,packageName:c,id:a}=o;if(t.push([(0,q.getStartTargetId)(),a]),!(!u||u.length===0))for(let p of u)if(p.includes("#")){let{packageName:d,task:h}=(0,q.getPackageAndTask)(p),g=(0,q.getTargetId)(d,h);i(g,a)}else if(p.startsWith("^^")&&c){let d=p.substring(2),h=[..._t(c,e)??[]],g=s(d,h);for(let m of g)i(m,a)}else if(p.startsWith("^")&&c){let d=p.substring(1),h=[...e.dependencies.get(c)??[]],g=s(d,h);for(let m of g)i(m,a)}else if(c){let d=p;r.has((0,q.getTargetId)(c,d))&&i((0,q.getTargetId)(c,d),a)}else{if(p.startsWith("^"))throw new Error(`invalid pipeline config detected: ${o.id}, packageName: ${c}, dep: ${p}`);{let h=s(p);for(let g of h)i(g,a)}}}return t}var ke=new Map;function _t(r,e){let t=ke.get(r);if(t)return t==="walk-in-progress"?new Set:t;{ke.set(r,"walk-in-progress");let i=[...e.dependencies.get(r)??[]],s=new Set(i);for(let n of i)for(let o of _t(n,e))s.add(o);return ke.set(r,s),s}}});var kt=f(Pe=>{"use strict";Object.defineProperty(Pe,"__esModule",{value:!0});Object.defineProperty(Pe,"prioritize",{enumerable:!0,get:function(){return Ur}});function Br(r){let e=[];for(let[t,i]of r)i.dependencies.length===0&&e.push(t);return e}function Fr(r){return new Map([...r.entries()].map(([e,t])=>[e,new Set(t.dependencies)]))}function Gr(r,e){let t=[],i=Fr(r),s=[...e];for(;s.length>0;){let n=s.pop();t.push(n),r.get(n).dependents.forEach(u=>{let c=i.get(u);c.delete(n),c.size===0&&s.push(u)})}return t}function Ur(r){let e=new Map,t=Br(r),i=Gr(r,t);for(let s of i){let n=r.get(s),o=n.priority||0,u=n.dependencies.map(p=>{let d=e.get(p);if(d===void 0)throw new Error(`Expected to have already computed the cumulative priority for node ${p}`);return d}),c=Math.max(...u,0),a=o+c;e.set(s,a)}for(let s of r.values()){let n=e.get(s.id);if(n===void 0)throw new Error(`Expected to have already computed the cumulative priority for node ${s.id}`);s.priority=n}}});var Se=f(Me=>{"use strict";Object.defineProperty(Me,"__esModule",{value:!0});Object.defineProperty(Me,"TargetGraphBuilder",{enumerable:!0,get:function(){return Te}});var be=W(),zr=kt(),Kr=we();function Hr(r,e,t){return e in r?Object.defineProperty(r,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):r[e]=t,r}var Te=class r{addTarget(e){return this.targets.set(e.id,e),this.addDependency((0,be.getStartTargetId)(),e.id),e}addDependency(e,t){if(this.targets.has(t)){let i=this.targets.get(t);i.dependencies.includes(e)||i.dependencies.push(e)}if(this.targets.has(e)){let i=this.targets.get(e);i.dependents.includes(t)||i.dependents.push(t)}}build(){let e=(0,Kr.detectCycles)(this.targets);if(e.hasCycle)throw new Error("Cycles detected in the target graph: "+e.cycle.concat(e.cycle[0]).join(" -> "));return(0,zr.prioritize)(this.targets),{targets:this.targets}}subgraph(e){let t=new r,i=new Set,s=[];for(let n of e)if(this.targets.has(n)){let o=this.targets.get(n);t.addTarget({...o,dependencies:[],dependents:[]}),s.push(n)}for(;s.length>0;){let n=s.shift();if(i.has(n))continue;i.add(n);let o=this.targets.get(n);if(!o)throw new Error("Subgraph builder failed - target not found: "+n);for(let u of o.dependencies)u!==(0,be.getStartTargetId)()&&(t.targets.has(u)||t.addTarget({...this.targets.get(u),dependencies:[],dependents:[]}),t.addDependency(u,n)),i.has(u)||s.push(u)}return t.build()}constructor(){Hr(this,"targets",new Map);let e=(0,be.getStartTargetId)();this.targets.set(e,{id:e,task:e,cwd:"",label:"Start",hidden:!0,dependencies:[],dependents:[],depSpecs:[],weight:1,priority:0})}}});var vt=f(We=>{"use strict";Object.defineProperty(We,"__esModule",{value:!0});Object.defineProperty(We,"getWeight",{enumerable:!0,get:function(){return Xr}});function Xr(r,e,t){return typeof e=="number"?e:typeof e=="function"?e(r,t):1}});var xe=f(Ie=>{"use strict";Object.defineProperty(Ie,"__esModule",{value:!0});Object.defineProperty(Ie,"TargetFactory",{enumerable:!0,get:function(){return Re}});var Oe=W(),Pt=vt();function bt(r,e,t){return e in r?Object.defineProperty(r,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):r[e]=t,r}var Re=class{getTargetType(e,t){return t.type?t.type:this.packageScripts.has(e)?"npmScript":"noop"}createPackageTarget(e,t,i){let{resolve:s}=this.options,{options:n,deps:o,dependsOn:u,cache:c,inputs:a,priority:p,maxWorkers:d,environmentGlob:h,weight:g}=i,m=s(e),w=this.getTargetType(t,i),k={id:(0,Oe.getTargetId)(e,t),label:`${e} - ${t}`,type:w,packageName:e,task:t,cache:c!==!1,cwd:m,depSpecs:u??o??[],dependencies:[],dependents:[],inputs:a,outputs:w==="noop"?[]:i.outputs,priority:p,maxWorkers:d,environmentGlob:h,weight:1,options:n,shouldRun:!0};return k.weight=(0,Pt.getWeight)(k,g,d),k}createGlobalTarget(e,t){let{root:i}=this.options,{options:s,deps:n,dependsOn:o,cache:u,inputs:c,outputs:a,priority:p,maxWorkers:d,environmentGlob:h,weight:g}=t,{task:m}=(0,Oe.getPackageAndTask)(e),w={id:e,label:e,type:this.getTargetType(m,t),task:m,cache:u!==!1,cwd:i,depSpecs:o??n??[],dependencies:[],dependents:[],inputs:c,outputs:a,priority:p,maxWorkers:d,environmentGlob:h,weight:1,options:s,shouldRun:!0};return w.weight=(0,Pt.getWeight)(w,g,d),w}createStagedTarget(e,t,i){let{root:s}=this.options,{dependsOn:n,priority:o}=t,u={...t.options};switch(t.type){case"noop":break;default:u.taskArgs=u.taskArgs??[],u.taskArgs.push(...i);break}let c=(0,Oe.getStagedTargetId)(e);return{id:c,label:c,type:t.type,task:e,cache:!1,cwd:s,depSpecs:n??[],dependencies:[],dependents:[],inputs:[],outputs:[],priority:o,maxWorkers:1,environmentGlob:[],weight:1,options:u,shouldRun:!0}}constructor(e){bt(this,"options",void 0),bt(this,"packageScripts",void 0),this.options=e,this.packageScripts=new Set;let{packageInfos:t}=e;for(let i of Object.values(t))for(let s of Object.keys(i.scripts??{}))this.packageScripts.add(s)}}});var Mt=f((Js,Tt)=>{var qe=class{constructor(e){this.value=e,this.next=void 0}},Ee=class{constructor(){this.clear()}enqueue(e){let t=new qe(e);this._head?(this._tail.next=t,this._tail=t):(this._head=t,this._tail=t),this._size++}dequeue(){let e=this._head;if(e)return this._head=this._head.next,this._size--,e.value}clear(){this._head=void 0,this._tail=void 0,this._size=0}get size(){return this._size}*[Symbol.iterator](){let e=this._head;for(;e;)yield e.value,e=e.next}};Tt.exports=Ee});var Wt=f((Qs,St)=>{"use strict";var Jr=Mt(),Qr=r=>{if(!((Number.isInteger(r)||r===1/0)&&r>0))throw new TypeError("Expected `concurrency` to be a number from 1 and up");let e=new Jr,t=0,i=()=>{t--,e.size>0&&e.dequeue()()},s=async(u,c,...a)=>{t++;let p=(async()=>u(...a))();c(p);try{await p}catch{}i()},n=(u,c,...a)=>{e.enqueue(s.bind(null,u,c,...a)),(async()=>(await Promise.resolve(),t<r&&e.size>0&&e.dequeue()()))()},o=(u,...c)=>new Promise(a=>{n(u,a,...c)});return Object.defineProperties(o,{activeCount:{get:()=>t},pendingCount:{get:()=>e.size},clearQueue:{value:()=>{e.clear()}}}),o};St.exports=Qr});var Rt=f(Ae=>{"use strict";Object.defineProperty(Ae,"__esModule",{value:!0});Object.defineProperty(Ae,"WorkspaceTargetGraphBuilder",{enumerable:!0,get:function(){return De}});var Vr=yt(),O=W(),Yr=wt(),Zr=Ot(require("path")),es=Se(),ts=xe(),rs=Ot(Wt());function S(r,e,t){return e in r?Object.defineProperty(r,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):r[e]=t,r}function Ot(r){return r&&r.__esModule?r:{default:r}}var ss=50,De=class{async addTargetConfig(e,t={},i){if(e.startsWith("//")||e.startsWith("#")){let s=this.targetFactory.createGlobalTarget(e,t);this.graphBuilder.addTarget(s),this.targetConfigMap.set(e,t),this.hasRootTarget=!0,this.processStagedConfig(s,t,i)}else if(e.includes("#")){let{packageName:s,task:n}=(0,O.getPackageAndTask)(e),o=this.targetFactory.createPackageTarget(s,n,t);this.graphBuilder.addTarget(o),this.targetConfigMap.set(e,t),this.processStagedConfig(o,t,i)}else{let s=Object.keys(this.packageInfos);for(let n of s){let o=e,u=this.targetFactory.createPackageTarget(n,o,t);this.graphBuilder.addTarget(u),this.targetConfigMap.set(e,t),this.processStagedConfig(u,t,i)}}}async processStagedConfig(e,t,i){if(typeof t.stagedTarget>"u"||typeof i>"u"||i.length===0||i.length>(t.stagedTarget.threshold??ss))return;this.hasStagedTarget=!0,e.type="noop",e.cache=!1,e.shouldRun=!1;let s=(0,O.getStagedTargetId)(e.task),n=this.graphBuilder.targets.has(s)?this.graphBuilder.targets.get(s):this.targetFactory.createStagedTarget(e.task,t.stagedTarget,i);this.graphBuilder.addTarget(n);let o=new Set(n.dependencies);for(let u of e.dependencies)o.add(u);if(n.dependencies=Array.from(o),e.dependents.length>0)throw new Error(`Parent target ${e.id} cannot have dependents when it has a staged target while running with a --since flag`)}shouldRun(e,t){return typeof e.shouldRun=="function"?e.shouldRun(t):!0}async build(e,t){let i=(0,Yr.expandDepSpecs)(this.graphBuilder.targets,this.dependencyMap);for(let[c,a]of i)this.graphBuilder.addDependency(c,a);let s=[];for(let c of e){if(t)for(let a of t)s.push((0,O.getTargetId)(a,c));else for(let a of Object.keys(this.packageInfos))s.push((0,O.getTargetId)(a,c));if(this.hasRootTarget){let a=(0,O.getTargetId)(void 0,c);this.graphBuilder.targets.has(a)&&s.push(a)}if(this.hasStagedTarget){let a=(0,O.getStagedTargetId)(c);this.graphBuilder.targets.has(a)&&s.push(a)}}let n=this.graphBuilder.subgraph(s),o=(0,rs.default)(8),u=[];for(let c of n.targets.values()){let a=this.targetConfigMap.get(c.id);a&&u.push(o(async()=>{c.shouldRun=await this.shouldRun(a,c)}))}return await Promise.all(u),{targets:n.targets}}constructor(e,t){S(this,"packageInfos",void 0),S(this,"dependencyMap",void 0),S(this,"graphBuilder",void 0),S(this,"targetFactory",void 0),S(this,"hasRootTarget",void 0),S(this,"hasStagedTarget",void 0),S(this,"targetConfigMap",void 0),this.packageInfos=t,this.hasRootTarget=!1,this.hasStagedTarget=!1,this.targetConfigMap=new Map,this.dependencyMap=(0,Vr.createDependencyMap)(t,{withDevDependencies:!0,withPeerDependencies:!1}),this.graphBuilder=new es.TargetGraphBuilder,this.targetFactory=new ts.TargetFactory({root:e,packageInfos:t,resolve(i){try{return Zr.default.dirname(t[i].packageJsonPath)}catch{throw new Error(`Cannot open package.json file for ${i}`)}}})}}});var It=f(Ne=>{"use strict";Object.defineProperty(Ne,"__esModule",{value:!0});Object.defineProperty(Ne,"removeNodes",{enumerable:!0,get:function(){return ns}});async function ns(r,e){let t=new Map;r.forEach(s=>t.set(s.id,s));let i=new Map;for(let s of r)if(await e(s)){t.delete(s.id);for(let o of s.dependencies)i.has(s.id)||i.set(s.id,new Set),i.get(s.id).add(o)}for(let s of t.values()){let n=new Set(s.dependencies);for(let o of s.dependencies)i.has(o)&&i.get(o).forEach(u=>n.add(u));s.dependencies=Array.from(n).filter(o=>t.has(o))}return Array.from(t.values())}});var xt=f(Ce=>{"use strict";Object.defineProperty(Ce,"__esModule",{value:!0});Object.defineProperty(Ce,"transitiveReduction",{enumerable:!0,get:function(){return is}});function is(r){let e=new Map,t=new Map;r.forEach(n=>{e.set(n.id,n),t.set(n.id,new Map),n.dependencies.forEach(o=>{t.get(n.id).set(o,!0)})});function i(n,o,u){var p;if(n===o)return!0;if(u.has(n))return!1;if(u.add(n),(p=t.get(n))!=null&&p.has(o))return t.get(n).get(o);let c=e.get(n);if(!c)return!1;let a=c.dependencies.some(d=>i(d,o,u));return t.get(n).set(o,a),a}return r.map(n=>({...n,dependencies:n.dependencies.filter(o=>{let u=new Set;return!n.dependencies.some(c=>c!==o&&i(c,o,u))})}))}});var qt=f(Le=>{"use strict";Object.defineProperty(Le,"__esModule",{value:!0});function os(r,e){for(var t in e)Object.defineProperty(r,t,{enumerable:!0,get:e[t]})}os(Le,{TargetFactory:function(){return ps.TargetFactory},TargetGraphBuilder:function(){return ds.TargetGraphBuilder},WorkspaceTargetGraphBuilder:function(){return cs.WorkspaceTargetGraphBuilder},detectCycles:function(){return us.detectCycles},getPackageAndTask:function(){return je.getPackageAndTask},getStartTargetId:function(){return je.getStartTargetId},getTargetId:function(){return je.getTargetId},removeNodes:function(){return ls.removeNodes},sortTargetsByPriority:function(){return as.sortTargetsByPriority},transitiveReduction:function(){return fs.transitiveReduction}});var as=gt(),je=W(),us=we(),cs=Rt(),ds=Se(),ps=xe(),ls=It(),fs=xt()});var Dt=f(Be=>{"use strict";Object.defineProperty(Be,"__esModule",{value:!0});Object.defineProperty(Be,"TargetRunnerPicker",{enumerable:!0,get:function(){return $e}});var Et=ys(require("path")),hs=qt(),gs=require("url");function ms(r,e,t){return e in r?Object.defineProperty(r,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):r[e]=t,r}function ys(r){return r&&r.__esModule?r:{default:r}}var $e=class{async pick(e){if(e.id===(0,hs.getStartTargetId)())return new(await Promise.resolve().then(()=>zt(ge()))).NoOpRunner;if(e.type||(e.type="npmScript"),this.options[e.type]){let t=this.options[e.type],{script:i,options:s}=t,n=i;n.startsWith("file://")||(n=(0,gs.pathToFileURL)(n).toString());let o=await import(n),u=Et.default.basename(i),c=u.replace(Et.default.extname(u),""),a=typeof o[c]=="function"?o[c]:typeof o.default=="function"?o.default:typeof o.default[c]=="function"?o.default[c]:o;return new a(s)}throw new Error(`No runner found for target ${e.id}`)}constructor(e){ms(this,"options",void 0),this.options=e}}});var At=f(Fe=>{"use strict";Object.defineProperty(Fe,"__esModule",{value:!0});function _s(r,e){for(var t in e)Object.defineProperty(r,t,{enumerable:!0,get:e[t]})}_s(Fe,{NoOpRunner:function(){return vs.NoOpRunner},NpmScriptRunner:function(){return ws.NpmScriptRunner},TargetRunnerPicker:function(){return Ps.TargetRunnerPicker},WorkerRunner:function(){return ks.WorkerRunner}});var ws=lt(),ks=ht(),vs=ge(),Ps=Dt()});Object.defineProperty(exports,"__esModule",{value:!0});var bs=dt(),Ts=At(),Ms=require("worker_threads");async function Ss(r){let{runners:e}=r,t=new Ts.TargetRunnerPicker(e);return{options:r,runnerPicker:t}}(async()=>{let{runnerPicker:r}=await Ss(Ms.workerData);async function e(t,i){let s;return s=await(await r.pick(t.target)).run({target:t.target,weight:0,abortSignal:i}),{skipped:!1,hash:void 0,value:s}}(0,bs.registerWorker)(e)})();
+`),"")),i(null,s)}})}});var Ve=f(Y=>{"use strict";Object.defineProperty(Y,"__esModule",{value:!0});Object.defineProperty(Y,"TaskInfo",{enumerable:!0,get:function(){return V}});var Yt=require("async_hooks");function Zt(r,e,t){return e in r?Object.defineProperty(r,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):r[e]=t,r}var V=class extends Yt.AsyncResource{get id(){return this.options.id}get weight(){return this.options.weight}get abortSignal(){return this.options.abortSignal}done(e,t){let{cleanup:i,worker:s,resolve:n,reject:o}=this.options;i&&this.runInAsyncScope(i,null,s),e?this.runInAsyncScope(o,null,e,s):this.runInAsyncScope(n,null,t,s),this.emitDestroy()}constructor(e){super("WorkerPoolTaskInfo"),Zt(this,"options",void 0),this.options=e,e.setup&&this.runInAsyncScope(e.setup,null,e.worker,e.worker.stdout,e.worker.stderr)}}});var ut=f(se=>{"use strict";Object.defineProperty(se,"__esModule",{value:!0});Object.defineProperty(se,"ThreadWorker",{enumerable:!0,get:function(){return te}});var Ye=Qe(),Ze=require("readline"),et=A(),er=require("events"),tt=require("stream"),tr=Ve(),rr=require("worker_threads"),sr=ot(require("crypto")),nr=ot(require("v8"));function nt(r,e){if(e.has(r))throw new TypeError("Cannot initialize the same private elements twice on an object")}function ir(r,e){return e.get?e.get.call(r):e.value}function or(r,e,t){if(e.set)e.set.call(r,t);else{if(!e.writable)throw new TypeError("attempted to set read only private field");e.value=t}}function it(r,e,t){if(!e.has(r))throw new TypeError("attempted to "+t+" private field on non-instance");return e.get(r)}function l(r,e){var t=it(r,e,"get");return ir(r,t)}function L(r,e,t){nt(r,e),e.set(r,t)}function T(r,e,t){var i=it(r,e,"set");return or(r,i,t),t}function b(r,e,t){if(!e.has(r))throw new TypeError("attempted to get private field on non-instance");return t}function $(r,e){nt(r,e),e.add(r)}function I(r,e,t){return e in r?Object.defineProperty(r,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):r[e]=t,r}function ot(r){return r&&r.__esModule?r:{default:r}}var ar="free",ur=nr.default.getHeapStatistics().total_available_size,y=new WeakMap,v=new WeakMap,P=new WeakMap,_=new WeakMap,Z=new WeakSet,ee=new WeakSet,at=new WeakSet,B=new WeakSet,te=class extends er.EventEmitter{start(e,t){this.status="busy";let{task:i,resolve:s,reject:n,cleanup:o,setup:u}=e;t==null||t.addEventListener("abort",b(this,B,re));let c=sr.default.randomBytes(32).toString("hex");T(this,y,new tr.TaskInfo({id:c,weight:e.weight,cleanup:o,resolve:s,reject:n,worker:this,setup:u,abortSignal:t})),l(this,v).promise=new Promise(a=>{l(this,v).resolve=a}),l(this,P).promise=new Promise(a=>{l(this,P).resolve=a}),l(this,_).postMessage({type:"start",task:{...i,weight:e.weight},id:c})}get weight(){var e;return((e=l(this,y))==null?void 0:e.weight)??1}get stdout(){return l(this,v).stream}get stderr(){return l(this,P).stream}get resourceLimits(){return l(this,_).resourceLimits}get threadId(){return l(this,_).threadId}terminate(){l(this,_).removeAllListeners(),l(this,_).terminate(),l(this,_).unref()}restart(){this.restarts++,this.status="busy",l(this,_).terminate(),b(this,Z,rt).call(this)}async checkMemoryUsage(){l(this,_).postMessage({type:"check-memory-usage"})}postMessage(e,t){l(this,_).postMessage(e,t)}constructor(e,t){super(),$(this,Z),$(this,ee),$(this,at),$(this,B),I(this,"script",void 0),I(this,"options",void 0),L(this,y,{writable:!0,value:void 0}),L(this,v,{writable:!0,value:void 0}),L(this,P,{writable:!0,value:void 0}),L(this,_,{writable:!0,value:void 0}),I(this,"status",void 0),I(this,"restarts",void 0),I(this,"maxWorkerMemoryUsage",void 0),this.script=e,this.options=t,T(this,v,{stream:new tt.Readable,promise:Promise.resolve(),resolve:()=>{}}),T(this,P,{stream:new tt.Readable,promise:Promise.resolve(),resolve:()=>{}}),this.status="busy",this.restarts=0,this.maxWorkerMemoryUsage=0,t.workerIdleMemoryLimitPercentage||(t.workerIdleMemoryLimitPercentage=80),b(this,Z,rt).call(this)}};function rt(){let{workerOptions:r}=this.options,e=this.script,t=new rr.Worker(e,{...r,stdout:!0,stderr:!0});b(this,at,cr).call(this,t);let i=t.stdout.pipe((0,Ye.createFilteredStreamTransform)()),s=t.stderr.pipe((0,Ye.createFilteredStreamTransform)()),n=()=>{},o=new Promise(p=>{n=p,p()}),u=()=>{},c=new Promise(p=>{u=p,p()}),a=p=>{var h;if(p.type==="status")Promise.all([l(this,v).promise,l(this,P).promise]).then(()=>{var k;let{err:g,results:m}=p;l(this,y)&&((k=l(this,y).abortSignal)==null||k.removeEventListener("abort",b(this,B,re)),l(this,y).done(g,m)),this.checkMemoryUsage()});else if(p.type==="report-memory-usage"){this.maxWorkerMemoryUsage=Math.max(this.maxWorkerMemoryUsage,p.memoryUsage);let g=(h=l(this,_).resourceLimits)==null?void 0:h.maxOldGenerationSizeMb,m=this.options.workerIdleMemoryLimit??(g?g*1024*1024:ur)*this.options.workerIdleMemoryLimitPercentage/100;m&&p.memoryUsage>m?this.restart():b(this,ee,st).call(this)}else this.emit("message",p)};t.on("message",a);let d=p=>{var h;l(this,v).resolve(),l(this,P).resolve(),l(this,y)?((h=l(this,y).abortSignal)==null||h.removeEventListener("abort",b(this,B,re)),l(this,y).done(p,null)):this.emit("error",p)};t.on("error",d),T(this,_,t),T(this,v,{stream:i,promise:o,resolve:n}),T(this,P,{stream:s,promise:c,resolve:u}),b(this,ee,st).call(this)}function st(){let r=1;l(this,y)&&(r=l(this,y).weight,T(this,y,void 0)),this.status="free",this.emit(ar,{weight:r})}function cr(r){let e=r.stdout,t=(0,Ze.createInterface)({input:e,crlfDelay:1/0}),i=r.stderr,s=(0,Ze.createInterface)({input:i,crlfDelay:1/0}),n=c=>{let a=[],d;return p=>{l(this,y)&&(p.includes((0,et.startMarker)(l(this,y).id))?(a=[],c==="stdout"?d=l(this,v).resolve:d=l(this,P).resolve):p.includes((0,et.endMarker)(l(this,y).id))?d():a.push(p))}},o=n("stdout"),u=n("stderr");t.on("line",o),s.on("line",u)}function re(){l(this,_)&&l(this,_).postMessage({type:"abort"})}});var oe=f(ie=>{"use strict";Object.defineProperty(ie,"__esModule",{value:!0});function dr(r,e){for(var t in e)Object.defineProperty(r,t,{enumerable:!0,get:e[t]})}dr(ie,{WorkerPool:function(){return ne},WorkerPoolEvents:function(){return x}});var pr=require("events"),lr=ut(),fr=hr(require("os"));function M(r,e,t){return e in r?Object.defineProperty(r,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):r[e]=t,r}function hr(r){return r&&r.__esModule?r:{default:r}}var x={freedWorker:"freedWorker",idle:"idle",busy:"busy",restarting:"restarting"},ne=class extends pr.EventEmitter{isIdle(){return this.workers.every(e=>e.status==="free")}get workerRestarts(){return this.workers.reduce((e,t)=>e+t.restarts,0)}get maxWorkerMemoryUsage(){return this.workers.reduce((e,t)=>Math.max(e,t.maxWorkerMemoryUsage),0)}stats(){return{maxWorkerMemoryUsage:this.maxWorkerMemoryUsage,workerRestarts:this.workerRestarts}}createInitialWorkers(){if(this.workers.length===0)for(let e=0;e<this.minWorkers;e++)this.addNewWorker()}addNewWorker(){if(this.workers.length<=this.maxWorkers){let{script:e,workerOptions:t}=this.options,i=new lr.ThreadWorker(e,{workerOptions:t,workerIdleMemoryLimit:this.options.workerIdleMemoryLimit});return i.on("free",s=>{let{weight:n}=s;this.availability+=n,this.emit(x.freedWorker)}),this.workers.push(i),i}}exec(e,t,i,s,n){return n!=null&&n.aborted?Promise.resolve():(t=Math.min(Math.max(1,t),this.maxWorkers),new Promise((o,u)=>{this.queue.push({task:{...e,weight:t},weight:t,resolve:o,reject:u,cleanup:s,setup:i}),this._exec(n)}))}_exec(e){let t=this.queue.findIndex(s=>s.weight<=this.availability);if(t===-1)return;let i=this.workers.find(s=>s.status==="free");if(i||(i=this.addNewWorker()),i){let s=this.queue[t];this.queue.splice(t,1),this.availability-=s.weight,i.start(s,e)}}async close(){await Promise.all(this.workers.map(e=>e.terminate()))}constructor(e){super(),M(this,"options",void 0),M(this,"workers",void 0),M(this,"freeWorkers",void 0),M(this,"queue",void 0),M(this,"minWorkers",void 0),M(this,"maxWorkers",void 0),M(this,"availability",void 0),this.options=e,this.workers=[],this.freeWorkers=[],this.queue=[],this.minWorkers=0,this.maxWorkers=0,this.availability=0,this.minWorkers=this.options.minWorkers??2,this.maxWorkers=this.options.maxWorkers??fr.default.cpus().length-1,this.availability=this.maxWorkers,this.workers=[],this.freeWorkers=[],this.queue=[],this.createInitialWorkers(),this.on(x.freedWorker,()=>{this.queue.length>0?(this._exec(),this.emit(x.busy)):this.isIdle()&&this.emit(x.idle)})}}});var ct=f(ce=>{"use strict";Object.defineProperty(ce,"__esModule",{value:!0});Object.defineProperty(ce,"AggregatedPool",{enumerable:!0,get:function(){return ue}});var F=oe(),gr=mr(require("events"));function ae(r,e,t){return e in r?Object.defineProperty(r,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):r[e]=t,r}function mr(r){return r&&r.__esModule?r:{default:r}}var ue=class extends gr.default{stats(){return[...this.groupedPools.values(),this.defaultPool].reduce((t,i)=>{if(i){let s=i.stats();t.maxWorkerMemoryUsage=Math.max(t.maxWorkerMemoryUsage,s.maxWorkerMemoryUsage),t.workerRestarts=t.workerRestarts+s.workerRestarts}return t},{maxWorkerMemoryUsage:0,workerRestarts:0})}async exec(e,t,i,s,n){let o=this.options.groupBy(e),u=this.groupedPools.get(o)??this.defaultPool;if(!u)throw new Error(`No pool found to be able to run ${o} tasks, try adjusting the maxWorkers & concurrency values`);return u.exec(e,t,i,s,n)}async close(){let e=[...this.groupedPools.values(),this.defaultPool].map(t=>t==null?void 0:t.close());return Promise.all(e)}constructor(e){super(),ae(this,"options",void 0),ae(this,"groupedPools",void 0),ae(this,"defaultPool",void 0),this.options=e,this.groupedPools=new Map;let{maxWorkers:t,maxWorkersByGroup:i,script:s,workerOptions:n}=e,o=0;for(let[a,d]of i.entries()){let p=new F.WorkerPool({maxWorkers:d,workerOptions:n,script:s,workerIdleMemoryLimit:e.workerIdleMemoryLimit});this.groupedPools.set(a,p),o+=d}if(o>t)throw new Error(`Total maxWorkers (${o}) configured across all groups exceeds concurrency (${t}). Try reducing the maxWorkers, or increasing the --concurrency CLI argument, or separate the tasks to be run`);let u=t-o;u>0&&(this.defaultPool=new F.WorkerPool({maxWorkers:u,workerOptions:n,script:s,workerIdleMemoryLimit:e.workerIdleMemoryLimit})),this.options.logger.verbose(`Workers pools created:  ${[...i.entries(),["default",u]].map(([a,d])=>`${a} (${d})`).join(", ")}`);let c=[...this.groupedPools.values(),this.defaultPool];c.forEach(a=>{a==null||a.on(F.WorkerPoolEvents.idle,()=>{c.every(d=>d==null?void 0:d.isIdle())&&this.emit(F.WorkerPoolEvents.idle)})})}}});var dt=f(de=>{"use strict";Object.defineProperty(de,"__esModule",{value:!0});function yr(r,e){for(var t in e)Object.defineProperty(r,t,{enumerable:!0,get:e[t]})}yr(de,{AggregatedPool:function(){return wr.AggregatedPool},WorkerPool:function(){return kr.WorkerPool},registerWorker:function(){return _r.registerWorker}});var _r=Je(),kr=oe(),wr=ct()});var lt=f(pe=>{"use strict";Object.defineProperty(pe,"__esModule",{value:!0});Object.defineProperty(pe,"NpmScriptRunner",{enumerable:!0,get:function(){return G}});var vr=require("path"),Pr=require("fs/promises"),br=require("child_process"),Tr=Mr(require("os"));function pt(r,e,t){return e in r?Object.defineProperty(r,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):r[e]=t,r}function Mr(r){return r&&r.__esModule?r:{default:r}}var G=class r{getNpmArgs(e,t){let i=t.length>0?["--",...t]:[];return["run",e,...i]}async hasNpmScript(e){var n,o;let t=((n=e.options)==null?void 0:n.script)??e.task,i=(0,vr.join)(e.cwd,"package.json");return!!((o=JSON.parse(await(0,Pr.readFile)(i,"utf8")).scripts)!=null&&o[t])}async shouldRun(e){return await this.hasNpmScript(e)&&(e.shouldRun??!0)}async run(e){var g,m,k;let{target:t,weight:i,abortSignal:s}=e,{nodeOptions:n,npmCmd:o,taskArgs:u}=this.options,c=((g=t.options)==null?void 0:g.script)??t.task,a;if(s){if(s.aborted)return{exitCode:1};let w=()=>{if(s.removeEventListener("abort",w),a&&!a.killed){let H=a.pid;process.stdout.write(`Abort signal detected, attempting to killing process id ${H}
+`),a.kill("SIGTERM");let R=setTimeout(()=>{a&&!a.killed&&a.kill("SIGKILL")},r.gracefulKillTimeout);R.unref&&R.unref()}};s.addEventListener("abort",w)}let d=[...u,...((m=t.options)==null?void 0:m.taskArgs)??[]],p=this.getNpmArgs(c,d),h=[n,(k=t.options)==null?void 0:k.nodeOptions].filter(w=>w).join(" ");return await new Promise((w,H)=>{a=(0,br.spawn)(o,p,{cwd:t.cwd,stdio:["inherit","pipe","pipe"],...Tr.default.platform()==="win32"&&{shell:!0},env:{...process.stdout.isTTY&&{FORCE_COLOR:"1"},...process.env,...h&&{NODE_OPTIONS:h},LAGE_PACKAGE_NAME:t.packageName,LAGE_TASK:t.task,LAGE_WEIGHT:String(i)}});let R=!1,E=D=>{var Ge,Ue,ze;if(a==null||a.off("exit",E),a==null||a.off("error",E),!R){if(R=!0,(Ge=a==null?void 0:a.stdout)==null||Ge.destroy(),(Ue=a==null?void 0:a.stderr)==null||Ue.destroy(),(ze=a==null?void 0:a.stdin)==null||ze.destroy(),D===0)return w({exitCode:D});H({exitCode:D,error:new Error(`NPM Script Runner: ${o} ${p.join(" ")} exited with code ${D}`)})}},{pid:Nt}=a;process.stdout.write(`Running ${[o,...p].join(" ")}, pid: ${Nt}
+`);let Ct=a.stdout,jt=a.stderr;Ct.pipe(process.stdout),jt.pipe(process.stderr),a.on("exit",E),a.on("error",()=>E(1))})}constructor(e){pt(this,"options",void 0),this.options=e}};pt(G,"gracefulKillTimeout",2500)});var ht=f(le=>{"use strict";Object.defineProperty(le,"__esModule",{value:!0});Object.defineProperty(le,"WorkerRunner",{enumerable:!0,get:function(){return U}});var Sr=require("url");function ft(r,e,t){return e in r?Object.defineProperty(r,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):r[e]=t,r}var U=class{async shouldRun(e){let t=await this.getScriptModule(e);return typeof t.shouldRun=="function"?await t.shouldRun(e)&&(e.shouldRun??!0):e.shouldRun??!0}async run(e){let{target:t,weight:i,abortSignal:s}=e,{taskArgs:n}=this.options,o=await this.getScriptModule(t),u=typeof o.run=="function"?o.run:typeof o.default=="function"?o.default:o;if(typeof u!="function")throw new Error("WorkerRunner: worker script must export a function; you likely need to use `module.exports = function() {...}`");return await u({target:t,weight:i,taskArgs:n,abortSignal:s})}async getScriptModule(e){var s,n;let t=((s=e.options)==null?void 0:s.worker)??((n=e.options)==null?void 0:n.script);if(!t)throw new Error('WorkerRunner: "script" configuration is required - e.g. { type: "worker", script: "./worker.js" }');let i=t;return i.startsWith("file://")||(i=(0,Sr.pathToFileURL)(i).toString()),await import(i)}constructor(e){ft(this,"options",void 0),this.options=e}};ft(U,"gracefulKillTimeout",2500)});var ge=f(he=>{"use strict";Object.defineProperty(he,"__esModule",{value:!0});Object.defineProperty(he,"NoOpRunner",{enumerable:!0,get:function(){return fe}});var fe=class{async shouldRun(){return!0}async run(){}}});var gt=f(me=>{"use strict";Object.defineProperty(me,"__esModule",{value:!0});Object.defineProperty(me,"sortTargetsByPriority",{enumerable:!0,get:function(){return Wr}});function Wr(r){return r.sort((e,t)=>(t.priority??0)-(e.priority??0))}});var O=f(ye=>{"use strict";Object.defineProperty(ye,"__esModule",{value:!0});function Or(r,e){for(var t in e)Object.defineProperty(r,t,{enumerable:!0,get:e[t]})}Or(ye,{getPackageAndTask:function(){return Ir},getStagedTargetId:function(){return Er},getStartTargetId:function(){return qr},getTargetId:function(){return Rr}});function Rr(r,e){return`${typeof r=="string"?r:""}#${e}`}function Ir(r){if(r.startsWith("\u0394"))return{packageName:void 0,task:r.slice(1)};if(r.includes("#")){let e=r.split("#");return r.startsWith("#")||e[0]==="//"?{packageName:void 0,task:e[1]}:{packageName:e[0],task:e[1]}}else return{packageName:void 0,task:r}}var xr="__start";function qr(){return xr}function Er(r){return`\u0394${r}`}});var ke=f(_e=>{"use strict";Object.defineProperty(_e,"__esModule",{value:!0});Object.defineProperty(_e,"detectCycles",{enumerable:!0,get:function(){return Dr}});function Dr(r){let e=new Map;for(let[t]of r.entries())if(!e.has(t)){let i=Ar(r,e,t);if(i.length>0)return{hasCycle:!0,cycle:i}}return{hasCycle:!1}}var Ar=(r,e,t)=>{let i=[{node:t,traversing:!1}];for(;i.length>0;){let s=i[i.length-1];if(s.traversing)e.set(s.node,!1),i.pop();else{if(e.has(s.node))if(e.get(s.node)){let o=i.filter(u=>u.traversing).map(u=>u.node);return o.slice(o.indexOf(s.node))}else{i.pop();continue}e.set(s.node,!0),i[i.length-1]={...s,traversing:!0};let n=r.get(s.node);if(!n)throw new Error(`Could not find node "${s.node}" in the graph`);i.push(...[...n.dependents].map(o=>({node:o,traversing:!1})))}}return[]}});var mt=f(z=>{"use strict";Object.defineProperty(z,"__esModule",{value:!0});z.getPackageDependencies=void 0;function Nr(r,e){var i,s,n,o;let t=((i=r.dependencies)==null?void 0:i[e])||((s=r.devDependencies)==null?void 0:s[e])||((n=r.peerDependencies)==null?void 0:n[e])||((o=r.optionalDependencies)==null?void 0:o[e]);return t?!t.startsWith("npm:")&&!t.startsWith("file:"):!1}function Cr(r,e,t={withDevDependencies:!0}){let i=[];if(r.dependencies)for(let n of Object.keys(r.dependencies))n!==r.name&&e.has(n)&&i.push(n);if(r.devDependencies&&t.withDevDependencies)for(let n of Object.keys(r.devDependencies))n!==r.name&&e.has(n)&&i.push(n);if(r.peerDependencies&&t.withPeerDependencies)for(let n of Object.keys(r.peerDependencies))n!==r.name&&e.has(n)&&i.push(n);if(r.optionalDependencies&&t.withOptionalDependencies)for(let n of Object.keys(r.optionalDependencies))n!==r.name&&e.has(n)&&i.push(n);return i.filter(n=>Nr(r,n))}z.getPackageDependencies=Cr});var yt=f(K=>{"use strict";Object.defineProperty(K,"__esModule",{value:!0});K.createDependencyMap=void 0;var jr=mt();function Lr(r,e={withDevDependencies:!0,withPeerDependencies:!1}){let t={dependencies:new Map,dependents:new Map},i=new Set(Object.keys(r));for(let[s,n]of Object.entries(r)){let o=(0,jr.getPackageDependencies)(n,i,e);for(let u of o)t.dependencies.has(s)||t.dependencies.set(s,new Set),t.dependencies.get(s).add(u),t.dependents.has(u)||t.dependents.set(u,new Set),t.dependents.get(u).add(s)}return t}K.createDependencyMap=Lr});var kt=f(ve=>{"use strict";Object.defineProperty(ve,"__esModule",{value:!0});Object.defineProperty(ve,"expandDepSpecs",{enumerable:!0,get:function(){return $r}});var q=O();function $r(r,e){let t=[],i=(o,u)=>{t.push([o,u])},s=(o,u)=>u?n.filter(c=>{let{task:a,packageName:d}=c;return a===o&&u.some(p=>p===d)}).map(c=>c.id):n.filter(c=>c.task===o).map(c=>c.id),n=[...r.values()];for(let o of n){let{depSpecs:u,packageName:c,id:a}=o;if(t.push([(0,q.getStartTargetId)(),a]),!(!u||u.length===0))for(let d of u)if(d.includes("#")){let{packageName:p,task:h}=(0,q.getPackageAndTask)(d),g=(0,q.getTargetId)(p,h);i(g,a)}else if(d.startsWith("^^")&&c){let p=d.substring(2),h=[..._t(c,e)??[]],g=s(p,h);for(let m of g)i(m,a)}else if(d.startsWith("^")&&c){let p=d.substring(1),h=[...e.dependencies.get(c)??[]],g=s(p,h);for(let m of g)i(m,a)}else if(c){let p=d;r.has((0,q.getTargetId)(c,p))&&i((0,q.getTargetId)(c,p),a)}else{if(d.startsWith("^"))throw new Error(`invalid pipeline config detected: ${o.id}, packageName: ${c}, dep: ${d}`);{let h=s(d);for(let g of h)i(g,a)}}}return t}var we=new Map;function _t(r,e){let t=we.get(r);if(t)return t==="walk-in-progress"?new Set:t;{we.set(r,"walk-in-progress");let i=[...e.dependencies.get(r)??[]],s=new Set(i);for(let n of i)for(let o of _t(n,e))s.add(o);return we.set(r,s),s}}});var wt=f(Pe=>{"use strict";Object.defineProperty(Pe,"__esModule",{value:!0});Object.defineProperty(Pe,"prioritize",{enumerable:!0,get:function(){return Ur}});function Br(r){let e=[];for(let[t,i]of r)i.dependencies.length===0&&e.push(t);return e}function Fr(r){return new Map([...r.entries()].map(([e,t])=>[e,new Set(t.dependencies)]))}function Gr(r,e){let t=[],i=Fr(r),s=[...e];for(;s.length>0;){let n=s.pop();t.unshift(n),r.get(n).dependents.forEach(u=>{let c=i.get(u);c.delete(n),c.size===0&&s.push(u)})}return t}function Ur(r){let e=new Map,t=Br(r),i=Gr(r,t);for(let s of i){let n=r.get(s),o=n.priority||0,u=n.dependents.map(d=>{let p=e.get(d);if(p===void 0)throw new Error(`Expected to have already computed the cumulative priority for node ${d}`);return p}),c=Math.max(...u,0),a=o+c;e.set(s,a)}for(let s of r.values()){let n=e.get(s.id);if(n===void 0)throw new Error(`Expected to have already computed the cumulative priority for node ${s.id}`);s.priority=n}}});var Se=f(Me=>{"use strict";Object.defineProperty(Me,"__esModule",{value:!0});Object.defineProperty(Me,"TargetGraphBuilder",{enumerable:!0,get:function(){return Te}});var be=O(),zr=wt(),Kr=ke();function Hr(r,e,t){return e in r?Object.defineProperty(r,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):r[e]=t,r}var Te=class r{addTarget(e){return this.targets.set(e.id,e),this.addDependency((0,be.getStartTargetId)(),e.id),e}addDependency(e,t){if(this.targets.has(t)){let i=this.targets.get(t);i.dependencies.includes(e)||i.dependencies.push(e)}if(this.targets.has(e)){let i=this.targets.get(e);i.dependents.includes(t)||i.dependents.push(t)}}build(){let e=(0,Kr.detectCycles)(this.targets);if(e.hasCycle)throw new Error("Cycles detected in the target graph: "+e.cycle.concat(e.cycle[0]).join(" -> "));return(0,zr.prioritize)(this.targets),{targets:this.targets}}subgraph(e){let t=new r,i=new Set,s=[];for(let n of e)if(this.targets.has(n)){let o=this.targets.get(n);t.addTarget({...o,dependencies:[],dependents:[]}),s.push(n)}for(;s.length>0;){let n=s.shift();if(i.has(n))continue;i.add(n);let o=this.targets.get(n);if(!o)throw new Error("Subgraph builder failed - target not found: "+n);for(let u of o.dependencies)u!==(0,be.getStartTargetId)()&&(t.targets.has(u)||t.addTarget({...this.targets.get(u),dependencies:[],dependents:[]}),t.addDependency(u,n)),i.has(u)||s.push(u)}return t.build()}constructor(){Hr(this,"targets",new Map);let e=(0,be.getStartTargetId)();this.targets.set(e,{id:e,task:e,cwd:"",label:"Start",hidden:!0,dependencies:[],dependents:[],depSpecs:[],weight:1,priority:0})}}});var vt=f(We=>{"use strict";Object.defineProperty(We,"__esModule",{value:!0});Object.defineProperty(We,"getWeight",{enumerable:!0,get:function(){return Xr}});function Xr(r,e,t){return typeof e=="number"?e:typeof e=="function"?e(r,t):1}});var xe=f(Ie=>{"use strict";Object.defineProperty(Ie,"__esModule",{value:!0});Object.defineProperty(Ie,"TargetFactory",{enumerable:!0,get:function(){return Re}});var Oe=O(),Pt=vt();function bt(r,e,t){return e in r?Object.defineProperty(r,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):r[e]=t,r}var Re=class{getTargetType(e,t){return t.type?t.type:this.packageScripts.has(e)?"npmScript":"noop"}createPackageTarget(e,t,i){let{resolve:s}=this.options,{options:n,deps:o,dependsOn:u,cache:c,inputs:a,priority:d,maxWorkers:p,environmentGlob:h,weight:g}=i,m=s(e),k=this.getTargetType(t,i),w={id:(0,Oe.getTargetId)(e,t),label:`${e} - ${t}`,type:k,packageName:e,task:t,cache:c!==!1,cwd:m,depSpecs:u??o??[],dependencies:[],dependents:[],inputs:a,outputs:k==="noop"?[]:i.outputs,priority:d,maxWorkers:p,environmentGlob:h,weight:1,options:n,shouldRun:!0};return w.weight=(0,Pt.getWeight)(w,g,p),w}createGlobalTarget(e,t){let{root:i}=this.options,{options:s,deps:n,dependsOn:o,cache:u,inputs:c,outputs:a,priority:d,maxWorkers:p,environmentGlob:h,weight:g}=t,{task:m}=(0,Oe.getPackageAndTask)(e),k={id:e,label:e,type:this.getTargetType(m,t),task:m,cache:u!==!1,cwd:i,depSpecs:o??n??[],dependencies:[],dependents:[],inputs:c,outputs:a,priority:d,maxWorkers:p,environmentGlob:h,weight:1,options:s,shouldRun:!0};return k.weight=(0,Pt.getWeight)(k,g,p),k}createStagedTarget(e,t,i){let{root:s}=this.options,{dependsOn:n,priority:o}=t,u={...t.options};switch(t.type){case"noop":break;default:u.taskArgs=u.taskArgs??[],u.taskArgs.push(...i);break}let c=(0,Oe.getStagedTargetId)(e);return{id:c,label:c,type:t.type,task:e,cache:!1,cwd:s,depSpecs:n??[],dependencies:[],dependents:[],inputs:[],outputs:[],priority:o,maxWorkers:1,environmentGlob:[],weight:1,options:u,shouldRun:!0}}constructor(e){bt(this,"options",void 0),bt(this,"packageScripts",void 0),this.options=e,this.packageScripts=new Set;let{packageInfos:t}=e;for(let i of Object.values(t))for(let s of Object.keys(i.scripts??{}))this.packageScripts.add(s)}}});var Mt=f((Js,Tt)=>{var qe=class{constructor(e){this.value=e,this.next=void 0}},Ee=class{constructor(){this.clear()}enqueue(e){let t=new qe(e);this._head?(this._tail.next=t,this._tail=t):(this._head=t,this._tail=t),this._size++}dequeue(){let e=this._head;if(e)return this._head=this._head.next,this._size--,e.value}clear(){this._head=void 0,this._tail=void 0,this._size=0}get size(){return this._size}*[Symbol.iterator](){let e=this._head;for(;e;)yield e.value,e=e.next}};Tt.exports=Ee});var Wt=f((Qs,St)=>{"use strict";var Jr=Mt(),Qr=r=>{if(!((Number.isInteger(r)||r===1/0)&&r>0))throw new TypeError("Expected `concurrency` to be a number from 1 and up");let e=new Jr,t=0,i=()=>{t--,e.size>0&&e.dequeue()()},s=async(u,c,...a)=>{t++;let d=(async()=>u(...a))();c(d);try{await d}catch{}i()},n=(u,c,...a)=>{e.enqueue(s.bind(null,u,c,...a)),(async()=>(await Promise.resolve(),t<r&&e.size>0&&e.dequeue()()))()},o=(u,...c)=>new Promise(a=>{n(u,a,...c)});return Object.defineProperties(o,{activeCount:{get:()=>t},pendingCount:{get:()=>e.size},clearQueue:{value:()=>{e.clear()}}}),o};St.exports=Qr});var Rt=f(Ae=>{"use strict";Object.defineProperty(Ae,"__esModule",{value:!0});Object.defineProperty(Ae,"WorkspaceTargetGraphBuilder",{enumerable:!0,get:function(){return De}});var Vr=yt(),S=O(),Yr=kt(),Zr=Ot(require("path")),es=Se(),ts=xe(),rs=Ot(Wt());function W(r,e,t){return e in r?Object.defineProperty(r,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):r[e]=t,r}function Ot(r){return r&&r.__esModule?r:{default:r}}var ss=50,De=class{async addTargetConfig(e,t={},i){if(e.startsWith("//")||e.startsWith("#")){let s=this.targetFactory.createGlobalTarget(e,t);this.graphBuilder.addTarget(s),this.targetConfigMap.set(e,t),this.hasRootTarget=!0,this.processStagedConfig(s,t,i)}else if(e.includes("#")){let{packageName:s,task:n}=(0,S.getPackageAndTask)(e),o=this.targetFactory.createPackageTarget(s,n,t);this.graphBuilder.addTarget(o),this.targetConfigMap.set(e,t),this.processStagedConfig(o,t,i)}else{let s=Object.keys(this.packageInfos);for(let n of s){let o=e,u=this.targetFactory.createPackageTarget(n,o,t);this.graphBuilder.addTarget(u),this.targetConfigMap.set(e,t),this.processStagedConfig(u,t,i)}}}async processStagedConfig(e,t,i){if(typeof t.stagedTarget>"u"||typeof i>"u"||i.length===0||i.length>(t.stagedTarget.threshold??ss))return;this.hasStagedTarget=!0,e.type="noop",e.cache=!1,e.shouldRun=!1;let s=(0,S.getStagedTargetId)(e.task),n=this.graphBuilder.targets.has(s)?this.graphBuilder.targets.get(s):this.targetFactory.createStagedTarget(e.task,t.stagedTarget,i);this.graphBuilder.addTarget(n);let o=new Set(n.dependencies);for(let u of e.dependencies)o.add(u);if(n.dependencies=Array.from(o),e.dependents.length>0)throw new Error(`Parent target ${e.id} cannot have dependents when it has a staged target while running with a --since flag`)}shouldRun(e,t){return typeof e.shouldRun=="function"?e.shouldRun(t):!0}async build(e,t,i){let s=(0,Yr.expandDepSpecs)(this.graphBuilder.targets,this.dependencyMap);for(let[a,d]of s)this.graphBuilder.addDependency(a,d);let n=[];for(let a of e){if(t)for(let d of t)n.push((0,S.getTargetId)(d,a));else for(let d of Object.keys(this.packageInfos))n.push((0,S.getTargetId)(d,a));if(this.hasRootTarget){let d=(0,S.getTargetId)(void 0,a);this.graphBuilder.targets.has(d)&&n.push(d)}if(this.hasStagedTarget){let d=(0,S.getStagedTargetId)(a);this.graphBuilder.targets.has(d)&&n.push(d)}}if(i){for(let a of i)if(a.package){let d=(0,S.getTargetId)(a.package,a.task),p=this.graphBuilder.targets.get(d);p&&(p.priority=p.priority?Math.max(p.priority,a.priority):a.priority)}}let o=this.graphBuilder.subgraph(n),u=(0,rs.default)(8),c=[];for(let a of o.targets.values()){let d=this.targetConfigMap.get(a.id);d&&c.push(u(async()=>{a.shouldRun=await this.shouldRun(d,a)}))}return await Promise.all(c),{targets:o.targets}}constructor(e,t){W(this,"packageInfos",void 0),W(this,"dependencyMap",void 0),W(this,"graphBuilder",void 0),W(this,"targetFactory",void 0),W(this,"hasRootTarget",void 0),W(this,"hasStagedTarget",void 0),W(this,"targetConfigMap",void 0),this.packageInfos=t,this.hasRootTarget=!1,this.hasStagedTarget=!1,this.targetConfigMap=new Map,this.dependencyMap=(0,Vr.createDependencyMap)(t,{withDevDependencies:!0,withPeerDependencies:!1}),this.graphBuilder=new es.TargetGraphBuilder,this.targetFactory=new ts.TargetFactory({root:e,packageInfos:t,resolve(i){try{return Zr.default.dirname(t[i].packageJsonPath)}catch{throw new Error(`Cannot open package.json file for ${i}`)}}})}}});var It=f(Ne=>{"use strict";Object.defineProperty(Ne,"__esModule",{value:!0});Object.defineProperty(Ne,"removeNodes",{enumerable:!0,get:function(){return ns}});async function ns(r,e){let t=new Map;r.forEach(s=>t.set(s.id,s));let i=new Map;for(let s of r)if(await e(s)){t.delete(s.id);for(let o of s.dependencies)i.has(s.id)||i.set(s.id,new Set),i.get(s.id).add(o)}for(let s of t.values()){let n=new Set(s.dependencies);for(let o of s.dependencies)i.has(o)&&i.get(o).forEach(u=>n.add(u));s.dependencies=Array.from(n).filter(o=>t.has(o))}return Array.from(t.values())}});var xt=f(Ce=>{"use strict";Object.defineProperty(Ce,"__esModule",{value:!0});Object.defineProperty(Ce,"transitiveReduction",{enumerable:!0,get:function(){return is}});function is(r){let e=new Map,t=new Map;r.forEach(n=>{e.set(n.id,n),t.set(n.id,new Map),n.dependencies.forEach(o=>{t.get(n.id).set(o,!0)})});function i(n,o,u){var d;if(n===o)return!0;if(u.has(n))return!1;if(u.add(n),(d=t.get(n))!=null&&d.has(o))return t.get(n).get(o);let c=e.get(n);if(!c)return!1;let a=c.dependencies.some(p=>i(p,o,u));return t.get(n).set(o,a),a}return r.map(n=>({...n,dependencies:n.dependencies.filter(o=>{let u=new Set;return!n.dependencies.some(c=>c!==o&&i(c,o,u))})}))}});var qt=f(Le=>{"use strict";Object.defineProperty(Le,"__esModule",{value:!0});function os(r,e){for(var t in e)Object.defineProperty(r,t,{enumerable:!0,get:e[t]})}os(Le,{TargetFactory:function(){return ps.TargetFactory},TargetGraphBuilder:function(){return ds.TargetGraphBuilder},WorkspaceTargetGraphBuilder:function(){return cs.WorkspaceTargetGraphBuilder},detectCycles:function(){return us.detectCycles},getPackageAndTask:function(){return je.getPackageAndTask},getStartTargetId:function(){return je.getStartTargetId},getTargetId:function(){return je.getTargetId},removeNodes:function(){return ls.removeNodes},sortTargetsByPriority:function(){return as.sortTargetsByPriority},transitiveReduction:function(){return fs.transitiveReduction}});var as=gt(),je=O(),us=ke(),cs=Rt(),ds=Se(),ps=xe(),ls=It(),fs=xt()});var Dt=f(Be=>{"use strict";Object.defineProperty(Be,"__esModule",{value:!0});Object.defineProperty(Be,"TargetRunnerPicker",{enumerable:!0,get:function(){return $e}});var Et=ys(require("path")),hs=qt(),gs=require("url");function ms(r,e,t){return e in r?Object.defineProperty(r,e,{value:t,enumerable:!0,configurable:!0,writable:!0}):r[e]=t,r}function ys(r){return r&&r.__esModule?r:{default:r}}var $e=class{async pick(e){if(e.id===(0,hs.getStartTargetId)())return new(await Promise.resolve().then(()=>zt(ge()))).NoOpRunner;if(e.type||(e.type="npmScript"),this.options[e.type]){let t=this.options[e.type],{script:i,options:s}=t,n=i;n.startsWith("file://")||(n=(0,gs.pathToFileURL)(n).toString());let o=await import(n),u=Et.default.basename(i),c=u.replace(Et.default.extname(u),""),a=typeof o[c]=="function"?o[c]:typeof o.default=="function"?o.default:typeof o.default[c]=="function"?o.default[c]:o;return new a(s)}throw new Error(`No runner found for target ${e.id}`)}constructor(e){ms(this,"options",void 0),this.options=e}}});var At=f(Fe=>{"use strict";Object.defineProperty(Fe,"__esModule",{value:!0});function _s(r,e){for(var t in e)Object.defineProperty(r,t,{enumerable:!0,get:e[t]})}_s(Fe,{NoOpRunner:function(){return vs.NoOpRunner},NpmScriptRunner:function(){return ks.NpmScriptRunner},TargetRunnerPicker:function(){return Ps.TargetRunnerPicker},WorkerRunner:function(){return ws.WorkerRunner}});var ks=lt(),ws=ht(),vs=ge(),Ps=Dt()});Object.defineProperty(exports,"__esModule",{value:!0});var bs=dt(),Ts=At(),Ms=require("worker_threads");async function Ss(r){let{runners:e}=r,t=new Ts.TargetRunnerPicker(e);return{options:r,runnerPicker:t}}(async()=>{let{runnerPicker:r}=await Ss(Ms.workerData);async function e(t,i){let s;return s=await(await r.pick(t.target)).run({target:t.target,weight:0,abortSignal:i}),{skipped:!1,hash:void 0,value:s}}(0,bs.registerWorker)(e)})();
 //# sourceMappingURL=singleTargetWorker.js.map

package.json

 {
   "name": "lage",
-  "version": "2.12.6",
+  "version": "2.12.7",
   "repository": {
@@ -26,4 +26,4 @@ "type": "git",
   "devDependencies": {
-    "@lage-run/cli": "^0.24.10",
-    "@lage-run/runners": "^1.2.0",
+    "@lage-run/cli": "^0.24.11",
+    "@lage-run/runners": "^1.2.1",
     "backfill-config": "6.4.2",
@@ -30,0 +30,0 @@ "dts-bundle-generator": "^9.5.1",

No alert changes

Improved metrics

Total package byte prevSize

29227810

increased by0.02%

Lines of code

32395

increased by0.01%

No dependency changes