fixes and QoL improvements, debugging tools added

2025-02-10 17:18:21 +01:00 · 2025-02-10 17:18:21 +01:00 · dd26e0dda2
commit dd26e0dda2
parent 99f308dd3a
4 changed files with 508 additions and 71 deletions
--- a/README.md
+++ b/README.md
@ -1,6 +1,10 @@
 # node-telnet-client [![Node.js CI](https://github.com/Hammer1279/node-telnet-client/actions/workflows/pkg.yml/badge.svg)](https://github.com/Hammer1279/node-telnet-client/actions/workflows/pkg.yml)

-To be used with HTDev BBS Server for encrypted communication and extended functionality.
+A zero dependency NodeJS Implementation of a [RFC-854](https://datatracker.ietf.org/doc/html/rfc854) telnet client.
+
+This is a very early version that so far isn't very compatible with most major telnet servers yet.
+
+It is developed for the [HTDev Telnet Server](telnet://ht-dev.de) for encrypted communication and extended functionality.

 ## Autorun command

@ -15,4 +19,9 @@ For experimental versions, check the pre-releases under releases, for "nightly"

 It has zero dependencies itself so to run a copy locally, just run it with `node index.js`

-To build the application, run `npm install` and then `npm run build`.
+To build the application, run `npm install` and then `npm run build`.
+
+## Build Dependencies
+
+- @yao-pkg/pkg: Compiling the Application
+- protocol-registry: Register the telnet uri as per [RFC-4248](https://datatracker.ietf.org/doc/html/rfc4248)
--- a/index.js
+++ b/index.js
@ -1,3 +1,5 @@
+// rework to use chunkermaster
+
 const fs = require("fs");
 const path = require("path");
 const { createConnection } = require('net');
@ -12,6 +14,7 @@ const encryptionDelay = 200; // additional delay for encryption
 const initializationDelay = 500; // additional delay for initialization

 const advancedFeatures = true; // Enable advanced features
+const printIO = false; // Print input/output data

 class MemoryStream extends Transform {
    constructor(options = {}) {
@ -24,8 +27,46 @@ class MemoryStream extends Transform {
    }
 }

+/**
+ * prepare the session and close handler when done
+ * @param {Buffer} data
+ * @returns {Buffer[]} chunks
+ */
+function chunkData(data) {
+    // Split data into chunks based on IAC
+    const chunks = [];
+    let currentChunk = Buffer.alloc(0);
+
+    for (let i = 0; i < data.length; i++) {
+        if (data[i] === IAC[0]) {
+            if (currentChunk.length > 0) {
+                chunks.push(currentChunk);
+            }
+            // Find the end of the IAC command
+            let cmdLength = 3; // Default IAC command length
+            if (data[i + 1] === SB[0]) {
+                // Find SE to end subnegotiation
+                const seIndex = data.indexOf(SE[0], i);
+                cmdLength = seIndex - i + 1;
+            }
+            chunks.push(data.subarray(i, i + cmdLength));
+            i += cmdLength - 1;
+            currentChunk = Buffer.alloc(0);
+        } else {
+            currentChunk = Buffer.concat([currentChunk, Buffer.from([data[i]])]);
+        }
+    }
+
+    if (currentChunk.length > 0) {
+        chunks.push(currentChunk);
+    }
+
+    return chunks;
+}
+
 const writer = new MemoryStream();
 let initialized = false; // Initialization status, do not modify directly, runtime only
+let handoffInit = false; // Handoff initialization status to server, do not modify directly, runtime only
 let encrypted = false; // Encryption status, do not modify directly, runtime only
 let privateKey; // Private key, do not modify directly, runtime only
 let keyCurve; // Key curve, do not modify directly, runtime only
@ -87,6 +128,42 @@ const RESUME = Buffer.from([0x87]); // Resume
 const START_CONTENT = Buffer.from([0x88]); // Start Content
 const END_CONTENT = Buffer.from([0x89]); // End Content

+// ANSI escape codes for colors
+const ANSI = {
+    // Reset
+    reset: '\x1b[0m',
+
+    // Basic foreground colors
+    black: '\x1b[30m',
+    red: '\x1b[31m',
+    green: '\x1b[32m',
+    yellow: '\x1b[33m',
+    blue: '\x1b[34m',
+    magenta: '\x1b[35m',
+    cyan: '\x1b[36m',
+    white: '\x1b[37m',
+
+    // Bright foreground colors
+    brightBlack: '\x1b[90m',
+    brightRed: '\x1b[91m',
+    brightGreen: '\x1b[92m',
+    brightYellow: '\x1b[93m',
+    brightBlue: '\x1b[94m',
+    brightMagenta: '\x1b[95m',
+    brightCyan: '\x1b[96m',
+    brightWhite: '\x1b[97m',
+
+    // Basic background colors
+    bgBlack: '\x1b[40m',
+    bgRed: '\x1b[41m',
+    bgGreen: '\x1b[42m',
+    bgYellow: '\x1b[43m',
+    bgBlue: '\x1b[44m',
+    bgMagenta: '\x1b[45m',
+    bgCyan: '\x1b[46m',
+    bgWhite: '\x1b[47m'
+};
+
 // Encrypt
 function encrypt(plaintext, key = privateKey, encoding = 'utf8') {
    // Generate a random IV (12 bytes recommended for GCM)
@ -154,7 +231,9 @@ process.stdin.resume();
 // format keys before sending to server
 process.stdin.on('data', async (key) => {
    if (key === '\u0004') { // Ctrl+D
-        process.exit();
+        socket.end(); // End connection
+        socket.destroy(); // Destroy socket
+        process.exit(); // Exit process
    } else if (key === '\u0003') { // Ctrl+C
        send(IP); // Interrupt Process
    } else if (key === '\u0018') { // Ctrl+X
@ -185,6 +264,7 @@ process.stdin.on('data', async (key) => {
            process.stdout.write("> ");
        } else if (command == "disconnect") {
            send(IP); // Interrupt Process
+            socket.end(); // End connection
        } else if (command == "status") {
            console.log("Client status:");
            console.log("Host:", hostname + ":" + port);
@ -195,6 +275,8 @@ process.stdin.on('data', async (key) => {
            // console.log("Public Key:", key.getPublicKey() ? key.getPublicKey().toString("hex") : "null");
            // console.log("Private Key:", privateKey ? privateKey.toString("hex") : "null");
            process.stdout.write("$ ");
+        } else if (command == "debug") {
+            socket.write(Buffer.concat([IAC, DO, STATUS])); // Debug request Status
        } else if (command == "keyinfo") {
            console.log("Key Information:");
            console.log("Key Curve:", keyCurve);
@ -206,6 +288,7 @@ process.stdin.on('data', async (key) => {
            // Add any additional functionality for client side commands
            console.log("Client commands:");
            console.log("status - Show client status");
+            console.log("debug - [DEV] Request server status");
            console.log("keyinfo - Show key information");
            console.log("disconnect - Disconnect from server");
            console.log("exit - Exit client command mode");
@ -217,67 +300,86 @@ process.stdin.on('data', async (key) => {
 });

 socket.on("data", (data) => {
-    if (!encrypted || !initialized) {
-        if (data.equals(PAUSE)) {
-            process.stdin.pause();
-        } else if (data.equals(RESUME)) {
-            process.stdin.resume();
-        } else if (data.equals(IP)) {
-            process.exit();
-        } else if (data.includes(Buffer.concat([IAC, SB, CUSTOM_CLIENT_INIT, NUL]))) {
-            const offsetBegin = data.indexOf(SB) + 2;
-            const offsetEnd = data.lastIndexOf(SE) - 1;
-            const algorithmData = data.subarray(offsetBegin + 1, offsetEnd);
-            keyCurve = algorithmData.toString('utf8');
-            echdKey = createECDH(keyCurve);
-            console.debug("Using key curve:", keyCurve);
-        } else if (data.equals(Buffer.concat([IAC, DO, CUSTOM_CLIENT_INIT]))) {
-            // server supports custom client features
-            socket.write(Buffer.concat([IAC, WILL, KEY_EXCHANGE])); // Start Key Exchange
-        } else if (data.includes(Buffer.concat([IAC, DO, KEY_EXCHANGE]))) {
-            // generate keys
-            const publicKey = echdKey.generateKeys();
-            console.debug("Generated Key: " + publicKey.toString("hex"));
-        } else if (data.equals(Buffer.concat([IAC, SB, KEY_EXCHANGE, ONE /* value required */, IAC, SE]))) {
-            socket.write(Buffer.concat([IAC, SB, KEY_EXCHANGE, NUL, echdKey.getPublicKey(), IAC, SE]));
-            // send key to server
-        } else if (data.includes(Buffer.concat([IAC, SB, KEY_EXCHANGE, NUL /* value provided */]))) {
-            // server sent its key, generate secret
-            console.debug("Key exchange received");
-            const offsetBegin = data.indexOf(SB) + 2;
-            const offsetEnd = data.lastIndexOf(SE) - 1;
-            const keyData = data.subarray(offsetBegin + 1, offsetEnd); // client public key
-            console.log("Extracted key:", keyData.toString("hex"));
-            privateKey = echdKey.computeSecret(keyData);
-            socket.write(Buffer.concat([IAC, WILL, ENCRYPTION])); // Enable Encryption
-        } else if (data.includes(Buffer.concat([IAC, SB, ENCRYPTION, NUL]))) {
-            const offsetBegin = data.indexOf(SB) + 2;
-            const offsetEnd = data.lastIndexOf(SE) - 1;
-            const algorithmData = data.subarray(offsetBegin + 1, offsetEnd);
-            encryptionAlgorithm = algorithmData.toString('utf8');
-            console.debug("Using encryption algorithm:", encryptionAlgorithm);
-        } else if (data.equals(Buffer.concat([IAC, DO, ENCRYPTION]))) {
-            // enable encryption
-            encrypted = true;
-            console.debug("Encryption enabled");
-            console.debug("Private Key: " + privateKey.toString("hex"));
-        } else if (!hold) {
-            process.stdout.write(data);
-        } else {
-            // console.debug("Data on hold");
-            holdBuffer += data.toString();
+    const chunks = chunkData(data);
+    for (const chunk of chunks) {
+        if (printIO) {
+            console.debug("Received chunk:", chunk.toString("hex"));
        }
-    } else {
-        // decrypt data
-        try {
-            const decryptedData = decrypt(data, privateKey);
-            process.stdout.write(decryptedData);
-        } catch (error) {
-            console.error("Decryption error:", error);
-            console.error("Data:", data.toString("hex"));
-            console.debug("Algorithm:", encryptionAlgorithm);
-            console.debug("Private Key:", privateKey.toString("hex"));
-            console.debug("Public Key:", echdKey.getPublicKey().toString("hex"));
+        if (!encrypted || !initialized) {
+            if (chunk.equals(PAUSE)) {
+                process.stdin.pause();
+            } else if (chunk.equals(RESUME)) {
+                process.stdin.resume();
+            } else if (chunk.equals(IP)) {
+                process.exit();
+            } else if (chunk.includes(Buffer.concat([IAC, SB, CUSTOM_CLIENT_INIT, NUL]))) {
+                const offsetBegin = chunk.indexOf(SB) + 2;
+                const offsetEnd = chunk.lastIndexOf(SE) - 1;
+                const algorithmData = chunk.subarray(offsetBegin + 1, offsetEnd);
+                keyCurve = algorithmData.toString('utf8');
+                echdKey = createECDH(keyCurve);
+                console.debug("Using key curve:", keyCurve);
+            } else if (chunk.equals(Buffer.concat([IAC, DO, CUSTOM_CLIENT_INIT]))) {
+                // server supports custom client features
+                socket.write(Buffer.concat([IAC, WILL, KEY_EXCHANGE])); // Start Key Exchange
+            } else if (chunk.includes(Buffer.concat([IAC, DO, KEY_EXCHANGE]))) {
+                // generate keys
+                const publicKey = echdKey.generateKeys();
+                console.debug("Generated Key: " + publicKey.toString("hex"));
+            } else if (chunk.equals(Buffer.concat([IAC, SB, KEY_EXCHANGE, ONE /* value required */, IAC, SE]))) {
+                socket.write(Buffer.concat([IAC, SB, KEY_EXCHANGE, NUL, echdKey.getPublicKey(), IAC, SE]));
+                // send key to server
+            } else if (chunk.includes(Buffer.concat([IAC, SB, KEY_EXCHANGE, NUL /* value provided */]))) {
+                // server sent its key, generate secret
+                console.debug("Key exchange received");
+                const offsetBegin = chunk.indexOf(SB) + 2;
+                const offsetEnd = chunk.lastIndexOf(SE) - 1;
+                const keyData = chunk.subarray(offsetBegin + 1, offsetEnd); // client public key
+                console.log("Extracted key:", keyData.toString("hex"));
+                privateKey = echdKey.computeSecret(keyData);
+                socket.write(Buffer.concat([IAC, WILL, ENCRYPTION])); // Enable Encryption
+            } else if (chunk.includes(Buffer.concat([IAC, SB, STATUS, NUL /* value provided */]))) {
+                // server sent status
+                const offsetBegin = chunk.indexOf(SB) + 2;
+                const offsetEnd = chunk.lastIndexOf(SE) - 1;
+                const statusData = chunk.subarray(offsetBegin + 1, offsetEnd);
+                console.debug("Server status:", require("util").inspect(JSON.parse(statusData.toString('utf8'))));
+            } else if (chunk.includes(Buffer.concat([IAC, SB, ENCRYPTION, NUL]))) {
+                const offsetBegin = chunk.indexOf(SB) + 2;
+                const offsetEnd = chunk.lastIndexOf(SE) - 1;
+                const algorithmData = chunk.subarray(offsetBegin + 1, offsetEnd);
+                encryptionAlgorithm = algorithmData.toString('utf8');
+                console.debug("Using encryption algorithm:", encryptionAlgorithm);
+            } else if (chunk.equals(Buffer.concat([IAC, DO, ENCRYPTION]))) {
+                // enable encryption
+                encrypted = true;
+                console.debug("Encryption enabled");
+                console.debug("Private Key: " + privateKey.toString("hex"));
+            } else if (chunk.equals(Buffer.concat([IAC, DO, Buffer.from([0x80])]))) {
+                handoffInit = true;
+                console.debug("Handoff initialization complete");
+            } else if (chunk.equals(Buffer.concat([IAC, DO, Buffer.from([0x80])]))) { // Initialize
+                socket.write(Buffer.concat([IAC, WILL, Buffer.from([0x80])]));
+                initialized = true;
+                console.debug("Initialization complete");
+            } else if (!hold) {
+                process.stdout.write(chunk);
+            } else {
+                // console.debug("Data on hold");
+                holdBuffer += chunk.toString();
+            }
+        } else {
+            // decrypt data
+            try {
+                const decryptedData = decrypt(chunk, privateKey);
+                process.stdout.write(decryptedData);
+            } catch (error) {
+                console.error("Decryption error:", error);
+                console.error("Data:", chunk.toString("hex"));
+                console.debug("Algorithm:", encryptionAlgorithm);
+                console.debug("Private Key:", privateKey.toString("hex"));
+                console.debug("Public Key:", echdKey.getPublicKey().toString("hex"));
+            }
        }
    }
 });
@ -301,7 +403,7 @@ socket.on("connect", async () => {
    await delay(delayMs); // Wait for server to process
    socket.write(Buffer.concat([IAC, WILL, TERMINAL_TYPE, IAC, SB, TERMINAL_TYPE, NUL, Buffer.from("xterm-256color"), IAC, SE])); // Terminal Type
    await delay(delayMs);
-    socket.write(Buffer.concat([IAC, DO, ECHO])); // Echo
+    socket.write(Buffer.concat([IAC, DO, ECHO])); // Tell server to echo input
    await delay(delayMs);
    if (advancedFeatures) {
        socket.write(Buffer.concat([IAC, WILL, CUSTOM_CLIENT_INIT])); // Custom Client Initialization
@ -313,14 +415,19 @@ socket.on("connect", async () => {
    }
    await delay(initializationDelay); // Wait for server to process
    await send(""); // Send empty command to initialize connection
-    initialized = true;
-    console.debug("Initialization complete");
+
+    if (!handoffInit) {
+        initialized = true; // Initialization is now handled by server
+        console.debug("Initialization complete");
+    }
+
    // socket.write(Buffer.from([0x0d, 0x0a])); // Line Feed
    // from here on encryption is enabled, do not use socket.write() directly anymore
    // initialization complete

    await send("help");
    await delay(delayMs);
+    process.stdout.write("\r" + ANSI.bgRed + ANSI.white + "DEPRECATION NOTICE:" + ANSI.reset + " This is an unsupported version and might not work fully." + "\r\n");
    process.stdout.write("\rCtrl+X for client side commands\r\nCtrl+C to exit, Ctrl+D to force close\r\n> ");
    process.stdin.resume(); // Resume input
    // more commands can be added here
@ -344,6 +451,28 @@ socket.on("end", () => {
    process.exit();
 });

+process.on('uncaughtException', (err) => {
+    if (err.code === 'ECONNRESET') {
+        console.warn("\nDisconnected from server");
+        process.exit();
+        } else if (err.code === 'ECONNREFUSED') {
+        console.warn("Connection refused");
+        process.exit();
+        } else if (err.code === 'ETIMEDOUT') {
+        console.warn("Connection timed out");
+        process.exit();
+        } else if (err.code === 'EHOSTUNREACH') {
+        console.warn("Host is unreachable");
+        process.exit();
+        } else if (err.code === 'ENETUNREACH') {
+        console.warn("Network is unreachable"); 
+        process.exit();
+    } else {
+        console.error('Unhandled exception:', err);
+        process.exit(1);
+    }
+});
+
 module.exports = {
    delay,
    send,
--- a/package-lock.json
+++ b/package-lock.json
@ -1,12 +1,12 @@
 {
  "name": "telnet-client",
-  "version": "0.0.2",
+  "version": "0.0.2-dev",
  "lockfileVersion": 3,
  "requires": true,
  "packages": {
    "": {
      "name": "telnet-client",
-      "version": "0.0.2",
+      "version": "0.0.2-dev",
      "license": "MIT",
      "dependencies": {
        "telnet-client": "file:"
@ -15,7 +15,8 @@
        "telnet-client": "index.js"
      },
      "devDependencies": {
-        "@yao-pkg/pkg": "^5.12.1"
+        "@yao-pkg/pkg": "^5.12.1",
+        "protocol-registry": "^1.6.0"
      }
    },
    "node_modules/@babel/generator": {
@ -85,6 +86,23 @@
        "node": ">=6.9.0"
      }
    },
+    "node_modules/@hapi/hoek": {
+      "version": "9.3.0",
+      "resolved": "https://registry.npmjs.org/@hapi/hoek/-/hoek-9.3.0.tgz",
+      "integrity": "sha512-/c6rf4UJlmHlC9b5BaNvzAcFv7HZ2QHaV0D4/HNlBdvFnvQq8RI4kYdhyPCl7Xj+oWvTWQ8ujhqS53LIgAe6KQ==",
+      "dev": true,
+      "license": "BSD-3-Clause"
+    },
+    "node_modules/@hapi/topo": {
+      "version": "5.1.0",
+      "resolved": "https://registry.npmjs.org/@hapi/topo/-/topo-5.1.0.tgz",
+      "integrity": "sha512-foQZKJig7Ob0BMAYBfcJk8d77QtOe7Wo4ox7ff1lQYoNNAb6jwcY1ncdoy2e9wQZzvNy7ODZCYJkK8kzmcAnAg==",
+      "dev": true,
+      "license": "BSD-3-Clause",
+      "dependencies": {
+        "@hapi/hoek": "^9.0.0"
+      }
+    },
    "node_modules/@jridgewell/gen-mapping": {
      "version": "0.3.8",
      "resolved": "https://registry.npmjs.org/@jridgewell/gen-mapping/-/gen-mapping-0.3.8.tgz",
@ -138,6 +156,40 @@
        "@jridgewell/sourcemap-codec": "^1.4.14"
      }
    },
+    "node_modules/@sideway/address": {
+      "version": "4.1.5",
+      "resolved": "https://registry.npmjs.org/@sideway/address/-/address-4.1.5.tgz",
+      "integrity": "sha512-IqO/DUQHUkPeixNQ8n0JA6102hT9CmaljNTPmQ1u8MEhBo/R4Q8eKLN/vGZxuebwOroDB4cbpjheD4+/sKFK4Q==",
+      "dev": true,
+      "license": "BSD-3-Clause",
+      "dependencies": {
+        "@hapi/hoek": "^9.0.0"
+      }
+    },
+    "node_modules/@sideway/formula": {
+      "version": "3.0.1",
+      "resolved": "https://registry.npmjs.org/@sideway/formula/-/formula-3.0.1.tgz",
+      "integrity": "sha512-/poHZJJVjx3L+zVD6g9KgHfYnb443oi7wLu/XKojDviHy6HOEOA6z1Trk5aR1dGcmPenJEgb2sK2I80LeS3MIg==",
+      "dev": true,
+      "license": "BSD-3-Clause"
+    },
+    "node_modules/@sideway/pinpoint": {
+      "version": "2.0.0",
+      "resolved": "https://registry.npmjs.org/@sideway/pinpoint/-/pinpoint-2.0.0.tgz",
+      "integrity": "sha512-RNiOoTPkptFtSVzQevY/yWtZwf/RxyVnPy/OcA9HBM3MlGDnBEYL5B41H0MTn0Uec8Hi+2qUtTfG2WWZBmMejQ==",
+      "dev": true,
+      "license": "BSD-3-Clause"
+    },
+    "node_modules/@xmldom/xmldom": {
+      "version": "0.8.10",
+      "resolved": "https://registry.npmjs.org/@xmldom/xmldom/-/xmldom-0.8.10.tgz",
+      "integrity": "sha512-2WALfTl4xo2SkGCYRt6rDTFfk9R1czmBvUQy12gK2KuRKIpWEhcbbzy8EZXtz/jkRqHX8bFEc6FC1HjX4TUWYw==",
+      "dev": true,
+      "license": "MIT",
+      "engines": {
+        "node": ">=10.0.0"
+      }
+    },
    "node_modules/@yao-pkg/pkg": {
      "version": "5.16.1",
      "resolved": "https://registry.npmjs.org/@yao-pkg/pkg/-/pkg-5.16.1.tgz",
@ -221,6 +273,20 @@
        "url": "https://github.com/chalk/ansi-styles?sponsor=1"
      }
    },
+    "node_modules/async": {
+      "version": "3.2.6",
+      "resolved": "https://registry.npmjs.org/async/-/async-3.2.6.tgz",
+      "integrity": "sha512-htCUDlxyyCLMgaM3xXg0C0LW2xqfuQ6p05pCEIsXuyQ+a1koYKTuBMzRNwmybfLgvJDMd0r1LTn4+E0Ti6C2AA==",
+      "dev": true,
+      "license": "MIT"
+    },
+    "node_modules/balanced-match": {
+      "version": "1.0.2",
+      "resolved": "https://registry.npmjs.org/balanced-match/-/balanced-match-1.0.2.tgz",
+      "integrity": "sha512-3oSeUO0TMV67hN1AmbXsK4yaqU7tjiHlbxRDZOpH0KW9+CeX4bRAaX0Anxt0tx2MrpRpWwQaPwIlISEJhYU5Pw==",
+      "dev": true,
+      "license": "MIT"
+    },
    "node_modules/base64-js": {
      "version": "1.5.1",
      "resolved": "https://registry.npmjs.org/base64-js/-/base64-js-1.5.1.tgz",
@ -269,6 +335,17 @@
        "node": ">= 6"
      }
    },
+    "node_modules/brace-expansion": {
+      "version": "1.1.11",
+      "resolved": "https://registry.npmjs.org/brace-expansion/-/brace-expansion-1.1.11.tgz",
+      "integrity": "sha512-iCuPHDFgrHX7H2vEI/5xpz07zSHB00TpugqhmYtVmMO6518mCuRMoOYFldEBl0g187ufozdaHgWKcYFb61qGiA==",
+      "dev": true,
+      "license": "MIT",
+      "dependencies": {
+        "balanced-match": "^1.0.0",
+        "concat-map": "0.0.1"
+      }
+    },
    "node_modules/buffer": {
      "version": "5.7.1",
      "resolved": "https://registry.npmjs.org/buffer/-/buffer-5.7.1.tgz",
@ -294,6 +371,23 @@
        "ieee754": "^1.1.13"
      }
    },
+    "node_modules/chalk": {
+      "version": "4.1.2",
+      "resolved": "https://registry.npmjs.org/chalk/-/chalk-4.1.2.tgz",
+      "integrity": "sha512-oKnbhFyRIXpUuez8iBMmyEa4nbj4IOQyuhc/wy9kY7/WVPcwIO9VA668Pu8RkO7+0G76SLROeyw9CpQ061i4mA==",
+      "dev": true,
+      "license": "MIT",
+      "dependencies": {
+        "ansi-styles": "^4.1.0",
+        "supports-color": "^7.1.0"
+      },
+      "engines": {
+        "node": ">=10"
+      },
+      "funding": {
+        "url": "https://github.com/chalk/chalk?sponsor=1"
+      }
+    },
    "node_modules/chownr": {
      "version": "1.1.4",
      "resolved": "https://registry.npmjs.org/chownr/-/chownr-1.1.4.tgz",
@ -333,6 +427,13 @@
      "dev": true,
      "license": "MIT"
    },
+    "node_modules/concat-map": {
+      "version": "0.0.1",
+      "resolved": "https://registry.npmjs.org/concat-map/-/concat-map-0.0.1.tgz",
+      "integrity": "sha512-/Srv4dswyQNBfohGpz9o6Yb3Gz3SrUDqBH5rTuhGR7ahtlbYKnVxw2bCFMRljaA7EXHaXZ8wsHdodFvbkhKmqg==",
+      "dev": true,
+      "license": "MIT"
+    },
    "node_modules/core-util-is": {
      "version": "1.0.3",
      "resolved": "https://registry.npmjs.org/core-util-is/-/core-util-is-1.0.3.tgz",
@ -394,6 +495,22 @@
        "node": ">=8"
      }
    },
+    "node_modules/ejs": {
+      "version": "3.1.10",
+      "resolved": "https://registry.npmjs.org/ejs/-/ejs-3.1.10.tgz",
+      "integrity": "sha512-UeJmFfOrAQS8OJWPZ4qtgHyWExa088/MtK5UEyoJGFH67cDEXkZSviOiKRCZ4Xij0zxI3JECgYs3oKx+AizQBA==",
+      "dev": true,
+      "license": "Apache-2.0",
+      "dependencies": {
+        "jake": "^10.8.5"
+      },
+      "bin": {
+        "ejs": "bin/cli.js"
+      },
+      "engines": {
+        "node": ">=0.10.0"
+      }
+    },
    "node_modules/emoji-regex": {
      "version": "8.0.0",
      "resolved": "https://registry.npmjs.org/emoji-regex/-/emoji-regex-8.0.0.tgz",
@ -446,6 +563,39 @@
        }
      }
    },
+    "node_modules/filelist": {
+      "version": "1.0.4",
+      "resolved": "https://registry.npmjs.org/filelist/-/filelist-1.0.4.tgz",
+      "integrity": "sha512-w1cEuf3S+DrLCQL7ET6kz+gmlJdbq9J7yXCSjK/OZCPA+qEN1WyF4ZAf0YYJa4/shHJra2t/d/r8SV4Ji+x+8Q==",
+      "dev": true,
+      "license": "Apache-2.0",
+      "dependencies": {
+        "minimatch": "^5.0.1"
+      }
+    },
+    "node_modules/filelist/node_modules/brace-expansion": {
+      "version": "2.0.1",
+      "resolved": "https://registry.npmjs.org/brace-expansion/-/brace-expansion-2.0.1.tgz",
+      "integrity": "sha512-XnAIvQ8eM+kC6aULx6wuQiwVsnzsi9d3WxzV3FpWTGA19F621kwdbsAcFKXgKUHZWsy+mY6iL1sHTxWEFCytDA==",
+      "dev": true,
+      "license": "MIT",
+      "dependencies": {
+        "balanced-match": "^1.0.0"
+      }
+    },
+    "node_modules/filelist/node_modules/minimatch": {
+      "version": "5.1.6",
+      "resolved": "https://registry.npmjs.org/minimatch/-/minimatch-5.1.6.tgz",
+      "integrity": "sha512-lKwV/1brpG6mBUFHtb7NUmtABCb2WZZmm2wNiOA5hAb8VdCS4B3dtMWyvcoViccwAW/COERjXLt0zP1zXUN26g==",
+      "dev": true,
+      "license": "ISC",
+      "dependencies": {
+        "brace-expansion": "^2.0.1"
+      },
+      "engines": {
+        "node": ">=10"
+      }
+    },
    "node_modules/from2": {
      "version": "2.3.0",
      "resolved": "https://registry.npmjs.org/from2/-/from2-2.3.0.tgz",
@ -491,6 +641,16 @@
      "dev": true,
      "license": "MIT"
    },
+    "node_modules/has-flag": {
+      "version": "4.0.0",
+      "resolved": "https://registry.npmjs.org/has-flag/-/has-flag-4.0.0.tgz",
+      "integrity": "sha512-EykJT/Q1KjTWctppgIAgfSO0tKVuZUjhgMr17kqTumMl6Afv3EISleU7qZUzoXDFTAHTDC4NOoG/ZxU3EvlMPQ==",
+      "dev": true,
+      "license": "MIT",
+      "engines": {
+        "node": ">=8"
+      }
+    },
    "node_modules/hasown": {
      "version": "2.0.2",
      "resolved": "https://registry.npmjs.org/hasown/-/hasown-2.0.2.tgz",
@ -586,6 +746,22 @@
        "url": "https://github.com/sponsors/ljharb"
      }
    },
+    "node_modules/is-docker": {
+      "version": "2.2.1",
+      "resolved": "https://registry.npmjs.org/is-docker/-/is-docker-2.2.1.tgz",
+      "integrity": "sha512-F+i2BKsFrH66iaUFc0woD8sLy8getkwTwtOBjvs56Cx4CgJDeKQeqfz8wAYiSb8JOprWhHH5p77PbmYCvvUuXQ==",
+      "dev": true,
+      "license": "MIT",
+      "bin": {
+        "is-docker": "cli.js"
+      },
+      "engines": {
+        "node": ">=8"
+      },
+      "funding": {
+        "url": "https://github.com/sponsors/sindresorhus"
+      }
+    },
    "node_modules/is-fullwidth-code-point": {
      "version": "3.0.0",
      "resolved": "https://registry.npmjs.org/is-fullwidth-code-point/-/is-fullwidth-code-point-3.0.0.tgz",
@ -596,6 +772,19 @@
        "node": ">=8"
      }
    },
+    "node_modules/is-wsl": {
+      "version": "2.2.0",
+      "resolved": "https://registry.npmjs.org/is-wsl/-/is-wsl-2.2.0.tgz",
+      "integrity": "sha512-fKzAra0rGJUUBwGBgNkHZuToZcn+TtXHpeCgmkMJMMYx1sQDYaCSyjJBSCa2nH1DGm7s3n1oBnohoVTBaN7Lww==",
+      "dev": true,
+      "license": "MIT",
+      "dependencies": {
+        "is-docker": "^2.0.0"
+      },
+      "engines": {
+        "node": ">=8"
+      }
+    },
    "node_modules/isarray": {
      "version": "1.0.0",
      "resolved": "https://registry.npmjs.org/isarray/-/isarray-1.0.0.tgz",
@ -603,6 +792,39 @@
      "dev": true,
      "license": "MIT"
    },
+    "node_modules/jake": {
+      "version": "10.9.2",
+      "resolved": "https://registry.npmjs.org/jake/-/jake-10.9.2.tgz",
+      "integrity": "sha512-2P4SQ0HrLQ+fw6llpLnOaGAvN2Zu6778SJMrCUwns4fOoG9ayrTiZk3VV8sCPkVZF8ab0zksVpS8FDY5pRCNBA==",
+      "dev": true,
+      "license": "Apache-2.0",
+      "dependencies": {
+        "async": "^3.2.3",
+        "chalk": "^4.0.2",
+        "filelist": "^1.0.4",
+        "minimatch": "^3.1.2"
+      },
+      "bin": {
+        "jake": "bin/cli.js"
+      },
+      "engines": {
+        "node": ">=10"
+      }
+    },
+    "node_modules/joi": {
+      "version": "17.13.3",
+      "resolved": "https://registry.npmjs.org/joi/-/joi-17.13.3.tgz",
+      "integrity": "sha512-otDA4ldcIx+ZXsKHWmp0YizCweVRZG96J10b0FevjfuncLO1oX59THoAmHkNubYJ+9gWsYsp5k8v4ib6oDv1fA==",
+      "dev": true,
+      "license": "BSD-3-Clause",
+      "dependencies": {
+        "@hapi/hoek": "^9.3.0",
+        "@hapi/topo": "^5.1.0",
+        "@sideway/address": "^4.1.5",
+        "@sideway/formula": "^3.0.1",
+        "@sideway/pinpoint": "^2.0.0"
+      }
+    },
    "node_modules/jsesc": {
      "version": "3.1.0",
      "resolved": "https://registry.npmjs.org/jsesc/-/jsesc-3.1.0.tgz",
@ -629,6 +851,19 @@
        "url": "https://github.com/sponsors/sindresorhus"
      }
    },
+    "node_modules/minimatch": {
+      "version": "3.1.2",
+      "resolved": "https://registry.npmjs.org/minimatch/-/minimatch-3.1.2.tgz",
+      "integrity": "sha512-J7p63hRiAjw1NDEww1W7i37+ByIrOWO5XQQAzZ3VOcL0PNybwpfmV/N05zFAzwQ9USyEcX6t3UO+K5aqBQOIHw==",
+      "dev": true,
+      "license": "ISC",
+      "dependencies": {
+        "brace-expansion": "^1.1.7"
+      },
+      "engines": {
+        "node": "*"
+      }
+    },
    "node_modules/minimist": {
      "version": "1.2.8",
      "resolved": "https://registry.npmjs.org/minimist/-/minimist-1.2.8.tgz",
@ -781,6 +1016,21 @@
        "url": "https://github.com/sponsors/jonschlinkert"
      }
    },
+    "node_modules/plist": {
+      "version": "3.1.0",
+      "resolved": "https://registry.npmjs.org/plist/-/plist-3.1.0.tgz",
+      "integrity": "sha512-uysumyrvkUX0rX/dEVqt8gC3sTBzd4zoWfLeS29nb53imdaXVvLINYXTI2GNqzaMuvacNx4uJQ8+b3zXR0pkgQ==",
+      "dev": true,
+      "license": "MIT",
+      "dependencies": {
+        "@xmldom/xmldom": "^0.8.8",
+        "base64-js": "^1.5.1",
+        "xmlbuilder": "^15.1.1"
+      },
+      "engines": {
+        "node": ">=10.4.0"
+      }
+    },
    "node_modules/prebuild-install": {
      "version": "7.1.2",
      "resolved": "https://registry.npmjs.org/prebuild-install/-/prebuild-install-7.1.2.tgz",
@ -825,6 +1075,24 @@
        "node": ">=0.4.0"
      }
    },
+    "node_modules/protocol-registry": {
+      "version": "1.6.0",
+      "resolved": "https://registry.npmjs.org/protocol-registry/-/protocol-registry-1.6.0.tgz",
+      "integrity": "sha512-a1xUGhQ3HUhqAmcGRxBwaAxWvsS1a8J7lMAbZ7vU2EB+1WAy5aCo0MmtgpdU7B+JpbYtG/xM/jkacH13IDkSCg==",
+      "dev": true,
+      "hasInstallScript": true,
+      "license": "MIT",
+      "dependencies": {
+        "ejs": "^3.1.8",
+        "is-wsl": "^2.2.0",
+        "joi": "^17.13.3",
+        "plist": "^3.1.0",
+        "winreg": "^1.2.4"
+      },
+      "engines": {
+        "node": ">=10.0.0"
+      }
+    },
    "node_modules/pump": {
      "version": "3.0.2",
      "resolved": "https://registry.npmjs.org/pump/-/pump-3.0.2.tgz",
@ -1024,6 +1292,19 @@
        "node": ">=0.10.0"
      }
    },
+    "node_modules/supports-color": {
+      "version": "7.2.0",
+      "resolved": "https://registry.npmjs.org/supports-color/-/supports-color-7.2.0.tgz",
+      "integrity": "sha512-qpCAvRl9stuOHveKsn7HncJRvv501qIacKzQlO/+Lwxc9+0q2wLyv4Dfvt80/DPn2pqOBsJdDiogXGR9+OvwRw==",
+      "dev": true,
+      "license": "MIT",
+      "dependencies": {
+        "has-flag": "^4.0.0"
+      },
+      "engines": {
+        "node": ">=8"
+      }
+    },
    "node_modules/supports-preserve-symlinks-flag": {
      "version": "1.0.0",
      "resolved": "https://registry.npmjs.org/supports-preserve-symlinks-flag/-/supports-preserve-symlinks-flag-1.0.0.tgz",
@ -1145,6 +1426,13 @@
        "webidl-conversions": "^3.0.0"
      }
    },
+    "node_modules/winreg": {
+      "version": "1.2.5",
+      "resolved": "https://registry.npmjs.org/winreg/-/winreg-1.2.5.tgz",
+      "integrity": "sha512-uf7tHf+tw0B1y+x+mKTLHkykBgK2KMs3g+KlzmyMbLvICSHQyB/xOFjTT8qZ3oeTFyU7Bbj4FzXitGG6jvKhYw==",
+      "dev": true,
+      "license": "BSD-2-Clause"
+    },
    "node_modules/wrap-ansi": {
      "version": "7.0.0",
      "resolved": "https://registry.npmjs.org/wrap-ansi/-/wrap-ansi-7.0.0.tgz",
@ -1170,6 +1458,16 @@
      "dev": true,
      "license": "ISC"
    },
+    "node_modules/xmlbuilder": {
+      "version": "15.1.1",
+      "resolved": "https://registry.npmjs.org/xmlbuilder/-/xmlbuilder-15.1.1.tgz",
+      "integrity": "sha512-yMqGBqtXyeN1e3TGYvgNgDVZ3j84W4cwkOXQswghol6APgZWaff9lnbvN7MHYJOiXsvGPXtjTYJEiC9J2wv9Eg==",
+      "dev": true,
+      "license": "MIT",
+      "engines": {
+        "node": ">=8.0"
+      }
+    },
    "node_modules/y18n": {
      "version": "5.0.8",
      "resolved": "https://registry.npmjs.org/y18n/-/y18n-5.0.8.tgz",
--- a/package.json
+++ b/package.json
@ -1,6 +1,6 @@
 {
  "name": "telnet-client",
-  "version": "0.0.2",
+  "version": "0.0.2-dev",
  "description": "To be used with HTDev BBS Server for encrypted communication and extended functionality.",
  "main": "index.js",
  "bin": "index.js",
@ -18,7 +18,8 @@
    "telnet-client": "file:"
  },
  "devDependencies": {
-    "@yao-pkg/pkg": "^5.12.1"
+    "@yao-pkg/pkg": "^5.12.1",
+    "protocol-registry": "^1.6.0"
  },
  "type": "commonjs",
  "pkg": {