Initial commit
[yaffs-website] / node_modules / websocket-driver / examples / tcp_server.js
1 var net       = require('net'),
2     websocket = require('..'),
3     deflate   = require('permessage-deflate');
4
5 var server = net.createServer(function(connection) {
6   var driver = websocket.server();
7   driver.addExtension(deflate);
8
9   driver.on('connect', function() {
10     if (websocket.isWebSocket(driver)) driver.start();
11   });
12
13   driver.on('close', function() { connection.end() });
14   connection.on('error', function() {});
15
16   connection.pipe(driver.io);
17   driver.io.pipe(connection);
18
19   driver.messages.pipe(driver.messages);
20 });
21
22 server.listen(process.argv[2]);