Gerrit Linnemann
971495b393
Error code overview: IPConnection.ERROR_ALREADY_CONNECTED = 11 IPConnection.ERROR_NOT_CONNECTED = 12 IPConnection.ERROR_CONNECT_FAILED = 13 IPConnection.ERROR_INVALID_FUNCTION_ID = 21 IPConnection.ERROR_TIMEOUT = 31 IPConnection.ERROR_INVALID_PARAMETER = 41 IPConnection.ERROR_FUNCTION_NOT_SUPPORTED = 42 IPConnection.ERROR_UNKNOWN_ERROR = 43 http://www.tinkerforge.com/de/doc/Software/Bricklets/MotionDetector_Bricklet_JavaScript.html https://www.npmjs.com/package/nodejs-websocket https://devcenter.heroku.com/articles/node-websockets
100 lines
2.4 KiB
JavaScript
100 lines
2.4 KiB
JavaScript
'use strict'
|
|
|
|
var Server = require('./Server'),
|
|
Connection = require('./Connection'),
|
|
net = require('net'),
|
|
tls = require('tls'),
|
|
url = require('url')
|
|
|
|
/**
|
|
* Create a WebSocket server
|
|
* @param {Object} [options] will be passed to net.createServer() or tls.createServer(), with the additional property 'secure' (a boolean)
|
|
* @param {Function} callback will be added as 'connection' listener
|
|
* @returns {Server}
|
|
*/
|
|
exports.createServer = function (options, callback) {
|
|
if (typeof options === 'function' || !arguments.length) {
|
|
return new Server(false, options)
|
|
}
|
|
return new Server(Boolean(options.secure), options, callback)
|
|
}
|
|
|
|
/**
|
|
* Create a WebSocket client
|
|
* @param {string} URL with the format 'ws://localhost:8000/chat' (the port can be ommited)
|
|
* @param {Object} [options] will be passed to net.connect() or tls.connect()
|
|
* @param {Function} callback will be added as 'connect' listener
|
|
* @returns {Connection}
|
|
*/
|
|
exports.connect = function (URL, options, callback) {
|
|
var socket
|
|
|
|
if (typeof options === 'function') {
|
|
callback = options
|
|
options = undefined
|
|
}
|
|
options = options || {}
|
|
|
|
URL = parseWSURL(URL)
|
|
options.port = URL.port
|
|
options.host = URL.host
|
|
|
|
if (options.hasOwnProperty('extraHeaders')) {
|
|
URL.extraHeaders = options.extraHeaders
|
|
}
|
|
|
|
if (URL.secure) {
|
|
socket = tls.connect(options)
|
|
} else {
|
|
socket = net.connect(options)
|
|
}
|
|
|
|
return new Connection(socket, URL, callback)
|
|
}
|
|
|
|
/**
|
|
* Set the minimum size of a pack of binary data to send in a single frame
|
|
* @param {number} bytes
|
|
*/
|
|
exports.setBinaryFragmentation = function (bytes) {
|
|
Connection.binaryFragmentation = bytes
|
|
}
|
|
|
|
/**
|
|
* Set the maximum size the internal Buffer can grow, to avoid memory attacks
|
|
* @param {number} bytes
|
|
*/
|
|
exports.setMaxBufferLength = function (bytes) {
|
|
Connection.maxBufferLength = bytes
|
|
}
|
|
|
|
/**
|
|
* Parse the WebSocket URL
|
|
* @param {string} URL
|
|
* @returns {Object}
|
|
* @private
|
|
*/
|
|
function parseWSURL(URL) {
|
|
var parts, secure
|
|
|
|
parts = url.parse(URL)
|
|
|
|
parts.protocol = parts.protocol || 'ws:'
|
|
if (parts.protocol === 'ws:') {
|
|
secure = false
|
|
} else if (parts.protocol === 'wss:') {
|
|
secure = true
|
|
} else {
|
|
throw new Error('Invalid protocol ' + parts.protocol + '. It must be ws or wss')
|
|
}
|
|
|
|
parts.port = parts.port || (secure ? 443 : 80)
|
|
parts.path = parts.path || '/'
|
|
|
|
return {
|
|
path: parts.path,
|
|
port: parts.port,
|
|
secure: secure,
|
|
host: parts.hostname
|
|
}
|
|
} |