Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- this.org = this.org || {};
- org.cometd = {};
- org.cometd.JSON = {};
- org.cometd.JSON.toJSON = org.cometd.JSON.fromJSON = function (e) {
- throw "Abstract"
- };
- org.cometd.Utils = {};
- org.cometd.Utils.isString = function (e) {
- if (e === undefined || e === null) {
- return false
- }
- return typeof e === "string" || e instanceof String
- };
- org.cometd.Utils.isArray = function (e) {
- if (e === undefined || e === null) {
- return false
- }
- return e instanceof Array
- };
- org.cometd.Utils.inArray = function (e, t) {
- for (var n = 0; n < t.length; ++n) {
- if (e === t[n]) {
- return n
- }
- }
- return -1
- };
- org.cometd.Utils.setTimeout = function (e, t, n) {
- return window.setTimeout(function () {
- try {
- t()
- } catch (n) {
- e._debug("Exception invoking timed function", t, n)
- }
- }, n)
- };
- org.cometd.Utils.clearTimeout = function (e) {
- window.clearTimeout(e)
- };
- org.cometd.TransportRegistry = function () {
- var e = [];
- var t = {};
- this.getTransportTypes = function () {
- return e.slice(0)
- };
- this.findTransportTypes = function (n, r, i) {
- var s = [];
- for (var o = 0; o < e.length; ++o) {
- var u = e[o];
- if (t[u].accept(n, r, i) === true) {
- s.push(u)
- }
- }
- return s
- };
- this.negotiateTransport = function (n, r, i, s) {
- for (var o = 0; o < e.length; ++o) {
- var u = e[o];
- for (var a = 0; a < n.length; ++a) {
- if (u === n[a]) {
- var f = t[u];
- if (f.accept(r, i, s) === true) {
- return f
- }
- }
- }
- }
- return null
- };
- this.add = function (n, r, i) {
- var s = false;
- for (var o = 0; o < e.length; ++o) {
- if (e[o] === n) {
- s = true;
- break
- }
- }
- if (!s) {
- if (typeof i !== "number") {
- e.push(n)
- } else {
- e.splice(i, 0, n)
- }
- t[n] = r
- }
- return !s
- };
- this.find = function (n) {
- for (var r = 0; r < e.length; ++r) {
- if (e[r] === n) {
- return t[n]
- }
- }
- return null
- };
- this.remove = function (n) {
- for (var r = 0; r < e.length; ++r) {
- if (e[r] === n) {
- e.splice(r, 1);
- var i = t[n];
- delete t[n];
- return i
- }
- }
- return null
- };
- this.clear = function () {
- e = [];
- t = {}
- };
- this.reset = function () {
- for (var n = 0; n < e.length; ++n) {
- t[e[n]].reset()
- }
- }
- };
- org.cometd.Transport = function () {
- var e;
- var t;
- this.registered = function (n, r) {
- e = n;
- t = r
- };
- this.unregistered = function () {
- e = null;
- t = null
- };
- this._debug = function () {
- t._debug.apply(t, arguments)
- };
- this._mixin = function () {
- return t._mixin.apply(t, arguments)
- };
- this.getConfiguration = function () {
- return t.getConfiguration()
- };
- this.getAdvice = function () {
- return t.getAdvice()
- };
- this.setTimeout = function (e, n) {
- return org.cometd.Utils.setTimeout(t, e, n)
- };
- this.clearTimeout = function (e) {
- org.cometd.Utils.clearTimeout(e)
- };
- this.convertToMessages = function (e) {
- if (org.cometd.Utils.isString(e)) {
- try {
- return org.cometd.JSON.fromJSON(e)
- } catch (t) {
- this._debug("Could not convert to JSON the following string", '"' + e + '"');
- throw t
- }
- }
- if (org.cometd.Utils.isArray(e)) {
- return e
- }
- if (e === undefined || e === null) {
- return []
- }
- if (e instanceof Object) {
- return [e]
- }
- throw "Conversion Error " + e + ", typeof " + typeof e
- };
- this.accept = function (e, t, n) {
- throw "Abstract"
- };
- this.getType = function () {
- return e
- };
- this.send = function (e, t) {
- throw "Abstract"
- };
- this.reset = function () {
- this._debug("Transport", e, "reset")
- };
- this.abort = function () {
- this._debug("Transport", e, "aborted")
- };
- this.toString = function () {
- return this.getType()
- }
- };
- org.cometd.Transport.derive = function (e) {
- function t() {}
- t.prototype = e;
- return new t
- };
- org.cometd.RequestTransport = function () {
- function o(e) {
- while (s.length > 0) {
- var t = s[0];
- var n = t[0];
- var r = t[1];
- if (n.url === e.url && n.sync === e.sync) {
- s.shift();
- e.messages = e.messages.concat(n.messages);
- this._debug("Coalesced", n.messages.length, "messages from request", r.id);
- continue
- }
- break
- }
- }
- function u(e, t) {
- this.transportSend(e, t);
- t.expired = false;
- if (!e.sync) {
- var n = this.getConfiguration().maxNetworkDelay;
- var r = n;
- if (t.metaConnect === true) {
- r += this.getAdvice().timeout
- }
- this._debug("Transport", this.getType(), "waiting at most", r, "ms for the response, maxNetworkDelay", n);
- var i = this;
- t.timeout = this.setTimeout(function () {
- t.expired = true;
- var n = "Request " + t.id + " of transport " + i.getType() + " exceeded " + r + " ms max network delay";
- var s = {
- reason: n
- };
- var o = t.xhr;
- s.httpCode = i.xhrStatus(o);
- i.abortXHR(o);
- i._debug(n);
- i.complete(t, false, t.metaConnect);
- e.onFailure(o, e.messages, s)
- }, r)
- }
- }
- function a(e) {
- var t = ++n;
- var r = {
- id: t,
- metaConnect: false
- };
- if (i.length < this.getConfiguration().maxConnections - 1) {
- i.push(r);
- u.call(this, e, r)
- } else {
- this._debug("Transport", this.getType(), "queueing request", t, "envelope", e);
- s.push([e, r])
- }
- }
- function f(e) {
- var t = e.id;
- this._debug("Transport", this.getType(), "metaConnect complete, request", t);
- if (r !== null && r.id !== t) {
- throw "Longpoll request mismatch, completing request " + t
- }
- r = null
- }
- function l(e, t) {
- var n = org.cometd.Utils.inArray(e, i);
- if (n >= 0) {
- i.splice(n, 1)
- }
- if (s.length > 0) {
- var r = s.shift();
- var u = r[0];
- var f = r[1];
- this._debug("Transport dequeued request", f.id);
- if (t) {
- if (this.getConfiguration().autoBatch) {
- o.call(this, u)
- }
- a.call(this, u);
- this._debug("Transport completed request", e.id, u)
- } else {
- var l = this;
- this.setTimeout(function () {
- l.complete(f, false, f.metaConnect);
- var e = {
- reason: "Previous request failed"
- };
- var t = f.xhr;
- e.httpCode = l.xhrStatus(t);
- u.onFailure(t, u.messages, e)
- }, 0)
- }
- }
- }
- function c(e) {
- if (r !== null) {
- throw "Concurrent metaConnect requests not allowed, request id=" + r.id + " not yet completed"
- }
- var t = ++n;
- this._debug("Transport", this.getType(), "metaConnect send, request", t, "envelope", e);
- var i = {
- id: t,
- metaConnect: true
- };
- u.call(this, e, i);
- r = i
- }
- var e = new org.cometd.Transport;
- var t = org.cometd.Transport.derive(e);
- var n = 0;
- var r = null;
- var i = [];
- var s = [];
- t.complete = function (e, t, n) {
- if (n) {
- f.call(this, e)
- } else {
- l.call(this, e, t)
- }
- };
- t.transportSend = function (e, t) {
- throw "Abstract"
- };
- t.transportSuccess = function (e, t, n) {
- if (!t.expired) {
- this.clearTimeout(t.timeout);
- this.complete(t, true, t.metaConnect);
- if (n && n.length > 0) {
- e.onSuccess(n)
- } else {
- e.onFailure(t.xhr, e.messages, {
- httpCode: 204
- })
- }
- }
- };
- t.transportFailure = function (e, t, n) {
- if (!t.expired) {
- this.clearTimeout(t.timeout);
- this.complete(t, false, t.metaConnect);
- e.onFailure(t.xhr, e.messages, n)
- }
- };
- t.send = function (e, t) {
- if (t) {
- c.call(this, e)
- } else {
- a.call(this, e)
- }
- };
- t.abort = function () {
- e.abort();
- for (var t = 0; t < i.length; ++t) {
- var n = i[t];
- this._debug("Aborting request", n);
- this.abortXHR(n.xhr)
- }
- if (r) {
- this._debug("Aborting metaConnect request", r);
- this.abortXHR(r.xhr)
- }
- this.reset()
- };
- t.reset = function () {
- e.reset();
- r = null;
- i = [];
- s = []
- };
- t.abortXHR = function (e) {
- if (e) {
- try {
- e.abort()
- } catch (t) {
- this._debug(t)
- }
- }
- };
- t.xhrStatus = function (e) {
- if (e) {
- try {
- return e.status
- } catch (t) {
- this._debug(t)
- }
- }
- return -1
- };
- return t
- };
- org.cometd.LongPollingTransport = function () {
- var e = new org.cometd.RequestTransport;
- var t = org.cometd.Transport.derive(e);
- var n = true;
- t.accept = function (e, t, r) {
- return n || !t
- };
- t.xhrSend = function (e) {
- throw "Abstract"
- };
- t.transportSend = function (e, t) {
- this._debug("Transport", this.getType(), "sending request", t.id, "envelope", e);
- var r = this;
- try {
- var i = true;
- t.xhr = this.xhrSend({
- transport: this,
- url: e.url,
- sync: e.sync,
- headers: this.getConfiguration().requestHeaders,
- body: org.cometd.JSON.toJSON(e.messages),
- onSuccess: function (i) {
- r._debug("Transport", r.getType(), "received response", i);
- var s = false;
- try {
- var o = r.convertToMessages(i);
- if (o.length === 0) {
- n = false;
- r.transportFailure(e, t, {
- httpCode: 204
- })
- } else {
- s = true;
- r.transportSuccess(e, t, o)
- }
- } catch (u) {
- r._debug(u);
- if (!s) {
- n = false;
- var a = {
- exception: u
- };
- a.httpCode = r.xhrStatus(t.xhr);
- r.transportFailure(e, t, a)
- }
- }
- },
- onError: function (s, o) {
- n = false;
- var u = {
- reason: s,
- exception: o
- };
- u.httpCode = r.xhrStatus(t.xhr);
- if (i) {
- r.setTimeout(function () {
- r.transportFailure(e, t, u)
- }, 0)
- } else {
- r.transportFailure(e, t, u)
- }
- }
- });
- i = false
- } catch (s) {
- n = false;
- this.setTimeout(function () {
- r.transportFailure(e, t, {
- exception: s
- })
- }, 0)
- }
- };
- t.reset = function () {
- e.reset();
- n = true
- };
- return t
- };
- org.cometd.CallbackPollingTransport = function () {
- var e = new org.cometd.RequestTransport;
- var t = org.cometd.Transport.derive(e);
- var n = 2e3;
- t.accept = function (e, t, n) {
- return true
- };
- t.jsonpSend = function (e) {
- throw "Abstract"
- };
- t.transportSend = function (e, t) {
- var r = this;
- var i = 0;
- var s = e.messages.length;
- var o = [];
- while (s > 0) {
- var u = org.cometd.JSON.toJSON(e.messages.slice(i, i + s));
- var a = e.url.length + encodeURI(u).length;
- if (a > n) {
- if (s === 1) {
- this.setTimeout(function () {
- r.transportFailure(e, t, {
- reason: "Bayeux message too big, max is " + n
- })
- }, 0);
- return
- }--s;
- continue
- }
- o.push(s);
- i += s;
- s = e.messages.length - i
- }
- var f = e;
- if (o.length > 1) {
- var l = 0;
- var c = o[0];
- this._debug("Transport", this.getType(), "split", e.messages.length, "messages into", o.join(" + "));
- f = this._mixin(false, {}, e);
- f.messages = e.messages.slice(l, c);
- f.onSuccess = e.onSuccess;
- f.onFailure = e.onFailure;
- for (var h = 1; h < o.length; ++h) {
- var p = this._mixin(false, {}, e);
- l = c;
- c += o[h];
- p.messages = e.messages.slice(l, c);
- p.onSuccess = e.onSuccess;
- p.onFailure = e.onFailure;
- this.send(p, t.metaConnect)
- }
- }
- this._debug("Transport", this.getType(), "sending request", t.id, "envelope", f);
- try {
- var d = true;
- this.jsonpSend({
- transport: this,
- url: f.url,
- sync: f.sync,
- headers: this.getConfiguration().requestHeaders,
- body: org.cometd.JSON.toJSON(f.messages),
- onSuccess: function (e) {
- var n = false;
- try {
- var i = r.convertToMessages(e);
- if (i.length === 0) {
- r.transportFailure(f, t, {
- httpCode: 204
- })
- } else {
- n = true;
- r.transportSuccess(f, t, i)
- }
- } catch (s) {
- r._debug(s);
- if (!n) {
- r.transportFailure(f, t, {
- exception: s
- })
- }
- }
- },
- onError: function (e, n) {
- var i = {
- reason: e,
- exception: n
- };
- if (d) {
- r.setTimeout(function () {
- r.transportFailure(f, t, i)
- }, 0)
- } else {
- r.transportFailure(f, t, i)
- }
- }
- });
- d = false
- } catch (v) {
- this.setTimeout(function () {
- r.transportFailure(f, t, {
- exception: v
- })
- }, 0)
- }
- };
- return t
- };
- org.cometd.WebSocketTransport = function () {
- function h() {
- if (a) {
- return
- }
- a = true;
- var e = n.getURL().replace(/^http/, "ws");
- this._debug("Transport", this.getType(), "connecting to URL", e);
- try {
- var t = n.getConfiguration().protocol;
- var i = t ? new org.cometd.WebSocket(e, t) : new org.cometd.WebSocket(e)
- } catch (o) {
- r = false;
- this._debug("Exception while creating WebSocket object", o);
- throw o
- }
- s = n.getConfiguration().stickyReconnect !== false;
- var u = this;
- var l = null;
- var c = n.getConfiguration().connectTimeout;
- if (c > 0) {
- l = this.setTimeout(function () {
- l = null;
- u._debug("Transport", u.getType(), "timed out while connecting to URL", e, ":", c, "ms");
- var t = {
- code: 1e3,
- reason: "Connect Timeout"
- };
- u.webSocketClose(i, t.code, t.reason);
- u.onClose(i, t)
- }, c)
- }
- var h = function () {
- u._debug("WebSocket opened", i);
- a = false;
- if (l) {
- u.clearTimeout(l);
- l = null
- }
- if (f) {
- n._warn("Closing Extra WebSocket Connections", i, f);
- u.webSocketClose(i, 1e3, "Extra Connection")
- } else {
- u.onOpen(i)
- }
- };
- var p = function (e) {
- e = e || {
- code: 1e3
- };
- u._debug("WebSocket closing", i, e);
- a = false;
- if (l) {
- u.clearTimeout(l);
- l = null
- }
- if (f !== null && i !== f) {
- u._debug("Closed Extra WebSocket Connection", i)
- } else {
- u.onClose(i, e)
- }
- };
- var d = function (e) {
- u._debug("WebSocket message", e, i);
- if (i !== f) {
- n._warn("Extra WebSocket Connections", i, f)
- }
- u.onMessage(i, e)
- };
- i.onopen = h;
- i.onclose = p;
- i.onerror = function () {
- p({
- code: 1002,
- reason: "Error"
- })
- };
- i.onmessage = d;
- this._debug("Transport", this.getType(), "configured callbacks on", i)
- }
- function p(e, t, n) {
- var r = org.cometd.JSON.toJSON(t.messages);
- e.send(r);
- this._debug("Transport", this.getType(), "sent", t, "metaConnect =", n);
- var i = this.getConfiguration().maxNetworkDelay;
- var s = i;
- if (n) {
- s += this.getAdvice().timeout;
- l = true
- }
- var o = this;
- var a = [];
- for (var f = 0; f < t.messages.length; ++f) {
- (function () {
- var n = t.messages[f];
- if (n.id) {
- a.push(n.id);
- u[n.id] = this.setTimeout(function () {
- o._debug("Transport", o.getType(), "timing out message", n.id, "after", s, "on", e);
- var t = {
- code: 1e3,
- reason: "Message Timeout"
- };
- o.webSocketClose(e, t.code, t.reason);
- o.onClose(e, t)
- }, s)
- }
- })()
- }
- this._debug("Transport", this.getType(), "waiting at most", s, "ms for messages", a, "maxNetworkDelay", i, ", timeouts:", u)
- }
- function d(e, t, n) {
- try {
- if (e === null) {
- h.call(this)
- } else {
- p.call(this, e, t, n)
- }
- } catch (r) {
- this.setTimeout(function () {
- t.onFailure(e, t.messages, {
- exception: r
- })
- }, 0)
- }
- }
- var e = new org.cometd.Transport;
- var t = org.cometd.Transport.derive(e);
- var n;
- var r = true;
- var i = false;
- var s = true;
- var o = {};
- var u = {};
- var a = false;
- var f = null;
- var l = false;
- var c = null;
- t.reset = function () {
- e.reset();
- r = true;
- i = false;
- s = true;
- o = {};
- u = {};
- a = false;
- f = null;
- l = false;
- c = null
- };
- t.onOpen = function (e) {
- this._debug("Transport", this.getType(), "opened", e);
- f = e;
- i = true;
- this._debug("Sending pending messages", o);
- for (var t in o) {
- var n = o[t];
- var r = n[0];
- var s = n[1];
- c = r.onSuccess;
- p.call(this, e, r, s)
- }
- };
- t.onMessage = function (e, t) {
- this._debug("Transport", this.getType(), "received websocket message", t, e);
- var n = false;
- var r = this.convertToMessages(t.data);
- var i = [];
- for (var s = 0; s < r.length; ++s) {
- var a = r[s];
- if (/^\/meta\//.test(a.channel) || a.successful !== undefined) {
- if (a.id) {
- i.push(a.id);
- var f = u[a.id];
- if (f) {
- this.clearTimeout(f);
- delete u[a.id];
- this._debug("Transport", this.getType(), "removed timeout for message", a.id, ", timeouts", u)
- }
- }
- }
- if ("/meta/connect" === a.channel) {
- l = false
- }
- if ("/meta/disconnect" === a.channel && !l) {
- n = true
- }
- }
- var h = false;
- for (var p = 0; p < i.length; ++p) {
- var d = i[p];
- for (var v in o) {
- var m = v.split(",");
- var g = org.cometd.Utils.inArray(d, m);
- if (g >= 0) {
- h = true;
- m.splice(g, 1);
- var y = o[v][0];
- var b = o[v][1];
- delete o[v];
- if (m.length > 0) {
- o[m.join(",")] = [y, b]
- }
- break
- }
- }
- }
- if (h) {
- this._debug("Transport", this.getType(), "removed envelope, envelopes", o)
- }
- c.call(this, r);
- if (n) {
- this.webSocketClose(e, 1e3, "Disconnect")
- }
- };
- t.onClose = function (e, t) {
- this._debug("Transport", this.getType(), "closed", e, t);
- r = s && i;
- for (var n in u) {
- this.clearTimeout(u[n])
- }
- u = {};
- for (var a in o) {
- var c = o[a][0];
- var h = o[a][1];
- if (h) {
- l = false
- }
- c.onFailure(e, c.messages, {
- websocketCode: t.code,
- reason: t.reason
- })
- }
- o = {};
- f = null
- };
- t.registered = function (t, r) {
- e.registered(t, r);
- n = r
- };
- t.accept = function (e, t, i) {
- return r && !! org.cometd.WebSocket && n.websocketEnabled !== false
- };
- t.send = function (e, t) {
- this._debug("Transport", this.getType(), "sending", e, "metaConnect =", t);
- var n = [];
- for (var r = 0; r < e.messages.length; ++r) {
- var i = e.messages[r];
- if (i.id) {
- n.push(i.id)
- }
- }
- o[n.join(",")] = [e, t];
- this._debug("Transport", this.getType(), "stored envelope, envelopes", o);
- d.call(this, f, e, t)
- };
- t.webSocketClose = function (e, t, n) {
- try {
- e.close(t, n)
- } catch (r) {
- this._debug(r)
- }
- };
- t.abort = function () {
- e.abort();
- if (f) {
- var t = {
- code: 1001,
- reason: "Abort"
- };
- this.webSocketClose(f, t.code, t.reason);
- this.onClose(f, t)
- }
- this.reset()
- };
- return t
- };
- org.cometd.Cometd = function (e) {
- function x(e, t) {
- try {
- return e[t]
- } catch (n) {
- return undefined
- }
- }
- function T(e) {
- return org.cometd.Utils.isString(e)
- }
- function N(e) {
- if (e === undefined || e === null) {
- return false
- }
- return typeof e === "function"
- }
- function C(e, t) {
- if (window.console) {
- var n = window.console[e];
- if (N(n)) {
- n.apply(window.console, t)
- }
- }
- }
- function k(e) {
- t._debug("Configuring cometd object with", e);
- if (T(e)) {
- e = {
- url: e
- }
- }
- if (!e) {
- e = {}
- }
- S = t._mixin(false, S, e);
- var n = t.getURL();
- if (!n) {
- throw "Missing required configuration parameter 'url' specifying the Bayeux server URL"
- }
- var i = /(^https?:\/\/)?(((\[[^\]]+\])|([^:\/\?#]+))(:(\d+))?)?([^\?#]*)(.*)?/.exec(n);
- var s = i[2];
- var o = i[8];
- var u = i[9];
- r = t._isCrossDomain(s);
- if (S.appendMessageTypeToURL) {
- if (u !== undefined && u.length > 0) {
- t._info("Appending message type to URI " + o + u + " is not supported, disabling 'appendMessageTypeToURL' configuration");
- S.appendMessageTypeToURL = false
- } else {
- var a = o.split("/");
- var f = a.length - 1;
- if (o.match(/\/$/)) {
- f -= 1
- }
- if (a[f].indexOf(".") >= 0) {
- t._info("Appending message type to URI " + o + " is not supported, disabling 'appendMessageTypeToURL' configuration");
- S.appendMessageTypeToURL = false
- }
- }
- }
- }
- function L(e) {
- if (e) {
- var n = h[e.channel];
- if (n && n[e.id]) {
- delete n[e.id];
- t._debug("Removed", e.listener ? "listener" : "subscription", e)
- }
- }
- }
- function A(e) {
- if (e && !e.listener) {
- L(e)
- }
- }
- function O() {
- for (var e in h) {
- var t = h[e];
- if (t) {
- for (var n = 0; n < t.length; ++n) {
- A(t[n])
- }
- }
- }
- }
- function M(e) {
- if (o !== e) {
- t._debug("Status", o, "->", e);
- o = e
- }
- }
- function _() {
- return o === "disconnecting" || o === "disconnected"
- }
- function D() {
- return ++u
- }
- function P(e, n, r, i, s) {
- try {
- return n.call(e, i)
- } catch (o) {
- t._debug("Exception during execution of extension", r, o);
- var u = t.onExtensionException;
- if (N(u)) {
- t._debug("Invoking extension exception callback", r, o);
- try {
- u.call(t, o, r, s, i)
- } catch (a) {
- t._info("Exception during execution of exception callback in extension", r, a)
- }
- }
- return i
- }
- }
- function H(e) {
- for (var t = 0; t < v.length; ++t) {
- if (e === undefined || e === null) {
- break
- }
- var n = S.reverseIncomingExtensions ? v.length - 1 - t : t;
- var r = v[n];
- var i = r.extension.incoming;
- if (N(i)) {
- var s = P(r.extension, i, r.name, e, false);
- e = s === undefined ? e : s
- }
- }
- return e
- }
- function B(e) {
- for (var t = 0; t < v.length; ++t) {
- if (e === undefined || e === null) {
- break
- }
- var n = v[t];
- var r = n.extension.outgoing;
- if (N(r)) {
- var i = P(n.extension, r, n.name, e, true);
- e = i === undefined ? e : i
- }
- }
- return e
- }
- function j(e, n) {
- var r = h[e];
- if (r && r.length > 0) {
- for (var i = 0; i < r.length; ++i) {
- var s = r[i];
- if (s) {
- try {
- s.callback.call(s.scope, n)
- } catch (o) {
- t._debug("Exception during notification", s, n, o);
- var u = t.onListenerException;
- if (N(u)) {
- t._debug("Invoking listener exception callback", s, o);
- try {
- u.call(t, o, s, s.listener, n)
- } catch (a) {
- t._info("Exception during execution of listener callback", s, a)
- }
- }
- }
- }
- }
- }
- }
- function F(e, t) {
- j(e, t);
- var n = e.split("/");
- var r = n.length - 1;
- for (var i = r; i > 0; --i) {
- var s = n.slice(0, i).join("/") + "/*";
- if (i === r) {
- j(s, t)
- }
- s += "*";
- j(s, t)
- }
- }
- function I() {
- if (d !== null) {
- org.cometd.Utils.clearTimeout(d)
- }
- d = null
- }
- function q(e) {
- I();
- var n = m.interval + p;
- t._debug("Function scheduled in", n, "ms, interval =", m.interval, "backoff =", p, e);
- d = org.cometd.Utils.setTimeout(t, e, n)
- }
- function z(e, n, r, i) {
- for (var o = 0; o < n.length; ++o) {
- var u = n[o];
- var f = "" + D();
- u.id = f;
- if (a) {
- u.clientId = a
- }
- var l = undefined;
- if (N(u._callback)) {
- l = u._callback;
- delete u._callback
- }
- u = B(u);
- if (u !== undefined && u !== null) {
- u.id = f;
- n[o] = u;
- if (l) {
- b[f] = l
- }
- } else {
- n.splice(o--, 1)
- }
- }
- if (n.length === 0) {
- return
- }
- var c = t.getURL();
- if (S.appendMessageTypeToURL) {
- if (!c.match(/\/$/)) {
- c = c + "/"
- }
- if (i) {
- c = c + i
- }
- }
- var h = {
- url: c,
- sync: e,
- messages: n,
- onSuccess: function (e) {
- try {
- R.call(t, e)
- } catch (n) {
- t._debug("Exception during handling of messages", n)
- }
- },
- onFailure: function (e, n, r) {
- try {
- r.connectionType = t.getTransport().getType();
- U.call(t, e, n, r)
- } catch (i) {
- t._debug("Exception during handling of failure", i)
- }
- }
- };
- t._debug("Send", h);
- s.send(h, r)
- }
- function W(e) {
- if (f > 0 || c === true) {
- l.push(e)
- } else {
- z(false, [e], false)
- }
- }
- function X() {
- p = 0
- }
- function V() {
- if (p < S.maxBackoff) {
- p += S.backoffIncrement
- }
- }
- function $() {
- ++f
- }
- function J() {
- var e = l;
- l = [];
- if (e.length > 0) {
- z(false, e, false)
- }
- }
- function K() {
- --f;
- if (f < 0) {
- throw "Calls to startBatch() and endBatch() are not paired"
- }
- if (f === 0 && !_() && !c) {
- J()
- }
- }
- function Q() {
- if (!_()) {
- var e = {
- channel: "/meta/connect",
- connectionType: s.getType()
- };
- if (!E) {
- e.advice = {
- timeout: 0
- }
- }
- M("connecting");
- t._debug("Connect sent", e);
- z(false, [e], true, "connect");
- M("connected")
- }
- }
- function G() {
- M("connecting");
- q(function () {
- Q()
- })
- }
- function Y(e) {
- if (e) {
- m = t._mixin(false, {}, S.advice, e);
- t._debug("New advice", m)
- }
- }
- function Z(e) {
- I();
- if (e) {
- s.abort()
- }
- a = null;
- M("disconnected");
- f = 0;
- X();
- s = null;
- if (l.length > 0) {
- U.call(t, undefined, l, {
- reason: "Disconnected"
- });
- l = []
- }
- }
- function et(e, n, r) {
- var i = t.onTransportFailure;
- if (N(i)) {
- t._debug("Invoking transport failure callback", e, n, r);
- try {
- i.call(t, e, n, r)
- } catch (s) {
- t._info("Exception during execution of transport failure callback", s)
- }
- }
- }
- function tt(e, n) {
- if (N(e)) {
- n = e;
- e = undefined
- }
- a = null;
- O();
- if (_()) {
- i.reset();
- Y(S.advice)
- } else {
- Y(t._mixin(false, m, {
- reconnect: "retry"
- }))
- }
- f = 0;
- c = true;
- g = e;
- y = n;
- var o = "1.0";
- var u = t.getURL();
- var l = i.findTransportTypes(o, r, u);
- var h = {
- version: o,
- minimumVersion: o,
- channel: "/meta/handshake",
- supportedConnectionTypes: l,
- _callback: n,
- advice: {
- timeout: m.timeout,
- interval: m.interval
- }
- };
- var p = t._mixin(false, {}, g, h);
- if (!s) {
- s = i.negotiateTransport(l, o, r, u);
- if (!s) {
- var d = "Could not find initial transport among: " + i.getTransportTypes();
- t._warn(d);
- throw d
- }
- }
- t._debug("Initial transport is", s.getType());
- M("handshaking");
- t._debug("Handshake sent", p);
- z(false, [p], false, "handshake")
- }
- function nt() {
- M("handshaking");
- c = true;
- q(function () {
- tt(g, y)
- })
- }
- function rt(e) {
- var n = b[e.id];
- if (N(n)) {
- delete b[e.id];
- n.call(t, e)
- }
- }
- function it(e) {
- rt(e);
- F("/meta/handshake", e);
- F("/meta/unsuccessful", e);
- var t = !_() && m.reconnect !== "none";
- if (t) {
- V();
- nt()
- } else {
- Z(false)
- }
- }
- function st(e) {
- if (e.successful) {
- a = e.clientId;
- var n = t.getURL();
- var o = i.negotiateTransport(e.supportedConnectionTypes, e.version, r, n);
- if (o === null) {
- var u = "Could not negotiate transport with server; client=[" + i.findTransportTypes(e.version, r, n) + "], server=[" + e.supportedConnectionTypes + "]";
- var f = t.getTransport();
- et(f.getType(), null, {
- reason: u,
- connectionType: f.getType(),
- transport: f
- });
- t._warn(u);
- Z(true);
- return
- } else if (s !== o) {
- t._debug("Transport", s.getType(), "->", o.getType());
- s = o
- }
- c = false;
- J();
- e.reestablish = w;
- w = true;
- rt(e);
- F("/meta/handshake", e);
- var l = _() ? "none" : m.reconnect;
- switch (l) {
- case "retry":
- X();
- G();
- break;
- case "none":
- Z(false);
- break;
- default:
- throw "Unrecognized advice action " + l
- }
- } else {
- it(e)
- }
- }
- function ot(e) {
- var n = "1.0";
- var o = t.getURL();
- var u = t.getTransport();
- var a = i.findTransportTypes(n, r, o);
- var f = i.negotiateTransport(a, n, r, o);
- if (!f) {
- et(u.getType(), null, e.failure);
- t._warn("Could not negotiate transport; client=[" + a + "]");
- Z(true);
- it(e)
- } else {
- t._debug("Transport", u.getType(), "->", f.getType());
- et(u.getType(), f.getType(), e.failure);
- it(e);
- s = f
- }
- }
- function ut(e) {
- F("/meta/connect", e);
- F("/meta/unsuccessful", e);
- var t = _() ? "none" : m.reconnect;
- switch (t) {
- case "retry":
- G();
- V();
- break;
- case "handshake":
- i.reset();
- X();
- nt();
- break;
- case "none":
- Z(false);
- break;
- default:
- throw "Unrecognized advice action" + t
- }
- }
- function at(e) {
- E = e.successful;
- if (E) {
- F("/meta/connect", e);
- var t = _() ? "none" : m.reconnect;
- switch (t) {
- case "retry":
- X();
- G();
- break;
- case "none":
- Z(false);
- break;
- default:
- throw "Unrecognized advice action " + t
- }
- } else {
- ut(e)
- }
- }
- function ft(e) {
- E = false;
- ut(e)
- }
- function lt(e) {
- Z(true);
- rt(e);
- F("/meta/disconnect", e);
- F("/meta/unsuccessful", e)
- }
- function ct(e) {
- if (e.successful) {
- Z(false);
- rt(e);
- F("/meta/disconnect", e)
- } else {
- lt(e)
- }
- }
- function ht(e) {
- lt(e)
- }
- function pt(e) {
- var n = h[e.subscription];
- if (n) {
- for (var r = n.length - 1; r >= 0; --r) {
- var i = n[r];
- if (i && !i.listener) {
- delete n[r];
- t._debug("Removed failed subscription", i);
- break
- }
- }
- }
- rt(e);
- F("/meta/subscribe", e);
- F("/meta/unsuccessful", e)
- }
- function dt(e) {
- if (e.successful) {
- rt(e);
- F("/meta/subscribe", e)
- } else {
- pt(e)
- }
- }
- function vt(e) {
- pt(e)
- }
- function mt(e) {
- rt(e);
- F("/meta/unsubscribe", e);
- F("/meta/unsuccessful", e)
- }
- function gt(e) {
- if (e.successful) {
- rt(e);
- F("/meta/unsubscribe", e)
- } else {
- mt(e)
- }
- }
- function yt(e) {
- mt(e)
- }
- function bt(e) {
- rt(e);
- F("/meta/publish", e);
- F("/meta/unsuccessful", e)
- }
- function wt(e) {
- if (e.successful === undefined) {
- if (e.data !== undefined) {
- F(e.channel, e)
- } else {
- t._warn("Unknown Bayeux Message", e)
- }
- } else {
- if (e.successful) {
- rt(e);
- F("/meta/publish", e)
- } else {
- bt(e)
- }
- }
- }
- function Et(e) {
- bt(e)
- }
- function St(e) {
- e = H(e);
- if (e === undefined || e === null) {
- return
- }
- Y(e.advice);
- var t = e.channel;
- switch (t) {
- case "/meta/handshake":
- st(e);
- break;
- case "/meta/connect":
- at(e);
- break;
- case "/meta/disconnect":
- ct(e);
- break;
- case "/meta/subscribe":
- dt(e);
- break;
- case "/meta/unsubscribe":
- gt(e);
- break;
- default:
- wt(e);
- break
- }
- }
- function xt(e) {
- var t = h[e];
- if (t) {
- for (var n = 0; n < t.length; ++n) {
- if (t[n]) {
- return true
- }
- }
- }
- return false
- }
- function Tt(e, t) {
- var n = {
- scope: e,
- method: t
- };
- if (N(e)) {
- n.scope = undefined;
- n.method = e
- } else {
- if (T(t)) {
- if (!e) {
- throw "Invalid scope " + e
- }
- n.method = e[t];
- if (!N(n.method)) {
- throw "Invalid callback " + t + " for scope " + e
- }
- } else if (!N(t)) {
- throw "Invalid callback " + t
- }
- }
- return n
- }
- function Nt(e, n, r, i) {
- var s = Tt(n, r);
- t._debug("Adding", i ? "listener" : "subscription", "on", e, "with scope", s.scope, "and callback", s.method);
- var o = {
- channel: e,
- scope: s.scope,
- callback: s.method,
- listener: i
- };
- var u = h[e];
- if (!u) {
- u = [];
- h[e] = u
- }
- o.id = u.push(o) - 1;
- t._debug("Added", i ? "listener" : "subscription", o);
- o[0] = e;
- o[1] = o.id;
- return o
- }
- var t = this;
- var n = e || "default";
- var r = false;
- var i = new org.cometd.TransportRegistry;
- var s;
- var o = "disconnected";
- var u = 0;
- var a = null;
- var f = 0;
- var l = [];
- var c = false;
- var h = {};
- var p = 0;
- var d = null;
- var v = [];
- var m = {};
- var g;
- var y;
- var b = {};
- var w = false;
- var E = false;
- var S = {
- protocol: null,
- stickyReconnect: true,
- connectTimeout: 0,
- maxConnections: 2,
- backoffIncrement: 1e3,
- maxBackoff: 6e4,
- logLevel: "info",
- reverseIncomingExtensions: true,
- maxNetworkDelay: 1e4,
- requestHeaders: {},
- appendMessageTypeToURL: true,
- autoBatch: false,
- advice: {
- timeout: 6e4,
- interval: 0,
- reconnect: "retry"
- }
- };
- this._mixin = function (e, t, n) {
- var r = t || {};
- for (var i = 2; i < arguments.length; ++i) {
- var s = arguments[i];
- if (s === undefined || s === null) {
- continue
- }
- for (var o in s) {
- var u = x(s, o);
- var a = x(r, o);
- if (u === t) {
- continue
- }
- if (u === undefined) {
- continue
- }
- if (e && typeof u === "object" && u !== null) {
- if (u instanceof Array) {
- r[o] = this._mixin(e, a instanceof Array ? a : [], u)
- } else {
- var f = typeof a === "object" && !(a instanceof Array) ? a : {};
- r[o] = this._mixin(e, f, u)
- }
- } else {
- r[o] = u
- }
- }
- }
- return r
- };
- this._warn = function () {
- C("warn", arguments)
- };
- this._info = function () {
- if (S.logLevel !== "warn") {
- C("info", arguments)
- }
- };
- this._debug = function () {
- if (S.logLevel === "debug") {
- C("debug", arguments)
- }
- };
- this._isCrossDomain = function (e) {
- return e && e !== window.location.host
- };
- var R;
- var U;
- this.send = W;
- this.receive = St;
- R = function (e) {
- t._debug("Received", e);
- for (var n = 0; n < e.length; ++n) {
- var r = e[n];
- St(r)
- }
- };
- U = function (e, n, r) {
- t._debug("handleFailure", e, n, r);
- r.transport = e;
- for (var i = 0; i < n.length; ++i) {
- var s = n[i];
- var o = {
- id: s.id,
- successful: false,
- channel: s.channel,
- failure: r
- };
- r.message = s;
- switch (s.channel) {
- case "/meta/handshake":
- ot(o);
- break;
- case "/meta/connect":
- ft(o);
- break;
- case "/meta/disconnect":
- ht(o);
- break;
- case "/meta/subscribe":
- o.subscription = s.subscription;
- vt(o);
- break;
- case "/meta/unsubscribe":
- o.subscription = s.subscription;
- yt(o);
- break;
- default:
- Et(o);
- break
- }
- }
- };
- this.registerTransport = function (e, t, n) {
- var r = i.add(e, t, n);
- if (r) {
- this._debug("Registered transport", e);
- if (N(t.registered)) {
- t.registered(e, this)
- }
- }
- return r
- };
- this.getTransportTypes = function () {
- return i.getTransportTypes()
- };
- this.unregisterTransport = function (e) {
- var t = i.remove(e);
- if (t !== null) {
- this._debug("Unregistered transport", e);
- if (N(t.unregistered)) {
- t.unregistered()
- }
- }
- return t
- };
- this.unregisterTransports = function () {
- i.clear()
- };
- this.findTransport = function (e) {
- return i.find(e)
- };
- this.configure = function (e) {
- k.call(this, e)
- };
- this.init = function (e, t) {
- this.configure(e);
- this.handshake(t)
- };
- this.handshake = function (e, t) {
- M("disconnected");
- w = false;
- tt(e, t)
- };
- this.disconnect = function (e, t, n) {
- if (_()) {
- return
- }
- if (typeof e !== "boolean") {
- n = t;
- t = e;
- e = false
- }
- if (N(t)) {
- n = t;
- t = undefined
- }
- var r = {
- channel: "/meta/disconnect",
- _callback: n
- };
- var i = this._mixin(false, {}, t, r);
- M("disconnecting");
- z(e === true, [i], false, "disconnect")
- };
- this.startBatch = function () {
- $()
- };
- this.endBatch = function () {
- K()
- };
- this.batch = function (e, t) {
- var n = Tt(e, t);
- this.startBatch();
- try {
- n.method.call(n.scope);
- this.endBatch()
- } catch (r) {
- this._info("Exception during execution of batch", r);
- this.endBatch();
- throw r
- }
- };
- this.addListener = function (e, t, n) {
- if (arguments.length < 2) {
- throw "Illegal arguments number: required 2, got " + arguments.length
- }
- if (!T(e)) {
- throw "Illegal argument type: channel must be a string"
- }
- return Nt(e, t, n, true)
- };
- this.removeListener = function (e) {
- if (!e || !e.channel || !("id" in e)) {
- throw "Invalid argument: expected subscription, not " + e
- }
- L(e)
- };
- this.clearListeners = function () {
- h = {}
- };
- this.subscribe = function (e, t, n, r, i) {
- if (arguments.length < 2) {
- throw "Illegal arguments number: required 2, got " + arguments.length
- }
- if (!T(e)) {
- throw "Illegal argument type: channel must be a string"
- }
- if (_()) {
- throw "Illegal state: already disconnected"
- }
- if (N(t)) {
- i = r;
- r = n;
- n = t;
- t = undefined
- }
- if (N(r)) {
- i = r;
- r = undefined
- }
- var s = !xt(e);
- var o = Nt(e, t, n, false);
- if (s) {
- var u = {
- channel: "/meta/subscribe",
- subscription: e,
- _callback: i
- };
- var a = this._mixin(false, {}, r, u);
- W(a)
- }
- return o
- };
- this.unsubscribe = function (e, t, n) {
- if (arguments.length < 1) {
- throw "Illegal arguments number: required 1, got " + arguments.length
- }
- if (_()) {
- throw "Illegal state: already disconnected"
- }
- if (N(t)) {
- n = t;
- t = undefined
- }
- this.removeListener(e);
- var r = e.channel;
- if (!xt(r)) {
- var i = {
- channel: "/meta/unsubscribe",
- subscription: r,
- _callback: n
- };
- var s = this._mixin(false, {}, t, i);
- W(s)
- }
- };
- this.resubscribe = function (e, t) {
- A(e);
- if (e) {
- return this.subscribe(e.channel, e.scope, e.callback, t)
- }
- return undefined
- };
- this.clearSubscriptions = function () {
- O()
- };
- this.publish = function (e, t, n, r) {
- if (arguments.length < 1) {
- throw "Illegal arguments number: required 1, got " + arguments.length
- }
- if (!T(e)) {
- throw "Illegal argument type: channel must be a string"
- }
- if (/^\/meta\//.test(e)) {
- throw "Illegal argument: cannot publish to meta channels"
- }
- if (_()) {
- throw "Illegal state: already disconnected"
- }
- if (N(t)) {
- r = t;
- t = n = {}
- } else if (N(n)) {
- r = n;
- n = {}
- }
- var i = {
- channel: e,
- data: t,
- _callback: r
- };
- var s = this._mixin(false, {}, n, i);
- W(s)
- };
- this.getStatus = function () {
- return o
- };
- this.isDisconnected = _;
- this.setBackoffIncrement = function (e) {
- S.backoffIncrement = e
- };
- this.getBackoffIncrement = function () {
- return S.backoffIncrement
- };
- this.getBackoffPeriod = function () {
- return p
- };
- this.setLogLevel = function (e) {
- S.logLevel = e
- };
- this.registerExtension = function (e, t) {
- if (arguments.length < 2) {
- throw "Illegal arguments number: required 2, got " + arguments.length
- }
- if (!T(e)) {
- throw "Illegal argument type: extension name must be a string"
- }
- var n = false;
- for (var r = 0; r < v.length; ++r) {
- var i = v[r];
- if (i.name === e) {
- n = true;
- break
- }
- }
- if (!n) {
- v.push({
- name: e,
- extension: t
- });
- this._debug("Registered extension", e);
- if (N(t.registered)) {
- t.registered(e, this)
- }
- return true
- } else {
- this._info("Could not register extension with name", e, "since another extension with the same name already exists");
- return false
- }
- };
- this.unregisterExtension = function (e) {
- if (!T(e)) {
- throw "Illegal argument type: extension name must be a string"
- }
- var t = false;
- for (var n = 0; n < v.length; ++n) {
- var r = v[n];
- if (r.name === e) {
- v.splice(n, 1);
- t = true;
- this._debug("Unregistered extension", e);
- var i = r.extension;
- if (N(i.unregistered)) {
- i.unregistered()
- }
- break
- }
- }
- return t
- };
- this.getExtension = function (e) {
- for (var t = 0; t < v.length; ++t) {
- var n = v[t];
- if (n.name === e) {
- return n.extension
- }
- }
- return null
- };
- this.getName = function () {
- return n
- };
- this.getClientId = function () {
- return a
- };
- this.getURL = function () {
- if (s && typeof S.urls === "object") {
- var e = S.urls[s.getType()];
- if (e) {
- return e
- }
- }
- return S.url
- };
- this.getTransport = function () {
- return s
- };
- this.getConfiguration = function () {
- return this._mixin(true, {}, S)
- };
- this.getAdvice = function () {
- return this._mixin(true, {}, m)
- };
- org.cometd.WebSocket = window.WebSocket;
- if (!org.cometd.WebSocket) {
- org.cometd.WebSocket = window.MozWebSocket
- }
- };
- if (typeof define === "function" && define.amd) {
- define(function () {
- return org.cometd
- })
- }(function () {
- function e(e) {
- return e.AckExtension = function () {
- function r(t, n) {
- e._debug(t, n)
- }
- var e;
- var t = false;
- var n = -1;
- this.registered = function (t, n) {
- e = n;
- r("AckExtension: executing registration callback")
- };
- this.unregistered = function () {
- r("AckExtension: executing unregistration callback");
- e = null
- };
- this.incoming = function (e) {
- var i = e.channel;
- if (i == "/meta/handshake") {
- t = e.ext && e.ext.ack;
- r("AckExtension: server supports acks", t)
- } else if (t && i == "/meta/connect" && e.successful) {
- var s = e.ext;
- if (s && typeof s.ack === "number") {
- n = s.ack;
- r("AckExtension: server sent ack id", n)
- }
- }
- return e
- };
- this.outgoing = function (i) {
- var s = i.channel;
- if (s == "/meta/handshake") {
- if (!i.ext) {
- i.ext = {}
- }
- i.ext.ack = e && e.ackEnabled !== false;
- n = -1
- } else if (t && s == "/meta/connect") {
- if (!i.ext) {
- i.ext = {}
- }
- i.ext.ack = n;
- r("AckExtension: client sending ack id", n)
- }
- return i
- }
- }
- }
- if (typeof define === "function" && define.amd) {
- define(["org/cometd"], e)
- } else {
- e(org.cometd)
- }
- })();
- (function () {
- function e(e) {
- return e.TimeSyncExtension = function (t) {
- function a(e, t) {
- n._debug(e, t)
- }
- var n;
- var r = t && t.maxSamples || 10;
- var i = [];
- var s = [];
- var o = 0;
- var u = 0;
- this.registered = function (e, t) {
- n = t;
- a("TimeSyncExtension: executing registration callback")
- };
- this.unregistered = function () {
- a("TimeSyncExtension: executing unregistration callback");
- n = null;
- i = [];
- s = []
- };
- this.incoming = function (e) {
- var t = e.channel;
- if (t && t.indexOf("/meta/") === 0) {
- if (e.ext && e.ext.timesync) {
- var n = e.ext.timesync;
- a("TimeSyncExtension: server sent timesync", n);
- var f = (new Date).getTime();
- var l = (f - n.tc - n.p) / 2;
- var c = n.ts - n.tc - l;
- i.push(l);
- s.push(c);
- if (s.length > r) {
- s.shift();
- i.shift()
- }
- var h = s.length;
- var p = 0;
- var d = 0;
- for (var v = 0; v < h; ++v) {
- p += i[v];
- d += s[v]
- }
- o = parseInt((p / h).toFixed());
- u = parseInt((d / h).toFixed());
- a("TimeSyncExtension: network lag", o, "ms, time offset with server", u, "ms", o, u)
- }
- }
- return e
- };
- this.outgoing = function (t) {
- var n = t.channel;
- if (n && n.indexOf("/meta/") === 0) {
- if (!t.ext) {
- t.ext = {}
- }
- t.ext.timesync = {
- tc: (new Date).getTime(),
- l: o,
- o: u
- };
- a("TimeSyncExtension: client sending timesync", e.JSON.toJSON(t.ext.timesync))
- }
- return t
- };
- this.getTimeOffset = function () {
- return u
- };
- this.getTimeOffsetSamples = function () {
- return s
- };
- this.getNetworkLag = function () {
- return o
- };
- this.getServerTime = function () {
- return (new Date).getTime() + u
- };
- this.getServerDate = function () {
- return new Date(this.getServerTime())
- };
- this.setTimeout = function (t, r) {
- var i = r instanceof Date ? r.getTime() : 0 + r;
- var s = i - u;
- var o = s - (new Date).getTime();
- if (o <= 0) {
- o = 1
- }
- return e.Utils.setTimeout(n, t, o)
- }
- }
- }
- if (typeof define === "function" && define.amd) {
- define(["org/cometd"], e)
- } else {
- e(org.cometd)
- }
- })();
- (function () {
- function e(e, t) {
- function n(e, t) {
- if (t) {
- for (var n in t) {
- if (n.toLowerCase() === "content-type") {
- continue
- }
- e.setRequestHeader(n, t[n])
- }
- }
- }
- function r() {
- var r = new t.LongPollingTransport;
- var i = t.Transport.derive(r);
- i.xhrSend = function (t) {
- return e.ajax({
- url: t.url,
- async: t.sync !== true,
- type: "POST",
- contentType: "application/json;charset=UTF-8",
- data: t.body,
- xhrFields: {
- withCredentials: true
- },
- beforeSend: function (e) {
- n(e, t.headers);
- return true
- },
- success: t.onSuccess,
- error: function (e, n, r) {
- t.onError(n, r)
- }
- })
- };
- return i
- }
- function i() {
- var r = new t.CallbackPollingTransport;
- var i = t.Transport.derive(r);
- i.jsonpSend = function (t) {
- e.ajax({
- url: t.url,
- async: t.sync !== true,
- type: "GET",
- dataType: "jsonp",
- jsonp: "jsonp",
- data: {
- message: t.body
- },
- beforeSend: function (e) {
- n(e, t.headers);
- return true
- },
- success: t.onSuccess,
- error: function (e, n, r) {
- t.onError(n, r)
- }
- })
- };
- return i
- }
- t.JSON.toJSON = JSON.stringify;
- t.JSON.fromJSON = JSON.parse;
- e.Cometd = function (e) {
- var n = new t.Cometd(e);
- if (t.WebSocket) {
- n.registerTransport("ssl-websocket", new t.WebSocketTransport)
- }
- n.registerTransport("long-polling", new r);
- n.registerTransport("ssl-long-polling", new r);
- n.registerTransport("callback-polling", new i);
- return n
- };
- e.cometd = new e.Cometd;
- return e.cometd
- }
- if (typeof define === "function" && define.amd) {
- define(["jquery", "org/cometd"], e)
- } else {
- e(jQuery, org.cometd)
- }
- })();
- (function () {
- function e(e, t) {
- var n = new e;
- t.registerExtension("ack", n);
- return n
- }
- if (typeof define === "function" && define.amd) {
- define(["org/cometd/AckExtension", "jquery.cometd"], e)
- } else {
- e(org.cometd.AckExtension, jQuery.cometd)
- }
- })();
- (function () {
- function e(e, t) {
- var n = new e;
- t.registerExtension("timesync", n);
- return n
- }
- if (typeof define === "function" && define.amd) {
- define(["org/cometd/TimeSyncExtension", "jquery.cometd"], e)
- } else {
- e(org.cometd.TimeSyncExtension, jQuery.cometd)
- }
- })()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement