|
1 | | -const net = require('net'); |
2 | | -const Errors = require('../Errors'); |
3 | | -const ServerInfo = require('../structures/ServerInfo'); |
4 | | -const varInt = require('../utils/varInt'); |
5 | | -const packetsToSend = ['1500E0050E6D632E6879706978656C2E6E657463DD01', '0100', '09010000000000000000'].map((x) => Buffer.from(x, 'hex')); // To avoid dependency hell, these are precompiled as hex. |
6 | | -module.exports = async function (repeats) { |
7 | | - if (repeats < 0 || typeof repeats !== 'number') repeats = 3; |
8 | | - if (repeats > 10) repeats = 10; |
9 | | - let aggregatedData = ''; |
10 | | - let dataLength = 0; |
11 | | - return await new Promise((resolve, reject) => { |
12 | | - const cli = net.createConnection(25565, 'mc.hypixel.net', () => { |
13 | | - cli.write(packetsToSend[0]); |
14 | | - cli.write(packetsToSend[1]); |
15 | | - }); |
16 | | - cli.on('error', () => { |
17 | | - reject(Errors.CONNECTION_ERROR); |
18 | | - }); |
19 | | - cli.on('data', async (data) => { |
20 | | - if (!aggregatedData) { |
21 | | - const varIntBorder = data.findIndex((x) => x === 0x00) + 1; |
22 | | - dataLength = varInt( |
23 | | - data |
24 | | - .toString('hex', 0, varIntBorder) |
25 | | - .match(/(..)/g) |
26 | | - .map((x) => parseInt(x, 16)) |
27 | | - ); |
28 | | - dataLength -= varIntBorder * 8; |
29 | | - aggregatedData += data.toString('utf-8', 5); |
30 | | - } else aggregatedData += data.toString('utf-8'); |
31 | | - |
32 | | - if (dataLength >= aggregatedData.length) return; |
33 | | - cli.removeAllListeners('data'); // Remove this listener |
34 | | - resolve(parseData(aggregatedData, await getPing(repeats, cli))); |
35 | | - }); |
36 | | - }); |
37 | | -}; |
38 | | -/** |
39 | | - * Gets hypixel's ping |
40 | | - * @param {number} amount Amount of times to ping |
41 | | - * @param {net.Socket} cli Socket connected to hypixel |
42 | | - * @returns {number} |
43 | | - */ |
44 | | -async function getPing(amount, cli) { |
45 | | - let pingSum = 0; |
46 | | - for (let i = 0; i < amount; i++) { |
47 | | - pingSum += await ping(cli); |
48 | | - } |
49 | | - cli.destroy(); |
50 | | - return Math.round(pingSum / amount); |
51 | | -} |
52 | | -/** |
53 | | - * Pings hypixel |
54 | | - * @param {net.Socket} cli Client socket, connected to hypixel. |
55 | | - * @returns {number} Ping |
56 | | - */ |
57 | | -async function ping(cli) { |
58 | | - await cli.write(packetsToSend[2]); |
59 | | - const time = Date.now(); |
60 | | - return new Promise((resolve) => { |
61 | | - cli.once('data', () => { |
62 | | - resolve(Date.now() - time); |
63 | | - }); |
64 | | - }); |
65 | | -} |
66 | | -/** |
67 | | - * Parses the MOTD & Server status |
68 | | - * @param {string} stringJson Parseable JSON string |
69 | | - * @param {number} ping Ping of the server |
70 | | - * @returns {Object} Object |
71 | | - */ |
72 | | -function parseData(stringJson, ping) { |
73 | | - try { |
74 | | - return new ServerInfo(JSON.parse(stringJson), ping); |
75 | | - } catch (e) { |
76 | | - return undefined; |
77 | | - } |
78 | | -} |
| 1 | +const net = require('net'); |
| 2 | +const Errors = require('../Errors'); |
| 3 | +const ServerInfo = require('../structures/ServerInfo'); |
| 4 | +const varInt = require('../utils/varInt'); |
| 5 | +const packetsToSend = ['1500E0050E6D632E6879706978656C2E6E657463DD01', '0100', '09010000000000000000'].map((x) => Buffer.from(x, 'hex')); // To avoid dependency hell, these are precompiled as hex. |
| 6 | +module.exports = async function (repeats) { |
| 7 | + if (repeats < 0 || typeof repeats !== 'number') repeats = 3; |
| 8 | + if (repeats > 10) repeats = 10; |
| 9 | + let aggregatedData = ''; |
| 10 | + let dataLength = 0; |
| 11 | + return await new Promise((resolve, reject) => { |
| 12 | + const cli = net.createConnection(25565, 'mc.hypixel.net', () => { |
| 13 | + cli.write(packetsToSend[0]); |
| 14 | + cli.write(packetsToSend[1]); |
| 15 | + }); |
| 16 | + cli.on('error', () => { |
| 17 | + reject(Errors.CONNECTION_ERROR); |
| 18 | + }); |
| 19 | + cli.on('data', async (data) => { |
| 20 | + if (!aggregatedData) { |
| 21 | + const varIntBorder = data.findIndex((x) => x === 0x00) + 1; |
| 22 | + dataLength = varInt( |
| 23 | + data |
| 24 | + .toString('hex', 0, varIntBorder) |
| 25 | + .match(/(..)/g) |
| 26 | + .map((x) => parseInt(x, 16)) |
| 27 | + ); |
| 28 | + dataLength -= varIntBorder * 8; |
| 29 | + aggregatedData += data.toString('utf-8', 5); |
| 30 | + } else aggregatedData += data.toString('utf-8'); |
| 31 | + |
| 32 | + if (dataLength >= aggregatedData.length) return; |
| 33 | + cli.removeAllListeners('data'); // Remove this listener |
| 34 | + resolve(parseData(aggregatedData, await getPing(repeats, cli))); |
| 35 | + }); |
| 36 | + }); |
| 37 | +}; |
| 38 | +/** |
| 39 | + * Gets hypixel's ping |
| 40 | + * @param {number} amount Amount of times to ping |
| 41 | + * @param {net.Socket} cli Socket connected to hypixel |
| 42 | + * @returns {number} |
| 43 | + */ |
| 44 | +async function getPing(amount, cli) { |
| 45 | + let pingSum = 0; |
| 46 | + for (let i = 0; i < amount; i++) { |
| 47 | + pingSum += await ping(cli); |
| 48 | + } |
| 49 | + cli.destroy(); |
| 50 | + return Math.round(pingSum / amount); |
| 51 | +} |
| 52 | +/** |
| 53 | + * Pings hypixel |
| 54 | + * @param {net.Socket} cli Client socket, connected to hypixel. |
| 55 | + * @returns {number} Ping |
| 56 | + */ |
| 57 | +async function ping(cli) { |
| 58 | + await cli.write(packetsToSend[2]); |
| 59 | + const time = Date.now(); |
| 60 | + return new Promise((resolve) => { |
| 61 | + cli.once('data', () => { |
| 62 | + resolve(Date.now() - time); |
| 63 | + }); |
| 64 | + }); |
| 65 | +} |
| 66 | +/** |
| 67 | + * Parses the MOTD & Server status |
| 68 | + * @param {string} stringJson Parseable JSON string |
| 69 | + * @param {number} ping Ping of the server |
| 70 | + * @returns {Object} Object |
| 71 | + */ |
| 72 | +function parseData(stringJson, ping) { |
| 73 | + try { |
| 74 | + return new ServerInfo(JSON.parse(stringJson), ping); |
| 75 | + } catch (e) { |
| 76 | + return undefined; |
| 77 | + } |
| 78 | +} |
0 commit comments