}
_handleDisconnect(e) {
const t = e.code;
let n = !0;
(t >= 3500 && t < 4e3 || t >= 4500 && t < 5e3) && (n = !1),
this._disconnect(t, e.reason, n)
}
_getPublicationContext(e, t) {
const n = {
channel: e,
data: t.data
};
return t.offset && (n.offset = t.offset),
t.info && (n.info = this._getJoinLeaveContext(t.info)),
t.tags && (n.tags = t.tags),
n
}
_getJoinLeaveContext(e) {
const t = {
client: e.client,
user: e.user
}
, n = e.conn_info;
n && (t.connInfo = n);
const i = e.chan_info;
return i && (t.chanInfo = i),
t
}
_handlePublication(e, t, n) {
const i = this._getSub(e, n);
if (i || !e)
i._handlePublication(t);
else if (this._isServerSub(e)) {
const n = this._getPublicationContext(e, t);
this.emit("publication", n),
void 0 !== t.offset && (this._serverSubs[e].offset = t.offset)
}
}
_handleMessage(e) {
this.emit("message", {
data: e.data
})
}
_handleServerPing(e) {
if (this._sendPong) {
const e = {};
this._transportSendCommands([e])
}
e()
}
_handlePush(e, t) {
const n = e.channel
, i = e.id;
e.pub ? this._handlePublication(n, e.pub, i) : e.message ? this._handleMessage(e.message) : e.join ? this._handleJoin(n, e.join, i) : e.leave ? this._handleLeave(n, e.leave, i) : e.unsubscribe ? this._handleUnsubscribe(n, e.unsubscribe) : e.subscribe ? this._handleSubscribe(n, e.subscribe) : e.disconnect && this._handleDisconnect(e.disconnect),
t()
}
_flush() {
const e = this._commands.slice(0);
this._commands = [],
this._transportSendCommands(e)
}
_createErrorObject(e, t, n) {
const i = {
code: e,
message: t
};
return n && (i.temporary = !0),
i
}
_registerCall(e, t, n) {
this._callbacks[e] = {
callback: t,
errback: n,
timeout: null
},
this._callbacks[e].timeout = setTimeout(( () => {
delete this._callbacks[e],
isFunction(n) && n({
error: this._createErrorObject(errorCodes.timeout, "timeout")
})
}
), this._config.timeout)
}
_addCommand(e) {
this._batching ? this._commands.push(e) : this._transportSendCommands([e])
}
_nextPromiseId() {
return ++this._promiseId
}
_nextTransportId() {
return ++this._transportId
}
_resolvePromises() {
for (const e in this._promises)
this._promises.hasOwnProperty(e) && (this._promises[e].timeout && clearTimeout(this._promises[e].timeout),
this._promises[e].resolve(),
delete this._promises[e])
}
_rejectPromises(e) {
for (const t in this._promises)
this._promises.hasOwnProperty(t) && (this._promises[t].timeout && clearTimeout(this._promises[t].timeout),
this._promises[t].reject(e),
delete this._promises[t])
}
}
Centrifuge.SubscriptionState = SubscriptionState,
Centrifuge.State = State$1,
Centrifuge.UnauthorizedError = UnauthorizedError;
var indexMinimal = {}, minimal$1 = {}, aspromise, hasRequiredAspromise;
function requireAspromise() {
return hasRequiredAspromise ? aspromise : (hasRequiredAspromise = 1,
aspromise = function(e, t) {
for (var n = new Array(arguments.length - 1), i = 0, r = 2, s = !0; r < arguments.length; )
n[i++] = arguments[r++];
return new Promise((function(r, o) {
n[i] = function(e) {
if (s)
if (s = !1,
e)
o(e);
else {
for (var t = new Array(arguments.length - 1), n = 0; n < t.length; )
t[n++] = arguments[n];
r.apply(null, t)
}
}
;
try {
e.apply(t || null, n)
} catch (e) {
s && (s = !1,
o(e))
}
}
))
}
)
}
var base64$1 = {}, hasRequiredBase64, eventemitter, hasRequiredEventemitter, float, hasRequiredFloat, inquire_1, hasRequiredInquire;
function requireBase64() {
return hasRequiredBase64 || (hasRequiredBase64 = 1,
function(e) {
var t = e;
t.length = function(e) {
var t = e.length;
if (!t)
return 0;
for (var n = 0; --t % 4 > 1 && "=" === e.charAt(t); )
++n;
return Math.ceil(3 * e.length) / 4 - n
}
;
for (var n |
