Implemented receiving messages from Discord

Author: DemonExposer

src/main/java/nl/ordewittetafel/minecom_plugin/Constants.java

@@ -6,4 +6,5 @@
 public class Constants {
 	public static final String DC_BOT_IP_KEY = "dcbot-ip";
 	public static final String DC_BOT_PORT_KEY = "dcbot-port";
+	public static final String PLUGIN_PORT_KEY = "plugin-port";
 }

src/main/java/nl/ordewittetafel/minecom_plugin/Main.java

@@ -2,10 +2,13 @@
 
 import nl.ordewittetafel.minecom_plugin.listeners.ChatListener;
 import nl.ordewittetafel.minecom_plugin.listeners.JoinQuitListener;
+import nl.ordewittetafel.minecom_plugin.network.MessageReceiver;
 import org.bukkit.Bukkit;
 import org.bukkit.configuration.file.FileConfiguration;
 import org.bukkit.plugin.java.JavaPlugin;
 
+import java.io.IOException;
+
 public class Main extends JavaPlugin {
 	@Override
 	public void onEnable() {
@@ -16,10 +19,18 @@ public void onEnable() {
 		 */
 		config.addDefault(Constants.DC_BOT_IP_KEY, "127.0.0.1"); // The address of the Discord bot
 		config.addDefault(Constants.DC_BOT_PORT_KEY, 500); // The port of the Discord bot
+		config.addDefault(Constants.PLUGIN_PORT_KEY, 501); // The port of this plugin
 		config.options().copyDefaults(true);
 		saveConfig();
 
 		Bukkit.getPluginManager().registerEvents(new JoinQuitListener(this), this);
 		Bukkit.getPluginManager().registerEvents(new ChatListener(this), this);
+
+		try {
+			new MessageReceiver(this);
+		} catch (IOException e) {
+			e.printStackTrace();
+			System.err.println("If this error shows up, it means you cannot receive any messages from the Discord bot, because the ServerSocket could not be created");
+		}
 	}
 }

src/main/java/nl/ordewittetafel/minecom_plugin/network/MessageReceiver.java

@@ -0,0 +1,39 @@
+package nl.ordewittetafel.minecom_plugin.network;
+
+import nl.ordewittetafel.minecom_plugin.Constants;
+import org.bukkit.Bukkit;
+import org.bukkit.plugin.java.JavaPlugin;
+import org.json.JSONException;
+import org.json.JSONObject;
+
+import java.io.DataInputStream;
+import java.io.IOException;
+import java.net.ServerSocket;
+import java.net.Socket;
+import java.util.Timer;
+import java.util.TimerTask;
+
+public class MessageReceiver {
+	public MessageReceiver(JavaPlugin plugin) throws IOException {
+		ServerSocket ss = new ServerSocket(plugin.getConfig().getInt(Constants.PLUGIN_PORT_KEY));
+		Timer timer = new Timer();
+		timer.schedule(new TimerTask() {
+			@Override
+			public void run() {
+				try {
+					Socket s = ss.accept();
+					DataInputStream din = new DataInputStream(s.getInputStream());
+					byte[] buffer = new byte[1024];
+					int read = din.read(buffer);
+					din.close();
+					s.close();
+
+					JSONObject messageObj = new JSONObject(new String(buffer, 0, read));
+					Bukkit.getServer().broadcastMessage("<" + messageObj.getString("sender") + "> " + messageObj.getString("message"));
+				} catch (IOException | JSONException e) {
+					Bukkit.getServer().broadcastMessage("<Unknown sender> \u00A74Message data lost");
+				}
+			}
+		}, 0, 1);
+	}
+}