merge

Better naming conventions

.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:
+  - oraclejdk8
+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,62 @@
-# StaffChat
-Simple and highly configurable staff chat
+[![Travis-CI](https://img.shields.io/travis/oskar3123/StaffChat.svg?style=flat)](https://travis-ci.org/oskar3123/StaffChat)
+[![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)
+[![Coverage Status](https://coveralls.io/repos/github/oskar3123/StaffChat/badge.svg?branch=master)](https://coveralls.io/github/oskar3123/StaffChat?branch=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
+
+```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

@@ -7,7 +7,11 @@
 
     <groupId>me.oskar3123</groupId>
     <artifactId>staffchat</artifactId>
-    <version>1.1.1-SNAPSHOT</version>
+    <version>1.1.4-SNAPSHOT</version>
+
+    <properties>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
 
     <repositories>
         <repository>
@@ -24,17 +28,17 @@
         <dependency>
             <groupId>org.spigotmc</groupId>
             <artifactId>spigot-api</artifactId>
-            <version>1.11.2-R0.1-SNAPSHOT</version>
+            <version>1.13-R0.1-SNAPSHOT</version>
         </dependency>
         <dependency>
             <groupId>org.bukkit</groupId>
             <artifactId>bukkit</artifactId>
-            <version>1.11.2-R0.1-SNAPSHOT</version>
+            <version>1.13-R0.1-SNAPSHOT</version>
         </dependency>
         <dependency>
             <groupId>net.md-5</groupId>
             <artifactId>bungeecord-api</artifactId>
-            <version>1.11-SNAPSHOT</version>
+            <version>1.13-SNAPSHOT</version>
         </dependency>
     </dependencies>
 
@@ -49,6 +53,24 @@
                     <target>1.8</target>
                 </configuration>
             </plugin>
+            <plugin>
+                <groupId>org.eluder.coveralls</groupId>
+                <artifactId>coveralls-maven-plugin</artifactId>
+                <version>4.3.0</version>
+            </plugin>
+            <plugin>
+                <groupId>org.jacoco</groupId>
+                <artifactId>jacoco-maven-plugin</artifactId>
+                <version>0.7.9</version>
+                <executions>
+                    <execution>
+                        <id>prepare-agent</id>
+                        <goals>
+                            <goal>prepare-agent</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
         </plugins>
     </build>
 

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

@@ -1,7 +1,7 @@
 package me.oskar3123.staffchat.bungee;
 
 import me.oskar3123.staffchat.bungee.command.BungeeStaffChatCommand;
-import me.oskar3123.staffchat.bungee.event.BungeeChatListener;
+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;
@@ -28,7 +28,6 @@ public class BungeeMain extends Plugin
         if (!reloadConfig())
         {
             getLogger().severe("Could not load config file, using defaults.");
-            return;
         }
         registerCommands();
         registerEvents();

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

@@ -9,96 +9,96 @@ import net.md_5.bungee.config.ConfigurationProvider;
 import net.md_5.bungee.config.YamlConfiguration;
 
 import javax.net.ssl.HttpsURLConnection;
-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.io.*;
 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.*;
 import java.util.concurrent.TimeUnit;
 import java.util.logging.Level;
 import java.util.zip.GZIPOutputStream;
 
 /**
  * bStats collects some data for plugin authors.
- *
+ * <p>
  * Check out https://bStats.org/ to learn more about bStats!
  */
 @SuppressWarnings("all")
-public class MetricsLite {
+public class MetricsLite
+{
 
-    static {
+    // 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' });
+        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)) {
+        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 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";
-
     // 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;
 
-    // A list with all known metrics class objects including this one
-    private static final List<Object> knownMetricsInstances = new ArrayList<>();
-
-    public MetricsLite(Plugin plugin) {
+    public MetricsLite(Plugin plugin)
+    {
         this.plugin = plugin;
 
-        try {
+        try
+        {
             loadConfig();
-        } catch (IOException e) {
+        }
+        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) {
+        if (!enabled)
+        {
             return;
         }
 
         Class<?> usedMetricsClass = getFirstBStatsClass();
-        if (usedMetricsClass == null) {
+        if (usedMetricsClass == null)
+        {
             // Failed to get first metrics class
             return;
         }
-        if (usedMetricsClass == getClass()) {
+        if (usedMetricsClass == getClass())
+        {
             // We are the first! :)
             linkMetrics(this);
             startSubmitting();
-        } else {
+        }
+        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) {
+            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);
                 }
             }
@@ -111,17 +111,76 @@ public class MetricsLite {
      *
      * @param metrics An object of the metrics class to link.
      */
-    public static void linkMetrics(Object metrics) {
+    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() {
+    public JsonObject getPluginData()
+    {
         JsonObject data = new JsonObject();
 
         String pluginName = plugin.getDescription().getName();
@@ -136,23 +195,28 @@ public class MetricsLite {
         return data;
     }
 
-    private void startSubmitting() {
+    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() {
+        timer.scheduleAtFixedRate(new TimerTask()
+        {
             @Override
-            public void run() {
+            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() {
+                scheduler.schedule(plugin, new Runnable()
+                {
                     @Override
-                    public void run() {
+                    public void run()
+                    {
                         submitData();
                     }
                 }, 0L, TimeUnit.SECONDS);
             }
-        }, 1000*60*2, 1000*60*30);
+        }, 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!
@@ -163,7 +227,8 @@ public class MetricsLite {
      *
      * @return The server specific data.
      */
-    private JsonObject getServerData() {
+    private JsonObject getServerData()
+    {
         // Minecraft specific data
         int playerAmount = plugin.getProxy().getOnlineCount();
         playerAmount = playerAmount > 500 ? 500 : playerAmount;
@@ -199,32 +264,45 @@ public class MetricsLite {
     /**
      * Collects the data and sends it afterwards.
      */
-    private void submitData() {
+    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 {
+        for (Object metrics : knownMetricsInstances)
+        {
+            try
+            {
                 Object plugin = metrics.getClass().getMethod("getPluginData").invoke(metrics);
-                if (plugin instanceof JsonObject) {
+                if (plugin instanceof JsonObject)
+                {
                     pluginData.add((JsonObject) plugin);
                 }
-            } catch (NoSuchMethodException | IllegalAccessException | InvocationTargetException ignored) { }
+            }
+            catch (NoSuchMethodException | IllegalAccessException | InvocationTargetException ignored)
+            {
+            }
         }
 
         data.add("plugins", pluginData);
 
         // Create a new thread for the connection to the bStats server
-        new Thread(new Runnable() {
+        new Thread(new Runnable()
+        {
             @Override
-            public void run() {
-                try {
+            public void run()
+            {
+                try
+                {
                     // Send the data
                     sendData(data);
-                } catch (Exception e) {
+                }
+                catch (Exception e)
+                {
                     // Something went wrong! :(
-                    if (logFailedRequests) {
+                    if (logFailedRequests)
+                    {
                         plugin.getLogger().log(Level.WARNING, "Could not submit plugin stats!", e);
                     }
                 }
@@ -237,11 +315,13 @@ public class MetricsLite {
      *
      * @throws IOException If something did not work :(
      */
-    private void loadConfig() throws IOException {
+    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()) {
+        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.",
@@ -265,23 +345,33 @@ public class MetricsLite {
      *
      * @return The first bStats metrics class.
      */
-    private Class<?> getFirstBStatsClass() {
+    private Class<?> getFirstBStatsClass()
+    {
         Path configPath = plugin.getDataFolder().toPath().getParent().resolve("bStats");
         configPath.toFile().mkdirs();
         File tempFile = new File(configPath.toFile(), "temp.txt");
 
-        try {
+        try
+        {
             String className = readFile(tempFile);
-            if (className != null) {
-                try {
+            if (className != null)
+            {
+                try
+                {
                     // Let's check if a class with the given name exists.
                     return Class.forName(className);
-                } catch (ClassNotFoundException ignored) { }
+                }
+                catch (ClassNotFoundException ignored)
+                {
+                }
             }
             writeFile(tempFile, getClass().getName());
             return getClass();
-        } catch (IOException e) {
-            if (logFailedRequests) {
+        }
+        catch (IOException e)
+        {
+            if (logFailedRequests)
+            {
                 plugin.getLogger().log(Level.WARNING, "Failed to get first bStats class!", e);
             }
             return null;
@@ -295,14 +385,17 @@ public class MetricsLite {
      * @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()) {
+    private String readFile(File file) throws IOException
+    {
+        if (!file.exists())
+        {
             return null;
         }
         try (
                 FileReader fileReader = new FileReader(file);
-                BufferedReader bufferedReader =  new BufferedReader(fileReader);
-        ) {
+                BufferedReader bufferedReader = new BufferedReader(fileReader);
+        )
+        {
             return bufferedReader.readLine();
         }
     }
@@ -310,76 +403,27 @@ public class MetricsLite {
     /**
      * 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 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()) {
+    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) {
+        )
+        {
+            for (String line : lines)
+            {
                 bufferedWriter.write(line);
                 bufferedWriter.newLine();
             }
         }
     }
 
-    /**
-     * 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();
-    }
-
 }

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

@@ -11,20 +11,20 @@ import net.md_5.bungee.config.Configuration;
 public class BungeeStaffChatCommand extends Command
 {
 
-    private BungeeMain main;
+    private BungeeMain plugin;
     private Configuration config;
 
-    public BungeeStaffChatCommand(BungeeMain main)
+    public BungeeStaffChatCommand(BungeeMain plugin)
     {
         super("staffchat");
-        this.main = main;
-        config = main.getConfig();
+        this.plugin = plugin;
+        config = plugin.getConfig();
     }
 
     public void execute(CommandSender sender, String[] args)
     {
         BaseComponent[] noPerm = txt(config.getString("messages.prefix") + config.getString("messages.nopermission"));
-        if (!sender.hasPermission(main.commandPerm))
+        if (!sender.hasPermission(plugin.commandPerm))
         {
             sender.sendMessage(noPerm);
             return;
@@ -36,7 +36,7 @@ public class BungeeStaffChatCommand extends Command
         }
         if (args[0].equalsIgnoreCase("reload"))
         {
-            if (sender.hasPermission(main.reloadPerm))
+            if (sender.hasPermission(plugin.reloadPerm))
             {
                 reload(sender);
             }
@@ -52,8 +52,8 @@ public class BungeeStaffChatCommand extends Command
     private void help(CommandSender sender, String label)
     {
         String prefix = config.getString("messages.prefix");
-        sender.sendMessage(txt(prefix + "Version " + main.getDescription().getVersion() + ", made by oskar3123"));
-        if (sender.hasPermission(main.reloadPerm))
+        sender.sendMessage(txt(prefix + "Version " + plugin.getDescription().getVersion() + ", made by oskar3123"));
+        if (sender.hasPermission(plugin.reloadPerm))
         {
             sender.sendMessage(txt(prefix + "/" + label + " reload - Reloads the config file"));
         }
@@ -61,8 +61,8 @@ public class BungeeStaffChatCommand extends Command
 
     private void reload(CommandSender sender)
     {
-        main.reloadConfig();
-        config = main.getConfig();
+        plugin.reloadConfig();
+        config = plugin.getConfig();
         sender.sendMessage(txt(config.getString("messages.prefix") + config.getString("messages.reloaded")));
     }
 

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

@@ -0,0 +1,54 @@
+package me.oskar3123.staffchat.bungee.event;
+
+import net.md_5.bungee.api.connection.ProxiedPlayer;
+import net.md_5.bungee.api.plugin.Cancellable;
+import net.md_5.bungee.api.plugin.Event;
+
+public class BungeeStaffChatEvent extends Event implements Cancellable
+{
+
+    private final String message;
+    private final ProxiedPlayer player;
+    private boolean cancelled = false;
+    private String format;
+
+    public BungeeStaffChatEvent(ProxiedPlayer player, String format, String message)
+    {
+        this.player = player;
+        this.format = format;
+        this.message = message;
+    }
+
+    public String getFormat()
+    {
+        return format;
+    }
+
+    public void setFormat(String format)
+    {
+        this.format = format;
+    }
+
+    public String getMessage()
+    {
+        return message;
+    }
+
+    public 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

@@ -1,6 +1,8 @@
-package me.oskar3123.staffchat.bungee.event;
+package me.oskar3123.staffchat.bungee.listener;
 
 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;
@@ -13,11 +15,11 @@ import net.md_5.bungee.event.EventHandler;
 public class BungeeChatListener implements Listener
 {
 
-    private BungeeMain main;
+    private BungeeMain plugin;
 
-    public BungeeChatListener(BungeeMain main)
+    public BungeeChatListener(BungeeMain plugin)
     {
-        this.main = main;
+        this.plugin = plugin;
     }
 
     @EventHandler
@@ -29,12 +31,12 @@ public class BungeeChatListener implements Listener
         }
 
         ProxiedPlayer player = (ProxiedPlayer) event.getSender();
-        if (!player.hasPermission(main.usePerm))
+        if (!player.hasPermission(plugin.usePerm))
         {
             return;
         }
 
-        Configuration config = main.getConfig();
+        Configuration config = plugin.getConfig();
         String character = config.getString("settings.character");
         if (!event.getMessage().startsWith(character))
         {
@@ -42,14 +44,24 @@ public class BungeeChatListener implements Listener
         }
 
         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);
+        String message = event.getMessage().substring(character.length()).trim();
 
-        main.getProxy().getPlayers().stream()
-                .filter(p -> p.hasPermission(main.seePerm))
-                .forEach(p -> p.sendMessage(message));
-        main.getLogger().info(ChatColor.stripColor(clr(format)));
+        BungeeStaffChatEvent chatEvent = new BungeeStaffChatEvent(player, format, message);
+        plugin.getProxy().getPluginManager().callEvent(chatEvent);
+        if (chatEvent.isCancelled())
+        {
+            return;
+        }
+        format = chatEvent.getFormat();
+
+        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);
     }

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

@@ -1,7 +1,7 @@
 package me.oskar3123.staffchat.spigot;
 
 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.plugin.java.JavaPlugin;
 

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

@@ -22,34 +22,34 @@ import java.util.zip.GZIPOutputStream;
 
 /**
  * bStats collects some data for plugin authors.
- *
+ * <p>
  * Check out https://bStats.org/ to learn more about bStats!
  */
 @SuppressWarnings("all")
-public class MetricsLite {
-
-    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!");
-        }
-    }
+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;
 
@@ -58,8 +58,10 @@ public class MetricsLite {
      *
      * @param plugin The plugin which stats should be submitted.
      */
-    public MetricsLite(JavaPlugin plugin) {
-        if (plugin == null) {
+    public MetricsLite(JavaPlugin plugin)
+    {
+        if (plugin == null)
+        {
             throw new IllegalArgumentException("Plugin cannot be null!");
         }
         this.plugin = plugin;
@@ -70,7 +72,8 @@ public class MetricsLite {
         YamlConfiguration config = YamlConfiguration.loadConfiguration(configFile);
 
         // Check if the config file exists
-        if (!config.isSet("serverUuid")) {
+        if (!config.isSet("serverUuid"))
+        {
 
             // Add default values
             config.addDefault("enabled", true);
@@ -86,166 +89,58 @@ public class MetricsLite {
                             "This has nearly no effect on the server performance!\n" +
                             "Check out https://bStats.org/ to learn more :)"
             ).copyDefaults(true);
-            try {
+            try
+            {
                 config.save(configFile);
-            } catch (IOException ignored) { }
+            }
+            catch (IOException ignored)
+            {
+            }
         }
 
         // Load the data
         serverUUID = config.getString("serverUuid");
         logFailedRequests = config.getBoolean("logFailedRequests", false);
-        if (config.getBoolean("enabled", true)) {
+        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 {
+            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) { }
+                }
+                catch (NoSuchFieldException ignored)
+                {
+                }
             }
             // Register our service
             Bukkit.getServicesManager().register(MetricsLite.class, this, plugin, ServicePriority.Normal);
-            if (!found) {
+            if (!found)
+            {
                 // We are the first!
                 startSubmitting();
             }
         }
     }
 
-    /**
-     * 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.put("pluginName", pluginName); // Append the name of the plugin
-        data.put("pluginVersion", pluginVersion); // Append the version of the plugin
-        JSONArray customCharts = new JSONArray();
-        data.put("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.put("serverUUID", serverUUID);
-
-        data.put("playerAmount", playerAmount);
-        data.put("onlineMode", onlineMode);
-        data.put("bukkitVersion", bukkitVersion);
-
-        data.put("javaVersion", javaVersion);
-        data.put("osName", osName);
-        data.put("osArch", osArch);
-        data.put("osVersion", osVersion);
-        data.put("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(service.getMethod("getPluginData").invoke(Bukkit.getServicesManager().load(service)));
-            } catch (NoSuchMethodException | IllegalAccessException | InvocationTargetException ignored) { }
-        }
-
-        data.put("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();
-    }
-
     /**
      * 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) {
+    private static void sendData(JSONObject data) throws Exception
+    {
+        if (data == null)
+        {
             throw new IllegalArgumentException("Data cannot be null!");
         }
-        if (Bukkit.isPrimaryThread()) {
+        if (Bukkit.isPrimaryThread())
+        {
             throw new IllegalAccessException("This method must not be called from the main thread!");
         }
         HttpsURLConnection connection = (HttpsURLConnection) new URL(URL).openConnection();
@@ -279,8 +174,10 @@ public class MetricsLite {
      * @return The gzipped String.
      * @throws IOException If the compression failed.
      */
-    private static byte[] compress(final String str) throws IOException {
-        if (str == null) {
+    private static byte[] compress(final String str) throws IOException
+    {
+        if (str == null)
+        {
             return null;
         }
         ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
@@ -290,4 +187,149 @@ public class MetricsLite {
         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.put("pluginName", pluginName); // Append the name of the plugin
+        data.put("pluginVersion", pluginVersion); // Append the version of the plugin
+        JSONArray customCharts = new JSONArray();
+        data.put("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.put("serverUUID", serverUUID);
+
+        data.put("playerAmount", playerAmount);
+        data.put("onlineMode", onlineMode);
+        data.put("bukkitVersion", bukkitVersion);
+
+        data.put("javaVersion", javaVersion);
+        data.put("osName", osName);
+        data.put("osArch", osArch);
+        data.put("osVersion", osVersion);
+        data.put("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(service.getMethod("getPluginData").invoke(Bukkit.getServicesManager().load(service)));
+            }
+            catch (NoSuchMethodException | IllegalAccessException | InvocationTargetException ignored)
+            {
+            }
+        }
+
+        data.put("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

@@ -10,20 +10,20 @@ import org.bukkit.configuration.file.FileConfiguration;
 public class StaffChatCommand implements CommandExecutor
 {
 
-    private Main main;
+    private Main plugin;
     private FileConfiguration config;
 
-    public StaffChatCommand(Main main)
+    public StaffChatCommand(Main plugin)
     {
-        this.main = main;
-        config = main.getConfig();
+        this.plugin = plugin;
+        config = plugin.getConfig();
     }
 
     @Override
     public boolean onCommand(CommandSender sender, Command command, String label, String[] args)
     {
         String noPerm = clr(config.getString("messages.prefix") + config.getString("messages.nopermission"));
-        if (!sender.hasPermission(main.commandPerm))
+        if (!sender.hasPermission(plugin.commandPerm))
         {
             sender.sendMessage(noPerm);
             return true;
@@ -35,7 +35,7 @@ public class StaffChatCommand implements CommandExecutor
         }
         if (args[0].equalsIgnoreCase("reload"))
         {
-            if (sender.hasPermission(main.reloadPerm))
+            if (sender.hasPermission(plugin.reloadPerm))
             {
                 reload(sender);
             }
@@ -52,8 +52,8 @@ public class StaffChatCommand implements CommandExecutor
     private void help(CommandSender sender, String label)
     {
         String prefix = clr(config.getString("messages.prefix"));
-        sender.sendMessage(prefix + "Version " + main.getDescription().getVersion() + ", made by oskar3123");
-        if (sender.hasPermission(main.reloadPerm))
+        sender.sendMessage(prefix + "Version " + plugin.getDescription().getVersion() + ", made by oskar3123");
+        if (sender.hasPermission(plugin.reloadPerm))
         {
             sender.sendMessage(prefix + "/" + label + " reload - Reloads the config file");
         }
@@ -61,8 +61,8 @@ public class StaffChatCommand implements CommandExecutor
 
     private void reload(CommandSender sender)
     {
-        main.reloadConfig();
-        config = main.getConfig();
+        plugin.reloadConfig();
+        config = plugin.getConfig();
         sender.sendMessage(clr(config.getString("messages.prefix") + config.getString("messages.reloaded")));
     }
 

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,67 @@
+package me.oskar3123.staffchat.spigot.event;
+
+import org.bukkit.entity.Player;
+import org.bukkit.event.Cancellable;
+import org.bukkit.event.Event;
+import org.bukkit.event.HandlerList;
+
+public class StaffChatEvent extends Event implements Cancellable
+{
+
+    private static HandlerList handlerList = new HandlerList();
+    private final Player player;
+    private final String message;
+    private boolean cancelled = false;
+    private String format;
+
+    public StaffChatEvent(Player player, String format, String message)
+    {
+        this.player = player;
+        this.format = format;
+        this.message = message;
+    }
+
+    public static HandlerList getHandlerList()
+    {
+        return handlerList;
+    }
+
+    public String getFormat()
+    {
+        return format;
+    }
+
+    public void setFormat(String format)
+    {
+        this.format = format;
+    }
+
+    public Player getPlayer()
+    {
+        return player;
+    }
+
+    public String getMessage()
+    {
+        return message;
+    }
+
+    @Override
+    public HandlerList getHandlers()
+    {
+        return handlerList;
+    }
+
+    @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,62 @@
+package me.oskar3123.staffchat.spigot.listener;
+
+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.event.EventHandler;
+import org.bukkit.event.Listener;
+import org.bukkit.event.player.AsyncPlayerChatEvent;
+
+public class ChatListener implements Listener
+{
+
+    private Main plugin;
+
+    public ChatListener(Main plugin)
+    {
+        this.plugin = plugin;
+    }
+
+    @EventHandler
+    public void chat(AsyncPlayerChatEvent event)
+    {
+        if (!event.getPlayer().hasPermission(plugin.usePerm))
+        {
+            return;
+        }
+
+        FileConfiguration config = plugin.getConfig();
+        String character = config.getString("settings.character");
+        if (!event.getMessage().startsWith(character))
+        {
+            return;
+        }
+
+        String format = config.getString("settings.format");
+        String message = event.getMessage().substring(character.length()).trim();
+
+        StaffChatEvent chatEvent = new StaffChatEvent(event.getPlayer(), format, message);
+        Bukkit.getServer().getPluginManager().callEvent(chatEvent);
+        if (chatEvent.isCancelled())
+        {
+            return;
+        }
+        format = chatEvent.getFormat();
+
+        format = format.replaceAll("\\{NAME\\}", StringUtils.sanitize(event.getPlayer().getName()));
+        format = format.replaceAll("\\{MESSAGE\\}", StringUtils.sanitize(message));
+        format = ChatColor.translateAlternateColorCodes('&', format);
+        final String finalMessage = format;
+
+        Bukkit.getOnlinePlayers().stream()
+                .filter(p -> p.hasPermission(plugin.seePerm))
+                .forEach(p -> p.sendMessage(finalMessage));
+        plugin.getLogger().info(ChatColor.stripColor(finalMessage));
+
+        event.setCancelled(true);
+    }
+
+}

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

@@ -0,0 +1,13 @@
+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]
 main: me.oskar3123.staffchat.bungee.BungeeMain
-version: 1.1.1
+version: 1.1.3

src/main/resources/plugin.yml

@@ -1,7 +1,7 @@
 name: StaffChat
 authors: [oskar3123]
 main: me.oskar3123.staffchat.spigot.Main
-version: 1.1.1
+version: 1.1.3
 
 commands:
   staffchat:

src/test/java/me/oskar3123/staffchat/TestProxiedPlayer.java

@@ -0,0 +1,308 @@
+package me.oskar3123.staffchat;
+
+import net.md_5.bungee.api.*;
+import net.md_5.bungee.api.chat.BaseComponent;
+import net.md_5.bungee.api.config.ServerInfo;
+import net.md_5.bungee.api.connection.PendingConnection;
+import net.md_5.bungee.api.connection.ProxiedPlayer;
+import net.md_5.bungee.api.connection.Server;
+import net.md_5.bungee.api.event.ServerConnectEvent;
+import net.md_5.bungee.api.score.Scoreboard;
+
+import java.net.InetSocketAddress;
+import java.util.Collection;
+import java.util.Locale;
+import java.util.Map;
+import java.util.UUID;
+
+public class TestProxiedPlayer implements ProxiedPlayer
+{
+
+    @Override
+    public String getDisplayName()
+    {
+        return null;
+    }
+
+    @Override
+    public void setDisplayName(String s)
+    {
+
+    }
+
+    @Override
+    public void sendMessage(ChatMessageType chatMessageType, BaseComponent... baseComponents)
+    {
+
+    }
+
+    @Override
+    public void sendMessage(ChatMessageType chatMessageType, BaseComponent baseComponent)
+    {
+
+    }
+
+    @Override
+    public void connect(ServerInfo serverInfo)
+    {
+
+    }
+
+    @Override
+    public void connect(ServerInfo serverInfo, ServerConnectEvent.Reason reason)
+    {
+
+    }
+
+    @Override
+    public void connect(ServerInfo serverInfo, Callback<Boolean> callback)
+    {
+
+    }
+
+    @Override
+    public void connect(ServerInfo serverInfo, Callback<Boolean> callback, ServerConnectEvent.Reason reason)
+    {
+
+    }
+
+    @Override
+    public void connect(ServerConnectRequest serverConnectRequest)
+    {
+
+    }
+
+    @Override
+    public Server getServer()
+    {
+        return null;
+    }
+
+    @Override
+    public int getPing()
+    {
+        return 0;
+    }
+
+    @Override
+    public void sendData(String s, byte[] bytes)
+    {
+
+    }
+
+    @Override
+    public PendingConnection getPendingConnection()
+    {
+        return null;
+    }
+
+    @Override
+    public void chat(String s)
+    {
+
+    }
+
+    @Override
+    public ServerInfo getReconnectServer()
+    {
+        return null;
+    }
+
+    @Override
+    public void setReconnectServer(ServerInfo serverInfo)
+    {
+
+    }
+
+    @Override
+    public String getUUID()
+    {
+        return null;
+    }
+
+    @Override
+    public UUID getUniqueId()
+    {
+        return null;
+    }
+
+    @Override
+    public Locale getLocale()
+    {
+        return null;
+    }
+
+    @Override
+    public byte getViewDistance()
+    {
+        return 0;
+    }
+
+    @Override
+    public ChatMode getChatMode()
+    {
+        return null;
+    }
+
+    @Override
+    public boolean hasChatColors()
+    {
+        return false;
+    }
+
+    @Override
+    public SkinConfiguration getSkinParts()
+    {
+        return null;
+    }
+
+    @Override
+    public MainHand getMainHand()
+    {
+        return null;
+    }
+
+    @Override
+    public void setTabHeader(BaseComponent baseComponent, BaseComponent baseComponent1)
+    {
+
+    }
+
+    @Override
+    public void setTabHeader(BaseComponent[] baseComponents, BaseComponent[] baseComponents1)
+    {
+
+    }
+
+    @Override
+    public void resetTabHeader()
+    {
+
+    }
+
+    @Override
+    public void sendTitle(Title title)
+    {
+
+    }
+
+    @Override
+    public boolean isForgeUser()
+    {
+        return false;
+    }
+
+    @Override
+    public Map<String, String> getModList()
+    {
+        return null;
+    }
+
+    @Override
+    public Scoreboard getScoreboard()
+    {
+        return null;
+    }
+
+    @Override
+    public String getName()
+    {
+        return null;
+    }
+
+    @Override
+    public void sendMessage(String s)
+    {
+
+    }
+
+    @Override
+    public void sendMessages(String... strings)
+    {
+
+    }
+
+    @Override
+    public void sendMessage(BaseComponent... baseComponents)
+    {
+
+    }
+
+    @Override
+    public void sendMessage(BaseComponent baseComponent)
+    {
+
+    }
+
+    @Override
+    public Collection<String> getGroups()
+    {
+        return null;
+    }
+
+    @Override
+    public void addGroups(String... strings)
+    {
+
+    }
+
+    @Override
+    public void removeGroups(String... strings)
+    {
+
+    }
+
+    @Override
+    public boolean hasPermission(String s)
+    {
+        return false;
+    }
+
+    @Override
+    public void setPermission(String s, boolean b)
+    {
+
+    }
+
+    @Override
+    public Collection<String> getPermissions()
+    {
+        return null;
+    }
+
+    @Override
+    public InetSocketAddress getAddress()
+    {
+        return null;
+    }
+
+    @Override
+    public void disconnect(String s)
+    {
+
+    }
+
+    @Override
+    public void disconnect(BaseComponent... baseComponents)
+    {
+
+    }
+
+    @Override
+    public void disconnect(BaseComponent baseComponent)
+    {
+
+    }
+
+    @Override
+    public boolean isConnected()
+    {
+        return false;
+    }
+
+    @Override
+    public Unsafe unsafe()
+    {
+        return null;
+    }
+}

src/test/java/me/oskar3123/staffchat/bungee/event/BungeeStaffChatEventTest.java

@@ -0,0 +1,57 @@
+package me.oskar3123.staffchat.bungee.event;
+
+import me.oskar3123.staffchat.TestProxiedPlayer;
+import net.md_5.bungee.api.connection.ProxiedPlayer;
+import org.junit.Before;
+import org.junit.Test;
+
+import static org.junit.Assert.*;
+
+public class BungeeStaffChatEventTest
+{
+
+    private ProxiedPlayer player;
+    private String format;
+    private String message;
+    private BungeeStaffChatEvent event;
+
+    @Before
+    public void before()
+    {
+        this.player = new TestProxiedPlayer();
+        this.format = "Format";
+        this.message = "Message";
+        this.event = new BungeeStaffChatEvent(player, format, message);
+    }
+
+    @Test
+    public void testFormat()
+    {
+        assertEquals(format, event.getFormat());
+        String newFormat = "New Format";
+        event.setFormat(newFormat);
+        assertEquals(newFormat, event.getFormat());
+    }
+
+    @Test
+    public void getMessage()
+    {
+        assertEquals(message, event.getMessage());
+    }
+
+    @Test
+    public void getPlayer()
+    {
+        assertEquals(player, event.getPlayer());
+    }
+
+    @Test
+    public void testCancelled()
+    {
+        event.setCancelled(true);
+        assertTrue(event.isCancelled());
+        event.setCancelled(false);
+        assertFalse(event.isCancelled());
+    }
+
+}

src/test/java/me/oskar3123/staffchat/spigot/event/StaffChatEventTest.java

@@ -0,0 +1,57 @@
+package me.oskar3123.staffchat.spigot.event;
+
+import me.oskar3123.staffchat.TestPlayer;
+import org.bukkit.entity.Player;
+import org.junit.Before;
+import org.junit.Test;
+
+import static org.junit.Assert.*;
+
+public class StaffChatEventTest
+{
+
+    private Player player;
+    private String format;
+    private String message;
+    private StaffChatEvent event;
+
+    @Before
+    public void before()
+    {
+        this.player = new TestPlayer();
+        this.format = "Format";
+        this.message = "Message";
+        this.event = new StaffChatEvent(player, format, message);
+    }
+
+    @Test
+    public void testFormat()
+    {
+        assertEquals(format, event.getFormat());
+        String newFormat = "New Format";
+        event.setFormat(newFormat);
+        assertEquals(newFormat, event.getFormat());
+    }
+
+    @Test
+    public void getPlayer()
+    {
+        assertEquals(player, event.getPlayer());
+    }
+
+    @Test
+    public void getMessage()
+    {
+        assertEquals(message, event.getMessage());
+    }
+
+    @Test
+    public void testCancelled()
+    {
+        event.setCancelled(true);
+        assertTrue(event.isCancelled());
+        event.setCancelled(false);
+        assertFalse(event.isCancelled());
+    }
+
+}

src/test/java/me/oskar3123/staffchat/util/StringUtilsTest.java

@@ -0,0 +1,16 @@
+package me.oskar3123.staffchat.util;
+
+import org.junit.Test;
+
+import static org.junit.Assert.*;
+
+public class StringUtilsTest
+{
+
+    @Test
+    public void sanitize()
+    {
+        assertEquals("message", "hejsan \\$ \\\\ xd", StringUtils.sanitize("hejsan $ \\ xd"));
+    }
+
+}