diff options
author | Andrey Zelenkov <zelenkov@nginx.com> | 2019-08-22 15:33:41 +0300 |
---|---|---|
committer | Andrey Zelenkov <zelenkov@nginx.com> | 2019-08-22 15:33:41 +0300 |
commit | 9bbf54e23e185e94054072fff2673f6f5cd203e9 (patch) | |
tree | 2ed538061b65259a1bb221f25d637740feb9906e /test/node/websockets/mirror/app.js | |
parent | 08601bbbf07a462924e4c6894b5fd6e83b7725ac (diff) | |
download | unit-9bbf54e23e185e94054072fff2673f6f5cd203e9.tar.gz unit-9bbf54e23e185e94054072fff2673f6f5cd203e9.tar.bz2 |
Tests: Node.js websockets.
Diffstat (limited to 'test/node/websockets/mirror/app.js')
-rwxr-xr-x | test/node/websockets/mirror/app.js | 31 |
1 files changed, 31 insertions, 0 deletions
diff --git a/test/node/websockets/mirror/app.js b/test/node/websockets/mirror/app.js new file mode 100755 index 00000000..23746465 --- /dev/null +++ b/test/node/websockets/mirror/app.js @@ -0,0 +1,31 @@ +#!/usr/bin/env node + +server = require('unit-http').createServer(function() {}); +webSocketServer = require('unit-http/websocket').server; +//server = require('http').createServer(function() {}); +//webSocketServer = require('websocket').server; + +server.listen(7080, function() {}); + +var wsServer = new webSocketServer({ + maxReceivedMessageSize: 0x1000000000, + maxReceivedFrameSize: 0x1000000000, + fragmentOutgoingMessages: false, + fragmentationThreshold: 0x1000000000, + httpServer: server, +}); + +wsServer.on('request', function(request) { + var connection = request.accept(null); + + connection.on('message', function(message) { + if (message.type === 'utf8') { + connection.send(message.utf8Data); + } else if (message.type === 'binary') { + connection.send(message.binaryData); + } + + }); + + connection.on('close', function(r) {}); +}); |