Function js

src/google/adk/cli/browser/chunk-NALL4A3P.js:9–9

`,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
`,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 ':'
${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: 
${JSON.stringify(d.error,void 0,4)}`):i.error("Received response message without id. No further error information provided.");else{let v=d.id,w=G.get(v);if(Zx(d,w),w!==void 0){G.delete(v);try{if(d.error){let z=d.error;w.reject(new K.ResponseError(z.code,z.message,z.data))}else if(d.result!==void 0)w.resolve(d.result);else throw new Error("Should never happen.")}catch(z){z.message?i.error(`Response handler '${w.method}' failed with message: ${z.message}`):i.error(`Response handler '${w.method}' failed unexpectedly.`)}}}}function pr(d){if(N())return;let v,w;if(d.method===go.type.method){let z=d.params.id;M.delete(z),uu(d);return}else{let z=h.get(d.method);z&&(w=z.handler,v=z.type)}if(w||p)try{if(uu(d),w)if(d.params===void 0)v!==void 0&&v.numberOfParams!==0&&v.parameterStructures!==K.ParameterStructures.byName&&i.error(`Notification ${d.method} defines ${v.numberOfParams} params but received none.`),w();else if(Array.isArray(d.params)){let z=d.params;d.method===ho.type.method&&z.length===2&&wp.is(z[0])?w({token:z[0],value:z[1]}):(v!==void 0&&(v.parameterStructures===K.ParameterStructures.byName&&i.error(`Notification ${d.method} defines parameters by name but received parameters by position`),v.numberOfParams!==d.params.length&&i.error(`Notification ${d.method} defines ${v.numberOfParams} params but received ${z.length} arguments`)),w(...z))}else v!==void 0&&v.parameterStructures===K.ParameterStructures.byPosition&&i.error(`Notification ${d.method} defines parameters by position but received parameters by name`),w(d.params);else p&&p(d.method,d.params)}catch(z){z.message?i.error(`Notification handler '${d.method}' failed with message: ${z.message}`):i.error(`Notification handler '${d.method}' failed unexpectedly.`)}else Qt.fire(d)}function Zt(d){if(!d){i.error("Received empty message.");return}i.error(`Received message which is neither a response nor a notification message:
${JSON.stringify(d,null,4)}`);let v=d;if(Fe.string(v.id)||Fe.number(v.id)){let w=v.id,z=G.get(w);z&&z.reject(new Error("The received response has neither a result nor an error property."))}}function ft(d){if(d!=null)switch(E){case fe.Verbose:return JSON.stringify(d,null,4);case fe.Compact:return JSON.stringify(d);default:return}}function Bs(d){if(!(E===fe.Off||!F))if(H===Wt.Text){let v;(E===fe.Verbose||E===fe.Compact)&&d.params&&(v=`Params: ${ft(d.params)}