Skip to content

Commit a572ac6

Browse files
committed
Added inline test expectations for WebSocket
1 parent 68f6f9f commit a572ac6

File tree

6 files changed

+41
-39
lines changed

6 files changed

+41
-39
lines changed
Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1,32 +1,32 @@
11
(function () {
2-
const socket = new WebSocket('ws://localhost:8080');
2+
const socket = new WebSocket('ws://localhost:8080'); // $clientSocket
33

44
socket.addEventListener('open', function (event) {
5-
socket.send('Hi from browser!');
5+
socket.send('Hi from browser!'); // $clientSend
66
});
77

88
socket.addEventListener('message', function (event) {
99
console.log('Message from server ', event.data);
10-
});
10+
}); // $clientReceive
1111

1212
socket.onmessage = function (event) {
1313
console.log("Message from server 2", event.data)
14-
};
14+
}; // $clientReceive
1515
})();
1616

1717

1818
(function () {
19-
var sock = new SockJS('http://0.0.0.0:9999/echo');
19+
var sock = new SockJS('http://0.0.0.0:9999/echo'); // $clientSocket
2020
sock.onopen = function () {
21-
sock.send('test');
21+
sock.send('test'); // $clientSend
2222
};
2323

2424
sock.onmessage = function (e) {
2525
console.log('message', e.data);
2626
sock.close();
27-
};
27+
}; // $clientReceive
2828

2929
sock.addEventListener('message', function (event) {
3030
console.log('Using addEventListener ', event.data);
31-
});
32-
})
31+
}); // $clientReceive
32+
})();
Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,13 @@
11
(function () {
22
const WebSocket = require('ws');
33

4-
const ws = new WebSocket('ws://example.org');
4+
const ws = new WebSocket('ws://example.org'); // $clientSocket
55

66
ws.on('open', function open() {
7-
ws.send('Hi from client!');
7+
ws.send('Hi from client!'); // $clientSend
88
});
99

1010
ws.on('message', function incoming(data) {
1111
console.log(data);
12-
});
13-
})();
12+
}); // $clientReceive
13+
})();

javascript/ql/test/library-tests/frameworks/WebSocket/server.js

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -3,11 +3,11 @@
33

44
const wss = new WebSocket.Server({ port: 8080 });
55

6-
wss.on('connection', function connection(ws) {
7-
ws.on('message', function incoming(message) {
6+
wss.on('connection', function connection(ws) { // $serverSocket
7+
ws.on('message', function incoming(message) { // $remoteFlow
88
console.log('received: %s', message);
9-
});
9+
}); // $serverReceive
1010

11-
ws.send('Hi from server!');
11+
ws.send('Hi from server!'); // $serverSend
1212
});
13-
})();
13+
})();

javascript/ql/test/library-tests/frameworks/WebSocket/sockjs.js

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -5,11 +5,11 @@ const sockjs = require('sockjs');
55
const app = express();
66
const server = http.createServer(app);
77
const sockjs_echo = sockjs.createServer({});
8-
sockjs_echo.on('connection', function (conn) {
9-
conn.on('data', function (message) {
8+
sockjs_echo.on('connection', function (conn) { // $serverSocket
9+
conn.on('data', function (message) { // $remoteFlow
1010
var data = JSON.parse(message);
11-
conn.write(JSON.stringify(eval(data.test)));
12-
});
11+
conn.write(JSON.stringify(eval(data.test))); // $serverSend
12+
}); // $serverReceive
1313
});
1414

1515
sockjs_echo.installHandlers(server, { prefix: '/echo' });
Lines changed: 17 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -1,26 +1,17 @@
1-
clientSocket
2-
| browser.js:2:17:2:52 | new Web ... :8080') |
3-
| browser.js:19:13:19:50 | new Soc ... /echo') |
4-
| client.js:4:13:4:45 | new Web ... e.org') |
5-
clientSend
6-
| browser.js:5:3:5:33 | socket. ... wser!') |
7-
| browser.js:21:3:21:19 | sock.send('test') |
8-
| client.js:7:3:7:28 | ws.send ... ient!') |
91
clientReceive
102
| browser.js:8:37:10:2 | functio ... ta);\\n\\t} |
113
| browser.js:12:21:14:2 | functio ... ata)\\n\\t} |
124
| browser.js:24:19:27:2 | functio ... e();\\n\\t} |
135
| browser.js:29:35:31:2 | functio ... ta);\\n\\t} |
146
| client.js:10:19:12:2 | functio ... ta);\\n\\t} |
15-
serverSocket
16-
| server.js:6:43:6:44 | ws |
17-
| sockjs.js:8:40:8:43 | conn |
18-
serverSend
19-
| server.js:11:3:11:28 | ws.send ... rver!') |
20-
| sockjs.js:11:9:11:51 | conn.wr ... test))) |
21-
serverReceive
22-
| server.js:7:3:9:4 | ws.on(' ... );\\n\\t\\t}) |
23-
| sockjs.js:9:5:12:6 | conn.on ... \\n }) |
7+
clientSend
8+
| browser.js:5:3:5:33 | socket. ... wser!') |
9+
| browser.js:21:3:21:19 | sock.send('test') |
10+
| client.js:7:3:7:28 | ws.send ... ient!') |
11+
clientSocket
12+
| browser.js:2:17:2:52 | new Web ... :8080') |
13+
| browser.js:19:13:19:50 | new Soc ... /echo') |
14+
| client.js:4:13:4:45 | new Web ... e.org') |
2415
flowSteps
2516
| browser.js:5:15:5:32 | 'Hi from browser!' | server.js:7:38:7:44 | message |
2617
| browser.js:21:13:21:18 | 'test' | sockjs.js:9:31:9:37 | message |
@@ -33,3 +24,12 @@ flowSteps
3324
remoteFlow
3425
| server.js:7:38:7:44 | message |
3526
| sockjs.js:9:31:9:37 | message |
27+
serverReceive
28+
| server.js:7:3:9:4 | ws.on(' ... );\\n\\t\\t}) |
29+
| sockjs.js:9:5:12:6 | conn.on ... \\n }) |
30+
serverSend
31+
| server.js:11:3:11:28 | ws.send ... rver!') |
32+
| sockjs.js:11:9:11:51 | conn.wr ... test))) |
33+
serverSocket
34+
| server.js:6:43:6:44 | ws |
35+
| sockjs.js:8:40:8:43 | conn |
Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
query: test.ql
2+
postprocess: utils/test/InlineExpectationsTestQuery.ql

0 commit comments

Comments
 (0)