One Hat Cyber Team

View File Name : 6377.45d36c143a694fc45bd3.js

"use strict";(self.webpackChunkgrafana=self.webpackChunkgrafana||[]).push([[6377],{48241:(S,p,i)=>{i.d(p,{iX:()=>e});var r=i(2543),t=i.n(r),n=i(47232),s=i(11261);const e=(h,f=!1)=>{const w=h.values;switch(h.type){case s.PU.number:return L(w,f);case s.PU.string:return R(w,f);case s.PU.boolean:return N(w,f);case s.PU.time:return typeof h.values[0]=="number"?b(w,f):P(w,f);default:return U(f)}},c=(h,f)=>{if(!h||!f)return v(h,f);if((0,r.isNumber)(h)&&(0,r.isNumber)(f))return l(h,f);if((0,n.u8)(h)&&(0,n.u8)(f)){if((0,n.KQ)(h).isBefore(f))return-1;if((0,n.KQ)(f).isBefore(h))return 1}return 0},l=(h,f)=>h-f,a=(h,f)=>!h||!f?v(h,f):h.localeCompare(f),g=(h,f)=>v(h,f),v=(h,f)=>!h&&f?1:h&&!f?-1:0,b=(h,f)=>{let w=f?-1:1;return(F,O)=>w*(h[F]-h[O])},P=(h,f)=>(w,F)=>{const O=h[w],M=h[F];return f?c(M,O):c(O,M)},N=(h,f)=>(w,F)=>{const O=h[w],M=h[F];return f?g(M,O):g(O,M)},L=(h,f)=>(w,F)=>{const O=h[w],M=h[F];return f?l(M,O):l(O,M)},R=(h,f)=>(w,F)=>{const O=h[w],M=h[F];return f?a(M,O):a(O,M)},U=h=>(f,w)=>h?l(w,f):l(f,w)},98358:(S,p,i)=>{i.d(p,{c:()=>t});var r=i(52622);function t(n,s,e){switch((n==null||e==null)&&(n==null&&(n="null"),e==null&&(e="null"),(s===r.zT.GTE||s===r.zT.LTE)&&(s=r.zT.EQ)),s){case r.zT.EQ:return`${n}`==`${e}`;case r.zT.NEQ:return`${n}`!=`${e}`;case r.zT.GT:return n>e;case r.zT.GTE:return n>=e;case r.zT.LT:return n<e;case r.zT.LTE:return n<=e;default:return!1}}},7029:(S,p,i)=>{i.d(p,{_:()=>l});var r=i(11261),t=i(1173);const n={id:t.Ct.byType,name:"Field Type",description:"match based on the field type",defaultOptions:r.PU.number,get:a=>(g,v,b)=>a===g.type,getOptionsDisplayText:a=>`Field type: ${a}`},s={id:t.Ct.byTypes,name:"Field Type",description:"match based on the field types",defaultOptions:new Set,get:a=>(g,v,b)=>a.has(g.type),getOptionsDisplayText:a=>`Field types: ${[...a].join(" | ")}`},e={id:t.Ct.numeric,name:"Numeric Fields",description:"Fields with type number",get:()=>n.get(r.PU.number),getOptionsDisplayText:()=>"Numeric Fields"},c={id:t.Ct.time,name:"Time Fields",description:"Fields with type time",get:()=>n.get(r.PU.time),getOptionsDisplayText:()=>"Time Fields"};function l(){return[n,s,e,c]}},24814:(S,p,i)=>{i.d(p,{u:()=>c});var r=i(52622),t=i(75059),n=i(98358),s=i(1173);function e(l){return l===t.gy.allIsNull||l===t.gy.allIsZero}const c={id:s.Ct.byValue,name:"By value (reducer)",description:"Reduce a field to a single value and test for inclusion",defaultOptions:{reducer:t.gy.allIsZero,op:r.zT.GTE,value:0},get:l=>{if(!l||!l.reducer)return()=>!1;let{reducer:a,op:g,value:v}=l;const b=e(a);return g||(g=r.zT.EQ),(P,N,L)=>{const R=(0,t.Nw)({field:P,reducers:[a]})[a];return b?!!R:(0,n.c)(R,g,v)}},getOptionsDisplayText:l=>`By value (${l.reducer})`}},1173:(S,p,i)=>{i.d(p,{Ct:()=>t,Js:()=>s,cV:()=>r,jR:()=>n});var r=(e=>(e.anyMatch="anyMatch",e.allMatch="allMatch",e.invertMatch="invertMatch",e.alwaysMatch="alwaysMatch",e.neverMatch="neverMatch",e))(r||{}),t=(e=>(e.numeric="numeric",e.time="time",e.first="first",e.firstTimeField="firstTimeField",e.byType="byType",e.byTypes="byTypes",e.byName="byName",e.byNames="byNames",e.byRegexp="byRegexp",e.byRegexpOrNames="byRegexpOrNames",e.byFrameRefID="byFrameRefID",e.byValue="byValue",e))(t||{}),n=(e=>(e.byName="byName",e.byRefId="byRefId",e.byIndex="byIndex",e))(n||{}),s=(e=>(e.regex="regex",e.isNull="isNull",e.isNotNull="isNotNull",e.greater="greater",e.greaterOrEqual="greaterOrEqual",e.lower="lower",e.lowerOrEqual="lowerOrEqual",e.equal="equal",e.notEqual="notEqual",e.between="between",e))(s||{})},8549:(S,p,i)=>{i.d(p,{i:()=>s});var r=i(54479),t=i(1173);const n={id:t.jR.byRefId,name:"Query refId",description:"match the refId",defaultOptions:"A",get:e=>{const c=(0,r.dO)(e);return l=>c.test(l.refId||"")},getOptionsDisplayText:e=>`RefID: ${e}`};function s(){return[n]}},83855:(S,p,i)=>{i.d(p,{W:()=>e});var r=i(11261),t=i(1173);const n={id:t.Ct.first,name:"First Field",description:"The first field in the frame",get:c=>(l,a,g)=>l===a.fields[0],getOptionsDisplayText:()=>"First field"},s={id:t.Ct.firstTimeField,name:"First time field",description:"The first field of type time in a frame",get:c=>(l,a,g)=>l.type===r.PU.time&&l===a.fields.find(v=>v.type===r.PU.time),getOptionsDisplayText:()=>"First time field"};function e(){return[n,s]}},60005:(S,p,i)=>{i.d(p,{d:()=>s});var r=i(1173);const t={id:r.Js.equal,name:"Is equal",description:"Match where value for given field is equal to options value.",get:e=>(c,l)=>l.values[c]==e.value,getOptionsDisplayText:()=>"Matches all rows where field is null.",isApplicable:()=>!0,getDefaultOptions:()=>({value:""})},n={id:r.Js.notEqual,name:"Is not equal",description:"Match where value for given field is not equal to options value.",get:e=>(c,l)=>l.values[c]!=e.value,getOptionsDisplayText:()=>"Matches all rows where field is not null.",isApplicable:()=>!0,getDefaultOptions:()=>({value:""})},s=()=>[t,n]},21262:(S,p,i)=>{i.d(p,{_:()=>s});var r=i(1173);const t={id:r.Js.isNull,name:"Is null",description:"Match where value for given field is null.",get:()=>(e,c)=>c.values[e]==null,getOptionsDisplayText:()=>"Matches all rows where field is null.",isApplicable:()=>!0,getDefaultOptions:()=>({})},n={id:r.Js.isNotNull,name:"Is not null",description:"Match where value for given field is not null.",get:()=>(e,c)=>c.values[e]!=null,getOptionsDisplayText:()=>"Matches all rows where field is not null.",isApplicable:()=>!0,getDefaultOptions:()=>({})},s=()=>[t,n]},70218:(S,p,i)=>{i.d(p,{E:()=>l});var r=i(11261),t=i(1173);const n={id:t.Js.greater,name:"Is greater",description:"Match when field value is greater than option.",get:a=>(g,v)=>{const b=v.values[g];return isNaN(b)?!1:b>a.value},getOptionsDisplayText:a=>`Matches all rows where field value is greater than: ${a.value}.`,isApplicable:a=>a.type===r.PU.number,getDefaultOptions:()=>({value:0})},s={id:t.Js.greaterOrEqual,name:"Is greater or equal",description:"Match when field value is greater than or equal to option.",get:a=>(g,v)=>{const b=v.values[g];return isNaN(b)?!1:b>=a.value},getOptionsDisplayText:a=>`Matches all rows where field value is greater than or equal to: ${a.value}.`,isApplicable:a=>a.type===r.PU.number,getDefaultOptions:()=>({value:0})},e={id:t.Js.lower,name:"Is lower",description:"Match when field value is lower than option.",get:a=>(g,v)=>{const b=v.values[g];return isNaN(b)?!1:b<a.value},getOptionsDisplayText:a=>`Matches all rows where field value is lower than: ${a.value}.`,isApplicable:a=>a.type===r.PU.number,getDefaultOptions:()=>({value:0})},c={id:t.Js.lowerOrEqual,name:"Is lower or equal",description:"Match when field value is lower or equal than option.",get:a=>(g,v)=>{const b=v.values[g];return isNaN(b)?!1:b<=a.value},getOptionsDisplayText:a=>`Matches all rows where field value is lower or equal than: ${a.value}.`,isApplicable:a=>a.type===r.PU.number,getDefaultOptions:()=>({value:0})},l=()=>[n,s,e,c]},55008:(S,p,i)=>{i.d(p,{G:()=>s});var r=i(11261),t=i(1173);const n={id:t.Js.between,name:"Is between",description:"Match when field value is between given option values.",get:e=>(c,l)=>{const a=l.values[c];return isNaN(a)?!1:a>e.from&&a<e.to},getOptionsDisplayText:e=>`Matches all rows where field value is between ${e.from} and ${e.to}.`,isApplicable:e=>e.type===r.PU.number,getDefaultOptions:()=>({from:0,to:100})},s=()=>[n]},16378:(S,p,i)=>{i.d(p,{z:()=>n});var r=i(1173);const t={id:r.Js.regex,name:"Regex",description:"Match when field value is matching regex.",get:s=>{const e=new RegExp(s.value);return(c,l)=>{const a=l.values[c];return e.test(a)}},getOptionsDisplayText:s=>`Matches all rows where field value is matching regex: ${s.value}`,isApplicable:()=>!0,getDefaultOptions:()=>({value:".*"})},n=()=>[t]},18282:(S,p,i)=>{i.d(p,{F:()=>r});var r=(t=>(t.append="append",t.reduce="reduce",t.order="order",t.organize="organize",t.rename="rename",t.calculateField="calculateField",t.seriesToColumns="seriesToColumns",t.seriesToRows="seriesToRows",t.merge="merge",t.concatenate="concatenate",t.labelsToFields="labelsToFields",t.filterFields="filterFields",t.filterFieldsByName="filterFieldsByName",t.filterFrames="filterFrames",t.filterByRefId="filterByRefId",t.renameByRegex="renameByRegex",t.filterByValue="filterByValue",t.noop="noop",t.ensureColumns="ensureColumns",t.groupBy="groupBy",t.sortBy="sortBy",t.histogram="histogram",t.configFromData="configFromData",t.rowsToFields="rowsToFields",t.prepareTimeSeries="prepareTimeSeries",t.convertFieldType="convertFieldType",t.fieldLookup="fieldLookup",t.heatmap="heatmap",t.spatial="spatial",t.joinByField="joinByField",t.joinByLabels="joinByLabels",t.extractFields="extractFields",t.groupingToMatrix="groupingToMatrix",t.limit="limit",t.partitionByValues="partitionByValues",t.timeSeriesTable="timeSeriesTable",t.formatTime="formatTime",t.formatString="formatString",t.regression="regression",t.groupToNestedTable="groupToNestedTable",t))(r||{})},83077:(S,p,i)=>{i.d(p,{O:()=>t});var r=i(43429);class t{constructor(s){this.init=s,this.ordered=[],this.byId=new Map,this.initialized=!1,this.setInit=e=>{if(this.initialized)throw new Error("Registry already initialized");this.init=e},this.init=s}getIfExists(s){if(this.initialized||this.initialize(),s)return this.byId.get(s)}initialize(){if(this.init)for(const s of this.init())this.register(s);this.sort(),this.initialized=!0}get(s){const e=this.getIfExists(s);if(!e)throw new Error(`"${s}" not found in: ${this.list().map(c=>c.id)}`);return e}selectOptions(s,e){this.initialized||this.initialize();const c={options:[],current:[]},l={};if(s)for(const a of s)l[a]={};for(const a of this.ordered){if(a.excludeFromPicker||e&&!e(a))continue;const g={value:a.id,label:a.name,description:a.description};a.state===r.pn.alpha&&(g.label+=" (alpha)"),c.options.push(g),l[a.id]&&(l[a.id]=g)}return s&&(c.current=Object.values(l)),c}list(s){if(this.initialized||this.initialize(),s){const e=[];for(const c of s){const l=this.getIfExists(c);l&&e.push(l)}return e}return this.ordered}isEmpty(){return this.initialized||this.initialize(),this.ordered.length===0}register(s){if(this.byId.has(s.id))throw new Error("Duplicate Key:"+s.id);if(this.byId.set(s.id,s),this.ordered.push(s),s.aliasIds)for(const e of s.aliasIds)this.byId.has(e)||this.byId.set(e,s);this.initialized&&this.sort()}sort(){}}},43659:(S,p,i)=>{i.d(p,{j:()=>r});function r(t,n){const s=/\{\{\s*(.+?)\s*\}\}/g;return t.replace(s,(e,c)=>n[c]?n[c]:c)}},12091:(S,p,i)=>{i.d(p,{u:()=>r});function r(t){const n=t||{};if(!n.message){if(typeof t=="string")return{message:t};let s="Query error";n.message?s=n.message:n.data&&n.data.message&&n.data?.message!=="Query data error"?s=n.data.message:n?.data?.message==="Query data error"&&n?.data?.error||n.data&&n.data.error?s=n.data.error:n.status&&(s=`Query error: ${n.status} ${n.statusText}`),n.message=s}return n}},97527:(S,p,i)=>{i.d(p,{w:()=>j});var r=i(35392),t=i(1005),n=i(96222),s=i(49426),e=i(55004),c=i(9631),l=i(88483),a=i(39741),g=i(81160),v=i(39070),b=i(12091),P=i(47118);const N=E=>o=>new l.c(u=>{let d=[],m=!0;const _=()=>{u.next(d),d=[]},T=E.subscribe({next:C=>{m=C,m&&d.length&&_()}}),A=o.subscribe({next(C){m?d.length?_():u.next([C]):d.push(C)},error(C){u.error(C)},complete(){u.complete()}});return()=>{A.unsubscribe(),T.unsubscribe()}});var L=(E=>(E[E.Error=0]="Error",E[E.NewValuesSameSchema=1]="NewValuesSameSchema",E[E.ChangedSchema=2]="ChangedSchema",E))(L||{});const R=E=>({values:E.reduce((o,{values:u})=>{for(let d=0;d<u.length;d++){o[d]||(o[d]=[]);for(let m=0;m<u[d].length;m++)o[d].push(u[d][m])}return o},[]),type:1}),U=(E,o)=>E.filter(u=>u.type===o);class h{constructor(o){this.deps=o,this.stream=new a.m(1),this.shutdown=()=>{this.stream.complete(),this.liveEventsSubscription.unsubscribe(),this.deps.onShutdown()},this.shutdownIfNoSubscribers=()=>{this.stream.observed||this.shutdown()},this.onError=u=>{console.log("LiveQuery [error]",{err:u},this.deps.channelId),this.stream.next({type:0,error:(0,b.u)(u)}),this.shutdown()},this.onComplete=()=>{console.log("LiveQuery [complete]",this.deps.channelId),this.shutdown()},this.onNext=u=>{if((0,e.Z7)(u)){this.process(u.message);return}const d=(0,e.ew)(u);if(d&&u.error){const m=(0,b.u)(u.error);this.stream.next({type:0,error:{...m,message:`Streaming channel error: ${m.message}`}})}d&&(u.state===e.ZF.Connected||u.state===e.ZF.Pending)&&u.message&&this.process(u.message)},this.process=u=>{this.frameBuffer.push(u).schemaChanged?this.stream.next({type:2}):this.stream.next({type:1,values:this.frameBuffer.getValuesFromLastPacket()})},this.resizeBuffer=u=>{u&&this.frameBuffer.needsResizing(u)&&this.frameBuffer.resize(u)},this.prepareInternalStreamForNewSubscription=u=>{!this.frameBuffer.hasAtLeastOnePacket()&&u.frame&&this.process(u.frame)},this.clearShutdownTimeout=()=>{this.shutdownTimeoutId&&(clearTimeout(this.shutdownTimeoutId),this.shutdownTimeoutId=void 0)},this.get=(u,d)=>{this.clearShutdownTimeout();const m=(0,c.m8)(u.buffer);this.resizeBuffer(m),this.prepareInternalStreamForNewSubscription(u);const _=u?.buffer?.action===c.Kh.Replace,T=u.filter?.fields,C=T?.length?({name:y})=>T.includes(y):void 0;let W;const K=(y,x)=>(W=C?this.frameBuffer.getMatchingFieldIndexes(C):void 0,_?x?{key:d,state:v.Gu.Error,data:[{type:P._w.FullFrame,frame:this.frameBuffer.serialize(C,m,{maxLength:0})}],error:x}:y.length?{key:d,state:v.Gu.Streaming,data:[{type:P._w.FullFrame,frame:this.frameBuffer.serialize(C,m,{maxLength:this.frameBuffer.packetInfo.length})}],error:x}:(console.warn(`expected to find at least one non error message ${y.map(({type:B})=>B)}`),{key:d,state:v.Gu.Streaming,data:[{type:P._w.FullFrame,frame:this.frameBuffer.serialize(C,m,{maxLength:0})}],error:x}):{key:d,state:x?v.Gu.Error:v.Gu.Streaming,data:[{type:P._w.FullFrame,frame:this.frameBuffer.serialize(C,m)}],error:x}),k=y=>{const x=y.length?y[y.length-1]:void 0,B=_&&x?x.values:R(y).values,z=W?B.filter((G,I)=>W?.includes(I)):B;return{key:d,state:v.Gu.Streaming,data:[{type:P._w.NewValuesSameSchema,values:z}]}};let V=!0;const Z=this.stream.pipe(N(this.deps.subscriberReadiness),(0,g.T)((y,x)=>{const B=U(y,0),z=B.length?B[B.length-1].error:void 0;if(V)return V=!1,K(y,z);if(B.length)return K(y,z);if(y.some($=>$.type===2))return K(y,void 0);const I=U(y,1);return I.length!==y.length&&console.warn(`unsupported message type ${y.map(({type:$})=>$)}`),k(I)}));return new l.c(y=>{const x=Z.subscribe({next:B=>{y.next(B)},error:B=>{y.error(B)},complete:()=>{y.complete()}});return()=>{x.unsubscribe(),this.stream.observed||(this.clearShutdownTimeout(),this.shutdownTimeoutId=setTimeout(this.shutdownIfNoSubscribers,this.deps.shutdownDelayInMs))}})},this.frameBuffer=c.k9.empty(o.defaultStreamingFrameOptions),this.liveEventsSubscription=o.liveEventsObservable.subscribe({error:this.onError,complete:this.onComplete,next:this.onNext})}}var f=i(13752);class w{constructor(o,u){this.opened=Date.now(),this.stream=new f.B,this.disconnectIfNoListeners=()=>{this.stream.observers.length===0&&this.disconnect()},this.id=o,this.addr=u,this.currentStatus={type:e.o4.Status,id:o,timestamp:this.opened,state:e.ZF.Pending},(0,e.aj)(u)||(this.currentStatus.state=e.ZF.Invalid,this.currentStatus.error="invalid channel address")}initalize(){if(this.initalized)throw new Error("Channel already initalized: "+this.id);this.initalized=!0,this.subscription.on("publication",o=>{try{o.data&&(o.data.schema&&(this.lastMessageWithSchema=o.data),this.stream.next({type:e.o4.Message,message:o.data})),this.currentStatus.error&&(this.currentStatus.timestamp=Date.now(),delete this.currentStatus.error,this.sendStatus())}catch(u){console.log("publish error",this.addr,u),this.currentStatus.error=u,this.currentStatus.timestamp=Date.now(),this.sendStatus()}}).on("error",o=>{this.currentStatus.timestamp=Date.now(),this.currentStatus.error=o.error.message,this.sendStatus()}).on("subscribed",o=>{this.currentStatus.timestamp=Date.now(),this.currentStatus.state=e.ZF.Connected,delete this.currentStatus.error,o.data?.schema&&(this.lastMessageWithSchema=o.data),this.sendStatus(o.data)}).on("unsubscribed",()=>{this.currentStatus.timestamp=Date.now(),this.currentStatus.state=e.ZF.Disconnected,this.sendStatus()}).on("subscribing",()=>{this.currentStatus.timestamp=Date.now(),this.currentStatus.state=e.ZF.Connecting,this.sendStatus()}).on("join",o=>{this.stream.next({type:e.o4.Join,user:o.info.user})}).on("leave",o=>{this.stream.next({type:e.o4.Leave,user:o.info.user})})}sendStatus(o){const u={...this.currentStatus};o&&(u.message=o),this.stream.next(u)}getStream(){return new l.c(o=>{const u={...this.currentStatus};this.lastMessageWithSchema?.schema&&(u.message={schema:this.lastMessageWithSchema?.schema}),o.next({...this.currentStatus,message:this.lastMessageWithSchema});const d=this.stream.subscribe(o);return()=>{d.unsubscribe(),this.stream.observers.length===0&&setTimeout(this.disconnectIfNoListeners,250)}})}async getPresence(){return this.subscription?this.subscription.presence().then(o=>({users:Object.keys(o.clients)})):Promise.reject("not subscribed")}disconnect(){this.currentStatus.state=e.ZF.Shutdown,this.currentStatus.timestamp=Date.now(),this.subscription&&(this.subscription.unsubscribe(),this.subscription.removeAllListeners(),this.subscription=void 0),this.stream.complete(),this.stream.next({...this.currentStatus}),this.stream.complete(),this.shutdownCallback&&this.shutdownCallback()}shutdownWithError(o){this.currentStatus.error=o,this.sendStatus(),this.disconnect()}}function F(E,o,u){return{id:o,opened:Date.now(),addr:u,getStream:()=>of({type:LiveChannelEventType.Status,id:o,timestamp:Date.now(),state:LiveChannelConnectionState.Invalid,error:E}),disconnect:()=>{}}}const O={maxLength:100,maxDelta:1/0,action:c.Kh.Append},M=5e3;class j{constructor(o){this.deps=o,this.open=new Map,this.liveDataStreamByChannelId={},this.onConnect=m=>{this.connectionState.next(!0)},this.onDisconnect=m=>{this.connectionState.next(!1)},this.onServerSideMessage=m=>{console.log("Publication from server-side channel",m)},this.getConnectionState=()=>this.connectionState.asObservable(),this.getStream=m=>this.getChannel(m).getStream(),this.createSubscriptionKey=m=>m.key??`xstr/${Q++}`,this.getLiveDataStream=m=>{const _=(0,e.Qp)(m.addr),T=this.liveDataStreamByChannelId[_];if(T)return T;const A=this.getChannel(m.addr);return this.liveDataStreamByChannelId[_]=new h({channelId:_,onShutdown:()=>{delete this.liveDataStreamByChannelId[_]},liveEventsObservable:A.getStream(),subscriberReadiness:this.dataStreamSubscriberReadiness,defaultStreamingFrameOptions:O,shutdownDelayInMs:M}),this.liveDataStreamByChannelId[_]},this.getDataStream=m=>{const _=this.createSubscriptionKey(m);return this.getLiveDataStream(m).get(m,_)},this.getQueryData=async m=>(this.centrifuge.state!==r.Uw.Connected&&await this.connectionBlocker,this.centrifuge.rpc("grafana.query",m.body)),this.getPresence=m=>this.getChannel(m).getPresence(),this.dataStreamSubscriberReadiness=o.dataStreamSubscriberReadiness.pipe((0,t.u)(),(0,n.Z)(!0));let u=`${o.appUrl.replace(/^http/,"ws")}/api/live/ws`;const d=o.grafanaAuthToken;d!==null&&d!==""&&(u+="?auth_token="+d),this.centrifuge=new r.Ft(u,{timeout:3e4}),o.liveEnabled&&o.orgRole!==""&&this.centrifuge.connect(),this.connectionState=new s.t(this.centrifuge.state===r.Uw.Connected),this.connectionBlocker=new Promise(m=>{if(this.centrifuge.state===r.Uw.Connected)return m();const _=()=>{m(),this.centrifuge.removeListener("connected",_)};this.centrifuge.addListener("connected",_)}),this.centrifuge.on("connected",this.onConnect),this.centrifuge.on("connecting",this.onDisconnect),this.centrifuge.on("disconnected",this.onDisconnect),this.centrifuge.on("publication",this.onServerSideMessage)}getChannel(o){const u=`${this.deps.orgId}/${o.scope}/${o.namespace}/${o.path}`;let d=this.open.get(u);return d!=null||(d=new w(u,o),d.currentStatus.state===e.ZF.Invalid)||(d.shutdownCallback=()=>{this.open.delete(u),this.centrifuge.removeSubscription(this.centrifuge.getSubscription(u))},this.open.set(u,d),this.initChannel(d).catch(m=>{d&&(d.currentStatus.state=e.ZF.Invalid,d.shutdownWithError(m)),this.open.delete(u)})),d}async initChannel(o){this.centrifuge.state!==r.Uw.Connected&&await this.connectionBlocker;const u=this.centrifuge.newSubscription(o.id,{data:o.addr.data});o.subscription=u,o.initalize(),u.subscribe()}}let Q=0},99355:(S,p,i)=>{var r=i(14590),t=i(75508);const n={canHandle(s){return!!(s&&s instanceof t.vU)},serialize(s){const e=r.BX(s),{port1:c,port2:l}=new MessageChannel;return r.p(e,c),[l,[l]]},deserialize(s){return s.start(),r.LV(s)}};r.J3.set("SubscriberHandler",n)}}]);

//# sourceMappingURL=6377.45d36c143a694fc45bd3.js.map