chore: bump version to 1.6.0

wiki.vg has been shut down and is in the process of being merged into minecraft.wiki

README.md

@@ -1,6 +1,6 @@
 # mineping
 
-`mineping` is a Javasript library thar provides Minecraft server ping protocol implementation. It can be used to collect information about the server, such as MODT, current online, server icon (java edition only) and etc.
+This JavaScript library provides an implementation of the Minecraft server ping protocol. **It allows you to gather information about a Minecraft server**, such as the MOTD, current online players, server icon (Java Edition only), and more.
 
 Mirror on my [<img src="https://git.zeldon.ru/assets/img/logo.svg" align="center" width="20" height="20"/> Git](https://git.zeldon.ru/zeldon/mineping)
 
@@ -10,6 +10,8 @@ Mirror on my [<img src="https://git.zeldon.ru/assets/img/logo.svg" align="center
 
 ## Install
 
+To install `mineping`, simply run the following command:
+
 ```
 npm i @minescope/mineping
 ```
@@ -17,6 +19,7 @@ npm i @minescope/mineping
 ## Loading and configuration the module
 
 ### ES Modules (ESM)
+If you are using ES Modules, you can import the library like this:
 
 ```js
 import { pingJava, pingBedrock } from '@minescope/mineping';
@@ -59,5 +62,7 @@ console.log(data);
 
 ## Acknowledgements
 
+Special thanks to the following projects:
+
 - [mcping](https://github.com/Scetch/mcping) crate for Rust
 - [mcping-js](https://github.com/Cryptkeeper/mcping-js) library for quering Minecraft Java Edition servers

example/parallel.js

@@ -13,6 +13,7 @@ const results = await Promise.allSettled(pingPromises);
 for (let result of results) {
     if (result.status === 'rejected') {
         console.error(result.reason);
+        break;
     }
 
     console.log(result.value);

example/single.js

@@ -0,0 +1,5 @@
+import { pingBedrock } from "../index.js";
+
+const host = "mc.nevertime.su";
+const ping = await pingBedrock(host);
+console.log(ping);

lib/bedrock.js

@@ -1,124 +1,65 @@
 /**
  * Implementation of the RakNet ping/pong protocol.
- * @see https://wiki.vg/Raknet_Protocol#Unconnected_Ping
- *
- * Data types:
- * @see https://wiki.vg/Raknet_Protocol#Data_types
+ * @see https://minecraft.wiki/w/Minecraft_Wiki:Projects/wiki.vg_merge/Raknet_Protocol
  */
 
-'use strict';
+"use strict";
 
-import dgram from 'dgram';
+import dgram from "node:dgram";
+import crypto from "node:crypto";
 
+const MAGIC = "00ffff00fefefefefdfdfdfd12345678";
 const START_TIME = new Date().getTime();
 
 /**
- * Creates a buffer with the specified length.
- * @param {number} length - The length of the buffer.
- * @returns {Buffer} - The created buffer.
+ * Creates an Unconnected Ping packet.
+ * @param {number} pingId
+ * @returns {Buffer}
+ * @see {@link https://minecraft.wiki/w/Minecraft_Wiki:Projects/wiki.vg_merge/Raknet_Protocol#Unconnected_Ping}
  */
-const createBuffer = (length) => {
-    const buffer = Buffer.alloc(length);
-    buffer[0] = 0x01;
-    return buffer;
+const createUnconnectedPingFrame = (timestamp) => {
+	const buffer = Buffer.alloc(33);
+	buffer.writeUInt8(0x01, 0); // Packet ID
+	buffer.writeBigInt64LE(BigInt(timestamp), 1); // Timestamp
+	Buffer.from(MAGIC, "hex").copy(buffer, 9); // OFFLINE_MESSAGE_DATA_ID (Magic)
+	Buffer.from(crypto.randomBytes(8)).copy(buffer, 25); // Client GUID
+	return buffer;
 };
 
 /**
- * Writes a BigInt value to the buffer at the specified offset using big-endian byte order.
- * @param {Buffer} buffer - The buffer to write to.
- * @param {number} value - The BigInt value to write.
- * @param {number} offset - The offset in the buffer to write the value.
+ * Extract Modt from Unconnected Pong Packet and convert to an object
+ * @param {Buffer} unconnectedPongPacket
+ * @returns {Object}
+ * @see {@link https://minecraft.wiki/w/Minecraft_Wiki:Projects/wiki.vg_merge/Raknet_Protocol#Unconnected_Pong}
  */
-const writeBigInt64BE = (buffer, value, offset) => {
-    buffer.writeBigInt64BE(BigInt(value), offset);
-};
+const extractModt = (unconnectedPongPacket) => {
+	// Skip everything to Modt
+	const offset = 33;
+	const length = unconnectedPongPacket.readUInt16BE(offset);
+	let modt = unconnectedPongPacket.toString(
+		"utf-8",
+		offset + 2,
+		offset + 2 + length
+	);
 
-/**
- * Copies the specified hex value to the buffer at the specified offset.
- * @param {Buffer} buffer - The buffer to copy to.
- * @param {string} hex - The hex value to copy.
- * @param {number} offset - The offset in the buffer to copy the value.
- */
-const copyHexToBuffer = (buffer, hex, offset) => {
-    Buffer.from(hex, 'hex').copy(buffer, offset);
-};
+	const components = modt.split(";");
+	const parsedComponents = {
+		edition: components[0],
+		name: components[1],
+		version: {
+			protocolVersion: Number(components[2]),
+			minecraftVersion: components[3],
+		},
+		players: {
+			online: Number(components[4]),
+			max: Number(components[5]),
+		},
+		serverId: components[6],
+		mapName: components[7],
+		gameMode: components[8],
+	};
 
-/**
- * Reads a BigInt value from the buffer at the specified offset using big-endian byte order.
- * @param {Buffer} buffer - The buffer to read from.
- * @param {number} offset - The offset in the buffer to read the value.
- * @returns {BigInt} - The read BigInt value.
- */
-const readBigInt64BE = (buffer, offset) => {
-    return buffer.readBigInt64BE(offset);
-};
-
-/**
- * Reads a string from the buffer at the specified offset.
- * @param {Buffer} buffer - The buffer to read from.
- * @param {number} offset - The offset in the buffer to read the string.
- * @returns {string} - The read string.
- */
-const readStringFromBuffer = (buffer, offset) => {
-    const length = buffer.readUInt16BE(offset);
-    return buffer.toString('utf8', offset + 2, offset + 2 + length);
-};
-
-/**
- * Parses the advertise string into an object with properties.
- * @param {string} advertiseStr - The advertise string to parse.
- * @returns {Object} - The parsed object with properties.
- */
-const parseAdvertiseString = (advertiseStr) => {
-    const parts = advertiseStr.split(';');
-    return {
-        gameId: parts[0],
-        description: parts[1],
-        protocolVersion: parts[2],
-        gameVersion: parts[3],
-        currentPlayers: parts[4],
-        maxPlayers: parts[5],
-        name: parts[7],
-        mode: parts[8]
-    };
-};
-
-/**
- * Creates an Unconnected Ping buffer.
- * @param {number} pingId - The ping ID.
- * @returns {Buffer} - The Unconnected Ping buffer.
- * @see {@link https://wiki.vg/Raknet_Protocol#Unconnected_Ping}
- */
-const UNCONNECTED_PING = (pingId) => {
-    const buffer = createBuffer(35);
-    writeBigInt64BE(buffer, pingId, 1);
-    copyHexToBuffer(buffer, '00ffff00fefefefefdfdfdfd12345678', 9);
-    writeBigInt64BE(buffer, 0, 25);
-    return buffer;
-};
-
-/**
- * Decodes an Unconnected Pong buffer and returns the parsed data.
- * @param {Buffer} buffer - The Unconnected Pong buffer.
- * @returns {Object} - The parsed Unconnected Pong data.
- * @see {@link https://wiki.vg/Raknet_Protocol#Unconnected_Pong}
- */
-const UNCONNECTED_PONG = (buffer) => {
-    const pingId = readBigInt64BE(buffer, 1);
-    const serverId = readBigInt64BE(buffer, 9);
-    let offset = 25;
-    let advertiseStr;
-
-    try {
-        advertiseStr = readStringFromBuffer(buffer, offset);
-    } catch (err) {
-        const length = parseInt(err.message.substr(err.message.indexOf(',') + 2, 3));
-        advertiseStr = buffer.toString('utf8', offset, offset + length);
-    }
-
-    const parsedAdvertiseStr = parseAdvertiseString(advertiseStr);
-
-    return { pingId, advertiseStr, serverId, offset, ...parsedAdvertiseStr };
+	return parsedComponents;
 };
 
 /**
@@ -129,76 +70,63 @@ const UNCONNECTED_PONG = (buffer) => {
  * @param {number} [timeout=5000] - The timeout duration in milliseconds.
  */
 const ping = (host, port = 19132, cb, timeout = 5000) => {
-    const socket = dgram.createSocket('udp4');
+	const socket = dgram.createSocket("udp4");
 
-    // Set manual timeout interval.
-    // This ensures the connection will NEVER hang regardless of internal state
-    const timeoutTask = setTimeout(() => {
-        socket.emit('error', new Error('Socket timeout'));
-    }, timeout);
+	// Set manual timeout interval.
+	// This ensures the connection will NEVER hang regardless of internal state
+	const timeoutTask = setTimeout(() => {
+		socket.emit("error", new Error("Socket timeout"));
+	}, timeout);
 
-    const closeSocket = () => {
-        socket.close();
-        clearTimeout(timeoutTask);
-    };
+	const closeSocket = () => {
+		socket.close();
+		clearTimeout(timeoutTask);
+	};
 
-    // Generic error handler
-    // This protects multiple error callbacks given the complex socket state
-    // This is mostly dangerous since it can swallow errors
-    let didFireError = false;
+	// Generic error handler
+	// This protects multiple error callbacks given the complex socket state
+	// This is mostly dangerous since it can swallow errors
+	let didFireError = false;
 
-    /**
-     * Handle any error that occurs during the ping process.
-     * @param {Error} err The error that occurred.
-     */
-    const handleError = (err) => {
-        closeSocket();
+	/**
+	 * Handle any error that occurs during the ping process.
+	 * @param {Error} err The error that occurred.
+	 */
+	const handleError = (err) => {
+		closeSocket();
 
-        if (!didFireError) {
-            didFireError = true;
-            cb(null, err);
-        }
-    };
+		if (!didFireError) {
+			didFireError = true;
+			cb(null, err);
+		}
+	};
 
-    try {
-        const ping = UNCONNECTED_PING(new Date().getTime() - START_TIME);
-        socket.send(ping, 0, ping.length, port, host);
-    } catch (err) {
-        handleError(err);
-    }
+	try {
+		const ping = createUnconnectedPingFrame(new Date().getTime() - START_TIME);
+		socket.send(ping, 0, ping.length, port, host);
+	} catch (err) {
+		handleError(err);
+	}
 
-    socket.on('message', (msg) => {
-        const id = msg[0];
+	socket.on("message", (pongPacket) => {
+		const id = pongPacket[0];
 
-        switch (id) {
-            case 0x1c: {
-                const pong = UNCONNECTED_PONG(msg);
-                const clientData = {
-                    version: {
-                        name: pong.name,
-                        protocol: pong.protocolVersion
-                    },
-                    players: {
-                        max: pong.maxPlayers,
-                        online: pong.currentPlayers
-                    },
-                    description: pong.description.replace(/\xA7[0-9A-FK-OR]/ig, ''),
-                    gamemode: pong.mode
-                };
+		switch (id) {
+			case 0x1c: {
+				const modtObject = extractModt(pongPacket);
+				closeSocket();
+				cb(modtObject, null);
+				break;
+			}
 
-                closeSocket();
-                cb(clientData, null);
-                break;
-            }
+			default: {
+				handleError(new Error("Received unexpected packet"));
+				break;
+			}
+		}
+	});
 
-            default: {
-                handleError(new Error('Received unexpected packet'));
-                break;
-            }
-        }
-    });
-
-    socket.on('error', handleError);
+	socket.on("error", handleError);
 };
 
 /**
@@ -209,13 +137,18 @@ const ping = (host, port = 19132, cb, timeout = 5000) => {
  * @returns {Promise<import('../types/index.js').BedrockPingResponse>}
  */
 export const pingBedrock = (host, options = {}) => {
-    if (!host) throw new Error('Host argument is not provided');
+	if (!host) throw new Error("Host argument is not provided");
 
-    const { port = 19132, timeout = 5000 } = options;
+	const { port = 19132, timeout = 5000 } = options;
 
-    return new Promise((resolve, reject) => {
-        ping(host, port, (res, err) => {
-            err ? reject(err) : resolve(res);
-        }, timeout);
-    });
+	return new Promise((resolve, reject) => {
+		ping(
+			host,
+			port,
+			(res, err) => {
+				err ? reject(err) : resolve(res);
+			},
+			timeout
+		);
+	});
 };

lib/java.js

@@ -1,136 +1,149 @@
 /**
  * Implementation of the Java Minecraft ping protocol.
- * @see https://wiki.vg/Server_List_Ping
+ * @see https://minecraft.wiki/w/Minecraft_Wiki:Projects/wiki.vg_merge/Server_List_Ping
  */
 
-'use strict';
+"use strict";
 
-import net from 'net';
-import varint from './varint.js';
-
-const PROTOCOL_VERSION = 0;
+import net from "node:net";
+import varint from "./varint.js";
 
 /**
  * Ping a Minecraft Java server.
  * @param {string} host The host of the Java server.
+ * @param {string} virtualHost The host sent in handshake.
  * @param {number} [port=25565] The port of the Java server.
  * @param {function} cb The callback function to handle the ping response.
  * @param {number} [timeout=5000] The timeout duration in milliseconds.
+ * @param {number} [protocolVersion=-1] The protocol version of the Java client.
  */
-function ping(host, port = 25565, cb, timeout = 5000) {
-    const socket = net.createConnection(({ host, port }));
+function ping(host, virtualHost, port = 25565, cb, timeout = 5000, protocolVersion = -1) {
+	const socket = net.createConnection({ host, port });
 
-    // Set manual timeout interval.
-    // This ensures the connection will NEVER hang regardless of internal state
-    const timeoutTask = setTimeout(() => {
-        socket.emit('error', new Error('Socket timeout'));
-    }, timeout);
+	// Set manual timeout interval.
+	// This ensures the connection will NEVER hang regardless of internal state
+	const timeoutTask = setTimeout(() => {
+		socket.emit("error", new Error("Socket timeout"));
+	}, timeout);
 
-    const closeSocket = () => {
-        socket.destroy();
-        clearTimeout(timeoutTask);
-    };
+	const closeSocket = () => {
+		socket.destroy();
+		clearTimeout(timeoutTask);
+	};
 
-    // Generic error handler
-    // This protects multiple error callbacks given the complex socket state
-    // This is mostly dangerous since it can swallow errors
-    let didFireError = false;
+	// Generic error handler
+	// This protects multiple error callbacks given the complex socket state
+	// This is mostly dangerous since it can swallow errors
+	let didFireError = false;
 
-    /**
-     * Handle any error that occurs during the ping process.
-     * @param {Error} err The error that occurred.
-     */
-    const handleError = (err) => {
-        closeSocket();
+	/**
+	 * Handle any error that occurs during the ping process.
+	 * @param {Error} err The error that occurred.
+	 */
+	const handleError = (err) => {
+		closeSocket();
 
-        if (!didFireError) {
-            didFireError = true;
-            cb(null, err);
-        }
-    };
+		if (!didFireError) {
+			didFireError = true;
+			cb(null, err);
+		}
+	};
 
-    // #setNoDelay instantly flushes data during read/writes
-    // This prevents the runtime from delaying the write at all
-    socket.setNoDelay(true);
+	// #setNoDelay instantly flushes data during read/writes
+	// This prevents the runtime from delaying the write at all
+	socket.setNoDelay(true);
 
-    socket.on('connect', () => {
-        const handshake = varint.concat([
-            varint.encodeInt(0),
-            varint.encodeInt(PROTOCOL_VERSION),
-            varint.encodeInt(host.length),
-            varint.encodeString(host),
-            varint.encodeUShort(port),
-            varint.encodeInt(1)
-        ]);
+	socket.on("connect", () => {
+		const handshake = varint.concat([
+			varint.encodeInt(0),
+			varint.encodeInt(protocolVersion),
+			varint.encodeInt(virtualHost.length),
+			varint.encodeString(virtualHost),
+			varint.encodeUShort(port),
+			varint.encodeInt(1),
+		]);
 
-        socket.write(handshake);
+		socket.write(handshake);
 
-        const request = varint.concat([
-            varint.encodeInt(0)
-        ]);
+		const request = varint.concat([varint.encodeInt(0)]);
 
-        socket.write(request);
-    });
+		socket.write(request);
+	});
 
-    let incomingBuffer = Buffer.alloc(0);
+	let incomingBuffer = Buffer.alloc(0);
 
-    socket.on('data', (data) => {
-        incomingBuffer = Buffer.concat([incomingBuffer, data]);
+	socket.on("data", (data) => {
+		incomingBuffer = Buffer.concat([incomingBuffer, data]);
 
-        // Wait until incomingBuffer is at least 5 bytes long to ensure it has captured the first VarInt value
-        // This value is used to determine the full read length of the response
-        // "VarInts are never longer than 5 bytes"
-        // https://wiki.vg/Data_types#VarInt_and_VarLong
-        if (incomingBuffer.length < 5) {
-            return;
-        }
+		// Wait until incomingBuffer is at least 5 bytes long to ensure it has captured the first VarInt value
+		// This value is used to determine the full read length of the response
+		// "VarInts are never longer than 5 bytes"
+		// https://minecraft.wiki/w/Minecraft_Wiki:Projects/wiki.vg_merge/Data_types#VarInt_and_VarLong
+		if (incomingBuffer.length < 5) {
+			return;
+		}
 
-        let offset = 0;
-        const packetLength = varint.decodeInt(incomingBuffer, offset);
+		let offset = 0;
+		const packetLength = varint.decodeInt(incomingBuffer, offset);
 
-        // Ensure incomingBuffer contains the full response
-        if (incomingBuffer.length - offset < packetLength) {
-            return;
-        }
+		// Ensure incomingBuffer contains the full response
+		if (incomingBuffer.length - offset < packetLength) {
+			return;
+		}
 
-        const packetId = varint.decodeInt(incomingBuffer, varint.decodeLength(packetLength));
+		const packetId = varint.decodeInt(
+			incomingBuffer,
+			varint.decodeLength(packetLength)
+		);
 
-        if (packetId === 0) {
-            const data = incomingBuffer.subarray(varint.decodeLength(packetLength) + varint.decodeLength(packetId));
-            const responseLength = varint.decodeInt(data, 0);
-            const response = data.subarray(varint.decodeLength(responseLength), varint.decodeLength(responseLength) + responseLength);
+		if (packetId === 0) {
+			const data = incomingBuffer.subarray(
+				varint.decodeLength(packetLength) + varint.decodeLength(packetId)
+			);
+			const responseLength = varint.decodeInt(data, 0);
+			const response = data.subarray(
+				varint.decodeLength(responseLength),
+				varint.decodeLength(responseLength) + responseLength
+			);
 
-            try {
-                const message = JSON.parse(response);
+			try {
+				const message = JSON.parse(response);
 
-                closeSocket();
-                cb(message, null);
-            } catch (err) {
-                handleError(err);
-            }
-        } else {
-            handleError(new Error('Received unexpected packet'));
-        }
-    });
+				closeSocket();
+				cb(message, null);
+			} catch (err) {
+				handleError(err);
+			}
+		} else {
+			handleError(new Error("Received unexpected packet"));
+		}
+	});
 
-    socket.on('error', handleError);
+	socket.on("error", handleError);
 }
 
 /**
  * Asynchronously ping Minecraft Java server.
- * The optional `options` argument can be an object with a `ping` (default is `25565`) or/and `timeout` (default is `5000`) property.
+ * The optional `options` argument can be an object with a `port` (default is `25565`) or/and `timeout` (default is `5000`) or/and `protocolVersion` (default is `-1`) property.
  * @param {string} host The Java server address.
  * @param {import('../types/index.js').PingOptions} options The configuration for pinging Minecraft Java server.
  * @returns {Promise<import('../types/index.js').JavaPingResponse>}
  */
 export function pingJava(host, options = {}) {
-    if (!host) throw new Error('Host argument is not provided');
+	if (!host) throw new Error("Host argument is not provided");
 
-    const { port = 25565, timeout = 5000 } = options;
+	const { port = 25565, timeout = 5000, protocolVersion = -1, virtualHost = null } = options;
 
-    return new Promise((resolve, reject) => {
-        ping(host, port, (res, err) => {
-            err ? reject(err) : resolve(res);
-        }, timeout);
-    });
-}
+	return new Promise((resolve, reject) => {
+		ping(
+			host,
+			virtualHost || host,
+			port,
+			(res, err) => {
+				err ? reject(err) : resolve(res);
+			},
+			timeout,
+			protocolVersion
+		);
+	});
+}

lib/varint.js

@@ -1,127 +1,131 @@
-// https://wiki.vg/Data_types
+// https://minecraft.wiki/w/Minecraft_Wiki:Projects/wiki.vg_merge/Protocol#Data_types
 
 /**
  * A utility object for encoding and decoding varints.
  */
 const varint = {
-    /**
-     * Encodes an integer value into a varint byte buffer.
-     * @param {number} val - The integer value to encode.
-     * @returns {Buffer}
-     */
-    encodeInt: (val) => {
-        // "constInts are never longer than 5 bytes"
-        // https://wiki.vg/Data_types#constInt_and_constLong
-        const buf = Buffer.alloc(5);
-        let written = 0;
+	/**
+	 * Encodes an integer value into a varint byte buffer.
+	 * @param {number} val - The integer value to encode.
+	 * @returns {Buffer}
+	 */
+	encodeInt: (val) => {
+		// "VarInts are never longer than 5 bytes"
+		// https://minecraft.wiki/w/Minecraft_Wiki:Projects/wiki.vg_merge/Data_types#VarInt_and_VarLong
+		const buf = Buffer.alloc(5);
+		let written = 0;
 
-        while (true) {
-            const byte = val & 0x7F;
-            val >>>= 7;
+		while (true) {
+			const byte = val & 0x7f;
+			val >>>= 7;
 
-            if (val === 0) {
-                buf.writeUInt8(byte, written++);
-                break;
-            }
+			if (val === 0) {
+				buf.writeUInt8(byte, written++);
+				break;
+			}
 
-            buf.writeUInt8(byte | 0x80, written++);
-        }
+			buf.writeUInt8(byte | 0x80, written++);
+		}
 
-        return buf.slice(0, written);
-    },
+		return buf.slice(0, written);
+	},
 
-    /**
-     * Encodes a string value into a UTF-8 byte buffer.
-     * @param {string} val - The string value to encode.
-     * @returns {Buffer}
-     */
-    encodeString: (val) => {
-        return Buffer.from(val, 'utf-8');
-    },
+	/**
+	 * Encodes a string value into a UTF-8 byte buffer.
+	 * @param {string} val - The string value to encode.
+	 * @returns {Buffer}
+	 */
+	encodeString: (val) => {
+		return Buffer.from(val, "utf-8");
+	},
 
-    /**
-     * Encodes an unsigned short value into a byte buffer.
-     * @param {number} val - The unsigned short value to encode.
-     * @returns {Buffer}
-     */
-    encodeUShort: (val) => {
-        return Buffer.from([val >> 8, val & 0xFF]);
-    },
+	/**
+	 * Encodes an unsigned short value into a byte buffer.
+	 * @param {number} val - The unsigned short value to encode.
+	 * @returns {Buffer}
+	 */
+	encodeUShort: (val) => {
+		return Buffer.from([val >> 8, val & 0xff]);
+	},
 
-    /**
-     * Concatenates multiple byte buffers into a single byte buffer.
-     * @param {Buffer[]} chunks - An array of byte buffers to concatenate.
-     * @returns {Buffer}
-     */
-    concat: (chunks) => {
-        let length = 0;
+	/**
+	 * Concatenates multiple byte buffers into a single byte buffer.
+	 * @param {Buffer[]} chunks - An array of byte buffers to concatenate.
+	 * @returns {Buffer}
+	 */
+	concat: (chunks) => {
+		let length = 0;
 
-        for (const chunk of chunks) {
-            length += chunk.length;
-        }
+		for (const chunk of chunks) {
+			length += chunk.length;
+		}
 
-        const buffer = [
-            varint.encodeInt(length),
-            ...chunks
-        ];
+		const buffer = [varint.encodeInt(length), ...chunks];
 
-        return Buffer.concat(buffer);
-    },
+		return Buffer.concat(buffer);
+	},
 
-    /**
-     * Decodes a varint integer value from a byte buffer.
-     * @param {Buffer} buffer - The byte buffer to decode from.
-     * @param {number} offset - The offset in the buffer to start decoding from.
-     * @returns {number}
-     */
-    decodeInt: (buffer, offset) => {
-        let val = 0;
-        let count = 0;
+	/**
+	 * Decodes a varint integer value from a byte buffer.
+	 * @param {Buffer} buffer - The byte buffer to decode from.
+	 * @param {number} offset - The offset in the buffer to start decoding from.
+	 * @returns {number}
+	 */
+	decodeInt: (buffer, offset) => {
+		let val = 0;
+		let count = 0;
 
-        while (true) {
-            const byte = buffer.readUInt8(offset++);
+		while (true) {
+			const byte = buffer.readUInt8(offset++);
 
-            val |= (byte & 0x7F) << count++ * 7;
+			val |= (byte & 0x7f) << (count++ * 7);
 
-            if ((byte & 0x80) !== 0x80) {
-                break;
-            }
-        }
+			if ((byte & 0x80) !== 0x80) {
+				break;
+			}
+		}
 
-        return val;
-    },
+		return val;
+	},
 
-    /**
-     * Calculates the number of bytes required to decode a varint integer value.
-     * @param {number} val - The varint integer value.
-     * @returns {5 | 7 | 8 | 1 | 2 | 3 | 4 | 6 | 9 | 10}
-     */
-    decodeLength: (val) => {
-        // Constants representing the powers of 2 used for comparison
-        const N1 = Math.pow(2, 7);
-        const N2 = Math.pow(2, 14);
-        const N3 = Math.pow(2, 21);
-        const N4 = Math.pow(2, 28);
-        const N5 = Math.pow(2, 35);
-        const N6 = Math.pow(2, 42);
-        const N7 = Math.pow(2, 49);
-        const N8 = Math.pow(2, 56);
-        const N9 = Math.pow(2, 63);
+	/**
+	 * Calculates the number of bytes required to decode a varint integer value.
+	 * @param {number} val - The varint integer value.
+	 * @returns {5 | 7 | 8 | 1 | 2 | 3 | 4 | 6 | 9 | 10}
+	 */
+	decodeLength: (val) => {
+		// Constants representing the powers of 2 used for comparison
+		const N1 = Math.pow(2, 7);
+		const N2 = Math.pow(2, 14);
+		const N3 = Math.pow(2, 21);
+		const N4 = Math.pow(2, 28);
+		const N5 = Math.pow(2, 35);
+		const N6 = Math.pow(2, 42);
+		const N7 = Math.pow(2, 49);
+		const N8 = Math.pow(2, 56);
+		const N9 = Math.pow(2, 63);
 
-        // Return the number of bytes required based on the value
-        return (
-            val < N1 ? 1
-                : val < N2 ? 2
-                    : val < N3 ? 3
-                        : val < N4 ? 4
-                            : val < N5 ? 5
-                                : val < N6 ? 6
-                                    : val < N7 ? 7
-                                        : val < N8 ? 8
-                                            : val < N9 ? 9
-                                                : 10
-        );
-    }
+		// Return the number of bytes required based on the value
+		return val < N1
+			? 1
+			: val < N2
+			? 2
+			: val < N3
+			? 3
+			: val < N4
+			? 4
+			: val < N5
+			? 5
+			: val < N6
+			? 6
+			: val < N7
+			? 7
+			: val < N8
+			? 8
+			: val < N9
+			? 9
+			: 10;
+	},
 };
 
 export default varint;

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@minescope/mineping",
-  "version": "1.1.1",
+  "version": "1.6.0",
   "description": "Ping both Minecraft Bedrock and Java servers.",
   "main": "index.js",
   "types": "types/index.d.ts",

types/lib/bedrock.d.ts

@@ -2,22 +2,25 @@
  * @param port The server port.
  * @param timeout The read/write socket timeout.
  */
-export type PingOptions = {
-    port: number,
-    timeout: number;
+export type BedrockPingOptions = {
+    port?: number;
+    timeout?: number;
 };
 
 export type BedrockPingResponse = {
+    edition: string;
+    name: string;
     version: {
-        name: string;
-        protocol: string;
+        protocolVersion: number;
+        minecraftVersion: string;
     };
     players: {
-        max: string;
-        online: string;
+        online: number;
+        max: number;
     };
-    description: string;
-    gamemode: string;
+    serverId: string;
+    mapName: string;
+    gameMode: string;
 };
 
 /**
@@ -26,6 +29,7 @@ export type BedrockPingResponse = {
  * The optional `options` argument can be an object with a `ping` (default is `19132`) or/and `timeout` (default is `5000`) property.
  * 
  * @param host The Bedrock server address.
+ * @param options The configuration for pinging Minecraft Bedrock server.
  * 
  * ```js
  * import { pingBedrock } from '@minescope/mineping';
@@ -45,5 +49,5 @@ export type BedrockPingResponse = {
  * ```
  * @see [source](https://github.com/minescope/mineping/blob/915edbec9c9ad811459458600af3531ec0836911/lib/bedrock.js#L204)
  */
-export function pingBedrock(host: string, options?: PingOptions): Promise<BedrockPingResponse>;
+export function pingBedrock(host: string, options?: BedrockPingOptions): Promise<BedrockPingResponse>;
 

types/lib/java.d.ts

@@ -1,43 +1,53 @@
-import { PingOptions } from "./bedrock";
+/**
+ * @param port The server port.
+ * @param timeout The read/write socket timeout.
+ * @param protocolVersion The protocol version.
+ */
+export type JavaPingOptions = {
+	port?: number | undefined;
+	timeout?: number | undefined;
+	protocolVersion?: number | undefined;
+	virtualHost?: string | undefined;
+};
 
 /**
  * JSON format chat component used for description field.
- * @see https://wiki.vg/Chat
+ * @see https://minecraft.wiki/w/Minecraft_Wiki:Projects/wiki.vg_merge/Chat
  */
 export type ChatComponent = {
-    text: string;
-    bold?: boolean;
-    italic?: boolean;
-    underlined?: boolean;
-    strikethrough?: boolean;
-    obfuscated?: boolean;
-    color?: string;
-    extra?: ChatComponent[];
+	text: string;
+	bold?: boolean;
+	italic?: boolean;
+	underlined?: boolean;
+	strikethrough?: boolean;
+	obfuscated?: boolean;
+	color?: string;
+	extra?: ChatComponent[];
 };
 
 export type SampleProp = {
-    name: string,
-    id: string;
+	name: string;
+	id: string;
 };
 
 /**
  * `JSON Response` field of Response packet.
- * @see https://wiki.vg/Server_List_Ping#Response
+ * @see https://minecraft.wiki/w/Minecraft_Wiki:Projects/wiki.vg_merge/Server_List_Ping#Status_Response
  */
 export type JavaPingResponse = {
-    version: {
-        name: string;
-        protocol: number;
-    };
-    players: {
-        max: number;
-        online: number;
-        sample?: SampleProp[];
-    };
-    description: string | ChatComponent;
-    favicon?: string;
-    enforcesSecureChat?: boolean;
-    previewsChat?: boolean;
+	version: {
+		name: string;
+		protocol: number;
+	};
+	players: {
+		max: number;
+		online: number;
+		sample?: SampleProp[];
+	};
+	description: string | ChatComponent;
+	favicon?: string;
+	enforcesSecureChat?: boolean;
+	previewsChat?: boolean;
 };
 
 /**
@@ -67,5 +77,7 @@ export type JavaPingResponse = {
  * ```
  * @see [source](https://github.com/minescope/mineping/blob/915edbec9c9ad811459458600af3531ec0836911/lib/java.js#L117)
  */
-export function pingJava(host: string, options?: PingOptions): Promise<JavaPingResponse>;
-
+export function pingJava(
+	host: string,
+	options?: JavaPingOptions
+): Promise<JavaPingResponse>;