version 1.3.0

spigot version:
  now sends a bungeecord forward plugin message to display on all servers under the same proxy
both versions:
  message is now editable in the events

.coveralls.yml

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

.gitignore

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

.travis.yml

@@ -9,3 +9,5 @@ deploy:
   skip_cleanup: true
   on:
     tags: true
+after_success:
+  - mvn clean test jacoco:report coveralls:report

README.md

@@ -1,7 +1,61 @@
+[![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)
+
 # [StaffChat](https://oskar3123.github.io/StaffChat)
-![Build status](https://api.travis-ci.org/oskar3123/StaffChat.svg?branch=master "Build status")
 
 Simple and highly configurable staffchat
 
 ## Download
 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

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

pom.xml

@@ -7,7 +7,11 @@
 
     <groupId>me.oskar3123</groupId>
     <artifactId>staffchat</artifactId>
-    <version>1.1.2-SNAPSHOT</version>
+    <version>1.3.0-SNAPSHOT</version>
+
+    <properties>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
 
     <repositories>
         <repository>
@@ -18,27 +22,38 @@
             <id>bungeecord-repo</id>
             <url>https://oss.sonatype.org/content/repositories/snapshots/</url>
         </repository>
+        <repository>
+            <id>placeholderapi</id>
+            <url>http://repo.extendedclip.com/content/repositories/placeholderapi/</url>
+        </repository>
     </repositories>
 
     <dependencies>
         <dependency>
             <groupId>org.spigotmc</groupId>
             <artifactId>spigot-api</artifactId>
-            <version>1.11.2-R0.1-SNAPSHOT</version>
+            <version>1.13.2-R0.1-SNAPSHOT</version>
         </dependency>
         <dependency>
             <groupId>org.bukkit</groupId>
             <artifactId>bukkit</artifactId>
-            <version>1.11.2-R0.1-SNAPSHOT</version>
+            <version>1.13.2-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>
+        <dependency>
+            <groupId>me.clip</groupId>
+            <artifactId>placeholderapi</artifactId>
+            <version>2.9.2</version>
+            <scope>provided</scope>
         </dependency>
     </dependencies>
 
     <build>
+        <finalName>${project.name}-${project.version}</finalName>
         <plugins>
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>

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;
@@ -19,6 +19,7 @@ public class BungeeMain extends Plugin
     public final String seePerm = "staffchat.see";
     public final String commandPerm = "staffchat.command";
     public final String reloadPerm = "staffchat.reload";
+    public final BungeeChatListener chatListener = new BungeeChatListener(this);
     private Configuration config;
 
     public void onEnable()
@@ -40,7 +41,7 @@ public class BungeeMain extends Plugin
 
     private void registerEvents()
     {
-        getProxy().getPluginManager().registerListener(this, new BungeeChatListener(this));
+        getProxy().getPluginManager().registerListener(this, chatListener);
     }
 
     public boolean reloadConfig()
@@ -48,15 +49,42 @@ public class BungeeMain extends Plugin
         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;
@@ -85,4 +113,17 @@ public class BungeeMain extends Plugin
         }
     }
 
+    public void saveConfig()
+    {
+        try
+        {
+            ConfigurationProvider.getProvider(YamlConfiguration.class).save(config, new File(getDataFolder(), "config.yml"));
+        }
+        catch (IOException e)
+        {
+            e.printStackTrace();
+            getLogger().severe("Failed to save config");
+        }
+    }
+
 }

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.*;
-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.*;
-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;
 
 /**
  * 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 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 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
+    public MetricsLite(Plugin plugin)
-    private static final List<Object> knownMetricsInstances = new ArrayList<>();
+    {
-
-    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 {
+            try
-                usedMetricsClass.getMethod("linkMetrics", Object.class).invoke(null,this);
+            {
-            } catch (NoSuchMethodException | IllegalAccessException | InvocationTargetException e) {
+                usedMetricsClass.getMethod("linkMetrics", Object.class).invoke(null, this);
-                if (logFailedRequests) {
+            }
+            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) {
+        for (Object metrics : knownMetricsInstances)
-            try {
+        {
+            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() {
+            public void run()
-                try {
+            {
+                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) {
+            if (className != null)
-                try {
+            {
+                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 {
+    private String readFile(File file) throws IOException
-        if (!file.exists()) {
+    {
+        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 {
+    private void writeFile(File file, String... lines) throws IOException
-        if (!file.exists()) {
+    {
+        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

@@ -5,6 +5,7 @@ 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;
 
@@ -46,13 +47,35 @@ public class BungeeStaffChatCommand extends Command
             }
             return;
         }
+        else if (args[0].equalsIgnoreCase("toggle"))
+        {
+            if (sender.hasPermission(plugin.usePerm))
+            {
+                toggle(sender);
+            }
+            else
+            {
+                sender.sendMessage(noPerm);
+            }
+            return;
+        }
         help(sender, getName());
     }
 
+    private void playerOnly(CommandSender sender)
+    {
+        sender.sendMessage(txt(config.getString("messages.prefix") + config.getString("messages.playeronly")));
+    }
+
     private void help(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))
         {
             sender.sendMessage(txt(prefix + "/" + label + " reload - Reloads the config file"));
@@ -66,6 +89,18 @@ public class BungeeStaffChatCommand extends Command
         sender.sendMessage(txt(config.getString("messages.prefix") + config.getString("messages.reloaded")));
     }
 
+    private void toggle(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)));
+    }
+
     private String clr(String string)
     {
         return ChatColor.translateAlternateColorCodes('&', string);

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

@@ -0,0 +1,59 @@
+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 ProxiedPlayer player;
+    private boolean cancelled = false;
+    private String format;
+    private String message;
+
+    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 void setMessage(String message)
+    {
+        this.message = 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;
@@ -10,10 +12,15 @@ import net.md_5.bungee.api.plugin.Listener;
 import net.md_5.bungee.config.Configuration;
 import net.md_5.bungee.event.EventHandler;
 
+import java.util.HashSet;
+import java.util.Set;
+import java.util.UUID;
+
 public class BungeeChatListener implements Listener
 {
 
     private BungeeMain plugin;
+    private Set<UUID> toggledPlayers = new HashSet<>();
 
     public BungeeChatListener(BungeeMain plugin)
     {
@@ -23,6 +30,10 @@ public class BungeeChatListener implements Listener
     @EventHandler
     public void chat(ChatEvent event)
     {
+        if (event.getMessage().startsWith("/"))
+        {
+            return;
+        }
         if (!(event.getSender() instanceof ProxiedPlayer))
         {
             return;
@@ -36,19 +47,31 @@ public class BungeeChatListener implements Listener
 
         Configuration config = plugin.getConfig();
         String character = config.getString("settings.character");
-        if (!event.getMessage().startsWith(character))
+        boolean isToggled = toggledPlayers.contains(player.getUniqueId());
+        if (!event.getMessage().startsWith(character) && !isToggled)
         {
             return;
         }
 
         String format = config.getString("settings.format");
-        format = format.replaceAll("\\{NAME\\}", player.getName());
+        String message = event.getMessage().substring(isToggled ? 0 : character.length()).trim();
-        format = format.replaceAll("\\{MESSAGE\\}", event.getMessage().substring(character.length()).trim());
+
-        final BaseComponent[] message = txt(format);
+        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(message));
+                .forEach(p -> p.sendMessage(messageComponents));
         plugin.getLogger().info(ChatColor.stripColor(clr(format)));
 
         event.setCancelled(true);
@@ -64,4 +87,15 @@ public class BungeeChatListener implements Listener
         return TextComponent.fromLegacyText(clr(text));
     }
 
+    public boolean togglePlayer(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,8 +1,10 @@
 package me.oskar3123.staffchat.spigot;
 
+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
@@ -12,15 +14,26 @@ public class Main extends JavaPlugin
     public final String seePerm = "staffchat.see";
     public final String commandPerm = "staffchat.command";
     public final String reloadPerm = "staffchat.reload";
+    public final ChatListener chatListener = new ChatListener(this);
 
     public void onEnable()
     {
+        getServer().getMessenger().registerOutgoingPluginChannel(this, "BungeeCord");
+        getServer().getMessenger().registerIncomingPluginChannel(this, "BungeeCord", chatListener);
         new MetricsLite(this);
         saveDefaultConfig();
         registerCommands();
         registerEvents();
     }
 
+    @Override
+    public void saveDefaultConfig()
+    {
+        super.saveDefaultConfig();
+        getConfig().options().copyDefaults(true);
+        saveConfig();
+    }
+
     private void registerCommands()
     {
         getCommand("staffchat").setExecutor(new StaffChatCommand(this));
@@ -28,7 +41,21 @@ public class Main extends JavaPlugin
 
     private void registerEvents()
     {
-        Bukkit.getPluginManager().registerEvents(new ChatListener(this), this);
+        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);
     }
 
 }

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 {
+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!");
-        }
-    }
 
     // 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) {
+    public MetricsLite(JavaPlugin plugin)
-        if (plugin == null) {
+    {
+        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()) {
+            for (Class<?> service : Bukkit.getServicesManager().getKnownServices())
-                try {
+            {
+                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 {
+    private static void sendData(JSONObject data) throws Exception
-        if (data == null) {
+    {
+        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 {
+    private static byte[] compress(final String str) throws IOException
-        if (str == null) {
+    {
+        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

@@ -6,6 +6,7 @@ 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;
 
 public class StaffChatCommand implements CommandExecutor
 {
@@ -45,14 +46,36 @@ public class StaffChatCommand implements CommandExecutor
             }
             return true;
         }
+        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 playerOnly(CommandSender sender)
+    {
+        sender.sendMessage(clr(config.getString("messages.prefix") + config.getString("messages.playeronly")));
+    }
+
     private void help(CommandSender sender, String label)
     {
         String prefix = clr(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))
         {
             sender.sendMessage(prefix + "/" + label + " reload - Reloads the config file");
@@ -66,6 +89,18 @@ public class StaffChatCommand implements CommandExecutor
         sender.sendMessage(clr(config.getString("messages.prefix") + config.getString("messages.reloaded")));
     }
 
+    private void toggle(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(config.getString("messages.toggled"), state)));
+    }
+
     private String clr(String string)
     {
         return ChatColor.translateAlternateColorCodes('&', string);

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

@@ -1,51 +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 plugin;
-
-    public ChatListener(Main plugin)
-    {
-        this.plugin = plugin;
-    }
-
-    @EventHandler(priority = EventPriority.HIGHEST, ignoreCancelled = true)
-    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");
-        format = format.replaceAll("\\{NAME\\}", event.getPlayer().getName());
-        format = format.replaceAll("\\{MESSAGE\\}", event.getMessage().substring(character.length()).trim());
-        format = ChatColor.translateAlternateColorCodes('&', format);
-        final String message = format;
-
-        Bukkit.getOnlinePlayers().stream()
-                .filter(p -> p.hasPermission(plugin.seePerm))
-                .forEach(p -> p.sendMessage(message));
-        plugin.getLogger().info(ChatColor.stripColor(message));
-
-        event.setCancelled(true);
-    }
-
-}

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

@@ -0,0 +1,72 @@
+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 boolean cancelled = false;
+    private String format;
+    private String message;
+
+    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;
+    }
+
+    public void setMessage(String message)
+    {
+        this.message = 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,155 @@
+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 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 java.io.*;
+import java.util.HashSet;
+import java.util.Set;
+import java.util.UUID;
+
+public class ChatListener implements Listener, PluginMessageListener
+{
+
+    private Main plugin;
+    private Set<UUID> toggledPlayers = new HashSet<>();
+
+    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");
+        boolean isToggled = toggledPlayers.contains(event.getPlayer().getUniqueId());
+        if (!event.getMessage().startsWith(character) && !isToggled)
+        {
+            return;
+        }
+
+        String format = 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.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("settings.sendmessagestoallservers"))
+        {
+            sendForwardPluginMessage(event.getPlayer(), finalMessage);
+        }
+        sendStaffChatMessage(finalMessage);
+
+        event.setCancelled(true);
+    }
+
+    @Override
+    public void onPluginMessageReceived(String channel, 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(final 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(Player player, final String finalMessage)
+    {
+        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(finalMessage);
+        }
+        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());
+    }
+
+    public boolean togglePlayer(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,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.2
+version: 1.3.0

src/main/resources/config.yml

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

src/main/resources/plugin.yml

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