118 lines
3.3 KiB
Java
118 lines
3.3 KiB
Java
package com.mesacarlos.webconsole;
|
|
|
|
import java.io.File;
|
|
import java.io.FileInputStream;
|
|
import java.io.IOException;
|
|
import java.net.InetSocketAddress;
|
|
import java.security.KeyStore;
|
|
|
|
import javax.net.ssl.KeyManagerFactory;
|
|
import javax.net.ssl.SSLContext;
|
|
import javax.net.ssl.TrustManagerFactory;
|
|
|
|
import org.apache.logging.log4j.LogManager;
|
|
import org.apache.logging.log4j.core.Filter;
|
|
import org.bukkit.Bukkit;
|
|
import org.bukkit.configuration.file.FileConfiguration;
|
|
import org.bukkit.plugin.java.JavaPlugin;
|
|
import org.java_websocket.server.DefaultSSLWebSocketServerFactory;
|
|
|
|
import com.mesacarlos.webconsole.util.LogFilter;
|
|
import com.mesacarlos.webconsole.websockets.WSServer;
|
|
|
|
public class WebConsole extends JavaPlugin {
|
|
FileConfiguration config = this.getConfig();
|
|
|
|
// Websocket server and thread
|
|
private WSServer server;
|
|
private Thread wsThread;
|
|
|
|
@Override
|
|
public void onEnable() {
|
|
createConfig();
|
|
|
|
try {
|
|
startWS();
|
|
} catch (Exception e) {
|
|
Bukkit.getLogger().warning("Error occured while starting WebSockets Server.");
|
|
e.printStackTrace();
|
|
}
|
|
|
|
Filter f = new LogFilter(getWSServer());
|
|
((org.apache.logging.log4j.core.Logger) LogManager.getRootLogger()).addFilter(f);
|
|
}
|
|
|
|
@Override
|
|
public void onDisable() {
|
|
try {
|
|
server.stop();
|
|
wsThread = null;
|
|
} catch (IOException | InterruptedException e) {
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Creates configuration file
|
|
*/
|
|
private void createConfig() {
|
|
// SSL variables
|
|
config.addDefault("useSSL", false);
|
|
config.addDefault("StoreType", "JKS");
|
|
config.addDefault("KeyStore", "plugins/WebConsole/keystore.jks");
|
|
config.addDefault("StorePassword", "storepassword");
|
|
config.addDefault("KeyPassword", "keypassword");
|
|
|
|
// Connection config variables
|
|
config.addDefault("host", "localhost");
|
|
config.addDefault("port", 8080);
|
|
config.addDefault("password", 1234);
|
|
|
|
config.options().copyDefaults(true);
|
|
saveConfig();
|
|
}
|
|
|
|
/**
|
|
* Start WebSocket server
|
|
*/
|
|
private void startWS() throws Exception {
|
|
// Create WebSocket server
|
|
server = new WSServer(this, new InetSocketAddress(config.getString("host"), config.getInt("port")));
|
|
|
|
if(config.getBoolean("useSSL")) {
|
|
// Configure SSL
|
|
String STORETYPE = config.getString("StoreType");
|
|
String KEYSTORE = config.getString("KeyStore");
|
|
String STOREPASSWORD = config.getString("StorePassword");
|
|
String KEYPASSWORD = config.getString("KeyPassword");
|
|
|
|
KeyStore ks = KeyStore.getInstance(STORETYPE);
|
|
File kf = new File(KEYSTORE);
|
|
ks.load(new FileInputStream(kf), STOREPASSWORD.toCharArray());
|
|
|
|
KeyManagerFactory kmf = KeyManagerFactory.getInstance("SunX509");
|
|
kmf.init(ks, KEYPASSWORD.toCharArray());
|
|
TrustManagerFactory tmf = TrustManagerFactory.getInstance("SunX509");
|
|
tmf.init(ks);
|
|
|
|
SSLContext sslContext = null;
|
|
sslContext = SSLContext.getInstance("TLS");
|
|
sslContext.init(kmf.getKeyManagers(), tmf.getTrustManagers(), null);
|
|
|
|
server.setWebSocketFactory(new DefaultSSLWebSocketServerFactory(sslContext));
|
|
}
|
|
|
|
// Start Server
|
|
wsThread = new Thread(new Runnable() {
|
|
@Override
|
|
public void run() {
|
|
server.run();
|
|
}
|
|
});
|
|
wsThread.start();
|
|
}
|
|
|
|
public WSServer getWSServer() {
|
|
return (WSServer) server;
|
|
}
|
|
} |