Initial release

Author: Tobias de Bruijn

build.gradle

@@ -8,7 +8,6 @@ plugins {
 allprojects {
 
 	version = pluginVersion
-	group = pluginGroup	
 
 	sourceCompatibility = 1.11
 	targetCompatibility = 1.11
@@ -22,19 +21,17 @@ allprojects {
 	processResources {
     	from(sourceSets.main.resources.srcDirs) {
         	filter ReplaceTokens, tokens: [version: version]
-			filter ReplaceTokens, tokens: [name: pluginName]
-			filter ReplaceTokens, tokens: [mainClassName: mainClassName]
-			filter ReplaceTokens, tokens: [groupId: pluginGroup]
-			filter ReplaceTokens, tokens: [author: pluginAuthor]
-			filter ReplaceTokens, tokens: [apiVersion: pluginApiVersion]
 		}
     }
 }
 
 dependencies {
-	
 	//Spigot API
-	compileOnly 'org.spigotmc:spigot-api:1.16.4-R0.1-SNAPSHOT'
+	compileOnly 'org.spigotmc:spigot-api:1.16.5-R0.1-SNAPSHOT'
+	
+	compileOnly group: 'org.apache.logging.log4j', name: 'log4j-api', version: '2.8.1'
+    compileOnly group: 'org.apache.logging.log4j', name: 'log4j-core', version: '2.8.1'
+	
 }
 
 task testJar(type: Jar) {

gradle.properties

@@ -1,6 +1 @@
-pluginVersion = 1.0
-pluginGroup = nl.thedutchmc.basebukkitplugin
-mainClassName = BaseBukkitPlugin
-pluginName = BaseBukkitPlugin
-pluginAuthor = TheDutchMC
-pluginApiVersion = 1.16
+pluginVersion = 0.1

settings.gradle

@@ -7,4 +7,4 @@
  * in the user guide at https://docs.gradle.org/5.1.1/userguide/multi_project_builds.html
  */
 
-rootProject.name = pluginName
+rootProject.name = 'rConsole'

src/main/java/nl/thedutchmc/BaseBukkitPlugin/BaseBukkitPlugin.java

@@ -0,0 +1,74 @@
+package nl.thedutchmc.rconsole;
+
+import java.io.IOException;
+import java.io.PrintWriter;
+import java.net.Socket;
+
+import org.bukkit.plugin.java.JavaPlugin;
+
+import com.google.gson.Gson;
+
+import nl.thedutchmc.rconsole.config.Configuration;
+import nl.thedutchmc.rconsole.gson.out.ServerShutdownPacket;
+import nl.thedutchmc.rconsole.tcp.TcpClient;
+import nl.thedutchmc.rconsole.tcp.TcpServer;
+
+public class RConsole extends JavaPlugin {
+
+	private static RConsole INSTANCE;
+	private static volatile boolean DEBUG = false;
+	private static volatile boolean IS_RUNNING = true;
+	
+	private TcpServer tcpServer;
+	
+	@Override
+	public void onEnable() {
+		RConsole.INSTANCE = this;
+		
+		Configuration config = new Configuration(this);
+		RConsole.DEBUG = config.getConfig().isDebugMode();
+		
+		this.tcpServer = new TcpServer(config.getConfig().getListenPort(), config.getConfig().getTokens(), this);
+		new Thread(tcpServer, "rConsole-TCPServer-Thread").start();		
+	}
+	
+	@Override
+	public void onDisable() {
+		
+		String packetSerialized = new Gson().toJson(new ServerShutdownPacket());
+		for(TcpClient client : this.tcpServer.getSignedInClients()) {
+			RConsole.logDebug(String.format("Disconnecting client '%s'", client.getName()));
+			Socket socket = client.getSocket();
+			
+			if(socket.isClosed()) {
+				continue;
+			}
+			
+			try {
+				PrintWriter pw = new PrintWriter(socket.getOutputStream());
+				pw.println(packetSerialized);
+				pw.flush();
+				pw.close();
+			} catch(IOException e) {
+			}
+		}
+	}
+	
+	public static void logInfo(Object log) {
+		RConsole.INSTANCE.getLogger().info(log.toString());
+	}
+	
+	public static void logWarn(Object log) {
+		RConsole.INSTANCE.getLogger().warning(log.toString());
+	}
+	
+	public static void logDebug(Object log) {
+		if(!RConsole.DEBUG) return;
+		
+		RConsole.INSTANCE.getLogger().info("[DEBUG] " + log.toString());
+	}
+	
+	public static boolean getIsRunning() {
+		return RConsole.IS_RUNNING;
+	}
+}

src/main/java/nl/thedutchmc/BaseBukkitPlugin/ConfigurationHandler.java

@@ -0,0 +1,15 @@
+package nl.thedutchmc.rconsole;
+
+import java.io.PrintWriter;
+import java.io.StringWriter;
+
+public class Util {
+	
+	public static String getStackTrace(Throwable e) {
+		StringWriter sw = new StringWriter();
+		PrintWriter pw = new PrintWriter(sw, true);
+		
+		e.printStackTrace(pw);
+		return sw.getBuffer().toString();
+	}
+}

src/main/java/nl/thedutchmc/rconsole/RConsole.java

@@ -0,0 +1,9 @@
+package nl.thedutchmc.rconsole.annotations;
+
+import java.lang.annotation.Documented;
+
+/**
+ * The returned value can be null, so you should do a null-check probably
+ */
+@Documented
+public @interface Nullable {}

src/main/java/nl/thedutchmc/rconsole/Util.java

@@ -0,0 +1,47 @@
+package nl.thedutchmc.rconsole.config;
+
+import java.io.File;
+import java.io.FileNotFoundException;
+import java.io.FileReader;
+import org.yaml.snakeyaml.Yaml;
+
+import com.google.gson.Gson;
+
+import nl.thedutchmc.rconsole.RConsole;
+import nl.thedutchmc.rconsole.config.gson.ConfigObject;
+
+public class Configuration {
+
+	private ConfigObject configObj;
+	
+	public Configuration(RConsole plugin) {
+		
+		loadConfig(plugin);
+	}
+	
+	private void loadConfig(RConsole plugin) {
+		File configFile = new File(plugin.getDataFolder(), "config.yml");
+		
+		if(!configFile.exists()) {
+			configFile.getParentFile().mkdirs();
+			plugin.saveResource("config.yml", false);
+		}
+		
+		final Yaml yaml = new Yaml();
+		final Gson gson = new Gson();
+
+		Object loadedYaml;
+		try {
+			loadedYaml = yaml.load(new FileReader(configFile));
+		} catch(FileNotFoundException e) {
+			return;
+		}
+
+		String json = gson.toJson(loadedYaml, java.util.LinkedHashMap.class);		
+		this.configObj = gson.fromJson(json, ConfigObject.class);
+	}
+	
+	public ConfigObject getConfig() {
+		return this.configObj;
+	}
+}

src/main/java/nl/thedutchmc/rconsole/annotations/Nullable.java

@@ -0,0 +1,26 @@
+package nl.thedutchmc.rconsole.config.gson;
+
+public class ConfigObject {
+	private boolean debugMode;
+	private int listenPort;
+	private TokenObject[] tokens;
+	/**
+	 * @return the debugMode
+	 */
+	public boolean isDebugMode() {
+		return debugMode;
+	}
+	/**
+	 * @return the listenPort
+	 */
+	public int getListenPort() {
+		return listenPort;
+	}
+	/**
+	 * @return the tokens
+	 */
+	public TokenObject[] getTokens() {
+		return tokens;
+	}
+	
+}

src/main/java/nl/thedutchmc/rconsole/config/Configuration.java

@@ -0,0 +1,27 @@
+package nl.thedutchmc.rconsole.config.gson;
+
+import nl.thedutchmc.rconsole.gson.Scope;
+
+public class TokenObject {
+	private String name, token;
+	private Scope[] scopes;
+	
+	/**
+	 * @return the name
+	 */
+	public String getName() {
+		return name;
+	}
+	/**
+	 * @return the token
+	 */
+	public String getToken() {
+		return token;
+	}
+	/**
+	 * @return the scopes
+	 */
+	public Scope[] getScopes() {
+		return scopes;
+	}
+}

src/main/java/nl/thedutchmc/rconsole/config/gson/ConfigObject.java

@@ -0,0 +1,5 @@
+package nl.thedutchmc.rconsole.features;
+
+public enum Feature {
+	READ_CONSOLE
+}

src/main/java/nl/thedutchmc/rconsole/config/gson/TokenObject.java

@@ -0,0 +1,27 @@
+package nl.thedutchmc.rconsole.features.readconsole;
+
+import org.apache.logging.log4j.core.LogEvent;
+import org.apache.logging.log4j.core.appender.AbstractAppender;
+import org.apache.logging.log4j.core.layout.PatternLayout;
+
+public class ConsoleAppender extends AbstractAppender {
+	
+	private ReadConsole readConsole;
+	
+	protected ConsoleAppender(ReadConsole readConsole) {
+		super("rconsole-appender", null, PatternLayout.createDefaultLayout());		
+		this.readConsole = readConsole;
+		super.start();		
+	}
+
+	@Override
+	public void append(LogEvent event) {
+		LogEvent eventImmutable = event.toImmutable();
+		
+		this.readConsole.send(
+				eventImmutable.getMessage().getFormattedMessage(),
+				eventImmutable.getTimeMillis() / 1000,
+				eventImmutable.getLevel().name(),
+				eventImmutable.getThreadName());
+	}	
+}