chore: bump version to 1.6.0

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

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
+ * @see https://minecraft.wiki/w/Minecraft_Wiki:Projects/wiki.vg_merge/Raknet_Protocol
- *
- * Data types:
- * @see https://wiki.vg/Raknet_Protocol#Data_types
  */
 
-'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.
+ * Creates an Unconnected Ping packet.
- * @param {number} length - The length of the buffer.
+ * @param {number} pingId
- * @returns {Buffer} - The created buffer.
+ * @returns {Buffer}
+ * @see {@link https://minecraft.wiki/w/Minecraft_Wiki:Projects/wiki.vg_merge/Raknet_Protocol#Unconnected_Ping}
  */
-const createBuffer = (length) => {
+const createUnconnectedPingFrame = (timestamp) => {
-    const buffer = Buffer.alloc(length);
+	const buffer = Buffer.alloc(33);
-    buffer[0] = 0x01;
+	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.
+ * Extract Modt from Unconnected Pong Packet and convert to an object
- * @param {Buffer} buffer - The buffer to write to.
+ * @param {Buffer} unconnectedPongPacket
- * @param {number} value - The BigInt value to write.
+ * @returns {Object}
- * @param {number} offset - The offset in the buffer to write the value.
+ * @see {@link https://minecraft.wiki/w/Minecraft_Wiki:Projects/wiki.vg_merge/Raknet_Protocol#Unconnected_Pong}
  */
-const writeBigInt64BE = (buffer, value, offset) => {
+const extractModt = (unconnectedPongPacket) => {
-    buffer.writeBigInt64BE(BigInt(value), offset);
+	// Skip everything to Modt
+	const offset = 33;
+	const length = unconnectedPongPacket.readUInt16BE(offset);
+	let modt = unconnectedPongPacket.toString(
+		"utf-8",
+		offset + 2,
+		offset + 2 + length
+	);
+
+	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],
 	};
 
-/**
+	return parsedComponents;
- * 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);
-};
-
-/**
- * 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 };
 };
 
 /**
@@ -129,12 +70,12 @@ 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'));
+		socket.emit("error", new Error("Socket timeout"));
 	}, timeout);
 
 	const closeSocket = () => {
@@ -161,44 +102,31 @@ const ping = (host, port = 19132, cb, timeout = 5000) => {
 	};
 
 	try {
-        const ping = UNCONNECTED_PING(new Date().getTime() - START_TIME);
+		const ping = createUnconnectedPingFrame(new Date().getTime() - START_TIME);
 		socket.send(ping, 0, ping.length, port, host);
 	} catch (err) {
 		handleError(err);
 	}
 
-    socket.on('message', (msg) => {
+	socket.on("message", (pongPacket) => {
-        const id = msg[0];
+		const id = pongPacket[0];
 
 		switch (id) {
 			case 0x1c: {
-                const pong = UNCONNECTED_PONG(msg);
+				const modtObject = extractModt(pongPacket);
-                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
-                };
-
 				closeSocket();
-                cb(clientData, null);
+				cb(modtObject, null);
 				break;
 			}
 
 			default: {
-                handleError(new Error('Received unexpected packet'));
+				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;
 
 	return new Promise((resolve, reject) => {
-        ping(host, port, (res, err) => {
+		ping(
+			host,
+			port,
+			(res, err) => {
 				err ? reject(err) : resolve(res);
-        }, timeout);
+			},
+			timeout
+		);
 	});
 };

lib/java.js

@@ -1,28 +1,29 @@
 /**
  * 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 net from "node:net";
-import varint from './varint.js';
+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, protocolVersion = -1) {
+function ping(host, virtualHost, port = 25565, cb, timeout = 5000, protocolVersion = -1) {
-    const socket = net.createConnection(({ host, port }));
+	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'));
+		socket.emit("error", new Error("Socket timeout"));
 	}, timeout);
 
 	const closeSocket = () => {
@@ -52,34 +53,32 @@ function ping(host, port = 25565, cb, timeout = 5000, protocolVersion = -1) {
 	// This prevents the runtime from delaying the write at all
 	socket.setNoDelay(true);
 
-    socket.on('connect', () => {
+	socket.on("connect", () => {
 		const handshake = varint.concat([
 			varint.encodeInt(0),
 			varint.encodeInt(protocolVersion),
-            varint.encodeInt(host.length),
+			varint.encodeInt(virtualHost.length),
-            varint.encodeString(host),
+			varint.encodeString(virtualHost),
 			varint.encodeUShort(port),
-            varint.encodeInt(1)
+			varint.encodeInt(1),
 		]);
 
 		socket.write(handshake);
 
-        const request = varint.concat([
+		const request = varint.concat([varint.encodeInt(0)]);
-            varint.encodeInt(0)
-        ]);
 
 		socket.write(request);
 	});
 
 	let incomingBuffer = Buffer.alloc(0);
 
-    socket.on('data', (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
+		// https://minecraft.wiki/w/Minecraft_Wiki:Projects/wiki.vg_merge/Data_types#VarInt_and_VarLong
 		if (incomingBuffer.length < 5) {
 			return;
 		}
@@ -92,12 +91,20 @@ function ping(host, port = 25565, cb, timeout = 5000, protocolVersion = -1) {
 			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 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);
+			const response = data.subarray(
+				varint.decodeLength(responseLength),
+				varint.decodeLength(responseLength) + responseLength
+			);
 
 			try {
 				const message = JSON.parse(response);
@@ -108,11 +115,11 @@ function ping(host, port = 25565, cb, timeout = 5000, protocolVersion = -1) {
 				handleError(err);
 			}
 		} else {
-            handleError(new Error('Received unexpected packet'));
+			handleError(new Error("Received unexpected packet"));
 		}
 	});
 
-    socket.on('error', handleError);
+	socket.on("error", handleError);
 }
 
 /**
@@ -123,13 +130,20 @@ function ping(host, port = 25565, cb, timeout = 5000, protocolVersion = -1) {
  * @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, protocolVersion = -1 } = options;
+	const { port = 25565, timeout = 5000, protocolVersion = -1, virtualHost = null } = options;
 
 	return new Promise((resolve, reject) => {
-        ping(host, port, (res, err) => {
+		ping(
+			host,
+			virtualHost || host,
+			port,
+			(res, err) => {
 				err ? reject(err) : resolve(res);
-        }, timeout, protocolVersion);
+			},
+			timeout,
+			protocolVersion
+		);
 	});
 }

lib/varint.js

@@ -1,4 +1,4 @@
-// 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.
@@ -10,13 +10,13 @@ const varint = {
 	 * @returns {Buffer}
 	 */
 	encodeInt: (val) => {
-        // "constInts are never longer than 5 bytes"
+		// "VarInts are never longer than 5 bytes"
-        // https://wiki.vg/Data_types#constInt_and_constLong
+		// 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;
+			const byte = val & 0x7f;
 			val >>>= 7;
 
 			if (val === 0) {
@@ -36,7 +36,7 @@ const varint = {
 	 * @returns {Buffer}
 	 */
 	encodeString: (val) => {
-        return Buffer.from(val, 'utf-8');
+		return Buffer.from(val, "utf-8");
 	},
 
 	/**
@@ -45,7 +45,7 @@ const varint = {
 	 * @returns {Buffer}
 	 */
 	encodeUShort: (val) => {
-        return Buffer.from([val >> 8, val & 0xFF]);
+		return Buffer.from([val >> 8, val & 0xff]);
 	},
 
 	/**
@@ -60,10 +60,7 @@ const varint = {
 			length += chunk.length;
 		}
 
-        const buffer = [
+		const buffer = [varint.encodeInt(length), ...chunks];
-            varint.encodeInt(length),
-            ...chunks
-        ];
 
 		return Buffer.concat(buffer);
 	},
@@ -81,7 +78,7 @@ const varint = {
 		while (true) {
 			const byte = buffer.readUInt8(offset++);
 
-            val |= (byte & 0x7F) << count++ * 7;
+			val |= (byte & 0x7f) << (count++ * 7);
 
 			if ((byte & 0x80) !== 0x80) {
 				break;
@@ -109,19 +106,26 @@ const varint = {
 		const N9 = Math.pow(2, 63);
 
 		// Return the number of bytes required based on the value
-        return (
+		return val < N1
-            val < N1 ? 1
+			? 1
-                : val < N2 ? 2
+			: val < N2
-                    : val < N3 ? 3
+			? 2
-                        : val < N4 ? 4
+			: val < N3
-                            : val < N5 ? 5
+			? 3
-                                : val < N6 ? 6
+			: val < N4
-                                    : val < N7 ? 7
+			? 4
-                                        : val < N8 ? 8
+			: val < N5
-                                            : val < N9 ? 9
+			? 5
-                                                : 10
+			: 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.2.0",
+  "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

@@ -3,21 +3,24 @@
  * @param timeout The read/write socket timeout.
  */
 export type BedrockPingOptions = {
-    port: number,
+    port?: number;
-    timeout: number;
+    timeout?: number;
 };
 
 export type BedrockPingResponse = {
-    version: {
+    edition: string;
     name: string;
-        protocol: string;
+    version: {
+        protocolVersion: number;
+        minecraftVersion: string;
     };
     players: {
-        max: string;
+        online: number;
-        online: string;
+        max: number;
     };
-    description: string;
+    serverId: string;
-    gamemode: 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';

types/lib/java.d.ts

@@ -4,14 +4,15 @@
  * @param protocolVersion The protocol version.
  */
 export type JavaPingOptions = {
-    port: number,
+	port?: number | undefined;
-    timeout: number,
+	timeout?: number | undefined;
-    protocolVersion: number;
+	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;
@@ -25,13 +26,13 @@ export type ChatComponent = {
 };
 
 export type SampleProp = {
-    name: 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: {
@@ -76,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?: JavaPingOptions): Promise<JavaPingResponse>;
+export function pingJava(
-
+	host: string,
+	options?: JavaPingOptions
+): Promise<JavaPingResponse>;