Sha256: 63cbf80645e189b25b38f07b6e20fdf0137d9efe20636a2d0cd13998a5718afb
Contents?: true
Size: 1.56 KB
Versions: 6
Compression:
Stored size: 1.56 KB
Contents
/**
* Copyright (c) 2014, Facebook, Inc.
* All rights reserved.
*
* This source code is licensed under the BSD-style license found in the
* LICENSE file in the root directory of this source tree. An additional grant
* of patent rights can be found in the PATENTS file in the same directory.
*/
var WebSocketClient = require('websocket').client;
function WebSocket(url) {
this.readyState = 0;
var client = new WebSocketClient();
this.onconnect = this.onconnect.bind(this);
client.once('connect', this.onconnect);
client.once('connectFailed', this.emit.bind(this, 'close'));
client.connect(url);
}
WebSocket.prototype.onconnect = function(connection) {
this.readyState = 1;
this.socket = connection;
this.socket.on('error', this.emit.bind(this, 'close'));
this.socket.on('close', function() {
this.readyState = 3;
this.emit('close', {});
}.bind(this));
this.socket.on('message', function(msg) {
var data = msg.utf8Data;
this.emit('message', {data: data});
}.bind(this));
this.emit('open');
};
WebSocket.prototype.send = function(arg) {
this.socket.sendUTF(arg);
};
WebSocket.prototype.close = function() {
this.readyState = 2;
this.socket.close();
};
WebSocket.prototype.emit = function(event) {
var handler = this['on' + event];
if (typeof handler === 'function') {
handler.apply(this, [].slice.call(arguments, 1));
}
};
var states = {
CONNECTING: 0,
OPEN: 1,
CLOSING: 2,
CLOSED: 3
};
Object.keys(states).forEach(function(state) {
WebSocket.prototype[state] = states[state];
});
module.exports = WebSocket;
Version data entries
6 entries across 6 versions & 1 rubygems