summaryrefslogtreecommitdiffhomepage
path: root/test/node/websockets/mirror/app.js
diff options
context:
space:
mode:
authorAndrey Zelenkov <zelenkov@nginx.com>2019-08-22 15:33:41 +0300
committerAndrey Zelenkov <zelenkov@nginx.com>2019-08-22 15:33:41 +0300
commit9bbf54e23e185e94054072fff2673f6f5cd203e9 (patch)
tree2ed538061b65259a1bb221f25d637740feb9906e /test/node/websockets/mirror/app.js
parent08601bbbf07a462924e4c6894b5fd6e83b7725ac (diff)
downloadunit-9bbf54e23e185e94054072fff2673f6f5cd203e9.tar.gz
unit-9bbf54e23e185e94054072fff2673f6f5cd203e9.tar.bz2
Tests: Node.js websockets.
Diffstat (limited to 'test/node/websockets/mirror/app.js')
-rwxr-xr-xtest/node/websockets/mirror/app.js31
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) {});
+});