-
Notifications
You must be signed in to change notification settings - Fork 6
/
feeder_cli.js
65 lines (58 loc) · 1.88 KB
/
feeder_cli.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
#!/usr/bin/env node
'use strict';
const random = require("./randomGenerators");
const WebSocket = require('ws');
const args = require('minimist')(process.argv.slice(2))
const host = "ws://localhost:" + require("./src/config/app").crustWsPort;
const sendIterative = (count) => {
const logs = [];
for (var i = 0; i < count; i++) {
const peer_requester = {
id: random.randomId(),
name: random.randomName(),
ip: random.randomIP(args["startIp"], args["endIp"]),
nat_type: random.randomNatType(),
os: random.randomOS(),
}
const peer_responder = {
id: random.randomId(),
name: random.randomName(),
ip: random.randomIP(args["startIp"], args["endIp"]),
nat_type: random.randomNatType(),
os: random.randomOS(),
}
const is_direct_successful = random.randomBoolean();
const udp_hole_punch_result = random.randomFailSucceed();
const tcp_hole_punch_result = random.randomFailSucceed();
logs.push({
message: JSON.stringify({
peer_requester,
peer_responder,
tcp_hole_punch_result,
udp_hole_punch_result,
is_direct_successful
})
});
}
return logs;
}
let ws = new WebSocket(host);
function error(i, err) {
console.log(`send log ${i}:` + (err ? ` Failed ${err}` : ` Success`));
ws.close();
}
ws.on('open', () => {
console.log('connected to ws server');
const logs = sendIterative(args['count'] || 100);
logs.forEach((log, i) => {
ws.send(JSON.stringify(log), (err) => {
error(i, err);
if (args['showlog'] === "true")
console.log(`${JSON.stringify(log)}\n`);
});
}
);
});
ws.on('close', function close() {
console.log('disconnected');
});