Release v1.4.0

#5: DiscordSRV support

.coveralls.yml

@@ -0,0 +1 @@
+repo_token: $COVERALLS_REPO_TOKEN

.gitignore

@@ -0,0 +1,4 @@
+.idea/
+out/
+target/
+StaffChat.iml

.travis.yml

@@ -0,0 +1,13 @@
+language: java
+jdk:
+  - openjdk8
+deploy:
+  provider: releases
+  api_key: $GITHUB_KEY
+  file_glob: true
+  file: "*/staffchat*.jar"
+  skip_cleanup: true
+  on:
+    tags: true
+after_success:
+  - mvn clean test jacoco:report coveralls:report

README.md

@@ -1,5 +1,63 @@
-# StaffChat
+[![Travis-CI](https://img.shields.io/travis/com/oskar3123/StaffChat.svg?style=flat)](https://app.travis-ci.com/github/oskar3123/StaffChat)
-Simple and highly configurable staff chat
+[![All Release](https://img.shields.io/github/downloads/oskar3123/StaffChat/total.svg?style=flat)](https://github.com/oskar3123/StaffChat/releases/latest)
+[![Latest Release](https://img.shields.io/github/release/oskar3123/StaffChat.svg?style=flat)](https://github.com/oskar3123/StaffChat/releases/latest)
+[![Github commits (since latest release)](https://img.shields.io/github/commits-since/oskar3123/StaffChat/latest.svg?style=flat)](https://github.com/oskar3123/StaffChat/commits/master)
+
+# [StaffChat](https://oskar3123.github.io/StaffChat)
+
+Simple and highly configurable staffchat
 
 ## Download
-You can download the binary from the [Spigot resource page](https://www.spigotmc.org/resources/37804/)
+You can download the plugin from the [Spigot resource page](https://www.spigotmc.org/resources/37804/) or via the [GitHub releases](https://github.com/oskar3123/StaffChat/releases)
+
+## Event API (For developers)
+
+### Bukkit/Spigot
+
+Because the event API in 1.14+ is now strict between sync and async events you should check whether this was called synchronously or asynchronously by using `event.isAsynchronous()`
+
+```java
+public class StaffChatListener implements Listener
+{
+
+    @EventHandler
+    public void onStaffChat(StaffChatEvent event)
+    {
+        // String format = event.getFormat();
+        // event.setFormat("&b{NAME} >> {MESSAGE}");
+        // String message = event.getMessage();
+        // Player player = event.getPlayer();
+        // event.setCancelled(true);
+    }
+
+}
+```
+Register the listener with
+```java
+getServer().getPluginManager().registerEvents(new StaffChatListener(), this);
+```
+in your plugin onEnable.
+
+### BungeeCord
+
+```java
+public class StaffChatListener implements Listener
+{
+
+    @EventHandler
+    public void onStaffChat(BungeeStaffChatEvent event)
+    {
+        // String format = event.getFormat();
+        // event.setFormat("&b{NAME} >> {MESSAGE}");
+        // String message = event.getMessage();
+        // Player player = event.getPlayer();
+        // event.setCancelled(true);
+    }
+
+}
+```
+Register the listener with
+```java
+getProxy().getPluginManager().registerListener(this, new StaffChatListener());
+```
+in your plugin onEnable.

_config.yml

@@ -0,0 +1,2 @@
+theme: jekyll-theme-cayman
+show_downloads: false

pom.xml

@@ -1,54 +1,91 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <project xmlns="http://maven.apache.org/POM/4.0.0"
-         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 
-    <modelVersion>4.0.0</modelVersion>
+  <modelVersion>4.0.0</modelVersion>
 
-    <groupId>me.oskar3123</groupId>
+  <name>StaffChat</name>
-    <artifactId>staffchat</artifactId>
+  <groupId>me.oskar3123</groupId>
-    <version>1.1.0-SNAPSHOT</version>
+  <artifactId>staffchat</artifactId>
+  <version>1.4.0</version>
 
-    <repositories>
+  <properties>
-        <repository>
+    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-            <id>spigot-repo</id>
+  </properties>
-            <url>https://hub.spigotmc.org/nexus/content/repositories/snapshots/</url>
-        </repository>
-        <repository>
-            <id>bungeecord-repo</id>
-            <url>https://oss.sonatype.org/content/repositories/snapshots/</url>
-        </repository>
-    </repositories>
 
-    <dependencies>
+  <repositories>
-        <dependency>
+    <repository>
-            <groupId>org.spigotmc</groupId>
+      <id>spigot-repo</id>
-            <artifactId>spigot-api</artifactId>
+      <url>https://hub.spigotmc.org/nexus/content/repositories/snapshots/</url>
-            <version>1.11.2-R0.1-SNAPSHOT</version>
+    </repository>
-        </dependency>
+    <repository>
-        <dependency>
+      <id>bungeecord-repo</id>
-            <groupId>org.bukkit</groupId>
+      <url>https://oss.sonatype.org/content/repositories/snapshots/</url>
-            <artifactId>bukkit</artifactId>
+    </repository>
-            <version>1.11.2-R0.1-SNAPSHOT</version>
+    <repository>
-        </dependency>
+      <id>placeholderapi</id>
-        <dependency>
+      <url>https://repo.extendedclip.com/content/repositories/placeholderapi/</url>
-            <groupId>net.md-5</groupId>
+    </repository>
-            <artifactId>bungeecord-api</artifactId>
+    <repository>
-            <version>1.11-SNAPSHOT</version>
+      <id>dv8tion</id>
-        </dependency>
+      <name>m2-dv8tion</name>
-    </dependencies>
+      <url>https://m2.dv8tion.net/releases</url>
+    </repository>
+    <repository>
+      <id>Scarsz-Nexus</id>
+      <url>https://nexus.scarsz.me/content/groups/public/</url>
+    </repository>
+  </repositories>
 
-    <build>
+  <dependencies>
-        <plugins>
+    <dependency>
-            <plugin>
+      <groupId>org.spigotmc</groupId>
-                <groupId>org.apache.maven.plugins</groupId>
+      <artifactId>spigot-api</artifactId>
-                <artifactId>maven-compiler-plugin</artifactId>
+      <version>1.18-R0.1-SNAPSHOT</version>
-                <configuration>
+      <scope>provided</scope>
-                    <source>1.8</source>
+    </dependency>
-                    <target>1.8</target>
+    <dependency>
-                </configuration>
+      <groupId>net.md-5</groupId>
-            </plugin>
+      <artifactId>bungeecord-api</artifactId>
-        </plugins>
+      <version>1.18-R0.1-SNAPSHOT</version>
-    </build>
+      <type>jar</type>
+      <scope>provided</scope>
+    </dependency>
+    <dependency>
+      <groupId>net.md-5</groupId>
+      <artifactId>bungeecord-api</artifactId>
+      <version>1.18-R0.1-SNAPSHOT</version>
+      <type>javadoc</type>
+      <scope>provided</scope>
+    </dependency>
+    <dependency>
+      <groupId>me.clip</groupId>
+      <artifactId>placeholderapi</artifactId>
+      <version>2.11.1</version>
+      <scope>provided</scope>
+    </dependency>
+    <dependency>
+      <groupId>com.discordsrv</groupId>
+      <artifactId>discordsrv</artifactId>
+      <version>1.25.1</version>
+      <scope>provided</scope>
+    </dependency>
+  </dependencies>
+
+  <build>
+    <finalName>${project.name}-${project.version}</finalName>
+    <plugins>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-compiler-plugin</artifactId>
+        <version>3.1</version>
+        <configuration>
+          <source>1.8</source>
+          <target>1.8</target>
+        </configuration>
+      </plugin>
+    </plugins>
+  </build>
 
 </project>

src/main/java/me/oskar3123/staffchat/bungee/BungeeMain.java

@@ -1,88 +1,112 @@
 package me.oskar3123.staffchat.bungee;
 
-import me.oskar3123.staffchat.bungee.command.BungeeStaffChatCommand;
-import me.oskar3123.staffchat.bungee.event.BungeeChatListener;
-import net.md_5.bungee.api.plugin.Plugin;
-import net.md_5.bungee.config.Configuration;
-import net.md_5.bungee.config.ConfigurationProvider;
-import net.md_5.bungee.config.YamlConfiguration;
-
 import java.io.File;
 import java.io.IOException;
 import java.io.InputStream;
 import java.nio.file.Files;
+import me.oskar3123.staffchat.bungee.command.BungeeStaffChatCommand;
+import me.oskar3123.staffchat.bungee.listener.BungeeChatListener;
+import net.md_5.bungee.api.plugin.Plugin;
+import net.md_5.bungee.config.Configuration;
+import net.md_5.bungee.config.ConfigurationProvider;
+import net.md_5.bungee.config.YamlConfiguration;
 
-public class BungeeMain extends Plugin
+public class BungeeMain extends Plugin {
-{
 
-    public final String usePerm = "staffchat.use";
+  public final String usePerm = "staffchat.use";
-    public final String seePerm = "staffchat.see";
+  public final String seePerm = "staffchat.see";
-    public final String commandPerm = "staffchat.command";
+  public final String commandPerm = "staffchat.command";
-    public final String reloadPerm = "staffchat.reload";
+  public final String reloadPerm = "staffchat.reload";
-    private Configuration config;
+  public final BungeeChatListener chatListener = new BungeeChatListener(this);
+  private Configuration config;
 
-    public void onEnable()
+  public void onEnable() {
-    {
+    new MetricsLite(this);
-        saveDefaultConfig();
+    saveDefaultConfig();
-        if (!reloadConfig())
+    if (!reloadConfig()) {
-        {
+      getLogger().severe("Could not load config file, using defaults.");
-            getLogger().severe("Could not load config file, using defaults.");
+    }
-            return;
+    registerCommands();
-        }
+    registerEvents();
-        registerCommands();
+  }
-        registerEvents();
+
+  private void registerCommands() {
+    getProxy().getPluginManager().registerCommand(this, new BungeeStaffChatCommand(this));
+  }
+
+  private void registerEvents() {
+    getProxy().getPluginManager().registerListener(this, chatListener);
+  }
+
+  public boolean reloadConfig() {
+    try {
+      config =
+          ConfigurationProvider.getProvider(YamlConfiguration.class)
+              .load(new File(getDataFolder(), "config.yml"));
+      loadDefaultValues();
+      return true;
+    } catch (IOException e) {
+      config =
+          ConfigurationProvider.getProvider(YamlConfiguration.class)
+              .load(getResourceAsStream("config.yml"));
+      loadDefaultValues();
+      return false;
+    }
+  }
+
+  private void loadDefaultValues() {
+    String[] keys =
+        new String[] {
+          "settings.character",
+          "settings.format",
+          "messages.prefix",
+          "messages.nopermission",
+          "messages.playeronly",
+          "messages.reloaded",
+          "messages.toggled",
+          "messages.onstring",
+          "messages.offstring",
+        };
+    Configuration def =
+        ConfigurationProvider.getProvider(YamlConfiguration.class)
+            .load(getResourceAsStream("config.yml"));
+    for (String key : keys) {
+      String v = config.getString(key);
+      if (v == null || v.isEmpty()) {
+        config.set(key, def.getString(key));
+      }
+    }
+    saveConfig();
+  }
+
+  public Configuration getConfig() {
+    return config;
+  }
+
+  private void saveDefaultConfig() {
+    if (!getDataFolder().exists()) {
+      //noinspection ResultOfMethodCallIgnored
+      getDataFolder().mkdir();
     }
 
-    private void registerCommands()
+    File file = new File(getDataFolder(), "config.yml");
-    {
+
-        getProxy().getPluginManager().registerCommand(this, new BungeeStaffChatCommand(this));
+    if (!file.exists()) {
+      try (InputStream in = getResourceAsStream("config.yml")) {
+        Files.copy(in, file.toPath());
+      } catch (IOException e) {
+        e.printStackTrace();
+      }
     }
+  }
 
-    private void registerEvents()
+  public void saveConfig() {
-    {
+    try {
-        getProxy().getPluginManager().registerListener(this, new BungeeChatListener(this));
+      ConfigurationProvider.getProvider(YamlConfiguration.class)
+          .save(config, new File(getDataFolder(), "config.yml"));
+    } catch (IOException e) {
+      e.printStackTrace();
+      getLogger().severe("Failed to save config");
     }
-
+  }
-    public boolean reloadConfig()
-    {
-        try
-        {
-            config = ConfigurationProvider.getProvider(YamlConfiguration.class).load(new File(getDataFolder(), "config.yml"));
-            return true;
-        }
-        catch (IOException e)
-        {
-            config = ConfigurationProvider.getProvider(YamlConfiguration.class).load(getResourceAsStream("config.yml"));
-            return false;
-        }
-    }
-
-    public Configuration getConfig()
-    {
-        return config;
-    }
-
-    private void saveDefaultConfig()
-    {
-        if (!getDataFolder().exists())
-        {
-            //noinspection ResultOfMethodCallIgnored
-            getDataFolder().mkdir();
-        }
-
-        File file = new File(getDataFolder(), "config.yml");
-
-        if (!file.exists())
-        {
-            try (InputStream in = getResourceAsStream("config.yml"))
-            {
-                Files.copy(in, file.toPath());
-            }
-            catch (IOException e)
-            {
-                e.printStackTrace();
-            }
-        }
-    }
-
 }

src/main/java/me/oskar3123/staffchat/bungee/MetricsLite.java

@@ -0,0 +1,395 @@
+package me.oskar3123.staffchat.bungee;
+
+import com.google.gson.JsonArray;
+import com.google.gson.JsonObject;
+import java.io.BufferedReader;
+import java.io.BufferedWriter;
+import java.io.ByteArrayOutputStream;
+import java.io.DataOutputStream;
+import java.io.File;
+import java.io.FileReader;
+import java.io.FileWriter;
+import java.io.IOException;
+import java.lang.reflect.InvocationTargetException;
+import java.net.URL;
+import java.nio.file.Path;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Timer;
+import java.util.TimerTask;
+import java.util.UUID;
+import java.util.concurrent.TimeUnit;
+import java.util.logging.Level;
+import java.util.zip.GZIPOutputStream;
+import javax.net.ssl.HttpsURLConnection;
+import net.md_5.bungee.api.plugin.Plugin;
+import net.md_5.bungee.api.scheduler.TaskScheduler;
+import net.md_5.bungee.config.Configuration;
+import net.md_5.bungee.config.ConfigurationProvider;
+import net.md_5.bungee.config.YamlConfiguration;
+
+/**
+ * bStats collects some data for plugin authors.
+ *
+ * <p>Check out https://bStats.org/ to learn more about bStats!
+ */
+@SuppressWarnings("all")
+public class MetricsLite {
+
+  // The version of this bStats class
+  public static final int B_STATS_VERSION = 1;
+  // The url to which the data is sent
+  private static final String URL = "https://bStats.org/submitData/bungeecord";
+  // A list with all known metrics class objects including this one
+  private static final List<Object> knownMetricsInstances = new ArrayList<>();
+
+  static {
+    // Maven's Relocate is clever and changes strings, too. So we have to use this little "trick"
+    // ... :D
+    final String defaultPackage =
+        new String(new byte[] {'o', 'r', 'g', '.', 'b', 's', 't', 'a', 't', 's'});
+    final String examplePackage =
+        new String(new byte[] {'y', 'o', 'u', 'r', '.', 'p', 'a', 'c', 'k', 'a', 'g', 'e'});
+    // We want to make sure nobody just copy & pastes the example and use the wrong package names
+    if (MetricsLite.class.getPackage().getName().equals(defaultPackage)
+        || MetricsLite.class.getPackage().getName().equals(examplePackage)) {
+      throw new IllegalStateException("bStats Metrics class has not been relocated correctly!");
+    }
+  }
+
+  // The plugin
+  private final Plugin plugin;
+  // Is bStats enabled on this server?
+  private boolean enabled;
+  // The uuid of the server
+  private String serverUUID;
+  // Should failed requests be logged?
+  private boolean logFailedRequests = false;
+
+  public MetricsLite(Plugin plugin) {
+    this.plugin = plugin;
+
+    try {
+      loadConfig();
+    } catch (IOException e) {
+      // Failed to load configuration
+      plugin.getLogger().log(Level.WARNING, "Failed to load bStats config!", e);
+      return;
+    }
+
+    // We are not allowed to send data about this server :(
+    if (!enabled) {
+      return;
+    }
+
+    Class<?> usedMetricsClass = getFirstBStatsClass();
+    if (usedMetricsClass == null) {
+      // Failed to get first metrics class
+      return;
+    }
+    if (usedMetricsClass == getClass()) {
+      // We are the first! :)
+      linkMetrics(this);
+      startSubmitting();
+    } else {
+      // We aren't the first so we link to the first metrics class
+      try {
+        usedMetricsClass.getMethod("linkMetrics", Object.class).invoke(null, this);
+      } catch (NoSuchMethodException | IllegalAccessException | InvocationTargetException e) {
+        if (logFailedRequests) {
+          plugin
+              .getLogger()
+              .log(
+                  Level.WARNING,
+                  "Failed to link to first metrics class " + usedMetricsClass.getName() + "!",
+                  e);
+        }
+      }
+    }
+  }
+
+  /**
+   * Links an other metrics class with this class. This method is called using Reflection.
+   *
+   * @param metrics An object of the metrics class to link.
+   */
+  public static void linkMetrics(Object metrics) {
+    knownMetricsInstances.add(metrics);
+  }
+
+  /**
+   * Sends the data to the bStats server.
+   *
+   * @param data The data to send.
+   * @throws Exception If the request failed.
+   */
+  private static void sendData(JsonObject data) throws Exception {
+    if (data == null) {
+      throw new IllegalArgumentException("Data cannot be null");
+    }
+
+    HttpsURLConnection connection = (HttpsURLConnection) new URL(URL).openConnection();
+
+    // Compress the data to save bandwidth
+    byte[] compressedData = compress(data.toString());
+
+    // Add headers
+    connection.setRequestMethod("POST");
+    connection.addRequestProperty("Accept", "application/json");
+    connection.addRequestProperty("Connection", "close");
+    connection.addRequestProperty("Content-Encoding", "gzip"); // We gzip our request
+    connection.addRequestProperty("Content-Length", String.valueOf(compressedData.length));
+    connection.setRequestProperty(
+        "Content-Type", "application/json"); // We send our data in JSON format
+    connection.setRequestProperty("User-Agent", "MC-Server/" + B_STATS_VERSION);
+
+    // Send data
+    connection.setDoOutput(true);
+    DataOutputStream outputStream = new DataOutputStream(connection.getOutputStream());
+    outputStream.write(compressedData);
+    outputStream.flush();
+    outputStream.close();
+
+    connection.getInputStream().close(); // We don't care about the response - Just send our data :)
+  }
+
+  /**
+   * Gzips the given String.
+   *
+   * @param str The string to gzip.
+   * @return The gzipped String.
+   * @throws IOException If the compression failed.
+   */
+  private static byte[] compress(final String str) throws IOException {
+    if (str == null) {
+      return null;
+    }
+    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
+    GZIPOutputStream gzip = new GZIPOutputStream(outputStream);
+    gzip.write(str.getBytes("UTF-8"));
+    gzip.close();
+    return outputStream.toByteArray();
+  }
+
+  /**
+   * Gets the plugin specific data. This method is called using Reflection.
+   *
+   * @return The plugin specific data.
+   */
+  public JsonObject getPluginData() {
+    JsonObject data = new JsonObject();
+
+    String pluginName = plugin.getDescription().getName();
+    String pluginVersion = plugin.getDescription().getVersion();
+
+    data.addProperty("pluginName", pluginName);
+    data.addProperty("pluginVersion", pluginVersion);
+
+    JsonArray customCharts = new JsonArray();
+    data.add("customCharts", customCharts);
+
+    return data;
+  }
+
+  private void startSubmitting() {
+    // We use a timer cause want to be independent from the server tps
+    final Timer timer = new Timer(true);
+    timer.scheduleAtFixedRate(
+        new TimerTask() {
+          @Override
+          public void run() {
+            // The data collection (e.g. for custom graphs) is done sync
+            // Don't be afraid! The connection to the bStats server is still async, only the stats
+            // collection is sync ;)
+            TaskScheduler scheduler = plugin.getProxy().getScheduler();
+            scheduler.schedule(
+                plugin,
+                new Runnable() {
+                  @Override
+                  public void run() {
+                    submitData();
+                  }
+                },
+                0L,
+                TimeUnit.SECONDS);
+          }
+        },
+        1000 * 60 * 2,
+        1000 * 60 * 30);
+    // Submit the data every 30 minutes, first time after 2 minutes to give other plugins enough
+    // time to start
+    // WARNING: Changing the frequency has no effect but your plugin WILL be blocked/deleted!
+    // WARNING: Just don't do it!
+  }
+
+  /**
+   * Gets the server specific data.
+   *
+   * @return The server specific data.
+   */
+  private JsonObject getServerData() {
+    // Minecraft specific data
+    int playerAmount = plugin.getProxy().getOnlineCount();
+    playerAmount = playerAmount > 500 ? 500 : playerAmount;
+    int onlineMode = plugin.getProxy().getConfig().isOnlineMode() ? 1 : 0;
+    String bungeecordVersion = plugin.getProxy().getVersion();
+    int managedServers = plugin.getProxy().getServers().size();
+
+    // OS/Java specific data
+    String javaVersion = System.getProperty("java.version");
+    String osName = System.getProperty("os.name");
+    String osArch = System.getProperty("os.arch");
+    String osVersion = System.getProperty("os.version");
+    int coreCount = Runtime.getRuntime().availableProcessors();
+
+    JsonObject data = new JsonObject();
+
+    data.addProperty("serverUUID", serverUUID);
+
+    data.addProperty("playerAmount", playerAmount);
+    data.addProperty("managedServers", managedServers);
+    data.addProperty("onlineMode", onlineMode);
+    data.addProperty("bungeecordVersion", bungeecordVersion);
+
+    data.addProperty("javaVersion", javaVersion);
+    data.addProperty("osName", osName);
+    data.addProperty("osArch", osArch);
+    data.addProperty("osVersion", osVersion);
+    data.addProperty("coreCount", coreCount);
+
+    return data;
+  }
+
+  /** Collects the data and sends it afterwards. */
+  private void submitData() {
+    final JsonObject data = getServerData();
+
+    final JsonArray pluginData = new JsonArray();
+    // Search for all other bStats Metrics classes to get their plugin data
+    for (Object metrics : knownMetricsInstances) {
+      try {
+        Object plugin = metrics.getClass().getMethod("getPluginData").invoke(metrics);
+        if (plugin instanceof JsonObject) {
+          pluginData.add((JsonObject) plugin);
+        }
+      } catch (NoSuchMethodException | IllegalAccessException | InvocationTargetException ignored) {
+      }
+    }
+
+    data.add("plugins", pluginData);
+
+    // Create a new thread for the connection to the bStats server
+    new Thread(
+            new Runnable() {
+              @Override
+              public void run() {
+                try {
+                  // Send the data
+                  sendData(data);
+                } catch (Exception e) {
+                  // Something went wrong! :(
+                  if (logFailedRequests) {
+                    plugin.getLogger().log(Level.WARNING, "Could not submit plugin stats!", e);
+                  }
+                }
+              }
+            })
+        .start();
+  }
+
+  /**
+   * Loads the bStats configuration.
+   *
+   * @throws IOException If something did not work :(
+   */
+  private void loadConfig() throws IOException {
+    Path configPath = plugin.getDataFolder().toPath().getParent().resolve("bStats");
+    configPath.toFile().mkdirs();
+    File configFile = new File(configPath.toFile(), "config.yml");
+    if (!configFile.exists()) {
+      writeFile(
+          configFile,
+          "#bStats collects some data for plugin authors like how many servers are using their plugins.",
+          "#To honor their work, you should not disable it.",
+          "#This has nearly no effect on the server performance!",
+          "#Check out https://bStats.org/ to learn more :)",
+          "enabled: true",
+          "serverUuid: \"" + UUID.randomUUID().toString() + "\"",
+          "logFailedRequests: false");
+    }
+
+    Configuration configuration =
+        ConfigurationProvider.getProvider(YamlConfiguration.class).load(configFile);
+
+    // Load configuration
+    enabled = configuration.getBoolean("enabled", true);
+    serverUUID = configuration.getString("serverUuid");
+    logFailedRequests = configuration.getBoolean("logFailedRequests", false);
+  }
+
+  /**
+   * Gets the first bStat Metrics class.
+   *
+   * @return The first bStats metrics class.
+   */
+  private Class<?> getFirstBStatsClass() {
+    Path configPath = plugin.getDataFolder().toPath().getParent().resolve("bStats");
+    configPath.toFile().mkdirs();
+    File tempFile = new File(configPath.toFile(), "temp.txt");
+
+    try {
+      String className = readFile(tempFile);
+      if (className != null) {
+        try {
+          // Let's check if a class with the given name exists.
+          return Class.forName(className);
+        } catch (ClassNotFoundException ignored) {
+        }
+      }
+      writeFile(tempFile, getClass().getName());
+      return getClass();
+    } catch (IOException e) {
+      if (logFailedRequests) {
+        plugin.getLogger().log(Level.WARNING, "Failed to get first bStats class!", e);
+      }
+      return null;
+    }
+  }
+
+  /**
+   * Reads the first line of the file.
+   *
+   * @param file The file to read. Cannot be null.
+   * @return The first line of the file or <code>null</code> if the file does not exist or is empty.
+   * @throws IOException If something did not work :(
+   */
+  private String readFile(File file) throws IOException {
+    if (!file.exists()) {
+      return null;
+    }
+    try (FileReader fileReader = new FileReader(file);
+        BufferedReader bufferedReader = new BufferedReader(fileReader); ) {
+      return bufferedReader.readLine();
+    }
+  }
+
+  /**
+   * Writes a String to a file. It also adds a note for the user,
+   *
+   * @param file The file to write to. Cannot be null.
+   * @param lines The lines to write.
+   * @throws IOException If something did not work :(
+   */
+  private void writeFile(File file, String... lines) throws IOException {
+    if (!file.exists()) {
+      file.createNewFile();
+    }
+    try (FileWriter fileWriter = new FileWriter(file);
+        BufferedWriter bufferedWriter = new BufferedWriter(fileWriter)) {
+      for (String line : lines) {
+        bufferedWriter.write(line);
+        bufferedWriter.newLine();
+      }
+    }
+  }
+}

src/main/java/me/oskar3123/staffchat/bungee/command/BungeeStaffChatCommand.java

@@ -5,75 +5,98 @@ import net.md_5.bungee.api.ChatColor;
 import net.md_5.bungee.api.CommandSender;
 import net.md_5.bungee.api.chat.BaseComponent;
 import net.md_5.bungee.api.chat.TextComponent;
+import net.md_5.bungee.api.connection.ProxiedPlayer;
 import net.md_5.bungee.api.plugin.Command;
 import net.md_5.bungee.config.Configuration;
+import org.jetbrains.annotations.Contract;
+import org.jetbrains.annotations.NotNull;
 
-public class BungeeStaffChatCommand extends Command
+public class BungeeStaffChatCommand extends Command {
-{
 
-    private BungeeMain main;
+  private final BungeeMain plugin;
-    private Configuration config;
+  private Configuration config;
 
-    public BungeeStaffChatCommand(BungeeMain main)
+  public BungeeStaffChatCommand(@NotNull BungeeMain plugin) {
-    {
+    super("staffchat");
-        super("staffchat");
+    this.plugin = plugin;
-        this.main = main;
+    config = plugin.getConfig();
-        config = main.getConfig();
+  }
+
+  public void execute(@NotNull CommandSender sender, @NotNull String[] args) {
+    BaseComponent[] noPerm =
+        txt(config.getString("messages.prefix") + config.getString("messages.nopermission"));
+    if (!sender.hasPermission(plugin.commandPerm)) {
+      sender.sendMessage(noPerm);
+      return;
     }
-
+    if (args.length < 1) {
-    public void execute(CommandSender sender, String[] args)
+      help(sender, getName());
-    {
+      return;
-        BaseComponent[] noPerm = txt(config.getString("messages.prefix") + config.getString("messages.nopermission"));
-        if (!sender.hasPermission(main.commandPerm))
-        {
-            sender.sendMessage(noPerm);
-            return;
-        }
-        if (args.length < 1)
-        {
-            help(sender, getName());
-            return;
-        }
-        if (args[0].equalsIgnoreCase("reload"))
-        {
-            if (sender.hasPermission(main.reloadPerm))
-            {
-                reload(sender);
-            }
-            else
-            {
-                sender.sendMessage(noPerm);
-            }
-            return;
-        }
-        help(sender, getName());
     }
-
+    if (args[0].equalsIgnoreCase("reload")) {
-    private void help(CommandSender sender, String label)
+      if (sender.hasPermission(plugin.reloadPerm)) {
-    {
+        reload(sender);
-        String prefix = config.getString("messages.prefix");
+      } else {
-        sender.sendMessage(txt(prefix + "Version " + main.getDescription().getVersion() + ", made by oskar3123"));
+        sender.sendMessage(noPerm);
-        if (sender.hasPermission(main.reloadPerm))
+      }
-        {
+      return;
-            sender.sendMessage(txt(prefix + "/" + label + " reload - Reloads the config file"));
+    } else if (args[0].equalsIgnoreCase("toggle")) {
-        }
+      if (sender.hasPermission(plugin.usePerm)) {
+        toggle(sender);
+      } else {
+        sender.sendMessage(noPerm);
+      }
+      return;
     }
+    help(sender, getName());
+  }
 
-    private void reload(CommandSender sender)
+  private void playerOnly(@NotNull CommandSender sender) {
-    {
+    sender.sendMessage(
-        main.reloadConfig();
+        txt(config.getString("messages.prefix") + config.getString("messages.playeronly")));
-        config = main.getConfig();
+  }
-        sender.sendMessage(txt(config.getString("messages.prefix") + config.getString("messages.reloaded")));
+
+  private void help(@NotNull CommandSender sender, String label) {
+    String prefix = config.getString("messages.prefix");
+    sender.sendMessage(
+        txt(prefix + "Version " + plugin.getDescription().getVersion() + ", made by oskar3123"));
+    if (sender.hasPermission(plugin.usePerm)) {
+      sender.sendMessage(txt(prefix + "Message prefix: " + config.getString("settings.character")));
+      sender.sendMessage(txt(prefix + "/" + label + " toggle - Toggles auto staffchat"));
     }
-
+    if (sender.hasPermission(plugin.reloadPerm)) {
-    private String clr(String string)
+      sender.sendMessage(txt(prefix + "/" + label + " reload - Reloads the config file"));
-    {
-        return ChatColor.translateAlternateColorCodes('&', string);
     }
+  }
 
-    private BaseComponent[] txt(String text)
+  private void reload(@NotNull CommandSender sender) {
-    {
+    plugin.reloadConfig();
-        return TextComponent.fromLegacyText(clr(text));
+    config = plugin.getConfig();
+    sender.sendMessage(
+        txt(config.getString("messages.prefix") + config.getString("messages.reloaded")));
+  }
+
+  private void toggle(@NotNull CommandSender sender) {
+    if (!(sender instanceof ProxiedPlayer)) {
+      playerOnly(sender);
+      return;
     }
+    boolean toggled = plugin.chatListener.togglePlayer(((ProxiedPlayer) sender).getUniqueId());
+    String state =
+        toggled ? config.getString("messages.onstring") : config.getString("messages.offstring");
+    sender.sendMessage(
+        txt(
+            config.getString("messages.prefix")
+                + String.format(config.getString("messages.toggled", ""), state)));
+  }
 
+  @Contract("_ -> new")
+  private @NotNull String clr(@NotNull String string) {
+    return ChatColor.translateAlternateColorCodes('&', string);
+  }
+
+  @Contract("_ -> new")
+  private @NotNull BaseComponent[] txt(@NotNull String text) {
+    return TextComponent.fromLegacyText(clr(text));
+  }
 }

src/main/java/me/oskar3123/staffchat/bungee/event/BungeeChatListener.java

@@ -1,67 +0,0 @@
-package me.oskar3123.staffchat.bungee.event;
-
-import me.oskar3123.staffchat.bungee.BungeeMain;
-import net.md_5.bungee.api.ChatColor;
-import net.md_5.bungee.api.chat.BaseComponent;
-import net.md_5.bungee.api.chat.TextComponent;
-import net.md_5.bungee.api.connection.ProxiedPlayer;
-import net.md_5.bungee.api.event.ChatEvent;
-import net.md_5.bungee.api.plugin.Listener;
-import net.md_5.bungee.config.Configuration;
-import net.md_5.bungee.event.EventHandler;
-
-public class BungeeChatListener implements Listener
-{
-
-    private BungeeMain main;
-
-    public BungeeChatListener(BungeeMain main)
-    {
-        this.main = main;
-    }
-
-    @EventHandler
-    public void chat(ChatEvent event)
-    {
-        if (!(event.getSender() instanceof ProxiedPlayer))
-        {
-            return;
-        }
-
-        ProxiedPlayer player = (ProxiedPlayer) event.getSender();
-        if (!player.hasPermission(main.usePerm))
-        {
-            return;
-        }
-
-        Configuration config = main.getConfig();
-        String character = config.getString("settings.character");
-        if (!event.getMessage().startsWith(character))
-        {
-            return;
-        }
-
-        String format = config.getString("settings.format");
-        format = format.replaceAll("\\{NAME\\}", player.getName());
-        format = format.replaceAll("\\{MESSAGE\\}", event.getMessage().substring(character.length()).trim());
-        final BaseComponent[] message = txt(format);
-
-        main.getProxy().getPlayers().stream()
-                .filter(p -> p.hasPermission(main.seePerm))
-                .forEach(p -> p.sendMessage(message));
-        main.getLogger().info(ChatColor.stripColor(clr(format)));
-
-        event.setCancelled(true);
-    }
-
-    private String clr(String string)
-    {
-        return ChatColor.translateAlternateColorCodes('&', string);
-    }
-
-    private BaseComponent[] txt(String text)
-    {
-        return TextComponent.fromLegacyText(clr(text));
-    }
-
-}

src/main/java/me/oskar3123/staffchat/bungee/event/BungeeStaffChatEvent.java

@@ -0,0 +1,53 @@
+package me.oskar3123.staffchat.bungee.event;
+
+import java.util.Objects;
+import net.md_5.bungee.api.connection.ProxiedPlayer;
+import net.md_5.bungee.api.plugin.Cancellable;
+import net.md_5.bungee.api.plugin.Event;
+import org.jetbrains.annotations.NotNull;
+
+public class BungeeStaffChatEvent extends Event implements Cancellable {
+
+  private final ProxiedPlayer player;
+
+  private boolean cancelled = false;
+  private String format;
+  private String message;
+
+  public BungeeStaffChatEvent(
+      @NotNull ProxiedPlayer player, @NotNull String format, @NotNull String message) {
+    this.player = player;
+    this.format = format;
+    this.message = message;
+  }
+
+  public @NotNull String getFormat() {
+    return format;
+  }
+
+  public void setFormat(@NotNull String format) {
+    this.format = Objects.requireNonNull(format);
+  }
+
+  public @NotNull String getMessage() {
+    return message;
+  }
+
+  public void setMessage(@NotNull String message) {
+    this.message = Objects.requireNonNull(message);
+  }
+
+  public @NotNull ProxiedPlayer getPlayer() {
+    return player;
+  }
+
+  @Override
+  public boolean isCancelled() {
+    return cancelled;
+  }
+
+  @Override
+  public void setCancelled(boolean cancelled) {
+    this.cancelled = cancelled;
+  }
+}

src/main/java/me/oskar3123/staffchat/bungee/listener/BungeeChatListener.java

@@ -0,0 +1,92 @@
+package me.oskar3123.staffchat.bungee.listener;
+
+import java.util.HashSet;
+import java.util.Objects;
+import java.util.Set;
+import java.util.UUID;
+import me.oskar3123.staffchat.bungee.BungeeMain;
+import me.oskar3123.staffchat.bungee.event.BungeeStaffChatEvent;
+import me.oskar3123.staffchat.util.StringUtils;
+import net.md_5.bungee.api.ChatColor;
+import net.md_5.bungee.api.chat.BaseComponent;
+import net.md_5.bungee.api.chat.TextComponent;
+import net.md_5.bungee.api.connection.ProxiedPlayer;
+import net.md_5.bungee.api.event.ChatEvent;
+import net.md_5.bungee.api.plugin.Listener;
+import net.md_5.bungee.config.Configuration;
+import net.md_5.bungee.event.EventHandler;
+import org.jetbrains.annotations.Contract;
+import org.jetbrains.annotations.NotNull;
+
+public class BungeeChatListener implements Listener {
+
+  private final BungeeMain plugin;
+  private final Set<UUID> toggledPlayers = new HashSet<>();
+
+  public BungeeChatListener(@NotNull BungeeMain plugin) {
+    this.plugin = plugin;
+  }
+
+  @EventHandler
+  public void chat(@NotNull ChatEvent event) {
+    if (event.getMessage().startsWith("/")) {
+      return;
+    }
+    if (!(event.getSender() instanceof ProxiedPlayer)) {
+      return;
+    }
+
+    ProxiedPlayer player = (ProxiedPlayer) event.getSender();
+    if (!player.hasPermission(plugin.usePerm)) {
+      return;
+    }
+
+    Configuration config = plugin.getConfig();
+    String character = Objects.requireNonNull(config.getString("settings.character", "@"));
+    boolean isToggled = toggledPlayers.contains(player.getUniqueId());
+    if (!event.getMessage().startsWith(character) && !isToggled) {
+      return;
+    }
+
+    String format = Objects.requireNonNull(config.getString("settings.format", ""));
+    String message = event.getMessage().substring(isToggled ? 0 : character.length()).trim();
+
+    BungeeStaffChatEvent chatEvent = new BungeeStaffChatEvent(player, format, message);
+    plugin.getProxy().getPluginManager().callEvent(chatEvent);
+    if (chatEvent.isCancelled()) {
+      return;
+    }
+    format = chatEvent.getFormat();
+    message = chatEvent.getMessage();
+
+    format = format.replaceAll("\\{NAME}", StringUtils.sanitize(player.getName()));
+    format = format.replaceAll("\\{MESSAGE}", StringUtils.sanitize(message));
+    final BaseComponent[] messageComponents = txt(format);
+
+    plugin.getProxy().getPlayers().stream()
+        .filter(p -> p.hasPermission(plugin.seePerm))
+        .forEach(p -> p.sendMessage(messageComponents));
+    plugin.getLogger().info(ChatColor.stripColor(clr(format)));
+
+    event.setCancelled(true);
+  }
+
+  @Contract("_ -> new")
+  private @NotNull String clr(@NotNull String string) {
+    return ChatColor.translateAlternateColorCodes('&', string);
+  }
+
+  @Contract("_ -> new")
+  private @NotNull BaseComponent[] txt(@NotNull String text) {
+    return TextComponent.fromLegacyText(clr(text));
+  }
+
+  public boolean togglePlayer(@NotNull UUID player) {
+    if (toggledPlayers.contains(player)) {
+      toggledPlayers.remove(player);
+      return false;
+    }
+    toggledPlayers.add(player);
+    return true;
+  }
+}

src/main/java/me/oskar3123/staffchat/spigot/Main.java

@@ -1,33 +1,54 @@
 package me.oskar3123.staffchat.spigot;
 
+import java.util.Optional;
+import me.clip.placeholderapi.PlaceholderAPI;
 import me.oskar3123.staffchat.spigot.command.StaffChatCommand;
-import me.oskar3123.staffchat.spigot.event.ChatListener;
+import me.oskar3123.staffchat.spigot.listener.ChatListener;
 import org.bukkit.Bukkit;
+import org.bukkit.entity.Player;
 import org.bukkit.plugin.java.JavaPlugin;
 
-public class Main extends JavaPlugin
+public class Main extends JavaPlugin {
-{
 
-    public final String usePerm = "staffchat.use";
+  public final String usePerm = "staffchat.use";
-    public final String seePerm = "staffchat.see";
+  public final String seePerm = "staffchat.see";
-    public final String commandPerm = "staffchat.command";
+  public final String commandPerm = "staffchat.command";
-    public final String reloadPerm = "staffchat.reload";
+  public final String reloadPerm = "staffchat.reload";
+  public final ChatListener chatListener = new ChatListener(this);
 
-    public void onEnable()
+  public void onEnable() {
-    {
+    getServer().getMessenger().registerOutgoingPluginChannel(this, "BungeeCord");
-        saveDefaultConfig();
+    getServer().getMessenger().registerIncomingPluginChannel(this, "BungeeCord", chatListener);
-        registerCommands();
+    new MetricsLite(this);
-        registerEvents();
+    saveDefaultConfig();
+    registerCommands();
+    registerEvents();
+  }
+
+  @Override
+  public void saveDefaultConfig() {
+    super.saveDefaultConfig();
+    getConfig().options().copyDefaults(true);
+    saveConfig();
+  }
+
+  private void registerCommands() {
+    Optional.ofNullable(getCommand("staffchat"))
+        .ifPresent(command -> command.setExecutor(new StaffChatCommand(this)));
+  }
+
+  private void registerEvents() {
+    Bukkit.getPluginManager().registerEvents(this.chatListener, this);
+  }
+
+  private boolean isPlaceholderApiEnabled() {
+    return Bukkit.getPluginManager().isPluginEnabled("PlaceholderAPI");
+  }
+
+  public String replacePlaceholders(Player player, String string) {
+    if (!isPlaceholderApiEnabled()) {
+      return string;
     }
-
+    return PlaceholderAPI.setPlaceholders(player, string);
-    private void registerCommands()
+  }
-    {
-        getCommand("staffchat").setExecutor(new StaffChatCommand(this));
-    }
-
-    private void registerEvents()
-    {
-        Bukkit.getPluginManager().registerEvents(new ChatListener(this), this);
-    }
-
 }

src/main/java/me/oskar3123/staffchat/spigot/MetricsLite.java

@@ -0,0 +1,316 @@
+package me.oskar3123.staffchat.spigot;
+
+import com.google.gson.JsonArray;
+import com.google.gson.JsonObject;
+import java.io.ByteArrayOutputStream;
+import java.io.DataOutputStream;
+import java.io.File;
+import java.io.IOException;
+import java.lang.reflect.InvocationTargetException;
+import java.net.URL;
+import java.util.Timer;
+import java.util.TimerTask;
+import java.util.UUID;
+import java.util.logging.Level;
+import java.util.zip.GZIPOutputStream;
+import javax.net.ssl.HttpsURLConnection;
+import org.bukkit.Bukkit;
+import org.bukkit.configuration.file.YamlConfiguration;
+import org.bukkit.plugin.ServicePriority;
+import org.bukkit.plugin.java.JavaPlugin;
+
+/**
+ * bStats collects some data for plugin authors.
+ *
+ * <p>Check out https://bStats.org/ to learn more about bStats!
+ */
+@SuppressWarnings("all")
+public class MetricsLite {
+
+  // The version of this bStats class
+  public static final int B_STATS_VERSION = 1;
+  // The url to which the data is sent
+  private static final String URL = "https://bStats.org/submitData/bukkit";
+  // Should failed requests be logged?
+  private static boolean logFailedRequests;
+  // The uuid of the server
+  private static String serverUUID;
+
+  static {
+    // Maven's Relocate is clever and changes strings, too. So we have to use this little "trick"
+    // ... :D
+    final String defaultPackage =
+        new String(new byte[] {'o', 'r', 'g', '.', 'b', 's', 't', 'a', 't', 's'});
+    final String examplePackage =
+        new String(new byte[] {'y', 'o', 'u', 'r', '.', 'p', 'a', 'c', 'k', 'a', 'g', 'e'});
+    // We want to make sure nobody just copy & pastes the example and use the wrong package names
+    if (MetricsLite.class.getPackage().getName().equals(defaultPackage)
+        || MetricsLite.class.getPackage().getName().equals(examplePackage)) {
+      throw new IllegalStateException("bStats Metrics class has not been relocated correctly!");
+    }
+  }
+
+  // The plugin
+  private final JavaPlugin plugin;
+
+  /**
+   * Class constructor.
+   *
+   * @param plugin The plugin which stats should be submitted.
+   */
+  public MetricsLite(JavaPlugin plugin) {
+    if (plugin == null) {
+      throw new IllegalArgumentException("Plugin cannot be null!");
+    }
+    this.plugin = plugin;
+
+    // Get the config file
+    File bStatsFolder = new File(plugin.getDataFolder().getParentFile(), "bStats");
+    File configFile = new File(bStatsFolder, "config.yml");
+    YamlConfiguration config = YamlConfiguration.loadConfiguration(configFile);
+
+    // Check if the config file exists
+    if (!config.isSet("serverUuid")) {
+
+      // Add default values
+      config.addDefault("enabled", true);
+      // Every server gets it's unique random id.
+      config.addDefault("serverUuid", UUID.randomUUID().toString());
+      // Should failed request be logged?
+      config.addDefault("logFailedRequests", false);
+
+      // Inform the server owners about bStats
+      config
+          .options()
+          .header(
+              "bStats collects some data for plugin authors like how many servers are using their plugins.\n"
+                  + "To honor their work, you should not disable it.\n"
+                  + "This has nearly no effect on the server performance!\n"
+                  + "Check out https://bStats.org/ to learn more :)")
+          .copyDefaults(true);
+      try {
+        config.save(configFile);
+      } catch (IOException ignored) {
+      }
+    }
+
+    // Load the data
+    serverUUID = config.getString("serverUuid");
+    logFailedRequests = config.getBoolean("logFailedRequests", false);
+    if (config.getBoolean("enabled", true)) {
+      boolean found = false;
+      // Search for all other bStats Metrics classes to see if we are the first one
+      for (Class<?> service : Bukkit.getServicesManager().getKnownServices()) {
+        try {
+          service.getField("B_STATS_VERSION"); // Our identifier :)
+          found = true; // We aren't the first
+          break;
+        } catch (NoSuchFieldException ignored) {
+        }
+      }
+      // Register our service
+      Bukkit.getServicesManager().register(MetricsLite.class, this, plugin, ServicePriority.Normal);
+      if (!found) {
+        // We are the first!
+        startSubmitting();
+      }
+    }
+  }
+
+  /**
+   * Sends the data to the bStats server.
+   *
+   * @param data The data to send.
+   * @throws Exception If the request failed.
+   */
+  private static void sendData(JsonObject data) throws Exception {
+    if (data == null) {
+      throw new IllegalArgumentException("Data cannot be null!");
+    }
+    if (Bukkit.isPrimaryThread()) {
+      throw new IllegalAccessException("This method must not be called from the main thread!");
+    }
+    HttpsURLConnection connection = (HttpsURLConnection) new URL(URL).openConnection();
+
+    // Compress the data to save bandwidth
+    byte[] compressedData = compress(data.toString());
+
+    // Add headers
+    connection.setRequestMethod("POST");
+    connection.addRequestProperty("Accept", "application/json");
+    connection.addRequestProperty("Connection", "close");
+    connection.addRequestProperty("Content-Encoding", "gzip"); // We gzip our request
+    connection.addRequestProperty("Content-Length", String.valueOf(compressedData.length));
+    connection.setRequestProperty(
+        "Content-Type", "application/json"); // We send our data in JSON format
+    connection.setRequestProperty("User-Agent", "MC-Server/" + B_STATS_VERSION);
+
+    // Send data
+    connection.setDoOutput(true);
+    DataOutputStream outputStream = new DataOutputStream(connection.getOutputStream());
+    outputStream.write(compressedData);
+    outputStream.flush();
+    outputStream.close();
+
+    connection.getInputStream().close(); // We don't care about the response - Just send our data :)
+  }
+
+  /**
+   * Gzips the given String.
+   *
+   * @param str The string to gzip.
+   * @return The gzipped String.
+   * @throws IOException If the compression failed.
+   */
+  private static byte[] compress(final String str) throws IOException {
+    if (str == null) {
+      return null;
+    }
+    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
+    GZIPOutputStream gzip = new GZIPOutputStream(outputStream);
+    gzip.write(str.getBytes("UTF-8"));
+    gzip.close();
+    return outputStream.toByteArray();
+  }
+
+  /** Starts the Scheduler which submits our data every 30 minutes. */
+  private void startSubmitting() {
+    final Timer timer =
+        new Timer(true); // We use a timer cause the Bukkit scheduler is affected by server lags
+    timer.scheduleAtFixedRate(
+        new TimerTask() {
+          @Override
+          public void run() {
+            if (!plugin.isEnabled()) { // Plugin was disabled
+              timer.cancel();
+              return;
+            }
+            // Nevertheless we want our code to run in the Bukkit main thread, so we have to use the
+            // Bukkit scheduler
+            // Don't be afraid! The connection to the bStats server is still async, only the stats
+            // collection is sync ;)
+            Bukkit.getScheduler()
+                .runTask(
+                    plugin,
+                    new Runnable() {
+                      @Override
+                      public void run() {
+                        submitData();
+                      }
+                    });
+          }
+        },
+        1000 * 60 * 5,
+        1000 * 60 * 30);
+    // Submit the data every 30 minutes, first time after 5 minutes to give other plugins enough
+    // time to start
+    // WARNING: Changing the frequency has no effect but your plugin WILL be blocked/deleted!
+    // WARNING: Just don't do it!
+  }
+
+  /**
+   * Gets the plugin specific data. This method is called using Reflection.
+   *
+   * @return The plugin specific data.
+   */
+  public JsonObject getPluginData() {
+    JsonObject data = new JsonObject();
+
+    String pluginName = plugin.getDescription().getName();
+    String pluginVersion = plugin.getDescription().getVersion();
+
+    data.addProperty("pluginName", pluginName); // Append the name of the plugin
+    data.addProperty("pluginVersion", pluginVersion); // Append the version of the plugin
+
+    JsonArray customCharts = new JsonArray();
+    data.add("customCharts", customCharts);
+
+    return data;
+  }
+
+  /**
+   * Gets the server specific data.
+   *
+   * @return The server specific data.
+   */
+  private JsonObject getServerData() {
+    // Minecraft specific data
+    int playerAmount = Bukkit.getOnlinePlayers().size();
+    int onlineMode = Bukkit.getOnlineMode() ? 1 : 0;
+    String bukkitVersion = Bukkit.getVersion();
+    bukkitVersion =
+        bukkitVersion.substring(bukkitVersion.indexOf("MC: ") + 4, bukkitVersion.length() - 1);
+
+    // OS/Java specific data
+    String javaVersion = System.getProperty("java.version");
+    String osName = System.getProperty("os.name");
+    String osArch = System.getProperty("os.arch");
+    String osVersion = System.getProperty("os.version");
+    int coreCount = Runtime.getRuntime().availableProcessors();
+
+    JsonObject data = new JsonObject();
+
+    data.addProperty("serverUUID", serverUUID);
+
+    data.addProperty("playerAmount", playerAmount);
+    data.addProperty("onlineMode", onlineMode);
+    data.addProperty("bukkitVersion", bukkitVersion);
+
+    data.addProperty("javaVersion", javaVersion);
+    data.addProperty("osName", osName);
+    data.addProperty("osArch", osArch);
+    data.addProperty("osVersion", osVersion);
+    data.addProperty("coreCount", coreCount);
+
+    return data;
+  }
+
+  /** Collects the data and sends it afterwards. */
+  private void submitData() {
+    final JsonObject data = getServerData();
+
+    JsonArray pluginData = new JsonArray();
+    // Search for all other bStats Metrics classes to get their plugin data
+    for (Class<?> service : Bukkit.getServicesManager().getKnownServices()) {
+      try {
+        service.getField("B_STATS_VERSION"); // Our identifier :)
+      } catch (NoSuchFieldException ignored) {
+        continue; // Continue "searching"
+      }
+      // Found one!
+      try {
+        pluginData.add(
+            (JsonObject)
+                service
+                    .getMethod("getPluginData")
+                    .invoke(Bukkit.getServicesManager().load(service)));
+      } catch (NoSuchMethodException | IllegalAccessException | InvocationTargetException ignored) {
+      }
+    }
+
+    data.add("plugins", pluginData);
+
+    // Create a new thread for the connection to the bStats server
+    new Thread(
+            new Runnable() {
+              @Override
+              public void run() {
+                try {
+                  // Send the data
+                  sendData(data);
+                } catch (Exception e) {
+                  // Something went wrong! :(
+                  if (logFailedRequests) {
+                    plugin
+                        .getLogger()
+                        .log(
+                            Level.WARNING,
+                            "Could not submit plugin stats of " + plugin.getName(),
+                            e);
+                  }
+                }
+              }
+            })
+        .start();
+  }
+}

src/main/java/me/oskar3123/staffchat/spigot/command/StaffChatCommand.java

@@ -1,74 +1,103 @@
 package me.oskar3123.staffchat.spigot.command;
 
+import java.util.Objects;
 import me.oskar3123.staffchat.spigot.Main;
 import org.bukkit.ChatColor;
 import org.bukkit.command.Command;
 import org.bukkit.command.CommandExecutor;
 import org.bukkit.command.CommandSender;
 import org.bukkit.configuration.file.FileConfiguration;
+import org.bukkit.entity.Player;
+import org.jetbrains.annotations.Contract;
+import org.jetbrains.annotations.NotNull;
 
-public class StaffChatCommand implements CommandExecutor
+public class StaffChatCommand implements CommandExecutor {
-{
 
-    private Main main;
+  private final Main plugin;
-    private FileConfiguration config;
+  private FileConfiguration config;
 
-    public StaffChatCommand(Main main)
+  public StaffChatCommand(@NotNull Main plugin) {
-    {
+    this.plugin = plugin;
-        this.main = main;
+    config = plugin.getConfig();
-        config = main.getConfig();
+  }
+
+  @Override
+  public boolean onCommand(
+      @NotNull CommandSender sender,
+      @NotNull Command command,
+      @NotNull String label,
+      @NotNull String[] args) {
+    String noPerm =
+        clr(config.getString("messages.prefix") + config.getString("messages.nopermission"));
+    if (!sender.hasPermission(plugin.commandPerm)) {
+      sender.sendMessage(noPerm);
+      return true;
     }
-
+    if (args.length < 1) {
-    @Override
+      help(sender, label);
-    public boolean onCommand(CommandSender sender, Command command, String label, String[] args)
+      return true;
-    {
-        String noPerm = clr(config.getString("messages.prefix") + config.getString("messages.nopermission"));
-        if (!sender.hasPermission(main.commandPerm))
-        {
-            sender.sendMessage(noPerm);
-            return true;
-        }
-        if (args.length < 1)
-        {
-            help(sender, label);
-            return true;
-        }
-        if (args[0].equalsIgnoreCase("reload"))
-        {
-            if (sender.hasPermission(main.reloadPerm))
-            {
-                reload(sender);
-            }
-            else
-            {
-                sender.sendMessage(noPerm);
-            }
-            return true;
-        }
-        help(sender, label);
-        return true;
     }
-
+    if (args[0].equalsIgnoreCase("reload")) {
-    private void help(CommandSender sender, String label)
+      if (sender.hasPermission(plugin.reloadPerm)) {
-    {
+        reload(sender);
-        String prefix = clr(config.getString("messages.prefix"));
+      } else {
-        sender.sendMessage(prefix + "Version " + main.getDescription().getVersion() + ", made by oskar3123");
+        sender.sendMessage(noPerm);
-        if (sender.hasPermission(main.reloadPerm))
+      }
-        {
+      return true;
-            sender.sendMessage(prefix + "/" + label + " reload - Reloads the config file");
+    } else if (args[0].equalsIgnoreCase("toggle")) {
-        }
+      if (sender.hasPermission(plugin.usePerm)) {
+        toggle(sender);
+      } else {
+        sender.sendMessage(noPerm);
+      }
+      return true;
     }
+    help(sender, label);
+    return true;
+  }
 
-    private void reload(CommandSender sender)
+  private void playerOnly(@NotNull CommandSender sender) {
-    {
+    sender.sendMessage(
-        main.reloadConfig();
+        clr(config.getString("messages.prefix") + config.getString("messages.playeronly")));
-        config = main.getConfig();
+  }
-        sender.sendMessage(clr(config.getString("messages.prefix") + config.getString("messages.reloaded")));
+
+  private void help(@NotNull CommandSender sender, String label) {
+    String prefix = clr(Objects.requireNonNull(config.getString("messages.prefix", "")));
+    sender.sendMessage(
+        prefix + "Version " + plugin.getDescription().getVersion() + ", made by oskar3123");
+    if (sender.hasPermission(plugin.usePerm)) {
+      sender.sendMessage(prefix + "Message prefix: " + config.getString("settings.character"));
+      sender.sendMessage(prefix + "/" + label + " toggle - Toggles auto staffchat");
     }
-
+    if (sender.hasPermission(plugin.reloadPerm)) {
-    private String clr(String string)
+      sender.sendMessage(prefix + "/" + label + " reload - Reloads the config file");
-    {
-        return ChatColor.translateAlternateColorCodes('&', string);
     }
+  }
 
+  private void reload(@NotNull CommandSender sender) {
+    plugin.reloadConfig();
+    config = plugin.getConfig();
+    sender.sendMessage(
+        clr(config.getString("messages.prefix") + config.getString("messages.reloaded")));
+  }
+
+  private void toggle(@NotNull CommandSender sender) {
+    if (!(sender instanceof Player)) {
+      playerOnly(sender);
+      return;
+    }
+    boolean toggled = plugin.chatListener.togglePlayer(((Player) sender).getUniqueId());
+    String state =
+        toggled ? config.getString("messages.onstring") : config.getString("messages.offstring");
+    sender.sendMessage(
+        clr(
+            config.getString("messages.prefix")
+                + String.format(
+                    Objects.requireNonNull(config.getString("messages.toggled", "")), state)));
+  }
+
+  @Contract("_ -> new")
+  private @NotNull String clr(@NotNull String string) {
+    return ChatColor.translateAlternateColorCodes('&', string);
+  }
 }

src/main/java/me/oskar3123/staffchat/spigot/event/ChatListener.java

@@ -1,56 +0,0 @@
-package me.oskar3123.staffchat.spigot.event;
-
-import me.oskar3123.staffchat.spigot.Main;
-import org.bukkit.Bukkit;
-import org.bukkit.ChatColor;
-import org.bukkit.configuration.file.FileConfiguration;
-import org.bukkit.event.EventHandler;
-import org.bukkit.event.EventPriority;
-import org.bukkit.event.Listener;
-import org.bukkit.event.player.AsyncPlayerChatEvent;
-
-public class ChatListener implements Listener
-{
-
-    private Main main;
-
-    public ChatListener(Main main)
-    {
-        this.main = main;
-    }
-
-    @EventHandler(priority = EventPriority.HIGHEST, ignoreCancelled = true)
-    public void chat(AsyncPlayerChatEvent event)
-    {
-        if (!event.getPlayer().hasPermission(main.usePerm))
-        {
-            return;
-        }
-
-        FileConfiguration config = main.getConfig();
-        String character = config.getString("settings.character");
-        if (!event.getMessage().startsWith(character))
-        {
-            return;
-        }
-
-        String format = config.getString("settings.format");
-        format = format.replaceAll("\\{NAME\\}", event.getPlayer().getName());
-        format = format.replaceAll("\\{MESSAGE\\}", event.getMessage().substring(character.length()).trim());
-        format = clr(format);
-        final String message = format;
-
-        Bukkit.getOnlinePlayers().stream()
-                .filter(p -> p.hasPermission(main.seePerm))
-                .forEach(p -> p.sendMessage(message));
-        main.getLogger().info(ChatColor.stripColor(message));
-
-        event.setCancelled(true);
-    }
-
-    private String clr(String string)
-    {
-        return ChatColor.translateAlternateColorCodes('&', string);
-    }
-
-}

src/main/java/me/oskar3123/staffchat/spigot/event/StaffChatEvent.java

@@ -0,0 +1,72 @@
+package me.oskar3123.staffchat.spigot.event;
+
+import java.util.Objects;
+import org.bukkit.entity.Player;
+import org.bukkit.event.Cancellable;
+import org.bukkit.event.Event;
+import org.bukkit.event.HandlerList;
+import org.jetbrains.annotations.NotNull;
+
+public class StaffChatEvent extends Event implements Cancellable {
+
+  private static final HandlerList HANDLER_LIST = new HandlerList();
+
+  private final Player player;
+
+  private boolean cancelled = false;
+  private String format;
+  private String message;
+
+  public StaffChatEvent(
+      boolean async, @NotNull Player player, @NotNull String format, @NotNull String message) {
+    super(async);
+    this.player = player;
+    this.format = format;
+    this.message = message;
+  }
+
+  /**
+   * Required by BungeeCord
+   *
+   * @return the handler list
+   */
+  @SuppressWarnings("unused")
+  public static @NotNull HandlerList getHandlerList() {
+    return HANDLER_LIST;
+  }
+
+  public @NotNull String getFormat() {
+    return format;
+  }
+
+  public void setFormat(String format) {
+    this.format = Objects.requireNonNull(format);
+  }
+
+  public @NotNull String getMessage() {
+    return message;
+  }
+
+  public void setMessage(String message) {
+    this.message = Objects.requireNonNull(message);
+  }
+
+  public @NotNull Player getPlayer() {
+    return player;
+  }
+
+  @Override
+  public @NotNull HandlerList getHandlers() {
+    return HANDLER_LIST;
+  }
+
+  @Override
+  public boolean isCancelled() {
+    return cancelled;
+  }
+
+  @Override
+  public void setCancelled(boolean cancelled) {
+    this.cancelled = cancelled;
+  }
+}

src/main/java/me/oskar3123/staffchat/spigot/listener/ChatListener.java

@@ -0,0 +1,161 @@
+package me.oskar3123.staffchat.spigot.listener;
+
+import com.google.common.io.ByteArrayDataInput;
+import com.google.common.io.ByteArrayDataOutput;
+import com.google.common.io.ByteStreams;
+import github.scarsz.discordsrv.DiscordSRV;
+import github.scarsz.discordsrv.util.DiscordUtil;
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.util.HashSet;
+import java.util.Objects;
+import java.util.Set;
+import java.util.UUID;
+import me.oskar3123.staffchat.spigot.Main;
+import me.oskar3123.staffchat.spigot.event.StaffChatEvent;
+import me.oskar3123.staffchat.util.StringUtils;
+import org.bukkit.Bukkit;
+import org.bukkit.ChatColor;
+import org.bukkit.configuration.file.FileConfiguration;
+import org.bukkit.entity.Player;
+import org.bukkit.event.EventHandler;
+import org.bukkit.event.Listener;
+import org.bukkit.event.player.AsyncPlayerChatEvent;
+import org.bukkit.plugin.messaging.PluginMessageListener;
+import org.jetbrains.annotations.NotNull;
+
+public class ChatListener implements Listener, PluginMessageListener {
+
+  private final Main plugin;
+  private final Set<UUID> toggledPlayers = new HashSet<>();
+
+  public ChatListener(@NotNull Main plugin) {
+    this.plugin = plugin;
+  }
+
+  @EventHandler
+  public void chat(@NotNull AsyncPlayerChatEvent event) {
+    if (!event.getPlayer().hasPermission(plugin.usePerm)) {
+      return;
+    }
+
+    FileConfiguration config = plugin.getConfig();
+    String character = Objects.requireNonNull(config.getString("settings.character", "@"));
+    boolean isToggled = toggledPlayers.contains(event.getPlayer().getUniqueId());
+    if (!event.getMessage().startsWith(character) && !isToggled) {
+      return;
+    }
+
+    String format = Objects.requireNonNull(config.getString("settings.format", ""));
+    String message = event.getMessage().substring(isToggled ? 0 : character.length()).trim();
+    if (config.getBoolean("settings.replaceplaceholdersinmessage")) {
+      message = plugin.replacePlaceholders(event.getPlayer(), message);
+    }
+
+    StaffChatEvent chatEvent =
+        new StaffChatEvent(event.isAsynchronous(), event.getPlayer(), format, message);
+    Bukkit.getServer().getPluginManager().callEvent(chatEvent);
+    if (chatEvent.isCancelled()) {
+      return;
+    }
+    format = chatEvent.getFormat();
+    message = chatEvent.getMessage();
+
+    format = plugin.replacePlaceholders(event.getPlayer(), format);
+    format = format.replaceAll("\\{NAME}", StringUtils.sanitize(event.getPlayer().getName()));
+    format = ChatColor.translateAlternateColorCodes('&', format);
+    format = format.replaceAll("\\{MESSAGE}", StringUtils.sanitize(message));
+    final String finalMessage = format;
+
+    if (plugin.getConfig().getBoolean("discordsrv.enable")) {
+      sendDiscordMessage(event.getPlayer(), message);
+    }
+    if (plugin.getConfig().getBoolean("settings.sendmessagestoallservers")) {
+      sendForwardPluginMessage(event.getPlayer(), finalMessage);
+    }
+    sendStaffChatMessage(finalMessage);
+
+    event.setCancelled(true);
+  }
+
+  @Override
+  public void onPluginMessageReceived(
+      @NotNull String channel, @NotNull Player player, byte[] message) {
+    if (!channel.equals("BungeeCord")) {
+      return;
+    }
+    ByteArrayDataInput in = ByteStreams.newDataInput(message);
+    String subChannel = in.readUTF();
+    if (!subChannel.equals("StaffChat")) {
+      return;
+    }
+    short len = in.readShort();
+    byte[] msgbytes = new byte[len];
+    in.readFully(msgbytes);
+
+    DataInputStream msgin = new DataInputStream(new ByteArrayInputStream(msgbytes));
+    String actualMessage;
+    try {
+      actualMessage = msgin.readUTF();
+    } catch (IOException e) {
+      e.printStackTrace();
+      plugin.getLogger().severe("Failed to read plugin message from bungeecord");
+      return;
+    }
+    sendStaffChatMessage(actualMessage);
+  }
+
+  private void sendStaffChatMessage(@NotNull String message) {
+    Bukkit.getOnlinePlayers().stream()
+        .filter(p -> p.hasPermission(plugin.seePerm))
+        .forEach(p -> p.sendMessage(message));
+    plugin.getLogger().info(ChatColor.stripColor(message));
+  }
+
+  private void sendForwardPluginMessage(@NotNull Player player, @NotNull String message) {
+    ByteArrayDataOutput out = ByteStreams.newDataOutput();
+    out.writeUTF("Forward");
+    out.writeUTF("ONLINE");
+    out.writeUTF("StaffChat");
+    ByteArrayOutputStream byteStream = new ByteArrayOutputStream();
+    DataOutputStream dataStream = new DataOutputStream(byteStream);
+    try {
+      dataStream.writeUTF(message);
+    } catch (IOException e) {
+      e.printStackTrace();
+      plugin.getLogger().severe("Failed to send plugin message to bungeecord");
+      return;
+    }
+    byte[] data = byteStream.toByteArray();
+    out.writeShort(data.length);
+    out.write(data);
+    player.sendPluginMessage(plugin, "BungeeCord", out.toByteArray());
+  }
+
+  private void sendDiscordMessage(Player player, String message) {
+    if (Bukkit.getPluginManager().isPluginEnabled("DiscordSRV")) {
+      String format =
+          plugin
+              .replacePlaceholders(player, plugin.getConfig().getString("discordsrv.format", ""))
+              .replaceAll("\\{NAME}", StringUtils.sanitize(player.getName()))
+              .replaceAll("\\{MESSAGE}", StringUtils.sanitize(message));
+      DiscordUtil.sendMessage(
+          DiscordSRV.getPlugin()
+              .getOptionalTextChannel(
+                  plugin.getConfig().getString("discordsrv.channel", "staffchat")),
+          format);
+    }
+  }
+
+  public boolean togglePlayer(@NotNull UUID player) {
+    if (toggledPlayers.contains(player)) {
+      toggledPlayers.remove(player);
+      return false;
+    }
+    toggledPlayers.add(player);
+    return true;
+  }
+}

src/main/java/me/oskar3123/staffchat/util/StringUtils.java

@@ -0,0 +1,10 @@
+package me.oskar3123.staffchat.util;
+
+public class StringUtils {
+
+  public static String sanitize(String string) {
+    string = string.replaceAll("\\\\", "\\\\\\\\");
+    string = string.replaceAll("\\$", "\\\\\\$");
+    return string;
+  }
+}

src/main/resources/bungee.yml

@@ -1,4 +1,4 @@
 name: StaffChat
-authors: [oskar3123]
+author: oskar3123
 main: me.oskar3123.staffchat.bungee.BungeeMain
-version: 1.1.0
+version: 1.4.0

src/main/resources/config.yml

@@ -1,7 +1,17 @@
 settings:
   character: '@'
   format: '&b{NAME}: {MESSAGE}'
+  replaceplaceholdersinmessage: true
+  sendmessagestoallservers: true
 messages:
   prefix: '&7StaffChat&8> &7'
   nopermission: '&cYou don''t have permission to do that'
-  reloaded: 'Reloaded the config file'
+  playeronly: '&cPlayer only command'
+  reloaded: 'Reloaded the config file'
+  toggled: 'You toggled auto staffchat %s'
+  onstring: 'on'
+  offstring: 'off'
+discordsrv:
+  enable: false
+  channel: 'staffchat'
+  format: '{NAME} » {MESSAGE}'

src/main/resources/plugin.yml

@@ -1,13 +1,13 @@
 name: StaffChat
-authors: [oskar3123]
+authors: [ oskar3123 ]
 main: me.oskar3123.staffchat.spigot.Main
-version: 1.1.0
+api-version: 1.13
-
+version: 1.4.0
+softdepend: [ PlaceholderAPI, DiscordSRV ]
 commands:
   staffchat:
     usage: /<command>
     description: Used to reload the config file.
-
 permissions:
   staffchat.*:
     description: Gives you permission to everything in the plugin.