1 files changed, 55 insertions, 0 deletions
diff --git a/testing/xpcshell/node-ws/test/websocket.integration.js b/testing/xpcshell/node-ws/test/websocket.integration.js
new file mode 100644
index 0000000000..abd96c61e4
--- /dev/null
+++ b/testing/xpcshell/node-ws/test/websocket.integration.js
@@ -0,0 +1,55 @@
+'use strict';
+
+const assert = require('assert');
+
+const WebSocket = require('..');
+
+describe('WebSocket', () => {
+  it('communicates successfully with echo service (ws)', (done) => {
+    const ws = new WebSocket('ws://websocket-echo.com/', {
+      protocolVersion: 13
+    });
+
+    let dataReceived = false;
+
+    ws.on('open', () => {
+      ws.send('hello');
+    });
+
+    ws.on('close', () => {
+      assert.ok(dataReceived);
+      done();
+    });
+
+    ws.on('message', (message, isBinary) => {
+      dataReceived = true;
+      assert.ok(!isBinary);
+      assert.strictEqual(message.toString(), 'hello');
+      ws.close();
+    });
+  });
+
+  it('communicates successfully with echo service (wss)', (done) => {
+    const ws = new WebSocket('wss://websocket-echo.com/', {
+      protocolVersion: 13
+    });
+
+    let dataReceived = false;
+
+    ws.on('open', () => {
+      ws.send('hello');
+    });
+
+    ws.on('close', () => {
+      assert.ok(dataReceived);
+      done();
+    });
+
+    ws.on('message', (message, isBinary) => {
+      dataReceived = true;
+      assert.ok(!isBinary);
+      assert.strictEqual(message.toString(), 'hello');
+      ws.close();
+    });
+  });
+});