hub / github.com/google/adk-python / onData

Method onData

src/google/adk/cli/browser/chunk-NALL4A3P.js:5–6 · view source on GitHub ↗

(e)

Source from the content-addressed store, hash-verified

3	`,"\r"];(function(t){function e(s,a,o,c){return new $d(s,a,o,c)}t.create=e;function r(s){let a=s;return!!(m.defined(a)&&m.string(a.uri)&&(m.undefined(a.languageId)\|\|m.string(a.languageId))&&m.uinteger(a.lineCount)&&m.func(a.getText)&&m.func(a.positionAt)&&m.func(a.offsetAt))}t.is=r;function n(s,a){let o=s.getText(),c=i(a,(u,p)=>{let h=u.range.start.line-p.range.start.line;return h===0?u.range.start.character-p.range.start.character:h}),l=o.length;for(let u=c.length-1;u>=0;u--){let p=c[u],h=s.offsetAt(p.range.start),g=s.offsetAt(p.range.end);if(g<=l)o=o.substring(0,h)+p.newText+o.substring(g,o.length);else throw new Error("Overlapping edit");l=h}return o}t.applyEdits=n;function i(s,a){if(s.length<=1)return s;let o=s.length/2\|0,c=s.slice(0,o),l=s.slice(o);i(c,a),i(l,a);let u=0,p=0,h=0;for(;u<c.length&&p<l.length;)a(c[u],l[p])<=0?s[h++]=c[u++]:s[h++]=l[p++];for(;u<c.length;)s[h++]=c[u++];for(;p<l.length;)s[h++]=l[p++];return s}})(Ad\|\|(Ad={}));$d=class{constructor(e,r,n,i){this._uri=e,this._languageId=r,this._version=n,this._content=i,this._lineOffsets=void 0}get uri(){return this._uri}get languageId(){return this._languageId}get version(){return this._version}getText(e){if(e){let r=this.offsetAt(e.start),n=this.offsetAt(e.end);return this._content.substring(r,n)}return this._content}update(e,r){this._content=e.text,this._version=r,this._lineOffsets=void 0}getLineOffsets(){if(this._lineOffsets===void 0){let e=[],r=this._content,n=!0;for(let i=0;i<r.length;i++){n&&(e.push(i),n=!1);let s=r.charAt(i);n=s==="\r"\|\|s===`
4	`,s==="\r"&&i+1<r.length&&r.charAt(i+1)===`
5	`&&i++}n&&r.length>0&&e.push(r.length),this._lineOffsets=e}return this._lineOffsets}positionAt(e){e=Math.max(Math.min(e,this._content.length),0);let r=this.getLineOffsets(),n=0,i=r.length;if(i===0)return ce.create(0,e);for(;n<i;){let a=Math.floor((n+i)/2);r[a]>e?i=a:n=a+1}let s=n-1;return ce.create(s,e-r[s])}offsetAt(e){let r=this.getLineOffsets();if(e.line>=r.length)return this._content.length;if(e.line<0)return 0;let n=r[e.line],i=e.line+1<r.length?r[e.line+1]:this._content.length;return Math.max(Math.min(n+e.character,i),n)}get lineCount(){return this.getLineOffsets().length}};(function(t){let e=Object.prototype.toString;function r(g){return typeof g<"u"}t.defined=r;function n(g){return typeof g>"u"}t.undefined=n;function i(g){return g===!0\|\|g===!1}t.boolean=i;function s(g){return e.call(g)==="[object String]"}t.string=s;function a(g){return e.call(g)==="[object Number]"}t.number=a;function o(g,C,k){return e.call(g)==="[object Number]"&&C<=g&&g<=k}t.numberRange=o;function c(g){return e.call(g)==="[object Number]"&&-2147483648<=g&&g<=2147483647}t.integer=c;function l(g){return e.call(g)==="[object Number]"&&0<=g&&g<=2147483647}t.uinteger=l;function u(g){return e.call(g)==="[object Function]"}t.func=u;function p(g){return g!==null&&typeof g=="object"}t.objectLiteral=p;function h(g,C){return Array.isArray(g)&&g.every(C)}t.typedArray=h})(m\|\|(m={}))});var Rn=X(Od=>{"use strict";Object.defineProperty(Od,"__esModule",{value:!0});var bd;function Pd(){if(bd===void 0)throw new Error("No runtime abstraction layer installed");return bd}(function(t){function e(r){if(r===void 0)throw new Error("No runtime abstraction layer provided");bd=r}t.install=e})(Pd\|\|(Pd={}));Od.default=Pd});var ls=X(Tt=>{"use strict";Object.defineProperty(Tt,"__esModule",{value:!0});Tt.stringArray=Tt.array=Tt.func=Tt.error=Tt.number=Tt.string=Tt.boolean=void 0;function zA(t){return t===!0\|\|t===!1}Tt.boolean=zA;function Hg(t){return typeof t=="string"\|\|t instanceof String}Tt.string=Hg;function jA(t){return typeof t=="number"\|\|t instanceof Number}Tt.number=jA;function BA(t){return t instanceof Error}Tt.error=BA;function WA(t){return typeof t=="function"}Tt.func=WA;function Yg(t){return Array.isArray(t)}Tt.array=Yg;function VA(t){return Yg(t)&&t.every(e=>Hg(e))}Tt.stringArray=VA});var ci=X(us=>{"use strict";Object.defineProperty(us,"__esModule",{value:!0});us.Emitter=us.Event=void 0;var KA=Rn(),Xg;(function(t){let e={dispose(){}};t.None=function(){return e}})(Xg\|\|(us.Event=Xg={}));var Ld=class{add(e,r=null,n){this._callbacks\|\|(this._callbacks=[],this._contexts=[]),this._callbacks.push(e),this._contexts.push(r),Array.isArray(n)&&n.push({dispose:()=>this.remove(e,r)})}remove(e,r=null){if(!this._callbacks)return;let n=!1;for(let i=0,s=this._callbacks.length;i<s;i++)if(this._callbacks[i]===e)if(this._contexts[i]===r){this._callbacks.splice(i,1),this._contexts.splice(i,1);return}else n=!0;if(n)throw new Error("When adding a listener with a context, you should remove it with the same context")}invoke(...e){if(!this._callbacks)return[];let r=[],n=this._callbacks.slice(0),i=this._contexts.slice(0);for(let s=0,a=n.length;s<a;s++)try{r.push(n[s].apply(i[s],e))}catch(o){(0,KA.default)().console.error(o)}return r}isEmpty(){return!this._callbacks\|\|this._callbacks.length===0}dispose(){this._callbacks=void 0,this._contexts=void 0}},ll=class t{constructor(e){this._options=e}get event(){return this._event\|\|(this._event=(e,r,n)=>{this._callbacks\|\|(this._callbacks=new Ld),this._options&&this._options.onFirstListenerAdd&&this._callbacks.isEmpty()&&this._options.onFirstListenerAdd(this),this._callbacks.add(e,r);let i={dispose:()=>{this._callbacks&&(this._callbacks.remove(e,r),i.dispose=t._noop,this._options&&this._options.onLastListenerRemove&&this._callbacks.isEmpty()&&this._options.onLastListenerRemove(this))}};return Array.isArray(n)&&n.push(i),i}),this._event}fire(e){this._callbacks&&this._callbacks.invoke.call(this._callbacks,e)}dispose(){this._callbacks&&(this._callbacks.dispose(),this._callbacks=void 0)}};us.Emitter=ll;ll._noop=function(){}});var Ka=X(fs=>{"use strict";Object.defineProperty(fs,"__esModule",{value:!0});fs.CancellationTokenSource=fs.CancellationToken=void 0;var HA=Rn(),YA=ls(),Dd=ci(),ul;(function(t){t.None=Object.freeze({isCancellationRequested:!1,onCancellationRequested:Dd.Event.None}),t.Cancelled=Object.freeze({isCancellationRequested:!0,onCancellationRequested:Dd.Event.None});function e(r){let n=r;return n&&(n===t.None\|\|n===t.Cancelled\|\|YA.boolean(n.isCancellationRequested)&&!!n.onCancellationRequested)}t.is=e})(ul\|\|(fs.CancellationToken=ul={}));var XA=Object.freeze(function(t,e){let r=(0,HA.default)().timer.setTimeout(t.bind(e),0);return{dispose(){r.dispose()}}}),fl=class{constructor(){this._isCancelled=!1}cancel(){this._isCancelled\|\|(this._isCancelled=!0,this._emitter&&(this._emitter.fire(void 0),this.dispose()))}get isCancellationRequested(){return this._isCancelled}get onCancellationRequested(){return this._isCancelled?XA:(this._emitter\|\|(this._emitter=new Dd.Emitter),this._emitter.event)}dispose(){this._emitter&&(this._emitter.dispose(),this._emitter=void 0)}},Md=class{get token(){return this._token\|\|(this._token=new fl),this._token}cancel(){this._token?this._token.cancel():this._token=ul.Cancelled}dispose(){this._token?this._token instanceof fl&&this._token.dispose():this._token=ul.None}};fs.CancellationTokenSource=Md});var dp=X(j=>{"use strict";Object.defineProperty(j,"__esModule",{value:!0});j.Message=j.NotificationType9=j.NotificationType8=j.NotificationType7=j.NotificationType6=j.NotificationType5=j.NotificationType4=j.NotificationType3=j.NotificationType2=j.NotificationType1=j.NotificationType0=j.NotificationType=j.RequestType9=j.RequestType8=j.RequestType7=j.RequestType6=j.RequestType5=j.RequestType4=j.RequestType3=j.RequestType2=j.RequestType1=j.RequestType=j.RequestType0=j.AbstractMessageSignature=j.ParameterStructures=j.ResponseError=j.ErrorCodes=void 0;var pi=ls(),zd=(function(t){return t.ParseError=-32700,t.InvalidRequest=-32600,t.MethodNotFound=-32601,t.InvalidParams=-32602,t.InternalError=-32603,t.jsonrpcReservedErrorRangeStart=-32099,t.serverErrorStart=-32099,t.MessageWriteError=-32099,t.MessageReadError=-32098,t.PendingResponseRejected=-32097,t.ConnectionInactive=-32096,t.ServerNotInitialized=-32002,t.UnknownErrorCode=-32001,t.jsonrpcReservedErrorRangeEnd=-32e3,t.serverErrorEnd=-32e3,t})(zd\|\|(j.ErrorCodes=zd={})),jd=class t extends Error{constructor(e,r,n){super(r),this.code=pi.number(e)?e:zd.UnknownErrorCode,this.data=n,Object.setPrototypeOf(this,t.prototype)}toJson(){let e={code:this.code,message:this.message};return this.data!==void 0&&(e.data=this.data),e}};j.ResponseError=jd;var Lt=class t{constructor(e){this.kind=e}static is(e){return e===t.auto\|\|e===t.byName\|\|e===t.byPosition}toString(){return this.kind}};j.ParameterStructures=Lt;Lt.auto=new Lt("auto");Lt.byPosition=new Lt("byPosition");Lt.byName=new Lt("byName");var Ie=class{constructor(e,r){this.method=e,this.numberOfParams=r}get parameterStructures(){return Lt.auto}};j.AbstractMessageSignature=Ie;var Bd=class extends Ie{constructor(e){super(e,0)}};j.RequestType0=Bd;var Wd=class extends Ie{constructor(e,r=Lt.auto){super(e,1),this._parameterStructures=r}get parameterStructures(){return this._parameterStructures}};j.RequestType=Wd;var Vd=class extends Ie{constructor(e,r=Lt.auto){super(e,1),this._parameterStructures=r}get parameterStructures(){return this._parameterStructures}};j.RequestType1=Vd;var Kd=class extends Ie{constructor(e){super(e,2)}};j.RequestType2=Kd;var Hd=class extends Ie{constructor(e){super(e,3)}};j.RequestType3=Hd;var Yd=class extends Ie{constructor(e){super(e,4)}};j.RequestType4=Yd;var Xd=class extends Ie{constructor(e){super(e,5)}};j.RequestType5=Xd;var Jd=class extends Ie{constructor(e){super(e,6)}};j.RequestType6=Jd;var Qd=class extends Ie{constructor(e){super(e,7)}};j.RequestType7=Qd;var Zd=class extends Ie{constructor(e){super(e,8)}};j.RequestType8=Zd;var ep=class extends Ie{constructor(e){super(e,9)}};j.RequestType9=ep;var tp=class extends Ie{constructor(e,r=Lt.auto){super(e,1),this._parameterStructures=r}get parameterStructures(){return this._parameterStructures}};j.NotificationType=tp;var rp=class extends Ie{constructor(e){super(e,0)}};j.NotificationType0=rp;var np=class extends Ie{constructor(e,r=Lt.auto){super(e,1),this._parameterStructures=r}get parameterStructures(){return this._parameterStructures}};j.NotificationType1=np;var ip=class extends Ie{constructor(e){super(e,2)}};j.NotificationType2=ip;var sp=class extends Ie{constructor(e){super(e,3)}};j.NotificationType3=sp;var ap=class extends Ie{constructor(e){super(e,4)}};j.NotificationType4=ap;var op=class extends Ie{constructor(e){super(e,5)}};j.NotificationType5=op;var cp=class extends Ie{constructor(e){super(e,6)}};j.NotificationType6=cp;var lp=class extends Ie{constructor(e){super(e,7)}};j.NotificationType7=lp;var up=class extends Ie{constructor(e){super(e,8)}};j.NotificationType8=up;var fp=class extends Ie{constructor(e){super(e,9)}};j.NotificationType9=fp;var cy;(function(t){function e(i){let s=i;return s&&pi.string(s.method)&&(pi.string(s.id)\|\|pi.number(s.id))}t.isRequest=e;function r(i){let s=i;return s&&pi.string(s.method)&&i.id===void 0}t.isNotification=r;function n(i){let s=i;return s&&(s.result!==void 0\|\|!!s.error)&&(pi.string(s.id)\|\|pi.number(s.id)\|\|s.id===null)}t.isResponse=n})(cy\|\|(j.Message=cy={}))});var hp=X(xn=>{"use strict";var ly;Object.defineProperty(xn,"__esModule",{value:!0});xn.LRUCache=xn.LinkedMap=xn.Touch=void 0;var xt;(function(t){t.None=0,t.First=1,t.AsOld=t.First,t.Last=2,t.AsNew=t.Last})(xt\|\|(xn.Touch=xt={}));var Tl=class{constructor(){this[ly]="LinkedMap",this._map=new Map,this._head=void 0,this._tail=void 0,this._size=0,this._state=0}clear(){this._map.clear(),this._head=void 0,this._tail=void 0,this._size=0,this._state++}isEmpty(){return!this._head&&!this._tail}get size(){return this._size}get first(){return this._head?.value}get last(){return this._tail?.value}has(e){return this._map.has(e)}get(e,r=xt.None){let n=this._map.get(e);if(n)return r!==xt.None&&this.touch(n,r),n.value}set(e,r,n=xt.None){let i=this._map.get(e);if(i)i.value=r,n!==xt.None&&this.touch(i,n);else{switch(i={key:e,value:r,next:void 0,previous:void 0},n){case xt.None:this.addItemLast(i);break;case xt.First:this.addItemFirst(i);break;case xt.Last:this.addItemLast(i);break;default:this.addItemLast(i);break}this._map.set(e,i),this._size++}return this}delete(e){return!!this.remove(e)}remove(e){let r=this._map.get(e);if(r)return this._map.delete(e),this.removeItem(r),this._size--,r.value}shift(){if(!this._head&&!this._tail)return;if(!this._head\|\|!this._tail)throw new Error("Invalid list");let e=this._head;return this._map.delete(e.key),this.removeItem(e),this._size--,e.value}forEach(e,r){let n=this._state,i=this._head;for(;i;){if(r?e.bind(r)(i.value,i.key,this):e(i.value,i.key,this),this._state!==n)throw new Error("LinkedMap got modified during iteration.");i=i.next}}keys(){let e=this._state,r=this._head,n={[Symbol.iterator]:()=>n,next:()=>{if(this._state!==e)throw new Error("LinkedMap got modified during iteration.");if(r){let i={value:r.key,done:!1};return r=r.next,i}else return{value:void 0,done:!0}}};return n}values(){let e=this._state,r=this._head,n={[Symbol.iterator]:()=>n,next:()=>{if(this._state!==e)throw new Error("LinkedMap got modified during iteration.");if(r){let i={value:r.value,done:!1};return r=r.next,i}else return{value:void 0,done:!0}}};return n}entries(){let e=this._state,r=this._head,n={[Symbol.iterator]:()=>n,next:()=>{if(this._state!==e)throw new Error("LinkedMap got modified during iteration.");if(r){let i={value:[r.key,r.value],done:!1};return r=r.next,i}else return{value:void 0,done:!0}}};return n}[(ly=Symbol.toStringTag,Symbol.iterator)](){return this.entries()}trimOld(e){if(e>=this.size)return;if(e===0){this.clear();return}let r=this._head,n=this.size;for(;r&&n>e;)this._map.delete(r.key),r=r.next,n--;this._head=r,this._size=n,r&&(r.previous=void 0),this._state++}addItemFirst(e){if(!this._head&&!this._tail)this._tail=e;else if(this._head)e.next=this._head,this._head.previous=e;else throw new Error("Invalid list");this._head=e,this._state++}addItemLast(e){if(!this._head&&!this._tail)this._head=e;else if(this._tail)e.previous=this._tail,this._tail.next=e;else throw new Error("Invalid list");this._tail=e,this._state++}removeItem(e){if(e===this._head&&e===this._tail)this._head=void 0,this._tail=void 0;else if(e===this._head){if(!e.next)throw new Error("Invalid list");e.next.previous=void 0,this._head=e.next}else if(e===this._tail){if(!e.previous)throw new Error("Invalid list");e.previous.next=void 0,this._tail=e.previous}else{let r=e.next,n=e.previous;if(!r\|\|!n)throw new Error("Invalid list");r.previous=n,n.next=r}e.next=void 0,e.previous=void 0,this._state++}touch(e,r){if(!this._head\|\|!this._tail)throw new Error("Invalid list");if(!(r!==xt.First&&r!==xt.Last)){if(r===xt.First){if(e===this._head)return;let n=e.next,i=e.previous;e===this._tail?(i.next=void 0,this._tail=i):(n.previous=i,i.next=n),e.previous=void 0,e.next=this._head,this._head.previous=e,this._head=e,this._state++}else if(r===xt.Last){if(e===this._tail)return;let n=e.next,i=e.previous;e===this._head?(n.previous=void 0,this._head=n):(n.previous=i,i.next=n),e.next=void 0,e.previous=this._tail,this._tail.next=e,this._tail=e,this._state++}}}toJSON(){let e=[];return this.forEach((r,n)=>{e.push([n,r])}),e}fromJSON(e){this.clear();for(let[r,n]of e)this.set(r,n)}};xn.LinkedMap=Tl;var pp=class extends Tl{constructor(e,r=1){super(),this._limit=e,this._ratio=Math.min(Math.max(0,r),1)}get limit(){return this._limit}set limit(e){this._limit=e,this.checkTrim()}get ratio(){return this._ratio}set ratio(e){this._ratio=Math.min(Math.max(0,e),1),this.checkTrim()}get(e,r=xt.AsNew){return super.get(e,r)}peek(e){return super.get(e,xt.None)}set(e,r){return super.set(e,r,xt.Last),this.checkTrim(),this}checkTrim(){this.size>this._limit&&this.trimOld(Math.round(this._limitthis._ratio))}};xn.LRUCache=pp});var fy=X(Rl=>{"use strict";Object.defineProperty(Rl,"__esModule",{value:!0});Rl.Disposable=void 0;var uy;(function(t){function e(r){return{dispose:r}}t.create=e})(uy\|\|(Rl.Disposable=uy={}))});var dy=X(Ts=>{"use strict";Object.defineProperty(Ts,"__esModule",{value:!0});Ts.SharedArrayReceiverStrategy=Ts.SharedArraySenderStrategy=void 0;var ZA=Ka(),xl=(function(t){return t.Continue=0,t.Cancelled=1,t})(xl\|\|{}),mp=class{constructor(){this.buffers=new Map}enableCancellation(e){if(e.id===null)return;let r=new SharedArrayBuffer(4),n=new Int32Array(r,0,1);n[0]=xl.Continue,this.buffers.set(e.id,r),e.$cancellationData=r}sendCancellation(e,r){return P(this,null,function(){let n=this.buffers.get(r);if(n===void 0)return;let i=new Int32Array(n,0,1);Atomics.store(i,0,xl.Cancelled)})}cleanup(e){this.buffers.delete(e)}dispose(){this.buffers.clear()}};Ts.SharedArraySenderStrategy=mp;var gp=class{constructor(e){this.data=new Int32Array(e,0,1)}get isCancellationRequested(){return Atomics.load(this.data,0)===xl.Cancelled}get onCancellationRequested(){throw new Error("Cancellation over SharedArrayBuffer doesn't support cancellation events")}},yp=class{constructor(e){this.token=new gp(e)}cancel(){}dispose(){}},Tp=class{constructor(){this.kind="request"}createCancellationTokenSource(e){let r=e.$cancellationData;return r===void 0?new ZA.CancellationTokenSource:new yp(r)}};Ts.SharedArrayReceiverStrategy=Tp});var xp=X(vl=>{"use strict";Object.defineProperty(vl,"__esModule",{value:!0});vl.Semaphore=void 0;var e$=Rn(),Rp=class{constructor(e=1){if(e<=0)throw new Error("Capacity must be greater than 0");this._capacity=e,this._active=0,this._waiting=[]}lock(e){return new Promise((r,n)=>{this._waiting.push({thunk:e,resolve:r,reject:n}),this.runNext()})}get active(){return this._active}runNext(){this._waiting.length===0\|\|this._active===this._capacity\|\|(0,e$.default)().timer.setImmediate(()=>this.doRunNext())}doRunNext(){if(this._waiting.length===0\|\|this._active===this._capacity)return;let e=this._waiting.shift();if(this._active++,this._active>this._capacity)throw new Error("To many thunks active");try{let r=e.thunk();r instanceof Promise?r.then(n=>{this._active--,e.resolve(n),this.runNext()},n=>{this._active--,e.reject(n),this.runNext()}):(this._active--,e.resolve(r),this.runNext())}catch(r){this._active--,e.reject(r),this.runNext()}}};vl.Semaphore=Rp});var hy=X(vn=>{"use strict";Object.defineProperty(vn,"__esModule",{value:!0});vn.ReadableStreamMessageReader=vn.AbstractMessageReader=vn.MessageReader=void 0;var Ep=Rn(),Rs=ls(),vp=ci(),t$=xp(),py;(function(t){function e(r){let n=r;return n&&Rs.func(n.listen)&&Rs.func(n.dispose)&&Rs.func(n.onError)&&Rs.func(n.onClose)&&Rs.func(n.onPartialMessage)}t.is=e})(py\|\|(vn.MessageReader=py={}));var El=class{constructor(){this.errorEmitter=new vp.Emitter,this.closeEmitter=new vp.Emitter,this.partialMessageEmitter=new vp.Emitter}dispose(){this.errorEmitter.dispose(),this.closeEmitter.dispose()}get onError(){return this.errorEmitter.event}fireError(e){this.errorEmitter.fire(this.asError(e))}get onClose(){return this.closeEmitter.event}fireClose(){this.closeEmitter.fire(void 0)}get onPartialMessage(){return this.partialMessageEmitter.event}firePartialMessage(e){this.partialMessageEmitter.fire(e)}asError(e){return e instanceof Error?e:new Error(`Reader received error. Reason: ${Rs.string(e.message)?e.message:"unknown"}`)}};vn.AbstractMessageReader=El;var Ap;(function(t){function e(r){let n,i,s,a=new Map,o,c=new Map;if(r===void 0\|\|typeof r=="string")n=r??"utf-8";else{if(n=r.charset??"utf-8",r.contentDecoder!==void 0&&(s=r.contentDecoder,a.set(s.name,s)),r.contentDecoders!==void 0)for(let l of r.contentDecoders)a.set(l.name,l);if(r.contentTypeDecoder!==void 0&&(o=r.contentTypeDecoder,c.set(o.name,o)),r.contentTypeDecoders!==void 0)for(let l of r.contentTypeDecoders)c.set(l.name,l)}return o===void 0&&(o=(0,Ep.default)().applicationJson.decoder,c.set(o.name,o)),{charset:n,contentDecoder:s,contentDecoders:a,contentTypeDecoder:o,contentTypeDecoders:c}}t.fromOptions=e})(Ap\|\|(Ap={}));var $p=class extends El{constructor(e,r){super(),this.readable=e,this.options=Ap.fromOptions(r),this.buffer=(0,Ep.default)().messageBuffer.create(this.options.charset),this._partialMessageTimeout=1e4,this.nextMessageLength=-1,this.messageToken=0,this.readSemaphore=new t$.Semaphore(1)}set partialMessageTimeout(e){this._partialMessageTimeout=e}get partialMessageTimeout(){return this._partialMessageTimeout}listen(e){this.nextMessageLength=-1,this.messageToken=0,this.partialMessageTimer=void 0,this.callback=e;let r=this.readable.onData(n=>{this.onData(n)});return this.readable.onError(n=>this.fireError(n)),this.readable.onClose(()=>this.fireClose()),r}onData(e){try{for(this.buffer.append(e);;){if(this.nextMessageLength===-1){let n=this.buffer.tryReadHeaders(!0);if(!n)return;let i=n.get("content-length");if(!i){this.fireError(new Error(`Header must provide a Content-Length property.
6	${JSON.stringify(Object.fromEntries(n))}`));return}let s=parseInt(i);if(isNaN(s)){this.fireError(new Error(`Content-Length value must be a number. Got ${i}`));return}this.nextMessageLength=s}let r=this.buffer.tryReadBody(this.nextMessageLength);if(r===void 0){this.setPartialMessageTimer();return}this.clearPartialMessageTimer(),this.nextMessageLength=-1,this.readSemaphore.lock(()=>P(this,null,function*(){let n=this.options.contentDecoder!==void 0?yield this.options.contentDecoder.decode(r):r,i=yield this.options.contentTypeDecoder.decode(n,this.options);this.callback(i)})).catch(n=>{this.fireError(n)})}}catch(r){this.fireError(r)}}clearPartialMessageTimer(){this.partialMessageTimer&&(this.partialMessageTimer.dispose(),this.partialMessageTimer=void 0)}setPartialMessageTimer(){this.clearPartialMessageTimer(),!(this._partialMessageTimeout<=0)&&(this.partialMessageTimer=(0,Ep.default)().timer.setTimeout((e,r)=>{this.partialMessageTimer=void 0,e===this.messageToken&&(this.firePartialMessage({messageToken:e,waitingTime:r}),this.setPartialMessageTimer())},this._partialMessageTimeout,this.messageToken,this._partialMessageTimeout))}};vn.ReadableStreamMessageReader=$p});var Ry=X(En=>{"use strict";Object.defineProperty(En,"__esModule",{value:!0});En.WriteableStreamMessageWriter=En.AbstractMessageWriter=En.MessageWriter=void 0;var my=Rn(),fo=ls(),r$=xp(),gy=ci(),n$="Content-Length: ",yy=`\r
7	`,Ty;(function(t){function e(r){let n=r;return n&&fo.func(n.dispose)&&fo.func(n.onClose)&&fo.func(n.onError)&&fo.func(n.write)}t.is=e})(Ty\|\|(En.MessageWriter=Ty={}));var Al=class{constructor(){this.errorEmitter=new gy.Emitter,this.closeEmitter=new gy.Emitter}dispose(){this.errorEmitter.dispose(),this.closeEmitter.dispose()}get onError(){return this.errorEmitter.event}fireError(e,r,n){this.errorEmitter.fire([this.asError(e),r,n])}get onClose(){return this.closeEmitter.event}fireClose(){this.closeEmitter.fire(void 0)}asError(e){return e instanceof Error?e:new Error(`Writer received error. Reason: ${fo.string(e.message)?e.message:"unknown"}`)}};En.AbstractMessageWriter=Al;var Sp;(function(t){function e(r){return r===void 0\|\|typeof r=="string"?{charset:r??"utf-8",contentTypeEncoder:(0,my.default)().applicationJson.encoder}:{charset:r.charset??"utf-8",contentEncoder:r.contentEncoder,contentTypeEncoder:r.contentTypeEncoder??(0,my.default)().applicationJson.encoder}}t.fromOptions=e})(Sp\|\|(Sp={}));var kp=class extends Al{constructor(e,r){super(),this.writable=e,this.options=Sp.fromOptions(r),this.errorCount=0,this.writeSemaphore=new r$.Semaphore(1),this.writable.onError(n=>this.fireError(n)),this.writable.onClose(()=>this.fireClose())}write(e){return P(this,null,function(){return this.writeSemaphore.lock(()=>P(this,null,function(){return this.options.contentTypeEncoder.encode(e,this.options).then(n=>this.options.contentEncoder!==void 0?this.options.contentEncoder.encode(n):n).then(n=>{let i=[];return i.push(n$,n.byteLength.toString(),yy),i.push(yy),this.doWrite(e,i,n)},n=>{throw this.fireError(n),n})}))})}doWrite(e,r,n){return P(this,null,function*(){try{return yield this.writable.write(r.join(""),"ascii"),this.writable.write(n)}catch(i){return this.handleError(i,e),Promise.reject(i)}})}handleError(e,r){this.errorCount++,this.fireError(e,r,this.errorCount)}end(){this.writable.end()}};En.WriteableStreamMessageWriter=kp});var xy=X($l=>{"use strict";Object.defineProperty($l,"__esModule",{value:!0});$l.AbstractMessageBuffer=void 0;var i$=13,s$=10,a$=`\r
8	`,Np=class{constructor(e="utf-8"){this._encoding=e,this._chunks=[],this._totalLength=0}get encoding(){return this._encoding}append(e){let r=typeof e=="string"?this.fromString(e,this._encoding):e;this._chunks.push(r),this._totalLength+=r.byteLength}tryReadHeaders(e=!1){if(this._chunks.length===0)return;let r=0,n=0,i=0,s=0;e:for(;n<this._chunks.length;){let l=this._chunks[n];for(i=0;i<l.length;){switch(l[i]){case i$:switch(r){case 0:r=1;break;case 2:r=3;break;default:r=0}break;case s$:switch(r){case 1:r=2;break;case 3:r=4,i++;break e;default:r=0}break;default:r=0}i++}s+=l.byteLength,n++}if(r!==4)return;let a=this._read(s+i),o=new Map,c=this.toString(a,"ascii").split(a$);if(c.length<2)return o;for(let l=0;l<c.length-2;l++){let u=c[l],p=u.indexOf(":");if(p===-1)throw new Error(`Message header must separate key and value using ':'
9	${u}`);let h=u.substr(0,p),g=u.substr(p+1).trim();o.set(e?h.toLowerCase():h,g)}return o}tryReadBody(e){if(!(this._totalLength<e))return this._read(e)}get numberOfBytes(){return this._totalLength}_read(e){if(e===0)return this.emptyBuffer();if(e>this._totalLength)throw new Error("Cannot read so many bytes!");if(this._chunks[0].byteLength===e){let s=this._chunks[0];return this._chunks.shift(),this._totalLength-=e,this.asNative(s)}if(this._chunks[0].byteLength>e){let s=this._chunks[0],a=this.asNative(s,e);return this._chunks[0]=s.slice(e),this._totalLength-=e,a}let r=this.allocNative(e),n=0,i=0;for(;e>0;){let s=this._chunks[i];if(s.byteLength>e){let a=s.slice(0,e);r.set(a,n),n+=e,this._chunks[i]=s.slice(e),this._totalLength-=e,e-=e}else r.set(s,n),n+=s.byteLength,this._chunks.shift(),this._totalLength-=s.byteLength,e-=s.byteLength}return r}};$l.AbstractMessageBuffer=Np});var Sy=X(J=>{"use strict";Object.defineProperty(J,"__esModule",{value:!0});J.createMessageConnection=J.ConnectionOptions=J.MessageStrategy=J.CancellationStrategy=J.CancellationSenderStrategy=J.CancellationReceiverStrategy=J.RequestCancellationReceiverStrategy=J.IdCancellationReceiverStrategy=J.ConnectionStrategy=J.ConnectionError=J.ConnectionErrors=J.LogTraceNotification=J.SetTraceNotification=J.TraceFormat=J.TraceValues=J.Trace=J.NullLogger=J.ProgressType=J.ProgressToken=void 0;var vy=Rn(),Fe=ls(),K=dp(),Ey=hp(),po=ci(),Cp=Ka(),go;(function(t){t.type=new K.NotificationType("$/cancelRequest")})(go\|\|(go={}));var wp;(function(t){function e(r){return typeof r=="string"\|\|typeof r=="number"}t.is=e})(wp\|\|(J.ProgressToken=wp={}));var ho;(function(t){t.type=new K.NotificationType("$/progress")})(ho\|\|(ho={}));var Ip=class{constructor(){}};J.ProgressType=Ip;var _p;(function(t){function e(r){return Fe.func(r)}t.is=e})(_p\|\|(_p={}));J.NullLogger=Object.freeze({error:()=>{},warn:()=>{},info:()=>{},log:()=>{}});var fe=(function(t){return t[t.Off=0]="Off",t[t.Messages=1]="Messages",t[t.Compact=2]="Compact",t[t.Verbose=3]="Verbose",t})(fe\|\|(J.Trace=fe={})),Ay=(function(t){return t.Off="off",t.Messages="messages",t.Compact="compact",t.Verbose="verbose",t})(Ay\|\|(J.TraceValues=Ay={}));(function(t){function e(n){if(!Fe.string(n))return t.Off;switch(n=n.toLowerCase(),n){case"off":return t.Off;case"messages":return t.Messages;case"compact":return t.Compact;case"verbose":return t.Verbose;default:return t.Off}}t.fromString=e;function r(n){switch(n){case t.Off:return"off";case t.Messages:return"messages";case t.Compact:return"compact";case t.Verbose:return"verbose";default:return"off"}}t.toString=r})(fe\|\|(J.Trace=fe={}));var Wt=(function(t){return t.Text="text",t.JSON="json",t})(Wt\|\|(J.TraceFormat=Wt={}));(function(t){function e(r){return Fe.string(r)?(r=r.toLowerCase(),r==="json"?t.JSON:t.Text):t.Text}t.fromString=e})(Wt\|\|(J.TraceFormat=Wt={}));var bp;(function(t){t.type=new K.NotificationType("$/setTrace")})(bp\|\|(J.SetTraceNotification=bp={}));var Sl;(function(t){t.type=new K.NotificationType("$/logTrace")})(Sl\|\|(J.LogTraceNotification=Sl={}));var mo=(function(t){return t[t.Closed=1]="Closed",t[t.Disposed=2]="Disposed",t[t.AlreadyListening=3]="AlreadyListening",t})(mo\|\|(J.ConnectionErrors=mo={})),xs=class t extends Error{constructor(e,r){super(r),this.code=e,Object.setPrototypeOf(this,t.prototype)}};J.ConnectionError=xs;var Pp;(function(t){function e(r){let n=r;return n&&Fe.func(n.cancelUndispatched)}t.is=e})(Pp\|\|(J.ConnectionStrategy=Pp={}));var kl;(function(t){function e(r){let n=r;return n&&(n.kind===void 0\|\|n.kind==="id")&&Fe.func(n.createCancellationTokenSource)&&(n.dispose===void 0\|\|Fe.func(n.dispose))}t.is=e})(kl\|\|(J.IdCancellationReceiverStrategy=kl={}));var Op;(function(t){function e(r){let n=r;return n&&n.kind==="request"&&Fe.func(n.createCancellationTokenSource)&&(n.dispose===void 0\|\|Fe.func(n.dispose))}t.is=e})(Op\|\|(J.RequestCancellationReceiverStrategy=Op={}));var Nl;(function(t){t.Message=Object.freeze({createCancellationTokenSource(r){return new Cp.CancellationTokenSource}});function e(r){return kl.is(r)\|\|Op.is(r)}t.is=e})(Nl\|\|(J.CancellationReceiverStrategy=Nl={}));var Cl;(function(t){t.Message=Object.freeze({sendCancellation(r,n){return r.sendNotification(go.type,{id:n})},cleanup(r){}});function e(r){let n=r;return n&&Fe.func(n.sendCancellation)&&Fe.func(n.cleanup)}t.is=e})(Cl\|\|(J.CancellationSenderStrategy=Cl={}));var wl;(function(t){t.Message=Object.freeze({receiver:Nl.Message,sender:Cl.Message});function e(r){let n=r;return n&&Nl.is(n.receiver)&&Cl.is(n.sender)}t.is=e})(wl\|\|(J.CancellationStrategy=wl={}));var Il;(function(t){function e(r){let n=r;return n&&Fe.func(n.handleMessage)}t.is=e})(Il\|\|(J.MessageStrategy=Il={}));var $y;(function(t){function e(r){let n=r;return n&&(wl.is(n.cancellationStrategy)\|\|Pp.is(n.connectionStrategy)\|\|Il.is(n.messageStrategy))}t.is=e})($y\|\|(J.ConnectionOptions=$y={}));var kr=(function(t){return t[t.New=1]="New",t[t.Listening=2]="Listening",t[t.Closed=3]="Closed",t[t.Disposed=4]="Disposed",t})(kr\|\|{});function o$(t,e,r,n){let i=r!==void 0?r:J.NullLogger,s=0,a=0,o=0,c="2.0",l,u=new Map,p,h=new Map,g=new Map,C,k=new Ey.LinkedMap,G=new Map,M=new Set,b=new Map,E=fe.Off,H=Wt.Text,F,ye=kr.New,dr=new po.Emitter,Je=new po.Emitter,Qt=new po.Emitter,Kt=new po.Emitter,$=new po.Emitter,y=n&&n.cancellationStrategy?n.cancellationStrategy:wl.Message;function L(d){if(d===null)throw new Error("Can't send requests with id null since the response can't be correlated.");return"req-"+d.toString()}function O(d){return d===null?"res-unknown-"+(++o).toString():"res-"+d.toString()}function T(){return"not-"+(++a).toString()}function x(d,v){K.Message.isRequest(v)?d.set(L(v.id),v):K.Message.isResponse(v)?d.set(O(v.id),v):d.set(T(),v)}function A(d){}function _(){return ye===kr.Listening}function U(){return ye===kr.Closed}function N(){return ye===kr.Disposed}function Y(){(ye===kr.New\|\|ye===kr.Listening)&&(ye=kr.Closed,Je.fire(void 0))}function Q(d){dr.fire([d,void 0,void 0])}function de(d){dr.fire(d)}t.onClose(Y),t.onError(Q),e.onClose(Y),e.onError(de);function ue(){C\|\|k.size===0\|\|(C=(0,vy.default)().timer.setImmediate(()=>{C=void 0,We()}))}function ve(d){K.Message.isRequest(d)?ot(d):K.Message.isNotification(d)?pr(d):K.Message.isResponse(d)?_t(d):Zt(d)}function We(){if(k.size===0)return;let d=k.shift();try{let v=n?.messageStrategy;Il.is(v)?v.handleMessage(d,ve):ve(d)}finally{ue()}}let js=d=>{try{if(K.Message.isNotification(d)&&d.method===go.type.method){let v=d.params.id,w=L(v),z=k.get(w);if(K.Message.isRequest(z)){let Te=n?.connectionStrategy,Ge=Te&&Te.cancelUndispatched?Te.cancelUndispatched(z,A):void 0;if(Ge&&(Ge.error!==void 0\|\|Ge.result!==void 0)){k.delete(w),b.delete(v),Ge.id=z.id,Do(Ge,d.method,Date.now()),e.write(Ge).catch(()=>i.error("Sending response for canceled message failed."));return}}let ke=b.get(v);if(ke!==void 0){ke.cancel(),uu(d);return}else M.add(v)}x(k,d)}finally{ue()}};function ot(d){if(N())return;function v(oe,be,me){let Qe={jsonrpc:c,id:d.id};oe instanceof K.ResponseError?Qe.error=oe.toJson():Qe.result=oe===void 0?null:oe,Do(Qe,be,me),e.write(Qe).catch(()=>i.error("Sending response failed."))}function w(oe,be,me){let Qe={jsonrpc:c,id:d.id,error:oe.toJson()};Do(Qe,be,me),e.write(Qe).catch(()=>i.error("Sending response failed."))}function z(oe,be,me){oe===void 0&&(oe=null);let Qe={jsonrpc:c,id:d.id,result:oe};Do(Qe,be,me),e.write(Qe).catch(()=>i.error("Sending response failed."))}Qx(d);let ke=u.get(d.method),Te,Ge;ke&&(Te=ke.type,Ge=ke.handler);let je=Date.now();if(Ge\|\|l){let oe=d.id??String(Date.now()),be=kl.is(y.receiver)?y.receiver.createCancellationTokenSource(oe):y.receiver.createCancellationTokenSource(d);d.id!==null&&M.has(d.id)&&be.cancel(),d.id!==null&&b.set(oe,be);try{let me;if(Ge)if(d.params===void 0){if(Te!==void 0&&Te.numberOfParams!==0){w(new K.ResponseError(K.ErrorCodes.InvalidParams,`Request ${d.method} defines ${Te.numberOfParams} params but received none.`),d.method,je);return}me=Ge(be.token)}else if(Array.isArray(d.params)){if(Te!==void 0&&Te.parameterStructures===K.ParameterStructures.byName){w(new K.ResponseError(K.ErrorCodes.InvalidParams,`Request ${d.method} defines parameters by name but received parameters by position`),d.method,je);return}me=Ge(...d.params,be.token)}else{if(Te!==void 0&&Te.parameterStructures===K.ParameterStructures.byPosition){w(new K.ResponseError(K.ErrorCodes.InvalidParams,`Request ${d.method} defines parameters by position but received parameters by name`),d.method,je);return}me=Ge(d.params,be.token)}else l&&(me=l(d.method,d.params,be.token));let Qe=me;me?Qe.then?Qe.then(Et=>{b.delete(oe),v(Et,d.method,je)},Et=>{b.delete(oe),Et instanceof K.ResponseError?w(Et,d.method,je):Et&&Fe.string(Et.message)?w(new K.ResponseError(K.ErrorCodes.InternalError,`Request ${d.method} failed with message: ${Et.message}`),d.method,je):w(new K.ResponseError(K.ErrorCodes.InternalError,`Request ${d.method} failed unexpectedly without providing any details.`),d.method,je)}):(b.delete(oe),v(me,d.method,je)):(b.delete(oe),z(me,d.method,je))}catch(me){b.delete(oe),me instanceof K.ResponseError?v(me,d.method,je):me&&Fe.string(me.message)?w(new K.ResponseError(K.ErrorCodes.InternalError,`Request ${d.method} failed with message: ${me.message}`),d.method,je):w(new K.ResponseError(K.ErrorCodes.InternalError,`Request ${d.method} failed unexpectedly without providing any details.`),d.method,je)}}else w(new K.ResponseError(K.ErrorCodes.MethodNotFound,`Unhandled method ${d.method}`),d.method,je)}function _t(d){if(!N())if(d.id===null)d.error?i.error(`Received response message without id: Error is:

Callers 1

listenMethod · 0.80

Calls 13

tryReadHeadersMethod · 0.80

fireErrorMethod · 0.80

fromEntriesMethod · 0.80

tryReadBodyMethod · 0.80

setPartialMessageTimerMethod · 0.80

clearPartialMessageTimerMethod · 0.80

lockMethod · 0.80

PFunction · 0.70

appendMethod · 0.45

getMethod · 0.45

catchMethod · 0.45

callbackMethod · 0.45

Tested by

no test coverage detected

3	`,"\r"];(function(t){function e(s,a,o,c){return new $d(s,a,o,c)}t.create=e;function r(s){let a=s;return!!(m.defined(a)&&m.string(a.uri)&&(m.undefined(a.languageId)\|\|m.string(a.languageId))&&m.uinteger(a.lineCount)&&m.func(a.getText)&&m.func(a.positionAt)&&m.func(a.offsetAt))}t.is=r;function n(s,a){let o=s.getText(),c=i(a,(u,p)=>{let h=u.range.start.line-p.range.start.line;return h===0?u.range.start.character-p.range.start.character:h}),l=o.length;for(let u=c.length-1;u>=0;u--){let p=c[u],h=s.offsetAt(p.range.start),g=s.offsetAt(p.range.end);if(g<=l)o=o.substring(0,h)+p.newText+o.substring(g,o.length);else throw new Error("Overlapping edit");l=h}return o}t.applyEdits=n;function i(s,a){if(s.length<=1)return s;let o=s.length/2\|0,c=s.slice(0,o),l=s.slice(o);i(c,a),i(l,a);let u=0,p=0,h=0;for(;u<c.length&&p<l.length;)a(c[u],l[p])<=0?s[h++]=c[u++]:s[h++]=l[p++];for(;u<c.length;)s[h++]=c[u++];for(;p<l.length;)s[h++]=l[p++];return s}})(Ad\|\|(Ad={}));$d=class{constructor(e,r,n,i){this._uri=e,this._languageId=r,this._version=n,this._content=i,this._lineOffsets=void 0}get uri(){return this._uri}get languageId(){return this._languageId}get version(){return this._version}getText(e){if(e){let r=this.offsetAt(e.start),n=this.offsetAt(e.end);return this._content.substring(r,n)}return this._content}update(e,r){this._content=e.text,this._version=r,this._lineOffsets=void 0}getLineOffsets(){if(this._lineOffsets===void 0){let e=[],r=this._content,n=!0;for(let i=0;i<r.length;i++){n&&(e.push(i),n=!1);let s=r.charAt(i);n=s==="\r"\|\|s===`
4	`,s==="\r"&&i+1<r.length&&r.charAt(i+1)===`
5	`&&i++}n&&r.length>0&&e.push(r.length),this._lineOffsets=e}return this._lineOffsets}positionAt(e){e=Math.max(Math.min(e,this._content.length),0);let r=this.getLineOffsets(),n=0,i=r.length;if(i===0)return ce.create(0,e);for(;n<i;){let a=Math.floor((n+i)/2);r[a]>e?i=a:n=a+1}let s=n-1;return ce.create(s,e-r[s])}offsetAt(e){let r=this.getLineOffsets();if(e.line>=r.length)return this._content.length;if(e.line<0)return 0;let n=r[e.line],i=e.line+1<r.length?r[e.line+1]:this._content.length;return Math.max(Math.min(n+e.character,i),n)}get lineCount(){return this.getLineOffsets().length}};(function(t){let e=Object.prototype.toString;function r(g){return typeof g<"u"}t.defined=r;function n(g){return typeof g>"u"}t.undefined=n;function i(g){return g===!0\|\|g===!1}t.boolean=i;function s(g){return e.call(g)==="[object String]"}t.string=s;function a(g){return e.call(g)==="[object Number]"}t.number=a;function o(g,C,k){return e.call(g)==="[object Number]"&&C<=g&&g<=k}t.numberRange=o;function c(g){return e.call(g)==="[object Number]"&&-2147483648<=g&&g<=2147483647}t.integer=c;function l(g){return e.call(g)==="[object Number]"&&0<=g&&g<=2147483647}t.uinteger=l;function u(g){return e.call(g)==="[object Function]"}t.func=u;function p(g){return g!==null&&typeof g=="object"}t.objectLiteral=p;function h(g,C){return Array.isArray(g)&&g.every(C)}t.typedArray=h})(m\|\|(m={}))});var Rn=X(Od=>{"use strict";Object.defineProperty(Od,"__esModule",{value:!0});var bd;function Pd(){if(bd===void 0)throw new Error("No runtime abstraction layer installed");return bd}(function(t){function e(r){if(r===void 0)throw new Error("No runtime abstraction layer provided");bd=r}t.install=e})(Pd\|\|(Pd={}));Od.default=Pd});var ls=X(Tt=>{"use strict";Object.defineProperty(Tt,"__esModule",{value:!0});Tt.stringArray=Tt.array=Tt.func=Tt.error=Tt.number=Tt.string=Tt.boolean=void 0;function zA(t){return t===!0\|\|t===!1}Tt.boolean=zA;function Hg(t){return typeof t=="string"\|\|t instanceof String}Tt.string=Hg;function jA(t){return typeof t=="number"\|\|t instanceof Number}Tt.number=jA;function BA(t){return t instanceof Error}Tt.error=BA;function WA(t){return typeof t=="function"}Tt.func=WA;function Yg(t){return Array.isArray(t)}Tt.array=Yg;function VA(t){return Yg(t)&&t.every(e=>Hg(e))}Tt.stringArray=VA});var ci=X(us=>{"use strict";Object.defineProperty(us,"__esModule",{value:!0});us.Emitter=us.Event=void 0;var KA=Rn(),Xg;(function(t){let e={dispose(){}};t.None=function(){return e}})(Xg\|\|(us.Event=Xg={}));var Ld=class{add(e,r=null,n){this._callbacks\|\|(this._callbacks=[],this._contexts=[]),this._callbacks.push(e),this._contexts.push(r),Array.isArray(n)&&n.push({dispose:()=>this.remove(e,r)})}remove(e,r=null){if(!this._callbacks)return;let n=!1;for(let i=0,s=this._callbacks.length;i<s;i++)if(this._callbacks[i]===e)if(this._contexts[i]===r){this._callbacks.splice(i,1),this._contexts.splice(i,1);return}else n=!0;if(n)throw new Error("When adding a listener with a context, you should remove it with the same context")}invoke(...e){if(!this._callbacks)return[];let r=[],n=this._callbacks.slice(0),i=this._contexts.slice(0);for(let s=0,a=n.length;s<a;s++)try{r.push(n[s].apply(i[s],e))}catch(o){(0,KA.default)().console.error(o)}return r}isEmpty(){return!this._callbacks\|\|this._callbacks.length===0}dispose(){this._callbacks=void 0,this._contexts=void 0}},ll=class t{constructor(e){this._options=e}get event(){return this._event\|\|(this._event=(e,r,n)=>{this._callbacks\|\|(this._callbacks=new Ld),this._options&&this._options.onFirstListenerAdd&&this._callbacks.isEmpty()&&this._options.onFirstListenerAdd(this),this._callbacks.add(e,r);let i={dispose:()=>{this._callbacks&&(this._callbacks.remove(e,r),i.dispose=t._noop,this._options&&this._options.onLastListenerRemove&&this._callbacks.isEmpty()&&this._options.onLastListenerRemove(this))}};return Array.isArray(n)&&n.push(i),i}),this._event}fire(e){this._callbacks&&this._callbacks.invoke.call(this._callbacks,e)}dispose(){this._callbacks&&(this._callbacks.dispose(),this._callbacks=void 0)}};us.Emitter=ll;ll._noop=function(){}});var Ka=X(fs=>{"use strict";Object.defineProperty(fs,"__esModule",{value:!0});fs.CancellationTokenSource=fs.CancellationToken=void 0;var HA=Rn(),YA=ls(),Dd=ci(),ul;(function(t){t.None=Object.freeze({isCancellationRequested:!1,onCancellationRequested:Dd.Event.None}),t.Cancelled=Object.freeze({isCancellationRequested:!0,onCancellationRequested:Dd.Event.None});function e(r){let n=r;return n&&(n===t.None\|\|n===t.Cancelled\|\|YA.boolean(n.isCancellationRequested)&&!!n.onCancellationRequested)}t.is=e})(ul\|\|(fs.CancellationToken=ul={}));var XA=Object.freeze(function(t,e){let r=(0,HA.default)().timer.setTimeout(t.bind(e),0);return{dispose(){r.dispose()}}}),fl=class{constructor(){this._isCancelled=!1}cancel(){this._isCancelled\|\|(this._isCancelled=!0,this._emitter&&(this._emitter.fire(void 0),this.dispose()))}get isCancellationRequested(){return this._isCancelled}get onCancellationRequested(){return this._isCancelled?XA:(this._emitter\|\|(this._emitter=new Dd.Emitter),this._emitter.event)}dispose(){this._emitter&&(this._emitter.dispose(),this._emitter=void 0)}},Md=class{get token(){return this._token\|\|(this._token=new fl),this._token}cancel(){this._token?this._token.cancel():this._token=ul.Cancelled}dispose(){this._token?this._token instanceof fl&&this._token.dispose():this._token=ul.None}};fs.CancellationTokenSource=Md});var dp=X(j=>{"use strict";Object.defineProperty(j,"__esModule",{value:!0});j.Message=j.NotificationType9=j.NotificationType8=j.NotificationType7=j.NotificationType6=j.NotificationType5=j.NotificationType4=j.NotificationType3=j.NotificationType2=j.NotificationType1=j.NotificationType0=j.NotificationType=j.RequestType9=j.RequestType8=j.RequestType7=j.RequestType6=j.RequestType5=j.RequestType4=j.RequestType3=j.RequestType2=j.RequestType1=j.RequestType=j.RequestType0=j.AbstractMessageSignature=j.ParameterStructures=j.ResponseError=j.ErrorCodes=void 0;var pi=ls(),zd=(function(t){return t.ParseError=-32700,t.InvalidRequest=-32600,t.MethodNotFound=-32601,t.InvalidParams=-32602,t.InternalError=-32603,t.jsonrpcReservedErrorRangeStart=-32099,t.serverErrorStart=-32099,t.MessageWriteError=-32099,t.MessageReadError=-32098,t.PendingResponseRejected=-32097,t.ConnectionInactive=-32096,t.ServerNotInitialized=-32002,t.UnknownErrorCode=-32001,t.jsonrpcReservedErrorRangeEnd=-32e3,t.serverErrorEnd=-32e3,t})(zd\|\|(j.ErrorCodes=zd={})),jd=class t extends Error{constructor(e,r,n){super(r),this.code=pi.number(e)?e:zd.UnknownErrorCode,this.data=n,Object.setPrototypeOf(this,t.prototype)}toJson(){let e={code:this.code,message:this.message};return this.data!==void 0&&(e.data=this.data),e}};j.ResponseError=jd;var Lt=class t{constructor(e){this.kind=e}static is(e){return e===t.auto\|\|e===t.byName\|\|e===t.byPosition}toString(){return this.kind}};j.ParameterStructures=Lt;Lt.auto=new Lt("auto");Lt.byPosition=new Lt("byPosition");Lt.byName=new Lt("byName");var Ie=class{constructor(e,r){this.method=e,this.numberOfParams=r}get parameterStructures(){return Lt.auto}};j.AbstractMessageSignature=Ie;var Bd=class extends Ie{constructor(e){super(e,0)}};j.RequestType0=Bd;var Wd=class extends Ie{constructor(e,r=Lt.auto){super(e,1),this._parameterStructures=r}get parameterStructures(){return this._parameterStructures}};j.RequestType=Wd;var Vd=class extends Ie{constructor(e,r=Lt.auto){super(e,1),this._parameterStructures=r}get parameterStructures(){return this._parameterStructures}};j.RequestType1=Vd;var Kd=class extends Ie{constructor(e){super(e,2)}};j.RequestType2=Kd;var Hd=class extends Ie{constructor(e){super(e,3)}};j.RequestType3=Hd;var Yd=class extends Ie{constructor(e){super(e,4)}};j.RequestType4=Yd;var Xd=class extends Ie{constructor(e){super(e,5)}};j.RequestType5=Xd;var Jd=class extends Ie{constructor(e){super(e,6)}};j.RequestType6=Jd;var Qd=class extends Ie{constructor(e){super(e,7)}};j.RequestType7=Qd;var Zd=class extends Ie{constructor(e){super(e,8)}};j.RequestType8=Zd;var ep=class extends Ie{constructor(e){super(e,9)}};j.RequestType9=ep;var tp=class extends Ie{constructor(e,r=Lt.auto){super(e,1),this._parameterStructures=r}get parameterStructures(){return this._parameterStructures}};j.NotificationType=tp;var rp=class extends Ie{constructor(e){super(e,0)}};j.NotificationType0=rp;var np=class extends Ie{constructor(e,r=Lt.auto){super(e,1),this._parameterStructures=r}get parameterStructures(){return this._parameterStructures}};j.NotificationType1=np;var ip=class extends Ie{constructor(e){super(e,2)}};j.NotificationType2=ip;var sp=class extends Ie{constructor(e){super(e,3)}};j.NotificationType3=sp;var ap=class extends Ie{constructor(e){super(e,4)}};j.NotificationType4=ap;var op=class extends Ie{constructor(e){super(e,5)}};j.NotificationType5=op;var cp=class extends Ie{constructor(e){super(e,6)}};j.NotificationType6=cp;var lp=class extends Ie{constructor(e){super(e,7)}};j.NotificationType7=lp;var up=class extends Ie{constructor(e){super(e,8)}};j.NotificationType8=up;var fp=class extends Ie{constructor(e){super(e,9)}};j.NotificationType9=fp;var cy;(function(t){function e(i){let s=i;return s&&pi.string(s.method)&&(pi.string(s.id)\|\|pi.number(s.id))}t.isRequest=e;function r(i){let s=i;return s&&pi.string(s.method)&&i.id===void 0}t.isNotification=r;function n(i){let s=i;return s&&(s.result!==void 0\|\|!!s.error)&&(pi.string(s.id)\|\|pi.number(s.id)\|\|s.id===null)}t.isResponse=n})(cy\|\|(j.Message=cy={}))});var hp=X(xn=>{"use strict";var ly;Object.defineProperty(xn,"__esModule",{value:!0});xn.LRUCache=xn.LinkedMap=xn.Touch=void 0;var xt;(function(t){t.None=0,t.First=1,t.AsOld=t.First,t.Last=2,t.AsNew=t.Last})(xt\|\|(xn.Touch=xt={}));var Tl=class{constructor(){this[ly]="LinkedMap",this._map=new Map,this._head=void 0,this._tail=void 0,this._size=0,this._state=0}clear(){this._map.clear(),this._head=void 0,this._tail=void 0,this._size=0,this._state++}isEmpty(){return!this._head&&!this._tail}get size(){return this._size}get first(){return this._head?.value}get last(){return this._tail?.value}has(e){return this._map.has(e)}get(e,r=xt.None){let n=this._map.get(e);if(n)return r!==xt.None&&this.touch(n,r),n.value}set(e,r,n=xt.None){let i=this._map.get(e);if(i)i.value=r,n!==xt.None&&this.touch(i,n);else{switch(i={key:e,value:r,next:void 0,previous:void 0},n){case xt.None:this.addItemLast(i);break;case xt.First:this.addItemFirst(i);break;case xt.Last:this.addItemLast(i);break;default:this.addItemLast(i);break}this._map.set(e,i),this._size++}return this}delete(e){return!!this.remove(e)}remove(e){let r=this._map.get(e);if(r)return this._map.delete(e),this.removeItem(r),this._size--,r.value}shift(){if(!this._head&&!this._tail)return;if(!this._head\|\|!this._tail)throw new Error("Invalid list");let e=this._head;return this._map.delete(e.key),this.removeItem(e),this._size--,e.value}forEach(e,r){let n=this._state,i=this._head;for(;i;){if(r?e.bind(r)(i.value,i.key,this):e(i.value,i.key,this),this._state!==n)throw new Error("LinkedMap got modified during iteration.");i=i.next}}keys(){let e=this._state,r=this._head,n={[Symbol.iterator]:()=>n,next:()=>{if(this._state!==e)throw new Error("LinkedMap got modified during iteration.");if(r){let i={value:r.key,done:!1};return r=r.next,i}else return{value:void 0,done:!0}}};return n}values(){let e=this._state,r=this._head,n={[Symbol.iterator]:()=>n,next:()=>{if(this._state!==e)throw new Error("LinkedMap got modified during iteration.");if(r){let i={value:r.value,done:!1};return r=r.next,i}else return{value:void 0,done:!0}}};return n}entries(){let e=this._state,r=this._head,n={[Symbol.iterator]:()=>n,next:()=>{if(this._state!==e)throw new Error("LinkedMap got modified during iteration.");if(r){let i={value:[r.key,r.value],done:!1};return r=r.next,i}else return{value:void 0,done:!0}}};return n}[(ly=Symbol.toStringTag,Symbol.iterator)](){return this.entries()}trimOld(e){if(e>=this.size)return;if(e===0){this.clear();return}let r=this._head,n=this.size;for(;r&&n>e;)this._map.delete(r.key),r=r.next,n--;this._head=r,this._size=n,r&&(r.previous=void 0),this._state++}addItemFirst(e){if(!this._head&&!this._tail)this._tail=e;else if(this._head)e.next=this._head,this._head.previous=e;else throw new Error("Invalid list");this._head=e,this._state++}addItemLast(e){if(!this._head&&!this._tail)this._head=e;else if(this._tail)e.previous=this._tail,this._tail.next=e;else throw new Error("Invalid list");this._tail=e,this._state++}removeItem(e){if(e===this._head&&e===this._tail)this._head=void 0,this._tail=void 0;else if(e===this._head){if(!e.next)throw new Error("Invalid list");e.next.previous=void 0,this._head=e.next}else if(e===this._tail){if(!e.previous)throw new Error("Invalid list");e.previous.next=void 0,this._tail=e.previous}else{let r=e.next,n=e.previous;if(!r\|\|!n)throw new Error("Invalid list");r.previous=n,n.next=r}e.next=void 0,e.previous=void 0,this._state++}touch(e,r){if(!this._head\|\|!this._tail)throw new Error("Invalid list");if(!(r!==xt.First&&r!==xt.Last)){if(r===xt.First){if(e===this._head)return;let n=e.next,i=e.previous;e===this._tail?(i.next=void 0,this._tail=i):(n.previous=i,i.next=n),e.previous=void 0,e.next=this._head,this._head.previous=e,this._head=e,this._state++}else if(r===xt.Last){if(e===this._tail)return;let n=e.next,i=e.previous;e===this._head?(n.previous=void 0,this._head=n):(n.previous=i,i.next=n),e.next=void 0,e.previous=this._tail,this._tail.next=e,this._tail=e,this._state++}}}toJSON(){let e=[];return this.forEach((r,n)=>{e.push([n,r])}),e}fromJSON(e){this.clear();for(let[r,n]of e)this.set(r,n)}};xn.LinkedMap=Tl;var pp=class extends Tl{constructor(e,r=1){super(),this._limit=e,this._ratio=Math.min(Math.max(0,r),1)}get limit(){return this._limit}set limit(e){this._limit=e,this.checkTrim()}get ratio(){return this._ratio}set ratio(e){this._ratio=Math.min(Math.max(0,e),1),this.checkTrim()}get(e,r=xt.AsNew){return super.get(e,r)}peek(e){return super.get(e,xt.None)}set(e,r){return super.set(e,r,xt.Last),this.checkTrim(),this}checkTrim(){this.size>this._limit&&this.trimOld(Math.round(this._limitthis._ratio))}};xn.LRUCache=pp});var fy=X(Rl=>{"use strict";Object.defineProperty(Rl,"__esModule",{value:!0});Rl.Disposable=void 0;var uy;(function(t){function e(r){return{dispose:r}}t.create=e})(uy\|\|(Rl.Disposable=uy={}))});var dy=X(Ts=>{"use strict";Object.defineProperty(Ts,"__esModule",{value:!0});Ts.SharedArrayReceiverStrategy=Ts.SharedArraySenderStrategy=void 0;var ZA=Ka(),xl=(function(t){return t.Continue=0,t.Cancelled=1,t})(xl\|\|{}),mp=class{constructor(){this.buffers=new Map}enableCancellation(e){if(e.id===null)return;let r=new SharedArrayBuffer(4),n=new Int32Array(r,0,1);n[0]=xl.Continue,this.buffers.set(e.id,r),e.$cancellationData=r}sendCancellation(e,r){return P(this,null,function(){let n=this.buffers.get(r);if(n===void 0)return;let i=new Int32Array(n,0,1);Atomics.store(i,0,xl.Cancelled)})}cleanup(e){this.buffers.delete(e)}dispose(){this.buffers.clear()}};Ts.SharedArraySenderStrategy=mp;var gp=class{constructor(e){this.data=new Int32Array(e,0,1)}get isCancellationRequested(){return Atomics.load(this.data,0)===xl.Cancelled}get onCancellationRequested(){throw new Error("Cancellation over SharedArrayBuffer doesn't support cancellation events")}},yp=class{constructor(e){this.token=new gp(e)}cancel(){}dispose(){}},Tp=class{constructor(){this.kind="request"}createCancellationTokenSource(e){let r=e.$cancellationData;return r===void 0?new ZA.CancellationTokenSource:new yp(r)}};Ts.SharedArrayReceiverStrategy=Tp});var xp=X(vl=>{"use strict";Object.defineProperty(vl,"__esModule",{value:!0});vl.Semaphore=void 0;var e$=Rn(),Rp=class{constructor(e=1){if(e<=0)throw new Error("Capacity must be greater than 0");this._capacity=e,this._active=0,this._waiting=[]}lock(e){return new Promise((r,n)=>{this._waiting.push({thunk:e,resolve:r,reject:n}),this.runNext()})}get active(){return this._active}runNext(){this._waiting.length===0\|\|this._active===this._capacity\|\|(0,e$.default)().timer.setImmediate(()=>this.doRunNext())}doRunNext(){if(this._waiting.length===0\|\|this._active===this._capacity)return;let e=this._waiting.shift();if(this._active++,this._active>this._capacity)throw new Error("To many thunks active");try{let r=e.thunk();r instanceof Promise?r.then(n=>{this._active--,e.resolve(n),this.runNext()},n=>{this._active--,e.reject(n),this.runNext()}):(this._active--,e.resolve(r),this.runNext())}catch(r){this._active--,e.reject(r),this.runNext()}}};vl.Semaphore=Rp});var hy=X(vn=>{"use strict";Object.defineProperty(vn,"__esModule",{value:!0});vn.ReadableStreamMessageReader=vn.AbstractMessageReader=vn.MessageReader=void 0;var Ep=Rn(),Rs=ls(),vp=ci(),t$=xp(),py;(function(t){function e(r){let n=r;return n&&Rs.func(n.listen)&&Rs.func(n.dispose)&&Rs.func(n.onError)&&Rs.func(n.onClose)&&Rs.func(n.onPartialMessage)}t.is=e})(py\|\|(vn.MessageReader=py={}));var El=class{constructor(){this.errorEmitter=new vp.Emitter,this.closeEmitter=new vp.Emitter,this.partialMessageEmitter=new vp.Emitter}dispose(){this.errorEmitter.dispose(),this.closeEmitter.dispose()}get onError(){return this.errorEmitter.event}fireError(e){this.errorEmitter.fire(this.asError(e))}get onClose(){return this.closeEmitter.event}fireClose(){this.closeEmitter.fire(void 0)}get onPartialMessage(){return this.partialMessageEmitter.event}firePartialMessage(e){this.partialMessageEmitter.fire(e)}asError(e){return e instanceof Error?e:new Error(`Reader received error. Reason: ${Rs.string(e.message)?e.message:"unknown"}`)}};vn.AbstractMessageReader=El;var Ap;(function(t){function e(r){let n,i,s,a=new Map,o,c=new Map;if(r===void 0\|\|typeof r=="string")n=r??"utf-8";else{if(n=r.charset??"utf-8",r.contentDecoder!==void 0&&(s=r.contentDecoder,a.set(s.name,s)),r.contentDecoders!==void 0)for(let l of r.contentDecoders)a.set(l.name,l);if(r.contentTypeDecoder!==void 0&&(o=r.contentTypeDecoder,c.set(o.name,o)),r.contentTypeDecoders!==void 0)for(let l of r.contentTypeDecoders)c.set(l.name,l)}return o===void 0&&(o=(0,Ep.default)().applicationJson.decoder,c.set(o.name,o)),{charset:n,contentDecoder:s,contentDecoders:a,contentTypeDecoder:o,contentTypeDecoders:c}}t.fromOptions=e})(Ap\|\|(Ap={}));var $p=class extends El{constructor(e,r){super(),this.readable=e,this.options=Ap.fromOptions(r),this.buffer=(0,Ep.default)().messageBuffer.create(this.options.charset),this._partialMessageTimeout=1e4,this.nextMessageLength=-1,this.messageToken=0,this.readSemaphore=new t$.Semaphore(1)}set partialMessageTimeout(e){this._partialMessageTimeout=e}get partialMessageTimeout(){return this._partialMessageTimeout}listen(e){this.nextMessageLength=-1,this.messageToken=0,this.partialMessageTimer=void 0,this.callback=e;let r=this.readable.onData(n=>{this.onData(n)});return this.readable.onError(n=>this.fireError(n)),this.readable.onClose(()=>this.fireClose()),r}onData(e){try{for(this.buffer.append(e);;){if(this.nextMessageLength===-1){let n=this.buffer.tryReadHeaders(!0);if(!n)return;let i=n.get("content-length");if(!i){this.fireError(new Error(`Header must provide a Content-Length property.
6	${JSON.stringify(Object.fromEntries(n))}`));return}let s=parseInt(i);if(isNaN(s)){this.fireError(new Error(`Content-Length value must be a number. Got ${i}`));return}this.nextMessageLength=s}let r=this.buffer.tryReadBody(this.nextMessageLength);if(r===void 0){this.setPartialMessageTimer();return}this.clearPartialMessageTimer(),this.nextMessageLength=-1,this.readSemaphore.lock(()=>P(this,null,function*(){let n=this.options.contentDecoder!==void 0?yield this.options.contentDecoder.decode(r):r,i=yield this.options.contentTypeDecoder.decode(n,this.options);this.callback(i)})).catch(n=>{this.fireError(n)})}}catch(r){this.fireError(r)}}clearPartialMessageTimer(){this.partialMessageTimer&&(this.partialMessageTimer.dispose(),this.partialMessageTimer=void 0)}setPartialMessageTimer(){this.clearPartialMessageTimer(),!(this._partialMessageTimeout<=0)&&(this.partialMessageTimer=(0,Ep.default)().timer.setTimeout((e,r)=>{this.partialMessageTimer=void 0,e===this.messageToken&&(this.firePartialMessage({messageToken:e,waitingTime:r}),this.setPartialMessageTimer())},this._partialMessageTimeout,this.messageToken,this._partialMessageTimeout))}};vn.ReadableStreamMessageReader=$p});var Ry=X(En=>{"use strict";Object.defineProperty(En,"__esModule",{value:!0});En.WriteableStreamMessageWriter=En.AbstractMessageWriter=En.MessageWriter=void 0;var my=Rn(),fo=ls(),r$=xp(),gy=ci(),n$="Content-Length: ",yy=`\r
7	`,Ty;(function(t){function e(r){let n=r;return n&&fo.func(n.dispose)&&fo.func(n.onClose)&&fo.func(n.onError)&&fo.func(n.write)}t.is=e})(Ty\|\|(En.MessageWriter=Ty={}));var Al=class{constructor(){this.errorEmitter=new gy.Emitter,this.closeEmitter=new gy.Emitter}dispose(){this.errorEmitter.dispose(),this.closeEmitter.dispose()}get onError(){return this.errorEmitter.event}fireError(e,r,n){this.errorEmitter.fire([this.asError(e),r,n])}get onClose(){return this.closeEmitter.event}fireClose(){this.closeEmitter.fire(void 0)}asError(e){return e instanceof Error?e:new Error(`Writer received error. Reason: ${fo.string(e.message)?e.message:"unknown"}`)}};En.AbstractMessageWriter=Al;var Sp;(function(t){function e(r){return r===void 0\|\|typeof r=="string"?{charset:r??"utf-8",contentTypeEncoder:(0,my.default)().applicationJson.encoder}:{charset:r.charset??"utf-8",contentEncoder:r.contentEncoder,contentTypeEncoder:r.contentTypeEncoder??(0,my.default)().applicationJson.encoder}}t.fromOptions=e})(Sp\|\|(Sp={}));var kp=class extends Al{constructor(e,r){super(),this.writable=e,this.options=Sp.fromOptions(r),this.errorCount=0,this.writeSemaphore=new r$.Semaphore(1),this.writable.onError(n=>this.fireError(n)),this.writable.onClose(()=>this.fireClose())}write(e){return P(this,null,function(){return this.writeSemaphore.lock(()=>P(this,null,function(){return this.options.contentTypeEncoder.encode(e,this.options).then(n=>this.options.contentEncoder!==void 0?this.options.contentEncoder.encode(n):n).then(n=>{let i=[];return i.push(n$,n.byteLength.toString(),yy),i.push(yy),this.doWrite(e,i,n)},n=>{throw this.fireError(n),n})}))})}doWrite(e,r,n){return P(this,null,function*(){try{return yield this.writable.write(r.join(""),"ascii"),this.writable.write(n)}catch(i){return this.handleError(i,e),Promise.reject(i)}})}handleError(e,r){this.errorCount++,this.fireError(e,r,this.errorCount)}end(){this.writable.end()}};En.WriteableStreamMessageWriter=kp});var xy=X($l=>{"use strict";Object.defineProperty($l,"__esModule",{value:!0});$l.AbstractMessageBuffer=void 0;var i$=13,s$=10,a$=`\r
8	`,Np=class{constructor(e="utf-8"){this._encoding=e,this._chunks=[],this._totalLength=0}get encoding(){return this._encoding}append(e){let r=typeof e=="string"?this.fromString(e,this._encoding):e;this._chunks.push(r),this._totalLength+=r.byteLength}tryReadHeaders(e=!1){if(this._chunks.length===0)return;let r=0,n=0,i=0,s=0;e:for(;n<this._chunks.length;){let l=this._chunks[n];for(i=0;i<l.length;){switch(l[i]){case i$:switch(r){case 0:r=1;break;case 2:r=3;break;default:r=0}break;case s$:switch(r){case 1:r=2;break;case 3:r=4,i++;break e;default:r=0}break;default:r=0}i++}s+=l.byteLength,n++}if(r!==4)return;let a=this._read(s+i),o=new Map,c=this.toString(a,"ascii").split(a$);if(c.length<2)return o;for(let l=0;l<c.length-2;l++){let u=c[l],p=u.indexOf(":");if(p===-1)throw new Error(`Message header must separate key and value using ':'
9	${u}`);let h=u.substr(0,p),g=u.substr(p+1).trim();o.set(e?h.toLowerCase():h,g)}return o}tryReadBody(e){if(!(this._totalLength<e))return this._read(e)}get numberOfBytes(){return this._totalLength}_read(e){if(e===0)return this.emptyBuffer();if(e>this._totalLength)throw new Error("Cannot read so many bytes!");if(this._chunks[0].byteLength===e){let s=this._chunks[0];return this._chunks.shift(),this._totalLength-=e,this.asNative(s)}if(this._chunks[0].byteLength>e){let s=this._chunks[0],a=this.asNative(s,e);return this._chunks[0]=s.slice(e),this._totalLength-=e,a}let r=this.allocNative(e),n=0,i=0;for(;e>0;){let s=this._chunks[i];if(s.byteLength>e){let a=s.slice(0,e);r.set(a,n),n+=e,this._chunks[i]=s.slice(e),this._totalLength-=e,e-=e}else r.set(s,n),n+=s.byteLength,this._chunks.shift(),this._totalLength-=s.byteLength,e-=s.byteLength}return r}};$l.AbstractMessageBuffer=Np});var Sy=X(J=>{"use strict";Object.defineProperty(J,"__esModule",{value:!0});J.createMessageConnection=J.ConnectionOptions=J.MessageStrategy=J.CancellationStrategy=J.CancellationSenderStrategy=J.CancellationReceiverStrategy=J.RequestCancellationReceiverStrategy=J.IdCancellationReceiverStrategy=J.ConnectionStrategy=J.ConnectionError=J.ConnectionErrors=J.LogTraceNotification=J.SetTraceNotification=J.TraceFormat=J.TraceValues=J.Trace=J.NullLogger=J.ProgressType=J.ProgressToken=void 0;var vy=Rn(),Fe=ls(),K=dp(),Ey=hp(),po=ci(),Cp=Ka(),go;(function(t){t.type=new K.NotificationType("$/cancelRequest")})(go\|\|(go={}));var wp;(function(t){function e(r){return typeof r=="string"\|\|typeof r=="number"}t.is=e})(wp\|\|(J.ProgressToken=wp={}));var ho;(function(t){t.type=new K.NotificationType("$/progress")})(ho\|\|(ho={}));var Ip=class{constructor(){}};J.ProgressType=Ip;var _p;(function(t){function e(r){return Fe.func(r)}t.is=e})(_p\|\|(_p={}));J.NullLogger=Object.freeze({error:()=>{},warn:()=>{},info:()=>{},log:()=>{}});var fe=(function(t){return t[t.Off=0]="Off",t[t.Messages=1]="Messages",t[t.Compact=2]="Compact",t[t.Verbose=3]="Verbose",t})(fe\|\|(J.Trace=fe={})),Ay=(function(t){return t.Off="off",t.Messages="messages",t.Compact="compact",t.Verbose="verbose",t})(Ay\|\|(J.TraceValues=Ay={}));(function(t){function e(n){if(!Fe.string(n))return t.Off;switch(n=n.toLowerCase(),n){case"off":return t.Off;case"messages":return t.Messages;case"compact":return t.Compact;case"verbose":return t.Verbose;default:return t.Off}}t.fromString=e;function r(n){switch(n){case t.Off:return"off";case t.Messages:return"messages";case t.Compact:return"compact";case t.Verbose:return"verbose";default:return"off"}}t.toString=r})(fe\|\|(J.Trace=fe={}));var Wt=(function(t){return t.Text="text",t.JSON="json",t})(Wt\|\|(J.TraceFormat=Wt={}));(function(t){function e(r){return Fe.string(r)?(r=r.toLowerCase(),r==="json"?t.JSON:t.Text):t.Text}t.fromString=e})(Wt\|\|(J.TraceFormat=Wt={}));var bp;(function(t){t.type=new K.NotificationType("$/setTrace")})(bp\|\|(J.SetTraceNotification=bp={}));var Sl;(function(t){t.type=new K.NotificationType("$/logTrace")})(Sl\|\|(J.LogTraceNotification=Sl={}));var mo=(function(t){return t[t.Closed=1]="Closed",t[t.Disposed=2]="Disposed",t[t.AlreadyListening=3]="AlreadyListening",t})(mo\|\|(J.ConnectionErrors=mo={})),xs=class t extends Error{constructor(e,r){super(r),this.code=e,Object.setPrototypeOf(this,t.prototype)}};J.ConnectionError=xs;var Pp;(function(t){function e(r){let n=r;return n&&Fe.func(n.cancelUndispatched)}t.is=e})(Pp\|\|(J.ConnectionStrategy=Pp={}));var kl;(function(t){function e(r){let n=r;return n&&(n.kind===void 0\|\|n.kind==="id")&&Fe.func(n.createCancellationTokenSource)&&(n.dispose===void 0\|\|Fe.func(n.dispose))}t.is=e})(kl\|\|(J.IdCancellationReceiverStrategy=kl={}));var Op;(function(t){function e(r){let n=r;return n&&n.kind==="request"&&Fe.func(n.createCancellationTokenSource)&&(n.dispose===void 0\|\|Fe.func(n.dispose))}t.is=e})(Op\|\|(J.RequestCancellationReceiverStrategy=Op={}));var Nl;(function(t){t.Message=Object.freeze({createCancellationTokenSource(r){return new Cp.CancellationTokenSource}});function e(r){return kl.is(r)\|\|Op.is(r)}t.is=e})(Nl\|\|(J.CancellationReceiverStrategy=Nl={}));var Cl;(function(t){t.Message=Object.freeze({sendCancellation(r,n){return r.sendNotification(go.type,{id:n})},cleanup(r){}});function e(r){let n=r;return n&&Fe.func(n.sendCancellation)&&Fe.func(n.cleanup)}t.is=e})(Cl\|\|(J.CancellationSenderStrategy=Cl={}));var wl;(function(t){t.Message=Object.freeze({receiver:Nl.Message,sender:Cl.Message});function e(r){let n=r;return n&&Nl.is(n.receiver)&&Cl.is(n.sender)}t.is=e})(wl\|\|(J.CancellationStrategy=wl={}));var Il;(function(t){function e(r){let n=r;return n&&Fe.func(n.handleMessage)}t.is=e})(Il\|\|(J.MessageStrategy=Il={}));var $y;(function(t){function e(r){let n=r;return n&&(wl.is(n.cancellationStrategy)\|\|Pp.is(n.connectionStrategy)\|\|Il.is(n.messageStrategy))}t.is=e})($y\|\|(J.ConnectionOptions=$y={}));var kr=(function(t){return t[t.New=1]="New",t[t.Listening=2]="Listening",t[t.Closed=3]="Closed",t[t.Disposed=4]="Disposed",t})(kr\|\|{});function o$(t,e,r,n){let i=r!==void 0?r:J.NullLogger,s=0,a=0,o=0,c="2.0",l,u=new Map,p,h=new Map,g=new Map,C,k=new Ey.LinkedMap,G=new Map,M=new Set,b=new Map,E=fe.Off,H=Wt.Text,F,ye=kr.New,dr=new po.Emitter,Je=new po.Emitter,Qt=new po.Emitter,Kt=new po.Emitter,$=new po.Emitter,y=n&&n.cancellationStrategy?n.cancellationStrategy:wl.Message;function L(d){if(d===null)throw new Error("Can't send requests with id null since the response can't be correlated.");return"req-"+d.toString()}function O(d){return d===null?"res-unknown-"+(++o).toString():"res-"+d.toString()}function T(){return"not-"+(++a).toString()}function x(d,v){K.Message.isRequest(v)?d.set(L(v.id),v):K.Message.isResponse(v)?d.set(O(v.id),v):d.set(T(),v)}function A(d){}function _(){return ye===kr.Listening}function U(){return ye===kr.Closed}function N(){return ye===kr.Disposed}function Y(){(ye===kr.New\|\|ye===kr.Listening)&&(ye=kr.Closed,Je.fire(void 0))}function Q(d){dr.fire([d,void 0,void 0])}function de(d){dr.fire(d)}t.onClose(Y),t.onError(Q),e.onClose(Y),e.onError(de);function ue(){C\|\|k.size===0\|\|(C=(0,vy.default)().timer.setImmediate(()=>{C=void 0,We()}))}function ve(d){K.Message.isRequest(d)?ot(d):K.Message.isNotification(d)?pr(d):K.Message.isResponse(d)?_t(d):Zt(d)}function We(){if(k.size===0)return;let d=k.shift();try{let v=n?.messageStrategy;Il.is(v)?v.handleMessage(d,ve):ve(d)}finally{ue()}}let js=d=>{try{if(K.Message.isNotification(d)&&d.method===go.type.method){let v=d.params.id,w=L(v),z=k.get(w);if(K.Message.isRequest(z)){let Te=n?.connectionStrategy,Ge=Te&&Te.cancelUndispatched?Te.cancelUndispatched(z,A):void 0;if(Ge&&(Ge.error!==void 0\|\|Ge.result!==void 0)){k.delete(w),b.delete(v),Ge.id=z.id,Do(Ge,d.method,Date.now()),e.write(Ge).catch(()=>i.error("Sending response for canceled message failed."));return}}let ke=b.get(v);if(ke!==void 0){ke.cancel(),uu(d);return}else M.add(v)}x(k,d)}finally{ue()}};function ot(d){if(N())return;function v(oe,be,me){let Qe={jsonrpc:c,id:d.id};oe instanceof K.ResponseError?Qe.error=oe.toJson():Qe.result=oe===void 0?null:oe,Do(Qe,be,me),e.write(Qe).catch(()=>i.error("Sending response failed."))}function w(oe,be,me){let Qe={jsonrpc:c,id:d.id,error:oe.toJson()};Do(Qe,be,me),e.write(Qe).catch(()=>i.error("Sending response failed."))}function z(oe,be,me){oe===void 0&&(oe=null);let Qe={jsonrpc:c,id:d.id,result:oe};Do(Qe,be,me),e.write(Qe).catch(()=>i.error("Sending response failed."))}Qx(d);let ke=u.get(d.method),Te,Ge;ke&&(Te=ke.type,Ge=ke.handler);let je=Date.now();if(Ge\|\|l){let oe=d.id??String(Date.now()),be=kl.is(y.receiver)?y.receiver.createCancellationTokenSource(oe):y.receiver.createCancellationTokenSource(d);d.id!==null&&M.has(d.id)&&be.cancel(),d.id!==null&&b.set(oe,be);try{let me;if(Ge)if(d.params===void 0){if(Te!==void 0&&Te.numberOfParams!==0){w(new K.ResponseError(K.ErrorCodes.InvalidParams,`Request ${d.method} defines ${Te.numberOfParams} params but received none.`),d.method,je);return}me=Ge(be.token)}else if(Array.isArray(d.params)){if(Te!==void 0&&Te.parameterStructures===K.ParameterStructures.byName){w(new K.ResponseError(K.ErrorCodes.InvalidParams,`Request ${d.method} defines parameters by name but received parameters by position`),d.method,je);return}me=Ge(...d.params,be.token)}else{if(Te!==void 0&&Te.parameterStructures===K.ParameterStructures.byPosition){w(new K.ResponseError(K.ErrorCodes.InvalidParams,`Request ${d.method} defines parameters by position but received parameters by name`),d.method,je);return}me=Ge(d.params,be.token)}else l&&(me=l(d.method,d.params,be.token));let Qe=me;me?Qe.then?Qe.then(Et=>{b.delete(oe),v(Et,d.method,je)},Et=>{b.delete(oe),Et instanceof K.ResponseError?w(Et,d.method,je):Et&&Fe.string(Et.message)?w(new K.ResponseError(K.ErrorCodes.InternalError,`Request ${d.method} failed with message: ${Et.message}`),d.method,je):w(new K.ResponseError(K.ErrorCodes.InternalError,`Request ${d.method} failed unexpectedly without providing any details.`),d.method,je)}):(b.delete(oe),v(me,d.method,je)):(b.delete(oe),z(me,d.method,je))}catch(me){b.delete(oe),me instanceof K.ResponseError?v(me,d.method,je):me&&Fe.string(me.message)?w(new K.ResponseError(K.ErrorCodes.InternalError,`Request ${d.method} failed with message: ${me.message}`),d.method,je):w(new K.ResponseError(K.ErrorCodes.InternalError,`Request ${d.method} failed unexpectedly without providing any details.`),d.method,je)}}else w(new K.ResponseError(K.ErrorCodes.MethodNotFound,`Unhandled method ${d.method}`),d.method,je)}function _t(d){if(!N())if(d.id===null)d.error?i.error(`Received response message without id: Error is: