quanGuoZongGongHui/public/myData/stomp.js

// Generated by CoffeeScript 1.7.1
/*
   Stomp Over WebSocket http://www.jmesnil.net/stomp-websocket/doc/ | Apache License V2.0

   Copyright (C) 2010-2013 [Jeff Mesnil](http://jmesnil.net/)
   Copyright (C) 2012 [FuseSource, Inc.](http://fusesource.com)
 */
;(function () {
  var t,
    e,
    n,
    i,
    r = {}.hasOwnProperty,
    o = [].slice
  t = { LF: '\n', NULL: '\x00' }
  n = (function () {
    var e
    function n(t, e, n) {
      this.command = t
      this.headers = e != null ? e : {}
      this.body = n != null ? n : ''
    }
    n.prototype.toString = function () {
      var e, i, o, s, u
      e = [this.command]
      o = this.headers['content-length'] === false ? true : false
      if (o) {
        delete this.headers['content-length']
      }
      u = this.headers
      for (i in u) {
        if (!r.call(u, i)) continue
        s = u[i]
        e.push('' + i + ':' + s)
      }
      if (this.body && !o) {
        e.push('content-length:' + n.sizeOfUTF8(this.body))
      }
      e.push(t.LF + this.body)
      return e.join(t.LF)
    }
    n.sizeOfUTF8 = function (t) {
      if (t) {
        return encodeURI(t).match(/%..|./g).length
      } else {
        return 0
      }
    }
    e = function (e) {
      var i, r, o, s, u, a, c, f, h, l, p, d, g, b, m, v, y
      s = e.search(RegExp('' + t.LF + t.LF))
      u = e.substring(0, s).split(t.LF)
      o = u.shift()
      a = {}
      d = function (t) {
        return t.replace(/^\s+|\s+$/g, '')
      }
      v = u.reverse()
      for (g = 0, m = v.length; g < m; g++) {
        l = v[g]
        f = l.indexOf(':')
        a[d(l.substring(0, f))] = d(l.substring(f + 1))
      }
      i = ''
      p = s + 2
      if (a['content-length']) {
        h = parseInt(a['content-length'])
        i = ('' + e).substring(p, p + h)
      } else {
        r = null
        for (c = b = p, y = e.length; p <= y ? b < y : b > y; c = p <= y ? ++b : --b) {
          r = e.charAt(c)
          if (r === t.NULL) {
            break
          }
          i += r
        }
      }
      return new n(o, a, i)
    }
    n.unmarshall = function (n) {
      var i
      return (function () {
        var r, o, s, u
        s = n.split(RegExp('' + t.NULL + t.LF + '*'))
        u = []
        for (r = 0, o = s.length; r < o; r++) {
          i = s[r]
          if ((i != null ? i.length : void 0) > 0) {
            u.push(e(i))
          }
        }
        return u
      })()
    }
    n.marshall = function (e, i, r) {
      var o
      o = new n(e, i, r)
      return o.toString() + t.NULL
    }
    return n
  })()
  e = (function () {
    var e
    function r(t) {
      this.ws = t
      this.ws.binaryType = 'arraybuffer'
      this.counter = 0
      this.connected = false
      this.heartbeat = { outgoing: 1e4, incoming: 1e4 }
      this.maxWebSocketFrameSize = 16 * 1024
      this.subscriptions = {}
    }
    r.prototype.debug = function (t) {
      var e
      return typeof window !== 'undefined' && window !== null
        ? (e = window.console) != null
          ? e.log(t)
          : void 0
        : void 0
    }
    e = function () {
      if (Date.now) {
        return Date.now()
      } else {
        return new Date().valueOf
      }
    }
    r.prototype._transmit = function (t, e, i) {
      var r
      r = n.marshall(t, e, i)
      if (typeof this.debug === 'function') {
        this.debug('>>> ' + r)
      }
      while (true) {
        if (r.length > this.maxWebSocketFrameSize) {
          this.ws.send(r.substring(0, this.maxWebSocketFrameSize))
          r = r.substring(this.maxWebSocketFrameSize)
          if (typeof this.debug === 'function') {
            this.debug('remaining = ' + r.length)
          }
        } else {
          return this.ws.send(r)
        }
      }
    }
    r.prototype._setupHeartbeat = function (n) {
      var r, o, s, u, a, c
      if ((a = n.version) !== i.VERSIONS.V1_1 && a !== i.VERSIONS.V1_2) {
        return
      }
      ;(c = (function () {
        var t, e, i, r
        i = n['heart-beat'].split(',')
        r = []
        for (t = 0, e = i.length; t < e; t++) {
          u = i[t]
          r.push(parseInt(u))
        }
        return r
      })()),
        (o = c[0]),
        (r = c[1])
      if (!(this.heartbeat.outgoing === 0 || r === 0)) {
        s = Math.max(this.heartbeat.outgoing, r)
        if (typeof this.debug === 'function') {
          this.debug('send PING every ' + s + 'ms')
        }
        this.pinger = i.setInterval(
          s,
          (function (e) {
            return function () {
              e.ws.send(t.LF)
              return typeof e.debug === 'function' ? e.debug('>>> PING') : void 0
            }
          })(this)
        )
      }
      if (!(this.heartbeat.incoming === 0 || o === 0)) {
        s = Math.max(this.heartbeat.incoming, o)
        if (typeof this.debug === 'function') {
          this.debug('check PONG every ' + s + 'ms')
        }
        return (this.ponger = i.setInterval(
          s,
          (function (t) {
            return function () {
              var n
              n = e() - t.serverActivity
              if (n > s * 2) {
                if (typeof t.debug === 'function') {
                  t.debug('did not receive server activity for the last ' + n + 'ms')
                }
                return t.ws.close()
              }
            }
          })(this)
        ))
      }
    }
    r.prototype._parseConnect = function () {
      var t, e, n, i
      t = 1 <= arguments.length ? o.call(arguments, 0) : []
      i = {}
      switch (t.length) {
        case 2:
          ;(i = t[0]), (e = t[1])
          break
        case 3:
          if (t[1] instanceof Function) {
            ;(i = t[0]), (e = t[1]), (n = t[2])
          } else {
            ;(i.login = t[0]), (i.passcode = t[1]), (e = t[2])
          }
          break
        case 4:
          ;(i.login = t[0]), (i.passcode = t[1]), (e = t[2]), (n = t[3])
          break
        default:
          ;(i.login = t[0]), (i.passcode = t[1]), (e = t[2]), (n = t[3]), (i.host = t[4])
      }
      return [i, e, n]
    }
    r.prototype.connect = function () {
      var r, s, u, a
      r = 1 <= arguments.length ? o.call(arguments, 0) : []
      a = this._parseConnect.apply(this, r)
      ;(u = a[0]), (this.connectCallback = a[1]), (s = a[2])
      if (typeof this.debug === 'function') {
        this.debug('Opening Web Socket...')
      }
      this.ws.onmessage = (function (i) {
        return function (r) {
          var o, u, a, c, f, h, l, p, d, g, b, m
          c =
            typeof ArrayBuffer !== 'undefined' && r.data instanceof ArrayBuffer
              ? ((o = new Uint8Array(r.data)),
                typeof i.debug === 'function'
                  ? i.debug('--- got data length: ' + o.length)
                  : void 0,
                (function () {
                  var t, e, n
                  n = []
                  for (t = 0, e = o.length; t < e; t++) {
                    u = o[t]
                    n.push(String.fromCharCode(u))
                  }
                  return n
                })().join(''))
              : r.data
          i.serverActivity = e()
          if (c === t.LF) {
            if (typeof i.debug === 'function') {
              i.debug('<<< PONG')
            }
            return
          }
          if (typeof i.debug === 'function') {
            i.debug('<<< ' + c)
          }
          b = n.unmarshall(c)
          m = []
          for (d = 0, g = b.length; d < g; d++) {
            f = b[d]
            switch (f.command) {
              case 'CONNECTED':
                if (typeof i.debug === 'function') {
                  i.debug('connected to server ' + f.headers.server)
                }
                i.connected = true
                i._setupHeartbeat(f.headers)
                m.push(
                  typeof i.connectCallback === 'function' ? i.connectCallback(f) : void 0
                )
                break
              case 'MESSAGE':
                p = f.headers.subscription
                l = i.subscriptions[p] || i.onreceive
                if (l) {
                  a = i
                  h = f.headers['message-id']
                  f.ack = function (t) {
                    if (t == null) {
                      t = {}
                    }
                    return a.ack(h, p, t)
                  }
                  f.nack = function (t) {
                    if (t == null) {
                      t = {}
                    }
                    return a.nack(h, p, t)
                  }
                  m.push(l(f))
                } else {
                  m.push(
                    typeof i.debug === 'function'
                      ? i.debug('Unhandled received MESSAGE: ' + f)
                      : void 0
                  )
                }
                break
              case 'RECEIPT':
                m.push(typeof i.onreceipt === 'function' ? i.onreceipt(f) : void 0)
                break
              case 'ERROR':
                m.push(typeof s === 'function' ? s(f) : void 0)
                break
              default:
                m.push(
                  typeof i.debug === 'function'
                    ? i.debug('Unhandled frame: ' + f)
                    : void 0
                )
            }
          }
          return m
        }
      })(this)
      this.ws.onclose = (function (t) {
        return function () {
          var e
          e = 'Whoops! Lost connection to ' + t.ws.url
          if (typeof t.debug === 'function') {
            t.debug(e)
          }
          t._cleanUp()
          return typeof s === 'function' ? s(e) : void 0
        }
      })(this)
      return (this.ws.onopen = (function (t) {
        return function () {
          if (typeof t.debug === 'function') {
            t.debug('Web Socket Opened...')
          }
          u['accept-version'] = i.VERSIONS.supportedVersions()
          u['heart-beat'] = [t.heartbeat.outgoing, t.heartbeat.incoming].join(',')
          return t._transmit('CONNECT', u)
        }
      })(this))
    }
    r.prototype.disconnect = function (t, e) {
      if (e == null) {
        e = {}
      }
      this._transmit('DISCONNECT', e)
      this.ws.onclose = null
      this.ws.close()
      this._cleanUp()
      return typeof t === 'function' ? t() : void 0
    }
    r.prototype._cleanUp = function () {
      this.connected = false
      if (this.pinger) {
        i.clearInterval(this.pinger)
      }
      if (this.ponger) {
        return i.clearInterval(this.ponger)
      }
    }
    r.prototype.send = function (t, e, n) {
      if (e == null) {
        e = {}
      }
      if (n == null) {
        n = ''
      }
      e.destination = t
      return this._transmit('SEND', e, n)
    }
    r.prototype.subscribe = function (t, e, n) {
      var i
      if (n == null) {
        n = {}
      }
      if (!n.id) {
        n.id = 'sub-' + this.counter++
      }
      n.destination = t
      this.subscriptions[n.id] = e
      this._transmit('SUBSCRIBE', n)
      i = this
      return {
        id: n.id,
        unsubscribe: function () {
          return i.unsubscribe(n.id)
        }
      }
    }
    r.prototype.unsubscribe = function (t) {
      delete this.subscriptions[t]
      return this._transmit('UNSUBSCRIBE', { id: t })
    }
    r.prototype.begin = function (t) {
      var e, n
      n = t || 'tx-' + this.counter++
      this._transmit('BEGIN', { transaction: n })
      e = this
      return {
        id: n,
        commit: function () {
          return e.commit(n)
        },
        abort: function () {
          return e.abort(n)
        }
      }
    }
    r.prototype.commit = function (t) {
      return this._transmit('COMMIT', { transaction: t })
    }
    r.prototype.abort = function (t) {
      return this._transmit('ABORT', { transaction: t })
    }
    r.prototype.ack = function (t, e, n) {
      if (n == null) {
        n = {}
      }
      n['message-id'] = t
      n.subscription = e
      return this._transmit('ACK', n)
    }
    r.prototype.nack = function (t, e, n) {
      if (n == null) {
        n = {}
      }
      n['message-id'] = t
      n.subscription = e
      return this._transmit('NACK', n)
    }
    return r
  })()
  i = {
    VERSIONS: {
      V1_0: '1.0',
      V1_1: '1.1',
      V1_2: '1.2',
      supportedVersions: function () {
        return '1.1,1.0'
      }
    },
    client: function (t, n) {
      var r, o
      if (n == null) {
        n = ['v10.stomp', 'v11.stomp']
      }
      r = i.WebSocketClass || WebSocket
      o = new r(t, n)
      return new e(o)
    },
    over: function (t) {
      return new e(t)
    },
    Frame: n
  }
  if (typeof exports !== 'undefined' && exports !== null) {
    exports.Stomp = i
  }
  if (typeof window !== 'undefined' && window !== null) {
    i.setInterval = function (t, e) {
      return window.setInterval(e, t)
    }
    i.clearInterval = function (t) {
      return window.clearInterval(t)
    }
    window.Stomp = i
  } else if (!exports) {
    self.Stomp = i
  }
}).call(this)