Implemented sending messages to the MC server

Author: DemonExposer

src/bot.js

@@ -1,6 +1,7 @@
 const Discord = require("discord.js");
 const client = new Discord.Client();
 const MessageReceiver = require("./network/messageReceiver.js");
+const MessageTransmitter = require("./network/messageTransmitter.js");
 
 class Bot {
 	#commands = ["--bindchannel", "--unbindchannel"].sort();
@@ -32,6 +33,9 @@ class Bot {
 	 * @param {Discord.Message} msg
 	 */
 	#messageHandler(msg) {
+		if (msg.author.bot)
+			return;
+
 		switch (msg.content) {
 			case "--bindchannel":
 				this.#msgRecv.bindChannel(msg.channel);
@@ -44,6 +48,19 @@ class Bot {
 				this.#commands.forEach(commandStr => response += `\`${commandStr}\`: ${this.#commandHelp[commandStr]}\n`);
 				msg.channel.send(response.slice(0, response.length-1));
 				break;
+			default:
+				if (!this.#msgRecv.isBound(msg.channel))
+					break;
+
+				MessageTransmitter.transmit(
+					"127.0.0.1",
+					501,
+					{
+						sender: msg.member.displayName,
+						message: msg.content
+					}
+				);
+				break;
 		}
 	}
 }

src/network/messageReceiver.js

@@ -69,6 +69,14 @@ class MessageReceiver {
 		var elementIndex = this.#boundChannels.indexOf(channel);
 		this.#boundChannels.splice(elementIndex, 1);
 	}
+
+	/**
+	 * Checks if a certain channel is bound to the bound Minecraft server text chat
+	 * @param {TextChannel} channel The channel to check
+	 */
+	isBound(channel) {
+		return this.#boundChannels.indexOf(channel) != -1;
+	}
 }
 
 module.exports = MessageReceiver;

src/network/messageTransmitter.js

@@ -0,0 +1,17 @@
+const Net = require("net");
+
+class MessageTransmitter {
+	/**
+	 * Transmits a message over TCP
+	 * @param {String} address The host to send the message to
+	 * @param {number} port The host's port
+	 * @param {Object} message A JSON object representing the message to send
+	 */
+	static transmit(address, port, message) {
+		var socket = new Net.Socket();
+		socket.connect(port, address, () => socket.write(JSON.stringify(message)));
+		socket.on("close", _ => socket.destroy());
+	}
+}
+
+module.exports = MessageTransmitter;