MCPcopy Create free account
hub / github.com/ChinaSiro/claude-code-sourcemap / makeServerStreamRequest

Method makeServerStreamRequest

package/cli.js:2076–2076  ·  view source on GitHub ↗
(q,K,_,z,Y,$)

Source from the content-addressed store, hash-verified

2074for call at
2075${K}`;return Object.assign(Error(_),q,{stack:Y})}class Uc4 extends Vkz.EventEmitter{constructor(){super()}cancel(){var q;(q=this.call)===null||q===void 0||q.cancelWithStatus(us6.Status.CANCELLED,"Cancelled on client")}getPeer(){var q,K;return(K=(q=this.call)===null||q===void 0?void 0:q.getPeer())!==null&&K!==void 0?K:"unknown"}getAuthContext(){var q,K;return(K=(q=this.call)===null||q===void 0?void 0:q.getAuthContext())!==null&&K!==void 0?K:null}}lc4.ClientUnaryCallImpl=Uc4;class Qc4 extends sQ1.Readable{constructor(q){super({objectMode:!0});this.deserialize=q}cancel(){var q;(q=this.call)===null||q===void 0||q.cancelWithStatus(us6.Status.CANCELLED,"Cancelled on client")}getPeer(){var q,K;return(K=(q=this.call)===null||q===void 0?void 0:q.getPeer())!==null&&K!==void 0?K:"unknown"}getAuthContext(){var q,K;return(K=(q=this.call)===null||q===void 0?void 0:q.getAuthContext())!==null&&K!==void 0?K:null}_read(q){var K;(K=this.call)===null||K===void 0||K.startRead()}}lc4.ClientReadableStreamImpl=Qc4;class dc4 extends sQ1.Writable{constructor(q){super({objectMode:!0});this.serialize=q}cancel(){var q;(q=this.call)===null||q===void 0||q.cancelWithStatus(us6.Status.CANCELLED,"Cancelled on client")}getPeer(){var q,K;return(K=(q=this.call)===null||q===void 0?void 0:q.getPeer())!==null&&K!==void 0?K:"unknown"}getAuthContext(){var q,K;return(K=(q=this.call)===null||q===void 0?void 0:q.getAuthContext())!==null&&K!==void 0?K:null}_write(q,K,_){var z;let Y={callback:_},$=Number(K);if(!Number.isNaN($))Y.flags=$;(z=this.call)===null||z===void 0||z.sendMessageWithContext(Y,q)}_final(q){var K;(K=this.call)===null||K===void 0||K.halfClose(),q()}}lc4.ClientWritableStreamImpl=dc4;class cc4 extends sQ1.Duplex{constructor(q,K){super({objectMode:!0});this.serialize=q,this.deserialize=K}cancel(){var q;(q=this.call)===null||q===void 0||q.cancelWithStatus(us6.Status.CANCELLED,"Cancelled on client")}getPeer(){var q,K;return(K=(q=this.call)===null||q===void 0?void 0:q.getPeer())!==null&&K!==void 0?K:"unknown"}getAuthContext(){var q,K;return(K=(q=this.call)===null||q===void 0?void 0:q.getAuthContext())!==null&&K!==void 0?K:null}_read(q){var K;(K=this.call)===null||K===void 0||K.startRead()}_write(q,K,_){var z;let Y={callback:_},$=Number(K);if(!Number.isNaN($))Y.flags=$;(z=this.call)===null||z===void 0||z.sendMessageWithContext(Y,q)}_final(q){var K;(K=this.call)===null||K===void 0||K.halfClose(),q()}}lc4.ClientDuplexStreamImpl=cc4});var J26=m((oc4)=>{Object.defineProperty(oc4,"__esModule",{value:!0});oc4.InterceptingListenerImpl=void 0;oc4.statusOrFromValue=Skz;oc4.statusOrFromError=Ckz;oc4.isInterceptingListener=bkz;var hkz=vD();function Skz(q){return{ok:!0,value:q}}function Ckz(q){var K;return{ok:!1,error:Object.assign(Object.assign({},q),{metadata:(K=q.metadata)!==null&&K!==void 0?K:new hkz.Metadata})}}function bkz(q){return q.onReceiveMetadata!==void 0&&q.onReceiveMetadata.length===1}class rc4{constructor(q,K){this.listener=q,this.nextListener=K,this.processingMetadata=!1,this.hasPendingMessage=!1,this.processingMessage=!1,this.pendingStatus=null}processPendingMessage(){if(this.hasPendingMessage)this.nextListener.onReceiveMessage(this.pendingMessage),this.pendingMessage=null,this.hasPendingMessage=!1}processPendingStatus(){if(this.pendingStatus)this.nextListener.onReceiveStatus(this.pendingStatus)}onReceiveMetadata(q){this.processingMetadata=!0,this.listener.onReceiveMetadata(q,(K)=>{this.processingMetadata=!1,this.nextListener.onReceiveMetadata(K),this.processPendingMessage(),this.processPendingStatus()})}onReceiveMessage(q){this.processingMessage=!0,this.listener.onReceiveMessage(q,(K)=>{if(this.processingMessage=!1,this.processingMetadata)this.pendingMessage=K,this.hasPendingMessage=!0;else this.nextListener.onReceiveMessage(K),this.processPendingStatus()})}onReceiveStatus(q){this.listener.onReceiveStatus(q,(K)=>{if(this.processingMetadata||this.processingMessage)this.pendingStatus=K;else this.nextListener.onReceiveStatus(K)})}}oc4.InterceptingListenerImpl=rc4});var qd1=m(($l4)=>{Object.defineProperty($l4,"__esModule",{value:!0});$l4.InterceptingCall=$l4.RequesterBuilder=$l4.ListenerBuilder=$l4.InterceptorConfigurationError=void 0;$l4.getInterceptingCall=gkz;var mkz=vD(),sc4=J26(),tc4=c_(),ec4=gR8();class ps6 extends Error{constructor(q){super(q);this.name="InterceptorConfigurationError",Error.captureStackTrace(this,ps6)}}$l4.InterceptorConfigurationError=ps6;class ql4{constructor(){this.metadata=void 0,this.message=void 0,this.status=void 0}withOnReceiveMetadata(q){return this.metadata=q,this}withOnReceiveMessage(q){return this.message=q,this}withOnReceiveStatus(q){return this.status=q,this}build(){return{onReceiveMetadata:this.metadata,onReceiveMessage:this.message,onReceiveStatus:this.status}}}$l4.ListenerBuilder=ql4;class Kl4{constructor(){this.start=void 0,this.message=void 0,this.halfClose=void 0,this.cancel=void 0}withStart(q){return this.start=q,this}withSendMessage(q){return this.message=q,this}withHalfClose(q){return this.halfClose=q,this}withCancel(q){return this.cancel=q,this}build(){return{start:this.start,sendMessage:this.message,halfClose:this.halfClose,cancel:this.cancel}}}$l4.RequesterBuilder=Kl4;var tQ1={onReceiveMetadata:(q,K)=>{K(q)},onReceiveMessage:(q,K)=>{K(q)},onReceiveStatus:(q,K)=>{K(q)}},ms6={start:(q,K,_)=>{_(q,K)},sendMessage:(q,K)=>{K(q)},halfClose:(q)=>{q()},cancel:(q)=>{q()}};class _l4{constructor(q,K){var _,z,Y,$;if(this.nextCall=q,this.processingMetadata=!1,this.pendingMessageContext=null,this.processingMessage=!1,this.pendingHalfClose=!1,K)this.requester={start:(_=K.start)!==null&&_!==void 0?_:ms6.start,sendMessage:(z=K.sendMessage)!==null&&z!==void 0?z:ms6.sendMessage,halfClose:(Y=K.halfClose)!==null&&Y!==void 0?Y:ms6.halfClose,cancel:($=K.cancel)!==null&&$!==void 0?$:ms6.cancel};else this.requester=ms6}cancelWithStatus(q,K){this.requester.cancel(()=>{this.nextCall.cancelWithStatus(q,K)})}getPeer(){return this.nextCall.getPeer()}processPendingMessage(){if(this.pendingMessageContext)this.nextCall.sendMessageWithContext(this.pendingMessageContext,this.pendingMessage),this.pendingMessageContext=null,this.pendingMessage=null}processPendingHalfClose(){if(this.pendingHalfClose)this.nextCall.halfClose()}start(q,K){var _,z,Y,$,A,O;let w={onReceiveMetadata:(z=(_=K===null||K===void 0?void 0:K.onReceiveMetadata)===null||_===void 0?void 0:_.bind(K))!==null&&z!==void 0?z:(j)=>{},onReceiveMessage:($=(Y=K===null||K===void 0?void 0:K.onReceiveMessage)===null||Y===void 0?void 0:Y.bind(K))!==null&&$!==void 0?$:(j)=>{},onReceiveStatus:(O=(A=K===null||K===void 0?void 0:K.onReceiveStatus)===null||A===void 0?void 0:A.bind(K))!==null&&O!==void 0?O:(j)=>{}};this.processingMetadata=!0,this.requester.start(q,w,(j,H)=>{var J,M,X;this.processingMetadata=!1;let P;if((0,sc4.isInterceptingListener)(H))P=H;else{let W={onReceiveMetadata:(J=H.onReceiveMetadata)!==null&&J!==void 0?J:tQ1.onReceiveMetadata,onReceiveMessage:(M=H.onReceiveMessage)!==null&&M!==void 0?M:tQ1.onReceiveMessage,onReceiveStatus:(X=H.onReceiveStatus)!==null&&X!==void 0?X:tQ1.onReceiveStatus};P=new sc4.InterceptingListenerImpl(W,w)}this.nextCall.start(j,P),this.processPendingMessage(),this.processPendingHalfClose()})}sendMessageWithContext(q,K){this.processingMessage=!0,this.requester.sendMessage(K,(_)=>{if(this.processingMessage=!1,this.processingMetadata)this.pendingMessageContext=q,this.pendingMessage=K;else this.nextCall.sendMessageWithContext(q,_),this.processPendingHalfClose()})}sendMessage(q){this.sendMessageWithContext({},q)}startRead(){this.nextCall.startRead()}halfClose(){this.requester.halfClose(()=>{if(this.processingMetadata||this.processingMessage)this.pendingHalfClose=!0;else this.nextCall.halfClose()})}getAuthContext(){return this.nextCall.getAuthContext()}}$l4.InterceptingCall=_l4;function pkz(q,K,_){var z,Y;let $=(z=_.deadline)!==null&&z!==void 0?z:1/0,A=_.host,O=(Y=_.parent)!==null&&Y!==void 0?Y:null,w=_.propagate_flags,j=_.credentials,H=q.createCall(K,$,A,O,w);if(j)H.setCredentials(j);return H}class eQ1{constructor(q,K){this.call=q,this.methodDefinition=K}cancelWithStatus(q,K){this.call.cancelWithStatus(q,K)}getPeer(){return this.call.getPeer()}sendMessageWithContext(q,K){let _;try{_=this.methodDefinition.requestSerialize(K)}catch(z){this.call.cancelWithStatus(tc4.Status.INTERNAL,`Request message serialization failure: ${(0,ec4.getErrorMessage)(z)}`);return}this.call.sendMessageWithContext(q,_)}sendMessage(q){this.sendMessageWithContext({},q)}start(q,K){let _=null;this.call.start(q,{onReceiveMetadata:(z)=>{var Y;(Y=K===null||K===void 0?void 0:K.onReceiveMetadata)===null||Y===void 0||Y.call(K,z)},onReceiveMessage:(z)=>{var Y;let $;try{$=this.methodDefinition.responseDeserialize(z)}catch(A){_={code:tc4.Status.INTERNAL,details:`Response message parsing error: ${(0,ec4.getErrorMessage)(A)}`,metadata:new mkz.Metadata},this.call.cancelWithStatus(_.code,_.details);return}(Y=K===null||K===void 0?void 0:K.onReceiveMessage)===null||Y===void 0||Y.call(K,$)},onReceiveStatus:(z)=>{var Y,$;if(_)(Y=K===null||K===void 0?void 0:K.onReceiveStatus)===null||Y===void 0||Y.call(K,_);else($=K===null||K===void 0?void 0:K.onReceiveStatus)===null||$===void 0||$.call(K,z)}})}startRead(){this.call.startRead()}halfClose(){this.call.halfClose()}getAuthContext(){return this.call.getAuthContext()}}class zl4 extends eQ1{constructor(q,K){super(q,K)}start(q,K){var _,z;let Y=!1,$={onReceiveMetadata:(z=(_=K===null||K===void 0?void 0:K.onReceiveMetadata)===null||_===void 0?void 0:_.bind(K))!==null&&z!==void 0?z:(A)=>{},onReceiveMessage:(A)=>{var O;Y=!0,(O=K===null||K===void 0?void 0:K.onReceiveMessage)===null||O===void 0||O.call(K,A)},onReceiveStatus:(A)=>{var O,w;if(!Y)(O=K===null||K===void 0?void 0:K.onReceiveMessage)===null||O===void 0||O.call(K,null);(w=K===null||K===void 0?void 0:K.onReceiveStatus)===null||w===void 0||w.call(K,A)}};super.start(q,$),this.call.startRead()}}class Yl4 extends eQ1{}function Bkz(q,K,_){let z=pkz(q,_.path,K);if(_.responseStream)return new Yl4(z,_);else return new zl4(z,_)}function gkz(q,K,_,z){if(q.clientInterceptors.length>0&&q.clientInterceptorProviders.length>0)throw new ps6("Both interceptors and interceptor_providers were passed as options to the client constructor. Only one of these is allowed.");if(q.callInterceptors.length>0&&q.callInterceptorProviders.length>0)throw new ps6("Both interceptors and interceptor_providers were passed as call options. Only one of these is allowed.");let Y=[];if(q.callInterceptors.length>0||q.callInterceptorProviders.length>0)Y=[].concat(q.callInterceptors,q.callInterceptorProviders.map((O)=>O(K))).filter((O)=>O);else Y=[].concat(q.clientInterceptors,q.clientInterceptorProviders.map((O)=>O(K))).filter((O)=>O);let $=Object.assign({},_,{method_definition:K});return Y.reduceRight((O,w)=>{return(j)=>w(j,O)},(O)=>Bkz(z,O,K))($)}});var _d1=m((wl4)=>{Object.defineProperty(wl4,"__esModule",{value:!0});wl4.Client=void 0;var qQ=ic4(),ckz=zd1(),lkz=ev(),f46=c_(),fy6=vD(),qh8=qd1(),km=Symbol(),Zy6=Symbol(),Gy6=Symbol(),Do=Symbol();function Kd1(q){return typeof q==="function"}function Ty6(q){var K;return((K=q.stack)===null||K===void 0?void 0:K.split(`
2076`).slice(1).join(`
2077`))||"no stack trace available"}class Ol4{constructor(q,K,_={}){var z,Y;if(_=Object.assign({},_),this[Zy6]=(z=_.interceptors)!==null&&z!==void 0?z:[],delete _.interceptors,this[Gy6]=(Y=_.interceptor_providers)!==null&&Y!==void 0?Y:[],delete _.interceptor_providers,this[Zy6].length>0&&this[Gy6].length>0)throw Error("Both interceptors and interceptor_providers were passed as options to the client constructor. Only one of these is allowed.");if(this[Do]=_.callInvocationTransformer,delete _.callInvocationTransformer,_.channelOverride)this[km]=_.channelOverride;else if(_.channelFactoryOverride){let $=_.channelFactoryOverride;delete _.channelFactoryOverride,this[km]=$(q,K,_)}else this[km]=new ckz.ChannelImplementation(q,K,_)}close(){this[km].close()}getChannel(){return this[km]}waitForReady(q,K){let _=(z)=>{if(z){K(Error("Failed to connect before the deadline"));return}let Y;try{Y=this[km].getConnectivityState(!0)}catch($){K(Error("The channel has been closed"));return}if(Y===lkz.ConnectivityState.READY)K();else try{this[km].watchConnectivityState(Y,q,_)}catch($){K(Error("The channel has been closed"))}};setImmediate(_)}checkOptionalUnaryResponseArguments(q,K,_){if(Kd1(q))return{metadata:new fy6.Metadata,options:{},callback:q};else if(Kd1(K))if(q instanceof fy6.Metadata)return{metadata:q,options:{},callback:K};else return{metadata:new fy6.Metadata,options:q,callback:K};else{if(!(q instanceof fy6.Metadata&&K instanceof Object&&Kd1(_)))throw Error("Incorrect arguments passed");return{metadata:q,options:K,callback:_}}}makeUnaryRequest(q,K,_,z,Y,$,A){var O,w;let j=this.checkOptionalUnaryResponseArguments(Y,$,A),H={path:q,requestStream:!1,responseStream:!1,requestSerialize:K,responseDeserialize:_},J={argument:z,metadata:j.metadata,call:new qQ.ClientUnaryCallImpl,channel:this[km],methodDefinition:H,callOptions:j.options,callback:j.callback};if(this[Do])J=this[Do](J);let M=J.call,X={clientInterceptors:this[Zy6],clientInterceptorProviders:this[Gy6],callInterceptors:(O=J.callOptions.interceptors)!==null&&O!==void 0?O:[],callInterceptorProviders:(w=J.callOptions.interceptor_providers)!==null&&w!==void 0?w:[]},P=(0,qh8.getInterceptingCall)(X,J.methodDefinition,J.callOptions,J.channel);M.call=P;let W=null,D=!1,f=Error();return P.start(J.metadata,{onReceiveMetadata:(G)=>{M.emit("metadata",G)},onReceiveMessage(G){if(W!==null)P.cancelWithStatus(f46.Status.UNIMPLEMENTED,"Too many responses received");W=G},onReceiveStatus(G){if(D)return;if(D=!0,G.code===f46.Status.OK)if(W===null){let Z=Ty6(f);J.callback((0,qQ.callErrorFromStatus)({code:f46.Status.UNIMPLEMENTED,details:"No message received",metadata:G.metadata},Z))}else J.callback(null,W);else{let Z=Ty6(f);J.callback((0,qQ.callErrorFromStatus)(G,Z))}f=null,M.emit("status",G)}}),P.sendMessage(z),P.halfClose(),M}makeClientStreamRequest(q,K,_,z,Y,$){var A,O;let w=this.checkOptionalUnaryResponseArguments(z,Y,$),j={path:q,requestStream:!0,responseStream:!1,requestSerialize:K,responseDeserialize:_},H={metadata:w.metadata,call:new qQ.ClientWritableStreamImpl(K),channel:this[km],methodDefinition:j,callOptions:w.options,callback:w.callback};if(this[Do])H=this[Do](H);let J=H.call,M={clientInterceptors:this[Zy6],clientInterceptorProviders:this[Gy6],callInterceptors:(A=H.callOptions.interceptors)!==null&&A!==void 0?A:[],callInterceptorProviders:(O=H.callOptions.interceptor_providers)!==null&&O!==void 0?O:[]},X=(0,qh8.getInterceptingCall)(M,H.methodDefinition,H.callOptions,H.channel);J.call=X;let P=null,W=!1,D=Error();return X.start(H.metadata,{onReceiveMetadata:(f)=>{J.emit("metadata",f)},onReceiveMessage(f){if(P!==null)X.cancelWithStatus(f46.Status.UNIMPLEMENTED,"Too many responses received");P=f,X.startRead()},onReceiveStatus(f){if(W)return;if(W=!0,f.code===f46.Status.OK)if(P===null){let G=Ty6(D);H.callback((0,qQ.callErrorFromStatus)({code:f46.Status.UNIMPLEMENTED,details:"No message received",metadata:f.metadata},G))}else H.callback(null,P);else{let G=Ty6(D);H.callback((0,qQ.callErrorFromStatus)(f,G))}D=null,J.emit("status",f)}}),J}checkMetadataAndOptions(q,K){let _,z;if(q instanceof fy6.Metadata)if(_=q,K)z=K;else z={};else{if(q)z=q;else z={};_=new fy6.Metadata}return{metadata:_,options:z}}makeServerStreamRequest(q,K,_,z,Y,$){var A,O;let w=this.checkMetadataAndOptions(Y,$),j={path:q,requestStream:!1,responseStream:!0,requestSerialize:K,responseDeserialize:_},H={argument:z,metadata:w.metadata,call:new qQ.ClientReadableStreamImpl(_),channel:this[km],methodDefinition:j,callOptions:w.options};if(this[Do])H=this[Do](H);let J=H.call,M={clientInterceptors:this[Zy6],clientInterceptorProviders:this[Gy6],callInterceptors:(A=H.callOptions.interceptors)!==null&&A!==void 0?A:[],callInterceptorProviders:(O=H.callOptions.interceptor_providers)!==null&&O!==void 0?O:[]},X=(0,qh8.getInterceptingCall)(M,H.methodDefinition,H.callOptions,H.channel);J.call=X;let P=!1,W=Error();return X.start(H.metadata,{onReceiveMetadata(D){J.emit("metadata",D)},onReceiveMessage(D){J.push(D)},onReceiveStatus(D){if(P)return;if(P=!0,J.push(null),D.code!==f46.Status.OK){let f=Ty6(W);J.emit("error",(0,qQ.callErrorFromStatus)(D,f))}W=null,J.emit("status",D)}}),X.sendMessage(z),X.halfClose(),J}makeBidiStreamRequest(q,K,_,z,Y){var $,A;let O=this.checkMetadataAndOptions(z,Y),w={path:q,requestStream:!0,responseStream:!0,requestSerialize:K,responseDeserialize:_},j={metadata:O.metadata,call:new qQ.ClientDuplexStreamImpl(K,_),channel:this[km],methodDefinition:w,callOptions:O.options};if(this[Do])j=this[Do](j);let H=j.call,J={clientInterceptors:this[Zy6],clientInterceptorProviders:this[Gy6],callInterceptors:($=j.callOptions.interceptors)!==null&&$!==void 0?$:[],callInterceptorProviders:(A=j.callOptions.interceptor_providers)!==null&&A!==void 0?A:[]},M=(0,qh8.getInterceptingCall)(J,j.methodDefinition,j.callOptions,j.channel);H.call=M;let X=!1,P=Error();return M.start(j.metadata,{onReceiveMetadata(W){H.emit("metadata",W)},onReceiveMessage(W){H.push(W)},onReceiveStatus(W){if(X)return;if(X=!0,H.push(null),W.code!==f46.Status.OK){let D=Ty6(P);H.emit("error",(0,qQ.callErrorFromStatus)(W,D))}P=null,H.emit("status",W)}}),H}}wl4.Client=Ol4});var Kh8=m((Jl4)=>{Object.defineProperty(Jl4,"__esModule",{value:!0});Jl4.makeClientConstructor=Hl4;Jl4.loadPackageDefinition=okz;var Bs6=_d1(),nkz={unary:Bs6.Client.prototype.makeUnaryRequest,server_stream:Bs6.Client.prototype.makeServerStreamRequest,client_stream:Bs6.Client.prototype.makeClientStreamRequest,bidi:Bs6.Client.prototype.makeBidiStreamRequest};function Yd1(q){return["__proto__","prototype","constructor"].includes(q)}function Hl4(q,K,_){if(!_)_={};class z extends Bs6.Client{}return Object.keys(q).forEach((Y)=>{if(Yd1(Y))return;let $=q[Y],A;if(typeof Y==="string"&&Y.charAt(0)==="$")throw Error("Method names cannot start with $");if($.requestStream)if($.responseStream)A="bidi";else A="client_stream";else if($.responseStream)A="server_stream";else A="unary";let{requestSerialize:O,responseDeserialize:w}=$,j=ikz(nkz[A],$.path,O,w);if(z.prototype[Y]=j,Object.assign(z.prototype[Y],$),$.originalName&&!Yd1($.originalName))z.prototype[$.originalName]=z.prototype[Y]}),z.service=q,z.serviceName=K,z}function ikz(q,K,_,z){return function(...Y){return q.call(this,K,_,z,...Y)}}function rkz(q){return"format"in q}function okz(q){let K={};for(let _ in q)if(Object.prototype.hasOwnProperty.call(q,_)){let z=q[_],Y=_.split(".");if(Y.some((O)=>Yd1(O)))continue;let $=Y[Y.length-1],A=K;for(let O of Y.slice(0,-1)){if(!A[O])A[O]={};A=A[O]}if(rkz(z))A[$]=z;else A[$]=Hl4(z,$,{})}return K}});var ml4=m((_LO,ul4)=>{var tkz=1/0,ekz="[object Symbol]",qVz=/[^\x00-\x2f\x3a-\x40\x5b-\x60\x7b-\x7f]+/g,KVz=/[\xc0-\xd6\xd8-\xf6\xf8-\xff\u0100-\u017f]/g,zh8="\\ud800-\\udfff",Gl4="\\u0300-\\u036f\\ufe20-\\ufe23",Tl4="\\u20d0-\\u20f0",vl4="\\u2700-\\u27bf",kl4="a-z\\xdf-\\xf6\\xf8-\\xff",_Vz="\\xac\\xb1\\xd7\\xf7",zVz="\\x00-\\x2f\\x3a-\\x40\\x5b-\\x60\\x7b-\\xbf",YVz="\\u2000-\\u206f",$Vz=" \\t\\x0b\\f\\xa0\\ufeff\\n\\r\\u2028\\u2029\\u1680\\u180e\\u2000\\u2001\\u2002\\u2003\\u2004\\u2005\\u2006\\u2007\\u2008\\u2009\\u200a\\u202f\\u205f\\u3000",Vl4="A-Z\\xc0-\\xd6\\xd8-\\xde",Nl4="\\ufe0e\\ufe0f",yl4=_Vz+zVz+YVz+$Vz,Ad1="['’]",AVz="["+zh8+"]",Ml4="["+yl4+"]",_h8="["+Gl4+Tl4+"]",El4="\\d+",OVz="["+vl4+"]",Ll4="["+kl4+"]",Rl4="[^"+zh8+yl4+El4+vl4+kl4+Vl4+"]",$d1="\\ud83c[\\udffb-\\udfff]",wVz="(?:"+_h8+"|"+$d1+")",hl4="[^"+zh8+"]",Od1="(?:\\ud83c[\\udde6-\\uddff]){2}",wd1="[\\ud800-\\udbff][\\udc00-\\udfff]",vy6="["+Vl4+"]",Sl4="\\u200d",Xl4="(?:"+Ll4+"|"+Rl4+")",jVz="(?:"+vy6+"|"+Rl4+")",Pl4="(?:"+Ad1+"(?:d|ll|m|re|s|t|ve))?",Wl4="(?:"+Ad1+"(?:D|LL|M|RE|S|T|VE))?",Cl4=wVz+"?",bl4="["+Nl4+"]?",HVz="(?:"+Sl4+"(?:"+[hl4,Od1,wd1].join("|")+")"+bl4+Cl4+")*",xl4=bl4+Cl4+HVz,JVz="(?:"+[OVz,Od1,wd1].join("|")+")"+xl4,MVz="(?:"+[hl4+_h8+"?",_h8,Od1,wd1,AVz].join("|")+")",XVz=RegExp(Ad1,"g"),PVz=RegExp(_h8,"g"),WVz=RegExp($d1+"(?="+$d1+")|"+MVz+xl4,"g"),DVz=RegExp([vy6+"?"+Ll4+"+"+Pl4+"(?="+[Ml4,vy6,"$"].join("|")+")",jVz+"+"+Wl4+"(?="+[Ml4,vy6+Xl4,"$"].join("|")+")",vy6+"?"+Xl4+"+"+Pl4,vy6+"+"+Wl4,El4,JVz].join("|"),"g"),fVz=RegExp("["+Sl4+zh8+Gl4+Tl4+Nl4+"]"),ZVz=/[a-z][A-Z]|[A-Z]{2,}[a-z]|[0-9][a-zA-Z]|[a-zA-Z][0-9]|[^a-zA-Z0-9 ]/,GVz={"À":"A","Á":"A","Â":"A","Ã":"A","Ä":"A","Å":"A","à":"a","á":"a","â":"a","ã":"a","ä":"a","å":"a","Ç":"C","ç":"c","Ð":"D","ð":"d","È":"E","É":"E","Ê":"E","Ë":"E","è":"e","é":"e","ê":"e","ë":"e","Ì":"I","Í":"I","Î":"I","Ï":"I","ì":"i","í":"i","î":"i","ï":"i","Ñ":"N","ñ":"n","Ò":"O","Ó":"O","Ô":"O","Õ":"O","Ö":"O","Ø":"O","ò":"o","ó":"o","ô":"o","õ":"o","ö":"o","ø":"o","Ù":"U","Ú":"U","Û":"U","Ü":"U","ù":"u","ú":"u","û":"u","ü":"u","Ý":"Y","ý":"y","ÿ":"y","Æ":"Ae","æ":"ae","Þ":"Th","þ":"th","ß":"ss","Ā":"A","Ă":"A","Ą":"A","ā":"a","ă":"a","ą":"a","Ć":"C","Ĉ":"C","Ċ":"C","Č":"C","ć":"c","ĉ":"c","ċ":"c","č":"c","Ď":"D","Đ":"D","ď":"d","đ":"d","Ē":"E","Ĕ":"E","Ė":"E","Ę":"E","Ě":"E","ē":"e","ĕ":"e","ė":"e","ę":"e","ě":"e","Ĝ":"G","Ğ":"G","Ġ":"G","Ģ":"G","ĝ":"g","ğ":"g","ġ":"g","ģ":"g","Ĥ":"H","Ħ":"H","ĥ":"h","ħ":"h","Ĩ":"I","Ī":"I","Ĭ":"I","Į":"I","İ":"I","ĩ":"i","ī":"i","ĭ":"i","į":"i","ı":"i","Ĵ":"J","ĵ":"j","Ķ":"K","ķ":"k","ĸ":"k","Ĺ":"L","Ļ":"L","Ľ":"L","Ŀ":"L","Ł":"L","ĺ":"l","ļ":"l","ľ":"l","ŀ":"l","ł":"l","Ń":"N","Ņ":"N","Ň":"N","Ŋ":"N","ń":"n","ņ":"n","ň":"n","ŋ":"n","Ō":"O","Ŏ":"O","Ő":"O","ō":"o","ŏ":"o","ő":"o","Ŕ":"R","Ŗ":"R","Ř":"R","ŕ":"r","ŗ":"r","ř":"r","Ś":"S","Ŝ":"S","Ş":"S","Š":"S","ś":"s","ŝ":"s","ş":"s","š":"s","Ţ":"T","Ť":"T","Ŧ":"T","ţ":"t","ť":"t","ŧ":"t","Ũ":"U","Ū":"U","Ŭ":"U","Ů":"U","Ű":"U","Ų":"U","ũ":"u","ū":"u","ŭ":"u","ů":"u","ű":"u","ų":"u","Ŵ":"W","ŵ":"w","Ŷ":"Y","ŷ":"y","Ÿ":"Y","Ź":"Z","Ż":"Z","Ž":"Z","ź":"z","ż":"z","ž":"z","IJ":"IJ","ij":"ij","Œ":"Oe","œ":"oe","ʼn":"'n","ſ":"ss"},TVz=typeof global=="object"&&global&&global.Object===Object&&global,vVz=typeof self=="object"&&self&&self.Object===Object&&self,kVz=TVz||vVz||Function("return this")();function VVz(q,K,_,z){var Y=-1,$=q?q.length:0;if(z&&$)_=q[++Y];while(++Y<$)_=K(_,q[Y],Y,q);return _}function NVz(q){return q.split("")}function yVz(q){return q.match(qVz)||[]}function EVz(q){return function(K){return q==null?void 0:q[K]}}var LVz=EVz(GVz);function Il4(q){return fVz.test(q)}function RVz(q){return ZVz.test(q)}function hVz(q){return Il4(q)?SVz(q):NVz(q)}function SVz(q){return q.match(WVz)||[]}function CVz(q){return q.match(DVz)||[]}var bVz=Object.prototype,xVz=bVz.toString,Dl4=kVz.Symbol,fl4=Dl4?Dl4.prototype:void 0,Zl4=fl4?fl4.toString:void 0;function IVz(q,K,_){var z=-1,Y=q.length;if(K<0)K=-K>Y?0:Y+K;if(_=_>Y?Y:_,_<0)_+=Y;Y=K>_?0:_-K>>>0,K>>>=0;var $=Array(Y);while(++z<Y)$[z]=q[z+K];return $}function uVz(q){if(typeof q=="string")return q;if(FVz(q))return Zl4?Zl4.call(q):"";var K=q+"";return K=="0"&&1/q==-tkz?"-0":K}function mVz(q,K,_){var z=q.length;return _=_===void 0?z:_,!K&&_>=z?q:IVz(q,K,_)}function pVz(q){return function(K){K=Yh8(K);var _=Il4(K)?hVz(K):void 0,z=_?_[0]:K.charAt(0),Y=_?mVz(_,1).join(""):K.slice(1);return z[q]()+Y}}function BVz(q){return function(K){return VVz(lVz(dVz(K).replace(XVz,"")),q,"")}}function gVz(q){return!!q&&typeof q=="object"}function FVz(q){return typeof q=="symbol"||gVz(q)&&xVz.call(q)==ekz}function Yh8(q){return q==null?"":uVz(q)}var UVz=BVz(function(q,K,_){return K=K.toLowerCase(),q+(_?QVz(K):K)});function QVz(q){return cVz(Yh8(q).toLowerCase())}function dVz(q){return q=Yh8(q),q&&q.replace(KVz,LVz).replace(PVz,"")}var cVz=pVz("toUpperCase");function lVz(q,K,_){if(q=Yh8(q),K=_?void 0:K,K===void 0)return RVz(q)?CVz(q):yVz(q);return q.match(K)||[]}ul4.exports=UVz});var Bl4=m((zLO,pl4)=>{pl4.exports=jd1;function jd1(q,K){if(typeof q==="string")K=q,q=void 0;var _=[];function z($){if(typeof $!=="string"){var A=Y();if(jd1.verbose)console.log("codegen: "+A);if(A="return "+A,$){var O=Object.keys($),w=Array(O.length+1),j=Array(O.length),H=0;while(H<O.length)w[H]=O[H],j[H]=$[O[H++]];return w[H]=A,Function.apply(null,w).apply(null,j)}return Function(A)()}var J=Array(arguments.length-1),M=0;while(M<J.length)J[M]=arguments[++M];if(M=0,$=$.replace(/%([%dfijs])/g,function(P,W){var D=J[M++];switch(W){case"d":case"f":return String(Number(D));case"i":return String(Math.floor(D));case"j":return JSON.stringify(D);case"s":return String(D)}return"%"}),M!==J.length)throw Error("parameter count mismatch");return _.push($),z}function Y($){return"function "+($||K||"")+"("+(q&&q.join(",")||"")+`){
2078 `+_.join(`
2079 `)+`

Callers

nothing calls this directly

Calls 4

startMethod · 0.45
sendMessageMethod · 0.45
halfCloseMethod · 0.45

Tested by

no test coverage detected