1 | var Socket = require('../')
|
2 | var test = require('tape')
|
3 |
|
4 | var SOCKET_SERVER = 'wss://echo.websocket.org'
|
5 |
|
6 | test('echo string', function (t) {
|
7 | t.plan(3)
|
8 |
|
9 | var socket = new Socket(SOCKET_SERVER)
|
10 | socket.on('connect', function () {
|
11 | t.pass('connect emitted')
|
12 | socket.send('sup!')
|
13 | socket.on('data', function (data) {
|
14 | t.equal(data.toString(), 'sup!')
|
15 |
|
16 | socket.destroy(function () {
|
17 | t.pass('destroyed socket')
|
18 | })
|
19 | })
|
20 | })
|
21 | })
|
22 |
|
23 | test('echo Uint8Array', function (t) {
|
24 | t.plan(4)
|
25 |
|
26 | var socket = new Socket(SOCKET_SERVER)
|
27 | socket.on('connect', function () {
|
28 | t.pass('connect emitted')
|
29 | socket.send(new Uint8Array([1, 2, 3]))
|
30 | socket.on('data', function (data) {
|
31 | t.ok(Buffer.isBuffer(data), 'data is Buffer')
|
32 | t.deepEqual(data, new Buffer([1, 2, 3]), 'got correct data')
|
33 |
|
34 | socket.destroy(function () {
|
35 | t.pass('destroyed socket')
|
36 | })
|
37 | })
|
38 | })
|
39 | })
|
40 |
|
41 | test('echo Buffer', function (t) {
|
42 | t.plan(4)
|
43 |
|
44 | var socket = new Socket(SOCKET_SERVER)
|
45 | socket.on('connect', function () {
|
46 | t.pass('connect emitted')
|
47 | socket.send(new Buffer([1, 2, 3]))
|
48 | socket.on('data', function (data) {
|
49 | t.ok(Buffer.isBuffer(data), 'data is Buffer')
|
50 | t.deepEqual(data, new Buffer([1, 2, 3]), 'got correct data')
|
51 |
|
52 | socket.destroy(function () {
|
53 | t.pass('destroyed socket')
|
54 | })
|
55 | })
|
56 | })
|
57 | })
|
58 |
|
59 | test('echo ArrayBuffer', function (t) {
|
60 | t.plan(4)
|
61 |
|
62 | var socket = new Socket(SOCKET_SERVER)
|
63 | socket.on('connect', function () {
|
64 | t.pass('connect emitted')
|
65 | socket.send(new Uint8Array([1, 2, 3]).buffer)
|
66 | socket.on('data', function (data) {
|
67 | t.ok(Buffer.isBuffer(data), 'data is Buffer')
|
68 | t.deepEqual(data, new Buffer([1, 2, 3]), 'got correct data')
|
69 |
|
70 | socket.destroy(function () {
|
71 | t.pass('destroyed socket')
|
72 | })
|
73 | })
|
74 | })
|
75 | })
|
76 |
|
77 | test('Socket.WEBSOCKET_SUPPORT', function (t) {
|
78 | t.ok(Socket.WEBSOCKET_SUPPORT)
|
79 | t.end()
|
80 | })
|