Merge pull request #45 from oskar3123/43-server-placeholder-for-velocity

#43: add server placeholder support for velocity

.github/workflows/build.yml

@@ -0,0 +1,36 @@
+# This workflow uses actions that are not certified by GitHub.
+# They are provided by a third-party and are governed by
+# separate terms of service, privacy policy, and support
+# documentation.
+# This workflow will build a Java project with Gradle and cache/restore any dependencies to improve the workflow execution time
+# For more information see: https://docs.github.com/en/actions/automating-builds-and-tests/building-and-testing-java-with-gradle
+
+name: build
+
+on:
+  push:
+    branches: [ "master" ]
+  pull_request:
+    branches: [ "master" ]
+
+permissions:
+  contents: read
+
+jobs:
+  build:
+
+    runs-on: ubuntu-latest
+
+    steps:
+    - uses: actions/checkout@v3
+    - name: Set up JDK 8 and 17
+      uses: actions/setup-java@v4
+      with:
+        java-version: |
+          8
+          17
+        distribution: 'corretto'
+    - name: Build with Gradle
+      uses: gradle/gradle-build-action@bd5760595778326ba7f1441bcf7e88b49de61a25 # v2.6.0
+      with:
+        arguments: shadowJar

.github/workflows/pre-release.yml

@@ -0,0 +1,33 @@
+name: "pre-release"
+
+on:
+  push:
+    branches:
+      - "master"
+
+jobs:
+  pre-release:
+    name: "Pre Release"
+    runs-on: "ubuntu-latest"
+
+    steps:
+      - uses: actions/checkout@v3
+      - name: Set up JDK 8 and 17
+        uses: actions/setup-java@v4
+        with:
+          java-version: |
+            8
+            17
+          distribution: 'corretto'
+      - name: Build with Gradle
+        uses: gradle/gradle-build-action@bd5760595778326ba7f1441bcf7e88b49de61a25 # v2.6.0
+        with:
+          arguments: shadowJar
+      - uses: "marvinpinto/action-automatic-releases@v1.2.1"
+        with:
+          repo_token: "${{ secrets.GITHUB_TOKEN }}"
+          automatic_release_tag: "latest"
+          prerelease: true
+          title: "Development Build"
+          files: |
+            build/libs/*.jar

.github/workflows/tagged-release.yml

@@ -0,0 +1,31 @@
+name: "tagged-release"
+
+on:
+  push:
+    tags:
+      - "v*"
+
+jobs:
+  tagged-release:
+    name: "Tagged Release"
+    runs-on: "ubuntu-latest"
+
+    steps:
+      - uses: actions/checkout@v3
+      - name: Set up JDK 8 and 17
+        uses: actions/setup-java@v4
+        with:
+          java-version: |
+            8
+            17
+          distribution: 'corretto'
+      - name: Build with Gradle
+        uses: gradle/gradle-build-action@bd5760595778326ba7f1441bcf7e88b49de61a25 # v2.6.0
+        with:
+          arguments: shadowJar
+      - uses: "marvinpinto/action-automatic-releases@v1.2.1"
+        with:
+          repo_token: "${{ secrets.GITHUB_TOKEN }}"
+          prerelease: false
+          files: |
+            build/libs/*.jar

.gitignore

@@ -0,0 +1,4 @@
+.idea/
+.gradle/
+build/
+StaffChat.iml

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2023 Oskar Nordling
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

README.md

@@ -1,5 +1,166 @@
-# StaffChat
-Simple and highly configurable staff chat
+[![Downloads](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/v/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)
+[![Latest Pre-release](https://img.shields.io/github/v/release/oskar3123/StaffChat.svg?style=flat&include_prereleases)](https://github.com/oskar3123/StaffChat/releases)
+[![Github commits (since latest pre-release)](https://img.shields.io/github/commits-since/oskar3123/StaffChat/latest.svg?style=flat&include_prereleases)](https://github.com/oskar3123/StaffChat/commits/master)
+
+[![Open Issues](https://img.shields.io/github/issues/oskar3123/StaffChat)](https://github.com/oskar3123/StaffChat/issues?q=is%3Aopen+is%3Aissue)
+[![Closed Issues](https://img.shields.io/github/issues-closed/oskar3123/StaffChat)](https://github.com/oskar3123/StaffChat/issues?q=is%3Aissue+is%3Aclosed)
+[![Open Pull requests](https://img.shields.io/github/issues-pr/oskar3123/StaffChat)](https://github.com/oskar3123/StaffChat/pulls?q=is%3Aopen+is%3Apr)
+[![Closed Pull requests](https://img.shields.io/github/issues-pr-closed/oskar3123/StaffChat)](https://github.com/oskar3123/StaffChat/pulls?q=is%3Apr+is%3Aclosed)
+
+# [StaffChat](https://oskar3123.github.io/StaffChat)
+
+Simple and highly configurable staff chat.
 
 ## 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).
+
+## License
+
+This plugin is licensed with the MIT License, for more information see
+the [LICENSE file](https://github.com/oskar3123/StaffChat/blob/master/LICENSE).
+
+## Building
+
+To build this yourself just clone the repository and run the `shadowJar` task with the Gradle
+Wrapper.
+
+The plugin jar-file can be found inside the `build/libs` folder after building.
+
+### Windows
+
+```bat
+git clone git@github.com:oskar3123/StaffChat.git
+cd StaffChat
+gradlew.bat shadowJar
+```
+
+### *nix (Linux, FreeBSD, macOS, ...)
+
+```bash
+git clone git@github.com:oskar3123/StaffChat.git
+cd StaffChat
+./gradlew shadowJar
+```
+
+## Event API (For developers)
+
+### Bukkit/Spigot
+
+Because the event API in 1.14+ is now strict between sync and async events you should check whether
+this was called synchronously or asynchronously by using `event.isAsynchronous()`.
+
+```java
+public class StaffChatListener implements Listener {
+
+  @EventHandler
+  public void onStaffChat(StaffChatEvent event) {
+    // Player player = event.getPlayer();
+    // String format = event.getFormat();
+    // String message = event.getMessage();
+    // event.setFormat("&b{NAME} >> {MESSAGE}");
+    // event.setMessage(filterMessage(message));
+    // event.setCancelled(true);
+  }
+
+  private static String filterMessage(String message) {
+    // ...
+    return message;
+  }
+}
+```
+
+Register the listener in the `onEnable` method of your plugin.
+
+```java
+public class YourPlugin extends JavaPlugin {
+
+  @Override
+  public void onEnable() {
+    getServer().getPluginManager().registerEvents(new StaffChatListener(), this);
+  }
+}
+```
+
+### BungeeCord
+
+```java
+public class StaffChatListener implements Listener {
+
+  @EventHandler
+  public void onStaffChat(BungeeStaffChatEvent event) {
+    // ProxiedPlayer player = event.getPlayer();
+    // String format = event.getFormat();
+    // String message = event.getMessage();
+    // event.setFormat("&b{NAME} >> {MESSAGE}");
+    // event.setMessage(filterMessage(message));
+    // event.setCancelled(true);
+  }
+
+  private static String filterMessage(String message) {
+    // ...
+    return message;
+  }
+}
+```
+
+Register the listener in the `onEnable` method of your plugin.
+
+```java
+public class YourPlugin extends Plugin {
+
+  @Override
+  public void onEnable() {
+    getProxy().getPluginManager().registerListener(this, new StaffChatListener());
+  }
+}
+```
+
+### Velocity
+
+```java
+public class StaffChatListener {
+
+  @Subscribe
+  public void onStaffChat(VelocityStaffChatEvent event) {
+    // Player player = event.getPlayer();
+    // String format = event.getFormat();
+    // String message = event.getMessage();
+    // StaffChatResult result = StaffChatResult.denied();
+    // StaffChatResult result = StaffChatResult.format("&b{NAME} >> {MESSAGE}");
+    // StaffChatResult result = StaffChatResult.message(filterMessage(message));
+    // StaffChatResult result = StaffChatResult.formatAndMessage("&b{NAME} >> {MESSAGE}", filterMessage(message));
+    // event.setResult(result);
+  }
+
+  private static String filterMessage(String message) {
+    // ...
+    return message;
+  }
+}
+```
+
+Register the listener on the `ProxyInitializeEvent` in your plugin.
+
+```java
+@Plugin
+public class YourPlugin {
+
+  private final ProxyServer server;
+
+  @Inject
+  public YourPlugin(ProxyServer server) {
+    this.server = server;
+  }
+
+  @Subscribe
+  public void onProxyInitialization(ProxyInitializeEvent event) {
+    server.getEventManager().register(this, new StaffChatListener());
+  }
+}
+```

_config.yml

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

build.gradle.kts

@@ -0,0 +1,84 @@
+plugins {
+    id("com.github.johnrengelman.shadow").version("8.1.1")
+    id("java")
+}
+
+group = "me.oskar3123"
+version = "SNAPSHOT"
+
+// Main sourceSet remains on Java 8
+java {
+    sourceCompatibility = JavaVersion.VERSION_1_8
+    targetCompatibility = JavaVersion.VERSION_1_8
+
+    toolchain {
+        languageVersion.set(JavaLanguageVersion.of(17))
+    }
+}
+
+// Create a sourceSet for Velocity code that uses Java 17
+sourceSets {
+    create("velocity") {
+        java {
+            srcDir("src/velocity/java")
+            compileClasspath += sourceSets.main.get().output + sourceSets.main.get().compileClasspath
+            runtimeClasspath += sourceSets.main.get().output + sourceSets.main.get().runtimeClasspath
+        }
+    }
+}
+
+// Configure the automatically created Velocity compilation task to use Java 17
+tasks.named<JavaCompile>("compileVelocityJava") {
+    sourceCompatibility = "17"
+    targetCompatibility = "17"
+}
+
+repositories {
+    mavenCentral()
+    maven {
+        url = uri("https://hub.spigotmc.org/nexus/content/repositories/snapshots/")
+    }
+    maven {
+        url = uri("https://oss.sonatype.org/content/repositories/snapshots/")
+    }
+    maven {
+        url = uri("https://repo.extendedclip.com/content/repositories/placeholderapi/")
+    }
+    maven {
+        name = "m2-dv8tion"
+        url = uri("https://m2.dv8tion.net/releases")
+    }
+    maven {
+        url = uri("https://nexus.scarsz.me/content/groups/public/")
+    }
+    maven {
+        name = "papermc"
+        url = uri("https://repo.papermc.io/repository/maven-public/")
+    }
+}
+
+dependencies {
+    compileOnly("org.spigotmc:spigot-api:1.20.2-R0.1-SNAPSHOT")
+    compileOnly("net.md-5:bungeecord-api:1.20-R0.2-SNAPSHOT")
+    compileOnly("me.clip:placeholderapi:2.11.1")
+    compileOnly("com.discordsrv:discordsrv:1.25.1")
+    "velocityCompileOnly"("com.velocitypowered:velocity-api:3.3.0-SNAPSHOT")
+    "velocityAnnotationProcessor"("com.velocitypowered:velocity-api:3.3.0-SNAPSHOT")
+
+    implementation("org.bstats:bstats-bukkit:3.1.0")
+    implementation("org.bstats:bstats-bungeecord:3.1.0")
+    implementation("org.bstats:bstats-velocity:3.1.0")
+
+    testImplementation(platform("org.junit:junit-bom:5.10.0"))
+    testImplementation("org.junit.jupiter:junit-jupiter:5.10.0")
+}
+
+tasks.shadowJar {
+    relocate("org.bstats", "me.oskar3123.staffchat.bstats")
+    dependsOn("compileVelocityJava")
+    from(sourceSets["velocity"].output)
+}
+
+tasks.test {
+    useJUnitPlatform()
+}

gradle/wrapper/gradle-wrapper.properties

@@ -0,0 +1,6 @@
+#Fri Sep 22 00:35:34 CEST 2023
+distributionBase=GRADLE_USER_HOME
+distributionPath=wrapper/dists
+distributionUrl=https\://services.gradle.org/distributions/gradle-8.2-bin.zip
+zipStoreBase=GRADLE_USER_HOME
+zipStorePath=wrapper/dists

gradlew

@@ -0,0 +1,234 @@
+#!/bin/sh
+
+#
+# Copyright © 2015-2021 the original authors.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      https://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+##############################################################################
+#
+#   Gradle start up script for POSIX generated by Gradle.
+#
+#   Important for running:
+#
+#   (1) You need a POSIX-compliant shell to run this script. If your /bin/sh is
+#       noncompliant, but you have some other compliant shell such as ksh or
+#       bash, then to run this script, type that shell name before the whole
+#       command line, like:
+#
+#           ksh Gradle
+#
+#       Busybox and similar reduced shells will NOT work, because this script
+#       requires all of these POSIX shell features:
+#         * functions;
+#         * expansions «$var», «${var}», «${var:-default}», «${var+SET}»,
+#           «${var#prefix}», «${var%suffix}», and «$( cmd )»;
+#         * compound commands having a testable exit status, especially «case»;
+#         * various built-in commands including «command», «set», and «ulimit».
+#
+#   Important for patching:
+#
+#   (2) This script targets any POSIX shell, so it avoids extensions provided
+#       by Bash, Ksh, etc; in particular arrays are avoided.
+#
+#       The "traditional" practice of packing multiple parameters into a
+#       space-separated string is a well documented source of bugs and security
+#       problems, so this is (mostly) avoided, by progressively accumulating
+#       options in "$@", and eventually passing that to Java.
+#
+#       Where the inherited environment variables (DEFAULT_JVM_OPTS, JAVA_OPTS,
+#       and GRADLE_OPTS) rely on word-splitting, this is performed explicitly;
+#       see the in-line comments for details.
+#
+#       There are tweaks for specific operating systems such as AIX, CygWin,
+#       Darwin, MinGW, and NonStop.
+#
+#   (3) This script is generated from the Groovy template
+#       https://github.com/gradle/gradle/blob/master/subprojects/plugins/src/main/resources/org/gradle/api/internal/plugins/unixStartScript.txt
+#       within the Gradle project.
+#
+#       You can find Gradle at https://github.com/gradle/gradle/.
+#
+##############################################################################
+
+# Attempt to set APP_HOME
+
+# Resolve links: $0 may be a link
+app_path=$0
+
+# Need this for daisy-chained symlinks.
+while
+    APP_HOME=${app_path%"${app_path##*/}"}  # leaves a trailing /; empty if no leading path
+    [ -h "$app_path" ]
+do
+    ls=$( ls -ld "$app_path" )
+    link=${ls#*' -> '}
+    case $link in             #(
+      /*)   app_path=$link ;; #(
+      *)    app_path=$APP_HOME$link ;;
+    esac
+done
+
+APP_HOME=$( cd "${APP_HOME:-./}" && pwd -P ) || exit
+
+APP_NAME="Gradle"
+APP_BASE_NAME=${0##*/}
+
+# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"'
+
+# Use the maximum available, or set MAX_FD != -1 to use that value.
+MAX_FD=maximum
+
+warn () {
+    echo "$*"
+} >&2
+
+die () {
+    echo
+    echo "$*"
+    echo
+    exit 1
+} >&2
+
+# OS specific support (must be 'true' or 'false').
+cygwin=false
+msys=false
+darwin=false
+nonstop=false
+case "$( uname )" in                #(
+  CYGWIN* )         cygwin=true  ;; #(
+  Darwin* )         darwin=true  ;; #(
+  MSYS* | MINGW* )  msys=true    ;; #(
+  NONSTOP* )        nonstop=true ;;
+esac
+
+CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
+
+
+# Determine the Java command to use to start the JVM.
+if [ -n "$JAVA_HOME" ] ; then
+    if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
+        # IBM's JDK on AIX uses strange locations for the executables
+        JAVACMD=$JAVA_HOME/jre/sh/java
+    else
+        JAVACMD=$JAVA_HOME/bin/java
+    fi
+    if [ ! -x "$JAVACMD" ] ; then
+        die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+    fi
+else
+    JAVACMD=java
+    which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+fi
+
+# Increase the maximum file descriptors if we can.
+if ! "$cygwin" && ! "$darwin" && ! "$nonstop" ; then
+    case $MAX_FD in #(
+      max*)
+        MAX_FD=$( ulimit -H -n ) ||
+            warn "Could not query maximum file descriptor limit"
+    esac
+    case $MAX_FD in  #(
+      '' | soft) :;; #(
+      *)
+        ulimit -n "$MAX_FD" ||
+            warn "Could not set maximum file descriptor limit to $MAX_FD"
+    esac
+fi
+
+# Collect all arguments for the java command, stacking in reverse order:
+#   * args from the command line
+#   * the main class name
+#   * -classpath
+#   * -D...appname settings
+#   * --module-path (only if needed)
+#   * DEFAULT_JVM_OPTS, JAVA_OPTS, and GRADLE_OPTS environment variables.
+
+# For Cygwin or MSYS, switch paths to Windows format before running java
+if "$cygwin" || "$msys" ; then
+    APP_HOME=$( cygpath --path --mixed "$APP_HOME" )
+    CLASSPATH=$( cygpath --path --mixed "$CLASSPATH" )
+
+    JAVACMD=$( cygpath --unix "$JAVACMD" )
+
+    # Now convert the arguments - kludge to limit ourselves to /bin/sh
+    for arg do
+        if
+            case $arg in                                #(
+              -*)   false ;;                            # don't mess with options #(
+              /?*)  t=${arg#/} t=/${t%%/*}              # looks like a POSIX filepath
+                    [ -e "$t" ] ;;                      #(
+              *)    false ;;
+            esac
+        then
+            arg=$( cygpath --path --ignore --mixed "$arg" )
+        fi
+        # Roll the args list around exactly as many times as the number of
+        # args, so each arg winds up back in the position where it started, but
+        # possibly modified.
+        #
+        # NB: a `for` loop captures its iteration list before it begins, so
+        # changing the positional parameters here affects neither the number of
+        # iterations, nor the values presented in `arg`.
+        shift                   # remove old arg
+        set -- "$@" "$arg"      # push replacement arg
+    done
+fi
+
+# Collect all arguments for the java command;
+#   * $DEFAULT_JVM_OPTS, $JAVA_OPTS, and $GRADLE_OPTS can contain fragments of
+#     shell script including quotes and variable substitutions, so put them in
+#     double quotes to make sure that they get re-expanded; and
+#   * put everything else in single quotes, so that it's not re-expanded.
+
+set -- \
+        "-Dorg.gradle.appname=$APP_BASE_NAME" \
+        -classpath "$CLASSPATH" \
+        org.gradle.wrapper.GradleWrapperMain \
+        "$@"
+
+# Use "xargs" to parse quoted args.
+#
+# With -n1 it outputs one arg per line, with the quotes and backslashes removed.
+#
+# In Bash we could simply go:
+#
+#   readarray ARGS < <( xargs -n1 <<<"$var" ) &&
+#   set -- "${ARGS[@]}" "$@"
+#
+# but POSIX shell has neither arrays nor command substitution, so instead we
+# post-process each arg (as a line of input to sed) to backslash-escape any
+# character that might be a shell metacharacter, then use eval to reverse
+# that process (while maintaining the separation between arguments), and wrap
+# the whole thing up as a single "set" statement.
+#
+# This will of course break if any of these variables contains a newline or
+# an unmatched quote.
+#
+
+eval "set -- $(
+        printf '%s\n' "$DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS" |
+        xargs -n1 |
+        sed ' s~[^-[:alnum:]+,./:=@_]~\\&~g; ' |
+        tr '\n' ' '
+    )" '"$@"'
+
+exec "$JAVACMD" "$@"

gradlew.bat

@@ -0,0 +1,89 @@
+@rem
+@rem Copyright 2015 the original author or authors.
+@rem
+@rem Licensed under the Apache License, Version 2.0 (the "License");
+@rem you may not use this file except in compliance with the License.
+@rem You may obtain a copy of the License at
+@rem
+@rem      https://www.apache.org/licenses/LICENSE-2.0
+@rem
+@rem Unless required by applicable law or agreed to in writing, software
+@rem distributed under the License is distributed on an "AS IS" BASIS,
+@rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+@rem See the License for the specific language governing permissions and
+@rem limitations under the License.
+@rem
+
+@if "%DEBUG%" == "" @echo off
+@rem ##########################################################################
+@rem
+@rem  Gradle startup script for Windows
+@rem
+@rem ##########################################################################
+
+@rem Set local scope for the variables with windows NT shell
+if "%OS%"=="Windows_NT" setlocal
+
+set DIRNAME=%~dp0
+if "%DIRNAME%" == "" set DIRNAME=.
+set APP_BASE_NAME=%~n0
+set APP_HOME=%DIRNAME%
+
+@rem Resolve any "." and ".." in APP_HOME to make it shorter.
+for %%i in ("%APP_HOME%") do set APP_HOME=%%~fi
+
+@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+set DEFAULT_JVM_OPTS="-Xmx64m" "-Xms64m"
+
+@rem Find java.exe
+if defined JAVA_HOME goto findJavaFromJavaHome
+
+set JAVA_EXE=java.exe
+%JAVA_EXE% -version >NUL 2>&1
+if "%ERRORLEVEL%" == "0" goto execute
+
+echo.
+echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:findJavaFromJavaHome
+set JAVA_HOME=%JAVA_HOME:"=%
+set JAVA_EXE=%JAVA_HOME%/bin/java.exe
+
+if exist "%JAVA_EXE%" goto execute
+
+echo.
+echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME%
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:execute
+@rem Setup the command line
+
+set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
+
+
+@rem Execute Gradle
+"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %*
+
+:end
+@rem End local scope for the variables with windows NT shell
+if "%ERRORLEVEL%"=="0" goto mainEnd
+
+:fail
+rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
+rem the _cmd.exe /c_ return code!
+if  not "" == "%GRADLE_EXIT_CONSOLE%" exit 1
+exit /b 1
+
+:mainEnd
+if "%OS%"=="Windows_NT" endlocal
+
+:omega

pom.xml

@@ -1,55 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0"
-         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-
-    <modelVersion>4.0.0</modelVersion>
-
-    <groupId>me.oskar3123</groupId>
-    <artifactId>staffchat</artifactId>
-    <version>1.1.1-SNAPSHOT</version>
-
-    <repositories>
-        <repository>
-            <id>spigot-repo</id>
-            <url>https://hub.spigotmc.org/nexus/content/repositories/snapshots/</url>
-        </repository>
-        <repository>
-            <id>bungeecord-repo</id>
-            <url>https://oss.sonatype.org/content/repositories/snapshots/</url>
-        </repository>
-    </repositories>
-
-    <dependencies>
-        <dependency>
-            <groupId>org.spigotmc</groupId>
-            <artifactId>spigot-api</artifactId>
-            <version>1.11.2-R0.1-SNAPSHOT</version>
-        </dependency>
-        <dependency>
-            <groupId>org.bukkit</groupId>
-            <artifactId>bukkit</artifactId>
-            <version>1.11.2-R0.1-SNAPSHOT</version>
-        </dependency>
-        <dependency>
-            <groupId>net.md-5</groupId>
-            <artifactId>bungeecord-api</artifactId>
-            <version>1.11-SNAPSHOT</version>
-        </dependency>
-    </dependencies>
-
-    <build>
-        <plugins>
-            <plugin>
-                <groupId>org.apache.maven.plugins</groupId>
-                <artifactId>maven-compiler-plugin</artifactId>
-                <version>3.1</version>
-                <configuration>
-                    <source>1.8</source>
-                    <target>1.8</target>
-                </configuration>
-            </plugin>
-        </plugins>
-    </build>
-
-</project>

settings.gradle.kts

@@ -0,0 +1 @@
+rootProject.name = "StaffChat"

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

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

@@ -1,385 +0,0 @@
-package me.oskar3123.staffchat.bungee;
-
-import com.google.gson.JsonArray;
-import com.google.gson.JsonObject;
-import net.md_5.bungee.api.plugin.Plugin;
-import net.md_5.bungee.api.scheduler.TaskScheduler;
-import net.md_5.bungee.config.Configuration;
-import net.md_5.bungee.config.ConfigurationProvider;
-import net.md_5.bungee.config.YamlConfiguration;
-
-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.lang.reflect.InvocationTargetException;
-import java.net.URL;
-import java.nio.file.Path;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Timer;
-import java.util.TimerTask;
-import java.util.UUID;
-import java.util.concurrent.TimeUnit;
-import java.util.logging.Level;
-import java.util.zip.GZIPOutputStream;
-
-/**
- * bStats collects some data for plugin authors.
- *
- * 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!");
-        }
-    }
-
-    // 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) {
-        this.plugin = plugin;
-
-        try {
-            loadConfig();
-        } catch (IOException e) {
-            // Failed to load configuration
-            plugin.getLogger().log(Level.WARNING, "Failed to load bStats config!", e);
-            return;
-        }
-
-        // We are not allowed to send data about this server :(
-        if (!enabled) {
-            return;
-        }
-
-        Class<?> usedMetricsClass = getFirstBStatsClass();
-        if (usedMetricsClass == null) {
-            // Failed to get first metrics class
-            return;
-        }
-        if (usedMetricsClass == getClass()) {
-            // We are the first! :)
-            linkMetrics(this);
-            startSubmitting();
-        } else {
-            // We aren't the first so we link to the first metrics class
-            try {
-                usedMetricsClass.getMethod("linkMetrics", Object.class).invoke(null,this);
-            } catch (NoSuchMethodException | IllegalAccessException | InvocationTargetException e) {
-                if (logFailedRequests) {
-                    plugin.getLogger().log(Level.WARNING, "Failed to link to first metrics class " + usedMetricsClass.getName() + "!", e);
-                }
-            }
-        }
-    }
-
-    /**
-     * Links an other metrics class with this class.
-     * This method is called using Reflection.
-     *
-     * @param metrics An object of the metrics class to link.
-     */
-    public static void linkMetrics(Object metrics) {
-        knownMetricsInstances.add(metrics);
-    }
-
-    /**
-     * Gets the plugin specific data.
-     * This method is called using Reflection.
-     *
-     * @return The plugin specific data.
-     */
-    public JsonObject getPluginData() {
-        JsonObject data = new JsonObject();
-
-        String pluginName = plugin.getDescription().getName();
-        String pluginVersion = plugin.getDescription().getVersion();
-
-        data.addProperty("pluginName", pluginName);
-        data.addProperty("pluginVersion", pluginVersion);
-
-        JsonArray customCharts = new JsonArray();
-        data.add("customCharts", customCharts);
-
-        return data;
-    }
-
-    private void startSubmitting() {
-        // We use a timer cause want to be independent from the server tps
-        final Timer timer = new Timer(true);
-        timer.scheduleAtFixedRate(new TimerTask() {
-            @Override
-            public void run() {
-                // The data collection (e.g. for custom graphs) is done sync
-                // Don't be afraid! The connection to the bStats server is still async, only the stats collection is sync ;)
-                TaskScheduler scheduler = plugin.getProxy().getScheduler();
-                scheduler.schedule(plugin, new Runnable() {
-                    @Override
-                    public void run() {
-                        submitData();
-                    }
-                }, 0L, TimeUnit.SECONDS);
-            }
-        }, 1000*60*2, 1000*60*30);
-        // Submit the data every 30 minutes, first time after 2 minutes to give other plugins enough time to start
-        // WARNING: Changing the frequency has no effect but your plugin WILL be blocked/deleted!
-        // WARNING: Just don't do it!
-    }
-
-    /**
-     * Gets the server specific data.
-     *
-     * @return The server specific data.
-     */
-    private JsonObject getServerData() {
-        // Minecraft specific data
-        int playerAmount = plugin.getProxy().getOnlineCount();
-        playerAmount = playerAmount > 500 ? 500 : playerAmount;
-        int onlineMode = plugin.getProxy().getConfig().isOnlineMode() ? 1 : 0;
-        String bungeecordVersion = plugin.getProxy().getVersion();
-        int managedServers = plugin.getProxy().getServers().size();
-
-        // OS/Java specific data
-        String javaVersion = System.getProperty("java.version");
-        String osName = System.getProperty("os.name");
-        String osArch = System.getProperty("os.arch");
-        String osVersion = System.getProperty("os.version");
-        int coreCount = Runtime.getRuntime().availableProcessors();
-
-        JsonObject data = new JsonObject();
-
-        data.addProperty("serverUUID", serverUUID);
-
-        data.addProperty("playerAmount", playerAmount);
-        data.addProperty("managedServers", managedServers);
-        data.addProperty("onlineMode", onlineMode);
-        data.addProperty("bungeecordVersion", bungeecordVersion);
-
-        data.addProperty("javaVersion", javaVersion);
-        data.addProperty("osName", osName);
-        data.addProperty("osArch", osArch);
-        data.addProperty("osVersion", osVersion);
-        data.addProperty("coreCount", coreCount);
-
-        return data;
-    }
-
-    /**
-     * Collects the data and sends it afterwards.
-     */
-    private void submitData() {
-        final JsonObject data = getServerData();
-
-        final JsonArray pluginData = new JsonArray();
-        // Search for all other bStats Metrics classes to get their plugin data
-        for (Object metrics : knownMetricsInstances) {
-            try {
-                Object plugin = metrics.getClass().getMethod("getPluginData").invoke(metrics);
-                if (plugin instanceof JsonObject) {
-                    pluginData.add((JsonObject) plugin);
-                }
-            } catch (NoSuchMethodException | IllegalAccessException | InvocationTargetException ignored) { }
-        }
-
-        data.add("plugins", pluginData);
-
-        // Create a new thread for the connection to the bStats server
-        new Thread(new Runnable() {
-            @Override
-            public void run() {
-                try {
-                    // Send the data
-                    sendData(data);
-                } catch (Exception e) {
-                    // Something went wrong! :(
-                    if (logFailedRequests) {
-                        plugin.getLogger().log(Level.WARNING, "Could not submit plugin stats!", e);
-                    }
-                }
-            }
-        }).start();
-    }
-
-    /**
-     * Loads the bStats configuration.
-     *
-     * @throws IOException If something did not work :(
-     */
-    private void loadConfig() throws IOException {
-        Path configPath = plugin.getDataFolder().toPath().getParent().resolve("bStats");
-        configPath.toFile().mkdirs();
-        File configFile = new File(configPath.toFile(), "config.yml");
-        if (!configFile.exists()) {
-            writeFile(configFile,
-                    "#bStats collects some data for plugin authors like how many servers are using their plugins.",
-                    "#To honor their work, you should not disable it.",
-                    "#This has nearly no effect on the server performance!",
-                    "#Check out https://bStats.org/ to learn more :)",
-                    "enabled: true",
-                    "serverUuid: \"" + UUID.randomUUID().toString() + "\"",
-                    "logFailedRequests: false");
-        }
-
-        Configuration configuration = ConfigurationProvider.getProvider(YamlConfiguration.class).load(configFile);
-
-        // Load configuration
-        enabled = configuration.getBoolean("enabled", true);
-        serverUUID = configuration.getString("serverUuid");
-        logFailedRequests = configuration.getBoolean("logFailedRequests", false);
-    }
-
-    /**
-     * Gets the first bStat Metrics class.
-     *
-     * @return The first bStats metrics class.
-     */
-    private Class<?> getFirstBStatsClass() {
-        Path configPath = plugin.getDataFolder().toPath().getParent().resolve("bStats");
-        configPath.toFile().mkdirs();
-        File tempFile = new File(configPath.toFile(), "temp.txt");
-
-        try {
-            String className = readFile(tempFile);
-            if (className != null) {
-                try {
-                    // Let's check if a class with the given name exists.
-                    return Class.forName(className);
-                } catch (ClassNotFoundException ignored) { }
-            }
-            writeFile(tempFile, getClass().getName());
-            return getClass();
-        } catch (IOException e) {
-            if (logFailedRequests) {
-                plugin.getLogger().log(Level.WARNING, "Failed to get first bStats class!", e);
-            }
-            return null;
-        }
-    }
-
-    /**
-     * Reads the first line of the file.
-     *
-     * @param file The file to read. Cannot be null.
-     * @return The first line of the file or <code>null</code> if the file does not exist or is empty.
-     * @throws IOException If something did not work :(
-     */
-    private String readFile(File file) throws IOException {
-        if (!file.exists()) {
-            return null;
-        }
-        try (
-                FileReader fileReader = new FileReader(file);
-                BufferedReader bufferedReader =  new BufferedReader(fileReader);
-        ) {
-            return bufferedReader.readLine();
-        }
-    }
-
-    /**
-     * Writes a String to a file. It also adds a note for the user,
-     *
-     * @param file The file to write to. Cannot be null.
-     * @param lines The lines to write.
-     * @throws IOException If something did not work :(
-     */
-    private void writeFile(File file, String... lines) throws IOException {
-        if (!file.exists()) {
-            file.createNewFile();
-        }
-        try (
-                FileWriter fileWriter = new FileWriter(file);
-                BufferedWriter bufferedWriter = new BufferedWriter(fileWriter)
-        ) {
-            for (String line : lines) {
-                bufferedWriter.write(line);
-                bufferedWriter.newLine();
-            }
-        }
-    }
-
-    /**
-     * 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

@@ -1,47 +1,50 @@
 package me.oskar3123.staffchat.bungee.command;
 
 import me.oskar3123.staffchat.bungee.BungeeMain;
+import me.oskar3123.staffchat.util.Permissions;
 import net.md_5.bungee.api.ChatColor;
 import net.md_5.bungee.api.CommandSender;
 import net.md_5.bungee.api.chat.BaseComponent;
 import net.md_5.bungee.api.chat.TextComponent;
+import net.md_5.bungee.api.connection.ProxiedPlayer;
 import net.md_5.bungee.api.plugin.Command;
 import net.md_5.bungee.config.Configuration;
+import org.jetbrains.annotations.Contract;
+import org.jetbrains.annotations.NotNull;
 
-public class BungeeStaffChatCommand extends Command
-{
+public class BungeeStaffChatCommand extends Command {
 
-    private BungeeMain main;
+  private final BungeeMain plugin;
   private Configuration config;
 
-    public BungeeStaffChatCommand(BungeeMain main)
-    {
+  public BungeeStaffChatCommand(@NotNull 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))
-        {
+  public void execute(@NotNull CommandSender sender, @NotNull String[] args) {
+    BaseComponent[] noPerm =
+        txt(config.getString("messages.prefix") + config.getString("messages.nopermission"));
+    if (!sender.hasPermission(Permissions.COMMAND.permission())) {
       sender.sendMessage(noPerm);
       return;
     }
-        if (args.length < 1)
-        {
+    if (args.length < 1) {
       help(sender, getName());
       return;
     }
-        if (args[0].equalsIgnoreCase("reload"))
-        {
-            if (sender.hasPermission(main.reloadPerm))
-            {
+    if (args[0].equalsIgnoreCase("reload")) {
+      if (sender.hasPermission(Permissions.RELOAD.permission())) {
         reload(sender);
+      } else {
+        sender.sendMessage(noPerm);
       }
-            else
-            {
+      return;
+    } else if (args[0].equalsIgnoreCase("toggle")) {
+      if (sender.hasPermission(Permissions.USE.permission())) {
+        toggle(sender);
+      } else {
         sender.sendMessage(noPerm);
       }
       return;
@@ -49,31 +52,47 @@ public class BungeeStaffChatCommand extends Command
     help(sender, getName());
   }
 
-    private void help(CommandSender sender, String label)
-    {
+  private void playerOnly(@NotNull CommandSender sender) {
+    sender.sendMessage(
+        txt(config.getString("messages.prefix") + config.getString("messages.playeronly")));
+  }
+
+  private void help(@NotNull 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(Permissions.USE.permission())) {
+      sender.sendMessage(txt(prefix + "Message prefix: " + config.getString("settings.character")));
+      sender.sendMessage(txt(prefix + "/" + label + " toggle - Toggles auto staffchat"));
+    }
+    if (sender.hasPermission(Permissions.RELOAD.permission())) {
       sender.sendMessage(txt(prefix + "/" + label + " reload - Reloads the config file"));
     }
   }
 
-    private void reload(CommandSender sender)
-    {
-        main.reloadConfig();
-        config = main.getConfig();
-        sender.sendMessage(txt(config.getString("messages.prefix") + config.getString("messages.reloaded")));
+  private void reload(@NotNull CommandSender sender) {
+    plugin.reloadConfig();
+    config = plugin.getConfig();
+    sender.sendMessage(
+        txt(config.getString("messages.prefix") + config.getString("messages.reloaded")));
   }
 
-    private String clr(String string)
-    {
-        return ChatColor.translateAlternateColorCodes('&', string);
+  private void toggle(@NotNull CommandSender sender) {
+    if (!(sender instanceof ProxiedPlayer)) {
+      playerOnly(sender);
+      return;
+    }
+    boolean toggled = plugin.chatListener.togglePlayer(((ProxiedPlayer) sender).getUniqueId());
+    String state =
+        toggled ? config.getString("messages.onstring") : config.getString("messages.offstring");
+    sender.sendMessage(
+        txt(
+            config.getString("messages.prefix")
+                + String.format(config.getString("messages.toggled", ""), state)));
   }
 
-    private BaseComponent[] txt(String text)
-    {
-        return TextComponent.fromLegacyText(clr(text));
+  @Contract("_ -> new")
+  private @NotNull BaseComponent[] txt(@NotNull String text) {
+    return TextComponent.fromLegacyText(ChatColor.translateAlternateColorCodes('&', text));
   }
-
 }

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

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

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

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

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

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

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

@@ -1,34 +1,63 @@
 package me.oskar3123.staffchat.spigot;
 
+import github.scarsz.discordsrv.DiscordSRV;
+import java.util.Optional;
+import me.clip.placeholderapi.PlaceholderAPI;
 import me.oskar3123.staffchat.spigot.command.StaffChatCommand;
-import me.oskar3123.staffchat.spigot.event.ChatListener;
+import me.oskar3123.staffchat.spigot.handler.StaffChatHandler;
+import me.oskar3123.staffchat.spigot.listener.ChatListener;
+import me.oskar3123.staffchat.spigot.listener.DiscordSrvListener;
+import me.oskar3123.staffchat.spigot.listener.StaffChatPml;
+import org.bstats.bukkit.Metrics;
 import org.bukkit.Bukkit;
+import org.bukkit.entity.Player;
 import org.bukkit.plugin.java.JavaPlugin;
+import org.jetbrains.annotations.NotNull;
 
-public class Main extends JavaPlugin
-{
+public class Main extends JavaPlugin {
 
-    public final String usePerm = "staffchat.use";
-    public final String seePerm = "staffchat.see";
-    public final String commandPerm = "staffchat.command";
-    public final String reloadPerm = "staffchat.reload";
+  private static final int BSTATS_PLUGIN_ID = 835;
 
-    public void onEnable()
-    {
-        new MetricsLite(this);
+  public final StaffChatHandler staffChatHandler = new StaffChatHandler(this);
+  public final ChatListener chatListener = new ChatListener(staffChatHandler);
+  public final StaffChatPml staffChatPml = new StaffChatPml(staffChatHandler);
+
+  public void onEnable() {
+    getServer().getMessenger().registerOutgoingPluginChannel(this, "BungeeCord");
+    getServer().getMessenger().registerIncomingPluginChannel(this, "BungeeCord", staffChatPml);
+    new Metrics(this, BSTATS_PLUGIN_ID);
     saveDefaultConfig();
     registerCommands();
     registerEvents();
+    if (Bukkit.getPluginManager().isPluginEnabled("DiscordSRV")) {
+      DiscordSRV.api.subscribe(new DiscordSrvListener(this));
+    }
   }
 
-    private void registerCommands()
-    {
-        getCommand("staffchat").setExecutor(new StaffChatCommand(this));
+  @Override
+  public void saveDefaultConfig() {
+    super.saveDefaultConfig();
+    getConfig().options().copyDefaults(true);
+    saveConfig();
   }
 
-    private void registerEvents()
-    {
-        Bukkit.getPluginManager().registerEvents(new ChatListener(this), this);
+  private void registerCommands() {
+    Optional.ofNullable(getCommand("staffchat"))
+        .ifPresent(command -> command.setExecutor(new StaffChatCommand(this)));
   }
 
+  private void registerEvents() {
+    Bukkit.getPluginManager().registerEvents(this.chatListener, this);
+  }
+
+  private boolean isPlaceholderApiEnabled() {
+    return Bukkit.getPluginManager().isPluginEnabled("PlaceholderAPI");
+  }
+
+  public @NotNull String replacePlaceholders(Player player, String string) {
+    if (!isPlaceholderApiEnabled()) {
+      return string;
+    }
+    return PlaceholderAPI.setPlaceholders(player, string);
+  }
 }

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

@@ -1,293 +0,0 @@
-package me.oskar3123.staffchat.spigot;
-
-import org.bukkit.Bukkit;
-import org.bukkit.configuration.file.YamlConfiguration;
-import org.bukkit.plugin.ServicePriority;
-import org.bukkit.plugin.java.JavaPlugin;
-import org.json.simple.JSONArray;
-import org.json.simple.JSONObject;
-
-import javax.net.ssl.HttpsURLConnection;
-import java.io.ByteArrayOutputStream;
-import java.io.DataOutputStream;
-import java.io.File;
-import java.io.IOException;
-import java.lang.reflect.InvocationTargetException;
-import java.net.URL;
-import java.util.Timer;
-import java.util.TimerTask;
-import java.util.UUID;
-import java.util.logging.Level;
-import java.util.zip.GZIPOutputStream;
-
-/**
- * bStats collects some data for plugin authors.
- *
- * 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!");
-        }
-    }
-
-    // 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;
-
-    // The plugin
-    private final JavaPlugin plugin;
-
-    /**
-     * Class constructor.
-     *
-     * @param plugin The plugin which stats should be submitted.
-     */
-    public MetricsLite(JavaPlugin plugin) {
-        if (plugin == null) {
-            throw new IllegalArgumentException("Plugin cannot be null!");
-        }
-        this.plugin = plugin;
-
-        // Get the config file
-        File bStatsFolder = new File(plugin.getDataFolder().getParentFile(), "bStats");
-        File configFile = new File(bStatsFolder, "config.yml");
-        YamlConfiguration config = YamlConfiguration.loadConfiguration(configFile);
-
-        // Check if the config file exists
-        if (!config.isSet("serverUuid")) {
-
-            // Add default values
-            config.addDefault("enabled", true);
-            // Every server gets it's unique random id.
-            config.addDefault("serverUuid", UUID.randomUUID().toString());
-            // Should failed request be logged?
-            config.addDefault("logFailedRequests", false);
-
-            // Inform the server owners about bStats
-            config.options().header(
-                    "bStats collects some data for plugin authors like how many servers are using their plugins.\n" +
-                            "To honor their work, you should not disable it.\n" +
-                            "This has nearly no effect on the server performance!\n" +
-                            "Check out https://bStats.org/ to learn more :)"
-            ).copyDefaults(true);
-            try {
-                config.save(configFile);
-            } catch (IOException ignored) { }
-        }
-
-        // Load the data
-        serverUUID = config.getString("serverUuid");
-        logFailedRequests = config.getBoolean("logFailedRequests", false);
-        if (config.getBoolean("enabled", true)) {
-            boolean found = false;
-            // Search for all other bStats Metrics classes to see if we are the first one
-            for (Class<?> service : Bukkit.getServicesManager().getKnownServices()) {
-                try {
-                    service.getField("B_STATS_VERSION"); // Our identifier :)
-                    found = true; // We aren't the first
-                    break;
-                } catch (NoSuchFieldException ignored) { }
-            }
-            // Register our service
-            Bukkit.getServicesManager().register(MetricsLite.class, this, plugin, ServicePriority.Normal);
-            if (!found) {
-                // We are the first!
-                startSubmitting();
-            }
-        }
-    }
-
-    /**
-     * 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) {
-            throw new IllegalArgumentException("Data cannot be null!");
-        }
-        if (Bukkit.isPrimaryThread()) {
-            throw new IllegalAccessException("This method must not be called from the main thread!");
-        }
-        HttpsURLConnection connection = (HttpsURLConnection) new URL(URL).openConnection();
-
-        // Compress the data to save bandwidth
-        byte[] compressedData = compress(data.toString());
-
-        // Add headers
-        connection.setRequestMethod("POST");
-        connection.addRequestProperty("Accept", "application/json");
-        connection.addRequestProperty("Connection", "close");
-        connection.addRequestProperty("Content-Encoding", "gzip"); // We gzip our request
-        connection.addRequestProperty("Content-Length", String.valueOf(compressedData.length));
-        connection.setRequestProperty("Content-Type", "application/json"); // We send our data in JSON format
-        connection.setRequestProperty("User-Agent", "MC-Server/" + B_STATS_VERSION);
-
-        // Send data
-        connection.setDoOutput(true);
-        DataOutputStream outputStream = new DataOutputStream(connection.getOutputStream());
-        outputStream.write(compressedData);
-        outputStream.flush();
-        outputStream.close();
-
-        connection.getInputStream().close(); // We don't care about the response - Just send our data :)
-    }
-
-    /**
-     * Gzips the given String.
-     *
-     * @param str The string to gzip.
-     * @return The gzipped String.
-     * @throws IOException If the compression failed.
-     */
-    private static byte[] compress(final String str) throws IOException {
-        if (str == null) {
-            return null;
-        }
-        ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
-        GZIPOutputStream gzip = new GZIPOutputStream(outputStream);
-        gzip.write(str.getBytes("UTF-8"));
-        gzip.close();
-        return outputStream.toByteArray();
-    }
-
-}

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

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

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

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

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

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

src/main/java/me/oskar3123/staffchat/spigot/handler/StaffChatHandler.java

@@ -0,0 +1,169 @@
+package me.oskar3123.staffchat.spigot.handler;
+
+import com.google.common.io.ByteArrayDataInput;
+import com.google.common.io.ByteArrayDataOutput;
+import com.google.common.io.ByteStreams;
+import github.scarsz.discordsrv.DiscordSRV;
+import github.scarsz.discordsrv.util.DiscordUtil;
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.util.HashSet;
+import java.util.Objects;
+import java.util.Set;
+import java.util.UUID;
+import java.util.function.Supplier;
+import java.util.logging.Level;
+import me.oskar3123.staffchat.spigot.Main;
+import me.oskar3123.staffchat.spigot.event.StaffChatEvent;
+import me.oskar3123.staffchat.util.FormatUtils;
+import me.oskar3123.staffchat.util.Permissions;
+import org.bukkit.Bukkit;
+import org.bukkit.ChatColor;
+import org.bukkit.configuration.file.FileConfiguration;
+import org.bukkit.entity.Player;
+import org.bukkit.event.player.AsyncPlayerChatEvent;
+import org.jetbrains.annotations.NotNull;
+
+public class StaffChatHandler {
+
+  private final Main plugin;
+  private final Set<UUID> toggledPlayers = new HashSet<>();
+
+  public StaffChatHandler(Main plugin) {
+    this.plugin = plugin;
+  }
+
+  public void onChatEvent(@NotNull AsyncPlayerChatEvent event) {
+    if (!event.getPlayer().hasPermission(Permissions.USE.permission())) {
+      return;
+    }
+
+    FileConfiguration config = plugin.getConfig();
+    String character = Objects.requireNonNull(config.getString("settings.character", "@"));
+    boolean isToggled = toggledPlayers.contains(event.getPlayer().getUniqueId());
+    if (!event.getMessage().startsWith(character) && !isToggled) {
+      return;
+    }
+
+    event.setCancelled(true);
+
+    String format = Objects.requireNonNull(config.getString("settings.format", ""));
+    String message = event.getMessage().substring(isToggled ? 0 : character.length()).trim();
+    if (config.getBoolean("settings.replaceplaceholdersinmessage")) {
+      message = plugin.replacePlaceholders(event.getPlayer(), message);
+    }
+
+    StaffChatEvent chatEvent =
+        new StaffChatEvent(event.isAsynchronous(), event.getPlayer(), format, message);
+    Bukkit.getServer().getPluginManager().callEvent(chatEvent);
+    if (chatEvent.isCancelled()) {
+      return;
+    }
+    format = chatEvent.getFormat();
+    message = chatEvent.getMessage();
+
+    format = plugin.replacePlaceholders(event.getPlayer(), format);
+
+    sendStaffChatMessage(format, event.getPlayer()::getName, message);
+
+    if (plugin.getConfig().getBoolean("discordsrv.enable")) {
+      sendDiscordMessage(event.getPlayer(), message);
+    }
+  }
+
+  public void sendStaffChatMessage(String format, Supplier<String> nameSupplier, String message) {
+    final String finalMessage =
+        FormatUtils.replacePlaceholders(
+            format, s -> ChatColor.translateAlternateColorCodes('&', s), nameSupplier, message);
+
+    if (plugin.getConfig().getBoolean("settings.sendmessagestoallservers")) {
+      // Find any player and send using that object
+      // (which player sends the plugin message is not important)
+      Bukkit.getOnlinePlayers().stream()
+          .findAny()
+          .ifPresent(player -> sendForwardPluginMessage(player, finalMessage));
+    }
+    sendStaffChatMessage(finalMessage);
+  }
+
+  public void onPluginMessageReceived(@NotNull String channel, 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) {
+      plugin.getLogger().log(Level.SEVERE, "Failed to read plugin message from bungeecord", e);
+      return;
+    }
+    sendStaffChatMessage(actualMessage);
+  }
+
+  private void sendForwardPluginMessage(@NotNull Player player, @NotNull String message) {
+    ByteArrayDataOutput out = ByteStreams.newDataOutput();
+    out.writeUTF("Forward");
+    out.writeUTF("ONLINE");
+    out.writeUTF("StaffChat");
+    ByteArrayOutputStream byteStream = new ByteArrayOutputStream();
+    DataOutputStream dataStream = new DataOutputStream(byteStream);
+    try {
+      dataStream.writeUTF(message);
+    } catch (IOException e) {
+      plugin.getLogger().log(Level.SEVERE, "Failed to send plugin message to bungeecord", e);
+      return;
+    }
+    byte[] data = byteStream.toByteArray();
+    out.writeShort(data.length);
+    out.write(data);
+    player.sendPluginMessage(plugin, "BungeeCord", out.toByteArray());
+  }
+
+  private void sendStaffChatMessage(@NotNull String message) {
+    Bukkit.getOnlinePlayers().stream()
+        .filter(p -> p.hasPermission(Permissions.SEE.permission()))
+        .forEach(p -> p.sendMessage(message));
+    plugin.getLogger().info(ChatColor.stripColor(message));
+  }
+
+  private void sendDiscordMessage(Player player, String message) {
+    if (Bukkit.getPluginManager().isPluginEnabled("DiscordSRV")) {
+      String format =
+          plugin.replacePlaceholders(
+              player, plugin.getConfig().getString("discordsrv.minecraft-to-discord-format", ""));
+      format =
+          FormatUtils.replacePlaceholders(
+              format,
+              s -> ChatColor.translateAlternateColorCodes('&', s),
+              player::getName,
+              message);
+      DiscordUtil.sendMessage(
+          DiscordSRV.getPlugin()
+              .getOptionalTextChannel(
+                  plugin.getConfig().getString("discordsrv.channel", "staffchat")),
+          format);
+    }
+  }
+
+  public boolean togglePlayer(@NotNull UUID player) {
+    if (toggledPlayers.contains(player)) {
+      toggledPlayers.remove(player);
+      return false;
+    }
+    toggledPlayers.add(player);
+    return true;
+  }
+}

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

@@ -0,0 +1,21 @@
+package me.oskar3123.staffchat.spigot.listener;
+
+import me.oskar3123.staffchat.spigot.handler.StaffChatHandler;
+import org.bukkit.event.EventHandler;
+import org.bukkit.event.Listener;
+import org.bukkit.event.player.AsyncPlayerChatEvent;
+import org.jetbrains.annotations.NotNull;
+
+public class ChatListener implements Listener {
+
+  private final StaffChatHandler staffChatHandler;
+
+  public ChatListener(@NotNull StaffChatHandler staffChatHandler) {
+    this.staffChatHandler = staffChatHandler;
+  }
+
+  @EventHandler
+  public void chat(@NotNull AsyncPlayerChatEvent event) {
+    staffChatHandler.onChatEvent(event);
+  }
+}

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

@@ -0,0 +1,56 @@
+package me.oskar3123.staffchat.spigot.listener;
+
+import github.scarsz.discordsrv.DiscordSRV;
+import github.scarsz.discordsrv.api.ListenerPriority;
+import github.scarsz.discordsrv.api.Subscribe;
+import github.scarsz.discordsrv.api.events.DiscordGuildMessageReceivedEvent;
+import github.scarsz.discordsrv.dependencies.jda.api.entities.Message;
+import github.scarsz.discordsrv.dependencies.jda.api.entities.User;
+import java.util.Optional;
+import me.oskar3123.staffchat.spigot.Main;
+import me.oskar3123.staffchat.spigot.util.FoliaUtils;
+import org.bukkit.configuration.Configuration;
+
+public class DiscordSrvListener {
+
+  private final Main plugin;
+  private final DiscordSRV discordSrv;
+
+  public DiscordSrvListener(Main plugin) {
+    this.plugin = plugin;
+    this.discordSrv = DiscordSRV.getPlugin();
+  }
+
+  @Subscribe(priority = ListenerPriority.MONITOR)
+  public void onDiscordGuildMessageReceivedEvent(DiscordGuildMessageReceivedEvent event) {
+    Configuration config = plugin.getConfig();
+    if (!isDiscordSrvEnabled(config)) {
+      return;
+    }
+    String channel = config.getString("discordsrv.channel", "staffchat");
+    Optional.ofNullable(discordSrv.getDestinationGameChannelNameForTextChannel(event.getChannel()))
+        .filter(gameChannel -> gameChannel.equals(channel))
+        .ifPresent(
+            gameChannel -> {
+              String name =
+                  Optional.ofNullable(event.getAuthor()).map(User::getName).orElse("Discord User");
+              String message =
+                  Optional.ofNullable(event.getMessage())
+                      .map(Message::getContentDisplay)
+                      .orElse("");
+              FoliaUtils.execute(
+                  plugin,
+                  () ->
+                      plugin.staffChatHandler.sendStaffChatMessage(
+                          plugin
+                              .getConfig()
+                              .getString("discordsrv.discord-to-minecraft-format", ""),
+                          () -> name,
+                          message));
+            });
+  }
+
+  private boolean isDiscordSrvEnabled(Configuration config) {
+    return config.getBoolean("discordsrv.enable", false);
+  }
+}

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

@@ -0,0 +1,21 @@
+package me.oskar3123.staffchat.spigot.listener;
+
+import me.oskar3123.staffchat.spigot.handler.StaffChatHandler;
+import org.bukkit.entity.Player;
+import org.bukkit.plugin.messaging.PluginMessageListener;
+import org.jetbrains.annotations.NotNull;
+
+public class StaffChatPml implements PluginMessageListener {
+
+  private final StaffChatHandler staffChatHandler;
+
+  public StaffChatPml(StaffChatHandler staffChatHandler) {
+    this.staffChatHandler = staffChatHandler;
+  }
+
+  @Override
+  public void onPluginMessageReceived(
+      @NotNull String channel, @NotNull Player player, byte[] message) {
+    staffChatHandler.onPluginMessageReceived(channel, message);
+  }
+}

src/main/java/me/oskar3123/staffchat/spigot/util/FoliaUtils.java

@@ -0,0 +1,52 @@
+package me.oskar3123.staffchat.spigot.util;
+
+import java.lang.reflect.InvocationTargetException;
+import java.lang.reflect.Method;
+import org.bukkit.Bukkit;
+import org.bukkit.plugin.Plugin;
+
+public class FoliaUtils {
+
+  private static final String FOLIA_PROBE_CLASS =
+      "io.papermc.paper.threadedregions.RegionizedServer";
+  private static final boolean IS_FOLIA;
+
+  static {
+    boolean isFolia;
+    try {
+      Class.forName(FOLIA_PROBE_CLASS);
+      isFolia = true;
+    } catch (ClassNotFoundException e) {
+      isFolia = false;
+    }
+    IS_FOLIA = isFolia;
+  }
+
+  private FoliaUtils() {}
+
+  public static boolean isFolia() {
+    return IS_FOLIA;
+  }
+
+  public static void execute(Plugin plugin, Runnable runnable) {
+    if (isFolia()) {
+      try {
+        Method getGlobalRegionSchedulerMethod =
+            Class.forName("org.bukkit.Bukkit").getDeclaredMethod("getGlobalRegionScheduler");
+        Method executeMethod =
+            Class.forName("io.papermc.paper.threadedregions.scheduler.GlobalRegionScheduler")
+                .getDeclaredMethod("execute", Plugin.class, Runnable.class);
+        Object globalRegionScheduler = getGlobalRegionSchedulerMethod.invoke(null);
+        executeMethod.invoke(globalRegionScheduler, plugin, runnable);
+      } catch (ClassNotFoundException
+          | IllegalAccessException
+          | NoSuchMethodException
+          | InvocationTargetException e) {
+        // Should not happen, rethrow as a runtime exception if it does
+        throw new RuntimeException(e);
+      }
+    } else {
+      Bukkit.getScheduler().runTask(plugin, runnable);
+    }
+  }
+}

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

@@ -0,0 +1,32 @@
+package me.oskar3123.staffchat.util;
+
+import java.util.function.Function;
+import java.util.function.Supplier;
+
+public class FormatUtils {
+
+  private FormatUtils() {}
+
+  public static String replacePlaceholders(
+      String string,
+      Function<String, String> colorize,
+      Supplier<String> serverSupplier,
+      Supplier<String> nameSupplier,
+      String message) {
+    string =
+        string.replaceAll("\\{SERVER}", StringUtils.sanitize(colorize.apply(serverSupplier.get())));
+    return replacePlaceholders(string, colorize, nameSupplier, message);
+  }
+
+  public static String replacePlaceholders(
+      String string,
+      Function<String, String> colorize,
+      Supplier<String> nameSupplier,
+      String message) {
+    string = colorize.apply(string);
+    string =
+        string.replaceAll("\\{NAME}", StringUtils.sanitize(colorize.apply(nameSupplier.get())));
+    string = string.replaceAll("\\{MESSAGE}", StringUtils.sanitize(message));
+    return string;
+  }
+}

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

@@ -0,0 +1,21 @@
+package me.oskar3123.staffchat.util;
+
+import org.jetbrains.annotations.NotNull;
+
+public enum Permissions {
+  USE("staffchat.use"),
+  SEE("staffchat.see"),
+  COMMAND("staffchat.command"),
+  RELOAD("staffchat.reload");
+
+  private final String permission;
+
+  Permissions(@NotNull String permission) {
+    this.permission = permission;
+  }
+
+  @NotNull
+  public String permission() {
+    return permission;
+  }
+}

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

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

src/main/resources/bungee.yml

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

src/main/resources/config.yml

@@ -1,7 +1,19 @@
 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'
+  reload-failed: '&cFailed to reload the config file'
+  toggled: 'You toggled auto staffchat %s'
+  onstring: 'on'
+  offstring: 'off'
+discordsrv:
+  enable: false
+  channel: 'staffchat'
+  minecraft-to-discord-format: '{NAME} » {MESSAGE}'
+  discord-to-minecraft-format: '&b(Discord) {NAME}: {MESSAGE}'

src/main/resources/plugin.yml

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

src/velocity/java/me/oskar3123/staffchat/velocity/VelocityStaffChat.java

@@ -0,0 +1,117 @@
+package me.oskar3123.staffchat.velocity;
+
+import com.google.inject.Inject;
+import com.velocitypowered.api.event.Subscribe;
+import com.velocitypowered.api.event.proxy.ProxyInitializeEvent;
+import com.velocitypowered.api.event.proxy.ProxyShutdownEvent;
+import com.velocitypowered.api.plugin.Plugin;
+import com.velocitypowered.api.plugin.annotation.DataDirectory;
+import com.velocitypowered.api.proxy.ProxyServer;
+import java.io.IOException;
+import java.io.InputStream;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import me.oskar3123.staffchat.velocity.command.VelocityStaffChatCommand;
+import me.oskar3123.staffchat.velocity.handler.VelocityStaffChatHandler;
+import me.oskar3123.staffchat.velocity.listener.VelocityStaffChatListener;
+import org.bstats.velocity.Metrics;
+import org.slf4j.Logger;
+import org.spongepowered.configurate.CommentedConfigurationNode;
+import org.spongepowered.configurate.yaml.YamlConfigurationLoader;
+
+@Plugin(
+    id = "staffchat",
+    name = "StaffChat",
+    version = VelocityStaffChat.PLUGIN_VERSION,
+    description = "A staff chat plugin",
+    authors = {"oskar3123"})
+public class VelocityStaffChat {
+
+  public static final String PLUGIN_VERSION = "SNAPSHOT";
+
+  private static final int BSTATS_PLUGIN_ID = 24679;
+
+  private final ProxyServer server;
+  private final Logger logger;
+  private final Path dataDirectory;
+  private final Metrics.Factory metricsFactory;
+  private VelocityStaffChatHandler staffChatHandler;
+  private CommentedConfigurationNode config;
+
+  @Inject
+  public VelocityStaffChat(
+      ProxyServer server,
+      Logger logger,
+      @DataDirectory Path dataDirectory,
+      Metrics.Factory metricsFactory) {
+    this.server = server;
+    this.logger = logger;
+    this.dataDirectory = dataDirectory;
+    this.metricsFactory = metricsFactory;
+  }
+
+  @Subscribe
+  public void onProxyInitialization(ProxyInitializeEvent event) {
+    try {
+      config = loadConfig();
+
+      // Initialize metrics
+      metricsFactory.make(this, BSTATS_PLUGIN_ID);
+
+      // Initialize handler
+      staffChatHandler = new VelocityStaffChatHandler(this);
+
+      // Register commands
+      server
+          .getCommandManager()
+          .register(
+              server.getCommandManager().metaBuilder("staffchat").build(),
+              new VelocityStaffChatCommand(this));
+
+      // Register listeners
+      server.getEventManager().register(this, new VelocityStaffChatListener(this));
+
+      logger.info("StaffChat has been enabled!");
+    } catch (IOException e) {
+      logger.error("Failed to start StaffChat!", e);
+    }
+  }
+
+  @Subscribe
+  public void onProxyShutdown(ProxyShutdownEvent event) {
+    logger.info("StaffChat has been disabled!");
+  }
+
+  public VelocityStaffChatHandler getStaffChatHandler() {
+    return staffChatHandler;
+  }
+
+  public ProxyServer getServer() {
+    return server;
+  }
+
+  public void reloadConfig() throws IOException {
+    config = loadConfig();
+  }
+
+  public CommentedConfigurationNode getConfig() {
+    return config;
+  }
+
+  private CommentedConfigurationNode loadConfig() throws IOException {
+    if (Files.notExists(dataDirectory)) {
+      Files.createDirectory(dataDirectory);
+    }
+    Path config = dataDirectory.resolve("config.yml");
+    if (Files.notExists(config)) {
+      try (InputStream stream = getClass().getClassLoader().getResourceAsStream("config.yml")) {
+        if (stream == null) {
+          throw new IOException("no default config.yml");
+        }
+        Files.copy(stream, config);
+      }
+    }
+    YamlConfigurationLoader loader = YamlConfigurationLoader.builder().path(config).build();
+    return loader.load();
+  }
+}

src/velocity/java/me/oskar3123/staffchat/velocity/command/VelocityStaffChatCommand.java

@@ -0,0 +1,123 @@
+package me.oskar3123.staffchat.velocity.command;
+
+import com.velocitypowered.api.command.CommandSource;
+import com.velocitypowered.api.command.SimpleCommand;
+import com.velocitypowered.api.proxy.Player;
+import java.io.IOException;
+import me.oskar3123.staffchat.util.Permissions;
+import me.oskar3123.staffchat.velocity.VelocityStaffChat;
+import net.kyori.adventure.text.Component;
+import net.kyori.adventure.text.serializer.legacy.LegacyComponentSerializer;
+import org.jetbrains.annotations.NotNull;
+import org.spongepowered.configurate.CommentedConfigurationNode;
+
+public class VelocityStaffChatCommand implements SimpleCommand {
+
+  private final VelocityStaffChat plugin;
+  private CommentedConfigurationNode config;
+
+  public VelocityStaffChatCommand(VelocityStaffChat plugin) {
+    this.plugin = plugin;
+    config = plugin.getConfig();
+  }
+
+  @Override
+  public void execute(Invocation invocation) {
+    CommandSource sender = invocation.source();
+    String label = invocation.alias();
+    String[] args = invocation.arguments();
+
+    Component noPerm =
+        txt(
+            config.node("messages", "prefix").getString()
+                + config.node("messages", "nopermission").getString());
+    if (!sender.hasPermission(Permissions.COMMAND.permission())) {
+      sender.sendMessage(noPerm);
+      return;
+    }
+    if (args.length < 1) {
+      help(sender, label);
+      return;
+    }
+    if (args[0].equalsIgnoreCase("reload")) {
+      if (sender.hasPermission(Permissions.RELOAD.permission())) {
+        reload(sender);
+      } else {
+        sender.sendMessage(noPerm);
+      }
+      return;
+    } else if (args[0].equalsIgnoreCase("toggle")) {
+      if (sender.hasPermission(Permissions.USE.permission())) {
+        toggle(sender);
+      } else {
+        sender.sendMessage(noPerm);
+      }
+      return;
+    }
+    help(sender, label);
+  }
+
+  @Override
+  public boolean hasPermission(Invocation invocation) {
+    return invocation.source().hasPermission(Permissions.COMMAND.permission());
+  }
+
+  private void playerOnly(@NotNull CommandSource sender) {
+    sender.sendMessage(
+        txt(
+            config.node("messages", "prefix").getString()
+                + config.node("messages", "playeronly").getString()));
+  }
+
+  private void help(@NotNull CommandSource sender, String label) {
+    String prefix = config.node("messages", "prefix").getString();
+    sender.sendMessage(
+        txt(prefix + "Version " + VelocityStaffChat.PLUGIN_VERSION + ", made by oskar3123"));
+    if (sender.hasPermission(Permissions.USE.permission())) {
+      sender.sendMessage(
+          txt(prefix + "Message prefix: " + config.node("settings", "character").getString()));
+      sender.sendMessage(txt(prefix + "/" + label + " toggle - Toggles auto staffchat"));
+    }
+    if (sender.hasPermission(Permissions.RELOAD.permission())) {
+      sender.sendMessage(txt(prefix + "/" + label + " reload - Reloads the config file"));
+    }
+  }
+
+  private void reload(@NotNull CommandSource sender) {
+    try {
+      plugin.reloadConfig();
+      config = plugin.getConfig();
+      sender.sendMessage(
+          txt(
+              config.node("messages", "prefix").getString()
+                  + config.node("messages", "reloaded").getString()));
+    } catch (IOException e) {
+      sender.sendMessage(
+          txt(
+              config.node("messages", "prefix").getString()
+                  + config
+                      .node("messages", "reload-failed")
+                      .getString("Failed to reload the config file")));
+    }
+  }
+
+  private void toggle(@NotNull CommandSource sender) {
+    if (!(sender instanceof Player player)) {
+      playerOnly(sender);
+      return;
+    }
+    boolean toggled = plugin.getStaffChatHandler().togglePlayer(player.getUniqueId());
+    String state =
+        toggled
+            ? config.node("messages", "onstring").getString()
+            : config.node("messages", "offstring").getString();
+    sender.sendMessage(
+        txt(
+            config.node("messages", "prefix").getString()
+                + String.format(config.node("messages", "toggled").getString(""), state)));
+  }
+
+  private @NotNull Component txt(@NotNull String text) {
+    return LegacyComponentSerializer.legacyAmpersand().deserialize(text);
+  }
+}

src/velocity/java/me/oskar3123/staffchat/velocity/event/VelocityStaffChatEvent.java

@@ -0,0 +1,260 @@
+package me.oskar3123.staffchat.velocity.event;
+
+import com.velocitypowered.api.event.ResultedEvent;
+import com.velocitypowered.api.proxy.Player;
+import java.util.Objects;
+import java.util.Optional;
+import java.util.StringJoiner;
+import me.oskar3123.staffchat.velocity.event.VelocityStaffChatEvent.StaffChatResult;
+import org.jetbrains.annotations.Contract;
+import org.jetbrains.annotations.NotNull;
+
+/**
+ * Event fired after deciding to broadcast a staff message.
+ *
+ * <p>Denying this event will still block the chat message.
+ */
+public class VelocityStaffChatEvent implements ResultedEvent<StaffChatResult> {
+
+  private final Player player;
+  private final String format;
+  private final String message;
+
+  private StaffChatResult result = StaffChatResult.allowed();
+
+  @Contract(pure = true)
+  public VelocityStaffChatEvent(
+      @NotNull Player player, @NotNull String format, @NotNull String message) {
+    this.player = Objects.requireNonNull(player, "player must not be null");
+    this.format = Objects.requireNonNull(format, "format must not be null");
+    this.message = Objects.requireNonNull(message, "message must not be null");
+  }
+
+  /**
+   * Gets the player that is sending the staff chat message.
+   *
+   * @return the player
+   */
+  @NotNull
+  @Contract(pure = true)
+  public Player getPlayer() {
+    return player;
+  }
+
+  /**
+   * Gets the initial format decided by the plugin.
+   *
+   * <p>Use {@link #getResult()} to get the potentially modified format.
+   *
+   * @return the initial format
+   */
+  @NotNull
+  @Contract(pure = true)
+  public String getFormat() {
+    return format;
+  }
+
+  /**
+   * Gets the initial message entered by the player.
+   *
+   * <p>Use {@link #getResult()} to get the potentially modified message.
+   *
+   * @return the initial message
+   */
+  @NotNull
+  @Contract(pure = true)
+  public String getMessage() {
+    return message;
+  }
+
+  /**
+   * Gets the current result.
+   *
+   * <p>This will by default be an allowed result with no modifications.
+   *
+   * @return the current result
+   */
+  @NotNull
+  @Contract(pure = true)
+  @Override
+  public StaffChatResult getResult() {
+    return result;
+  }
+
+  /**
+   * Sets the current result.
+   *
+   * <p>You can {@linkplain StaffChatResult#allowed() allow}, {@linkplain StaffChatResult#denied()
+   * deny}, {@linkplain StaffChatResult#format(String) modify the format}, {@linkplain
+   * StaffChatResult#message(String) modify the message}, or {@linkplain
+   * StaffChatResult#formatAndMessage(String, String) modify both the format and message}.
+   *
+   * @param result the new result
+   */
+  @Override
+  public void setResult(@NotNull StaffChatResult result) {
+    this.result = Objects.requireNonNull(result, "result must not be null");
+  }
+
+  @Override
+  public boolean equals(Object o) {
+    if (o == null || getClass() != o.getClass()) return false;
+    VelocityStaffChatEvent that = (VelocityStaffChatEvent) o;
+    return Objects.equals(player, that.player)
+        && Objects.equals(format, that.format)
+        && Objects.equals(message, that.message)
+        && Objects.equals(result, that.result);
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(player, format, message, result);
+  }
+
+  @Override
+  public String toString() {
+    return new StringJoiner(", ", VelocityStaffChatEvent.class.getSimpleName() + "[", "]")
+        .add("player=" + player)
+        .add("format='" + format + "'")
+        .add("message='" + message + "'")
+        .add("result=" + result)
+        .toString();
+  }
+
+  /** Result of the {@linkplain VelocityStaffChatEvent}. */
+  public static class StaffChatResult implements Result {
+
+    private static final StaffChatResult ALLOWED = new StaffChatResult(true, null, null);
+    private static final StaffChatResult DENIED = new StaffChatResult(false, null, null);
+
+    private final boolean allowed;
+    private final String format;
+    private final String message;
+
+    private StaffChatResult(boolean allowed, String format, String message) {
+      this.allowed = allowed;
+      this.format = format;
+      this.message = message;
+    }
+
+    /**
+     * Allows the message to be sent, without modifying anything.
+     *
+     * @return the allowed result
+     */
+    @NotNull
+    @Contract(pure = true)
+    public static StaffChatResult allowed() {
+      return ALLOWED;
+    }
+
+    /**
+     * Prevents the message from being sent.
+     *
+     * @return the denied result
+     */
+    @NotNull
+    @Contract(pure = true)
+    public static StaffChatResult denied() {
+      return DENIED;
+    }
+
+    /**
+     * Allows the message to be sent, modifying the format.
+     *
+     * @param format the format
+     * @return the modify format result
+     */
+    @NotNull
+    @Contract(value = "_ -> new", pure = true)
+    public static StaffChatResult format(@NotNull String format) {
+      return new StaffChatResult(
+          true, Objects.requireNonNull(format, "format must not be null"), null);
+    }
+
+    /**
+     * Allows the message to be sent, modifying the message.
+     *
+     * @param message the message
+     * @return the modify message result
+     */
+    @NotNull
+    @Contract(value = "_ -> new", pure = true)
+    public static StaffChatResult message(@NotNull String message) {
+      return new StaffChatResult(
+          true, null, Objects.requireNonNull(message, "message must not be null"));
+    }
+
+    /**
+     * Allows the message to be sent, modifying the format and message.
+     *
+     * @param format the format
+     * @param message the message
+     * @return the modify format and message result
+     */
+    @NotNull
+    @Contract(value = "_, _ -> new", pure = true)
+    public static StaffChatResult formatAndMessage(
+        @NotNull String format, @NotNull String message) {
+      return new StaffChatResult(
+          true,
+          Objects.requireNonNull(format, "format must not be null"),
+          Objects.requireNonNull(message, "message must not be null"));
+    }
+
+    @Contract(pure = true)
+    @Override
+    public boolean isAllowed() {
+      return allowed;
+    }
+
+    /**
+     * Gets the potentially modified format.
+     *
+     * <p>An empty optional means that the format has not been modified.
+     *
+     * @return the potentially modified format
+     */
+    @NotNull
+    @Contract(pure = true)
+    public Optional<String> getFormat() {
+      return Optional.ofNullable(format);
+    }
+
+    /**
+     * Gets the potentially modified message.
+     *
+     * <p>An empty optional means that the message has not been modified.
+     *
+     * @return the potentially modified message
+     */
+    @NotNull
+    @Contract(pure = true)
+    public Optional<String> getMessage() {
+      return Optional.ofNullable(message);
+    }
+
+    @Override
+    public boolean equals(Object o) {
+      if (o == null || getClass() != o.getClass()) return false;
+      StaffChatResult that = (StaffChatResult) o;
+      return allowed == that.allowed
+          && Objects.equals(format, that.format)
+          && Objects.equals(message, that.message);
+    }
+
+    @Override
+    public int hashCode() {
+      return Objects.hash(allowed, format, message);
+    }
+
+    @Override
+    public String toString() {
+      return new StringJoiner(", ", StaffChatResult.class.getSimpleName() + "[", "]")
+          .add("allowed=" + allowed)
+          .add("format='" + format + "'")
+          .add("message='" + message + "'")
+          .toString();
+    }
+  }
+}

src/velocity/java/me/oskar3123/staffchat/velocity/handler/VelocityStaffChatHandler.java

@@ -0,0 +1,82 @@
+package me.oskar3123.staffchat.velocity.handler;
+
+import com.velocitypowered.api.proxy.Player;
+import java.util.HashSet;
+import java.util.Set;
+import java.util.UUID;
+import java.util.function.Function;
+import me.oskar3123.staffchat.util.FormatUtils;
+import me.oskar3123.staffchat.util.Permissions;
+import me.oskar3123.staffchat.velocity.VelocityStaffChat;
+import me.oskar3123.staffchat.velocity.event.VelocityStaffChatEvent;
+import me.oskar3123.staffchat.velocity.event.VelocityStaffChatEvent.StaffChatResult;
+import net.kyori.adventure.text.TextComponent;
+import net.kyori.adventure.text.serializer.legacy.LegacyComponentSerializer;
+
+public class VelocityStaffChatHandler {
+
+  private final VelocityStaffChat plugin;
+  private final Set<UUID> toggledPlayers;
+
+  public VelocityStaffChatHandler(VelocityStaffChat plugin) {
+    this.plugin = plugin;
+    this.toggledPlayers = new HashSet<>();
+  }
+
+  public boolean isToggled(UUID uuid) {
+    return toggledPlayers.contains(uuid);
+  }
+
+  public boolean togglePlayer(UUID uuid) {
+    if (toggledPlayers.contains(uuid)) {
+      toggledPlayers.remove(uuid);
+      return false;
+    } else {
+      toggledPlayers.add(uuid);
+      return true;
+    }
+  }
+
+  public void broadcastStaffMessage(Player player, String message) {
+    String format = plugin.getConfig().node("settings", "format").getString("&b{NAME}: {MESSAGE}");
+
+    plugin
+        .getServer()
+        .getEventManager()
+        .fire(new VelocityStaffChatEvent(player, format, message))
+        .thenAccept(
+            staffChatEvent -> {
+              StaffChatResult result = staffChatEvent.getResult();
+
+              if (result.isAllowed()) {
+                plugin
+                    .getStaffChatHandler()
+                    .broadcastStaffMessage(
+                        player,
+                        result.getFormat().orElse(format),
+                        result.getMessage().orElse(message));
+              }
+            });
+  }
+
+  private void broadcastStaffMessage(Player player, String format, String message) {
+    String formattedMessage =
+        FormatUtils.replacePlaceholders(
+            format,
+            Function.identity(),
+            () ->
+                player
+                    .getCurrentServer()
+                    .map(connection -> connection.getServerInfo().getName())
+                    .orElse(""),
+            player::getUsername,
+            message);
+
+    TextComponent component =
+        LegacyComponentSerializer.legacyAmpersand().deserialize(formattedMessage);
+    plugin.getServer().getAllPlayers().stream()
+        .filter(p -> p.hasPermission(Permissions.SEE.permission()))
+        .forEach(p -> p.sendMessage(component));
+    plugin.getServer().getConsoleCommandSource().sendMessage(component);
+  }
+}

src/velocity/java/me/oskar3123/staffchat/velocity/listener/VelocityStaffChatListener.java

@@ -0,0 +1,36 @@
+package me.oskar3123.staffchat.velocity.listener;
+
+import com.velocitypowered.api.event.Subscribe;
+import com.velocitypowered.api.event.player.PlayerChatEvent;
+import com.velocitypowered.api.proxy.Player;
+import me.oskar3123.staffchat.util.Permissions;
+import me.oskar3123.staffchat.velocity.VelocityStaffChat;
+
+public class VelocityStaffChatListener {
+
+  private final VelocityStaffChat plugin;
+
+  public VelocityStaffChatListener(VelocityStaffChat plugin) {
+    this.plugin = plugin;
+  }
+
+  @Subscribe
+  public void onPlayerChat(PlayerChatEvent event) {
+    Player player = event.getPlayer();
+
+    if (!player.hasPermission(Permissions.USE.permission())) {
+      return;
+    }
+
+    String character = plugin.getConfig().node("settings", "character").getString("@");
+    String message = event.getMessage();
+    boolean toggled = plugin.getStaffChatHandler().isToggled(player.getUniqueId());
+
+    // Check if player has staff chat toggled on or message starts with @
+    if (toggled || message.startsWith(character)) {
+      String staffMessage = toggled ? message : message.substring(character.length()).trim();
+      plugin.getStaffChatHandler().broadcastStaffMessage(player, staffMessage);
+      event.setResult(PlayerChatEvent.ChatResult.denied());
+    }
+  }
+}