M_Viper/GlobalChat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 4 Wiki Activity

src/main/java/de/viper/globalchat/GlobalChat.java aktualisiert

Browse Source
This commit is contained in:
M_Viper
2026-01-12 17:26:34 +00:00
parent 66a87fecd2
commit 0f53292bc5
1 changed files with 802 additions and 672 deletions
Download Patch File Download Diff File Expand all files Collapse all files

318
src/main/java/de/viper/globalchat/GlobalChat.java
View File

@@ -20,14 +20,16 @@ import net.md_5.bungee.api.plugin.Command;
import net.md_5.bungee.api.plugin.Listener;
import net.md_5.bungee.api.plugin.Plugin;
import net.md_5.bungee.chat.ComponentSerializer;
import net.md_5.bungee.event.EventHandler;
import net.md_5.bungee.config.Configuration;
import net.md_5.bungee.config.ConfigurationProvider;
import net.md_5.bungee.config.YamlConfiguration;
import net.md_5.bungee.event.EventHandler;
import java.io.*;
import java.lang.Class;
import java.lang.reflect.Method;
import java.nio.charset.StandardCharsets;
import java.nio.file.*;
import java.nio.file.Files;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
@@ -35,28 +37,27 @@ import java.util.regex.Pattern;
/**
* GlobalChat - Bungee Plugin
* - Filter (filter.yml)
* - Logs (plugins/GlobalChat/logs/YYYY-MM-DD.log)
* - /support, /reply, /info, /togglechat
* - Prefix/Suffix via LuckPerms (Proxy-side)
* - Server Aliase & Farben (via bungee.yml)
* - ServerSwitch announcement
* - Relay Mode: Sendet JSON an Spigot Server, um Secure-Chat Probleme zu vermeiden.
*/
public class GlobalChat extends Plugin implements Listener {
private static final String CHANNEL_CONTROL = "global:control";
private static final String CHANNEL_CHAT = "global:chat";
private static final String CHANNEL_CHAT = "global:chat"; // Kanal für Chat-Relay
private List<String> badWords = new ArrayList<>();
private File logFolder;
private boolean chatMuted = false;
// NEU: Config Handling für BungeeCord (Server Aliase)
// Config Handling für BungeeCord
private File configFile;
private Configuration config;
private Map<String, String> serverAliases = new HashMap<>();
// Map für gruppen-spezifische Formate aus der bungee.yml
private Map<String, String> groupFormats = new HashMap<>();
// Map für manuelle Ränge (UUID Override) aus der bungee.yml
private final Map<String, String> manualRanks = new ConcurrentHashMap<>();
// Optional: falls Spigot-Server OP-Info per PluginMessage sendet
private final Map<UUID, Boolean> playerIsOp = new ConcurrentHashMap<>();
// Letzte Support-Kontakte (staff UUID -> target UUID)
@@ -64,7 +65,7 @@ public class GlobalChat extends Plugin implements Listener {
// Tracking für unterdrückte Join-/Quit-Nachrichten
private final Set<UUID> suppressJoinQuit = ConcurrentHashMap.newKeySet();
// NEU: Liste für Spieler, die Toggle-Chat aktiviert haben
// Liste für Spieler, die Toggle-Chat aktiviert haben
private final Set<UUID> chatLockPlayers = ConcurrentHashMap.newKeySet();
// ===========================
@@ -73,7 +74,9 @@ public class GlobalChat extends Plugin implements Listener {
private List<String> welcomeMessages = new ArrayList<>();
private void loadWelcomeMessages() {
File file = new File(getDataFolder(), "welcome.yml");
String fileName = "welcome.yml";
File file = new File(getDataFolder(), fileName);
if (!file.exists()) {
try {
getDataFolder().mkdirs();
@@ -131,19 +134,25 @@ public class GlobalChat extends Plugin implements Listener {
// Standard-Konfiguration kopieren, falls nicht vorhanden
if (!configFile.exists()) {
getLogger().info("bungee.yml nicht gefunden. Erstelle Standard...");
try (InputStream in = getResourceAsStream("bungee.yml")) {
Files.copy(in, configFile.toPath());
} catch (IOException e) {
e.printStackTrace();
}
} else {
getLogger().info("bungee.yml gefunden. Lade Konfiguration...");
}
loadConfigData();
loadServerAliases();
loadGroupFormats();
loadManualRanks(); // NEU: UUID Ränge laden
getProxy().getPluginManager().registerListener(this, this);
loadFilter();
loadWelcomeMessages();
loadServerAliases(); // NEU
logFolder = new File(getDataFolder(), "logs");
if (!logFolder.exists()) logFolder.mkdirs();
@@ -157,7 +166,7 @@ public class GlobalChat extends Plugin implements Listener {
getProxy().getPluginManager().registerCommand(this, new InfoCommand());
getProxy().getPluginManager().registerCommand(this, new ChatToggleCommand());
getLogger().info("§aGlobalChat aktiviert (Relay-Mode, ToggleChat, Zensur, Logs, Support, ServerAliase)!");
getLogger().info("§aGlobalChat aktiviert (UUID-Overrides via bungee.yml)!");
}
@Override
@@ -172,7 +181,7 @@ public class GlobalChat extends Plugin implements Listener {
}
// ===========================
// Konfiguration & Aliase
// Konfiguration laden
// ===========================
private void loadConfigData() {
try {
@@ -187,21 +196,69 @@ public class GlobalChat extends Plugin implements Listener {
if (config == null) return;
if (config.getSection("server-aliases") == null) {
return;
}
serverAliases.clear();
if (config.getSection("server-aliases") != null) {
for (String key : config.getSection("server-aliases").getKeys()) {
serverAliases.put(key, config.getString("server-aliases." + key));
}
}
getLogger().info("§eGeladene Server-Aliase: " + serverAliases.size());
}
private String getServerDisplayName(String rawServerName) {
if (serverAliases.containsKey(rawServerName)) {
return ChatColor.translateAlternateColorCodes('&', serverAliases.get(rawServerName));
private void loadGroupFormats() {
loadConfigData();
if (config == null) return;
groupFormats.clear();
if (config.getSection("group-formats") != null) {
for (String key : config.getSection("group-formats").getKeys()) {
groupFormats.put(key, config.getString("group-formats." + key));
}
return rawServerName; // Fallback
}
getLogger().info("§eGeladene Chat-Formate: " + groupFormats.size());
}
// NEU: UUID Ränge aus bungee.yml laden
private void loadManualRanks() {
loadConfigData(); // Reload sichern
if (config == null) {
getLogger().warning("§cConfig ist null! Kann bungee.yml nicht lesen.");
return;
}
manualRanks.clear();
// Prüfen, ob Sektion existiert
if (config.getSection("manual-ranks") == null) {
getLogger().warning("§cDer Bereich 'manual-ranks' wurde in der bungee.yml NICHT gefunden!");
getLogger().warning("§cTipp: Bitte lösche die alte bungee.yml und starte neu.");
return;
}
int loadedCount = 0;
if (config.getSection("manual-ranks").getKeys().isEmpty()) {
getLogger().warning("§cDer Bereich 'manual-ranks' ist leer (keine Overrides geladen).");
} else {
for (String uuidStr : config.getSection("manual-ranks").getKeys()) {
String groupName = config.getString("manual-ranks." + uuidStr);
if (groupName != null) {
try {
// UUID Prüfung nur zur Sicherheit
UUID.fromString(uuidStr);
manualRanks.put(uuidStr, groupName);
loadedCount++;
} catch (IllegalArgumentException ex) {
getLogger().warning("§cUngültige UUID in manual-ranks: " + uuidStr);
}
}
}
}
getLogger().info("§eGeladene UUID-Overrides: " + loadedCount);
}
private String getDisplayName(String serverName) {
String displayName = serverAliases.getOrDefault(serverName, serverName);
return ChatColor.translateAlternateColorCodes('&', displayName);
}
// ===========================
@@ -213,22 +270,18 @@ public class GlobalChat extends Plugin implements Listener {
if (e.isCommand()) return;
ProxiedPlayer player = (ProxiedPlayer) e.getSender();
String originalMsg = e.getMessage();
// ==================== CHAT LOCK / TOGGLE CHECK ====================
if (chatLockPlayers.contains(player.getUniqueId())) {
// Chat ist deaktiviert: Nachricht geht direkt zum Server (für Lands/Quests)
return;
return; // Nachricht geht direkt zum Server
}
// ========================================================================
// Optional: Debugging (auskommentiert für performance)
// getLogger().info("ChatEvent: Spieler=" + player.getName() + ", Nachricht=" + originalMsg);
String originalMsg = e.getMessage();
// Versuche, Join-/Quit-Nachrichten zu filtern
if (suppressJoinQuit.contains(player.getUniqueId()) &&
(originalMsg.contains("joined the Game") || originalMsg.contains("left the Game"))) {
getLogger().info("Unterdrücke Join-/Quit-Nachricht für " + player.getName() + ": " + originalMsg);
(originalMsg.contains("joined§ Game") || originalMsg.contains("left§ Game"))) {
getLogger().info("Unterdrücke Join-/Quit-Nachricht für " + player.getName());
e.setCancelled(true);
return;
}
@@ -247,49 +300,53 @@ public class GlobalChat extends Plugin implements Listener {
censoredMsg = censoredMsg.replaceAll("(?i)" + Pattern.quote(bad), repeat("*", bad.length()));
}
// Event canceln
e.setCancelled(true);
String serverName = player.getServer().getInfo().getName();
String serverDisplay = getServerDisplayName(serverName); // NEU: Alias nutzen
String serverDisplay = getDisplayName(serverName);
// Prefix/Suffix holen
// Index 0: Prefix (Rang), Index 1: Suffix, Index 2: Spielername Farbe, Index 3: Chat Farbe
String[] ps = getPrefixSuffix(player);
String prefix = ps[0] == null ? "" : ps[0].trim();
String suffix = ps[1] == null ? "" : ps[1].trim();
String prefix = ps[0];
String playerColor = ps[2];
String chatColor = ps[3];
String displayTag = "";
if (!prefix.isEmpty()) {
displayTag = prefix;
} else if (!suffix.isEmpty()) {
displayTag = suffix;
} else if (!ps[1].isEmpty()) {
displayTag = ps[1];
}
if (!displayTag.isEmpty() && !displayTag.endsWith(" ")) displayTag = displayTag + " ";
// Formatieren
StringBuilder out = new StringBuilder();
out.append("§7[").append(serverDisplay).append("] "); // NEU: serverDisplay
out.append("§7[").append(serverDisplay).append("§r§7] "); // FIX: Reset vor der Klammer
if (!displayTag.isEmpty()) out.append(displayTag);
out.append(player.getName());
out.append("§f: ").append(censoredMsg);
// Spielername mit eigener Farbe
out.append(playerColor).append(player.getName());
out.append("§f: ").append(chatColor).append(censoredMsg); // Chatnachricht mit eigener Farbe
String chatOut = out.toString();
// NEU: Nachricht als JSON an alle Server senden (Relay)
// NEU: Nachricht erstellen und an alle Server senden
TextComponent chatComponent = new TextComponent(chatOut);
String jsonMessage = ComponentSerializer.toString(chatComponent);
byte[] data = jsonMessage.getBytes(StandardCharsets.UTF_8);
for (ServerInfo server : getProxy().getServers().values()) {
if (server.getPlayers().isEmpty()) continue; // Optimierung
if (server.getPlayers().isEmpty()) continue;
try {
server.sendData(CHANNEL_CHAT, data);
server.sendData(CHANNEL_CHAT, jsonMessage.getBytes(StandardCharsets.UTF_8));
} catch (Exception ex) {
getLogger().warning("Konnte Chat-Nachricht nicht an " + server.getName() + " senden.");
getLogger().warning("Konnte Chat-Nachricht nicht an Server " + server.getName() + " senden.");
}
}
// Loggen
// Loggen (lokal auf Bungee)
String logEntry = "[" + serverName + "] " +
(displayTag.isEmpty() ? "" : stripColor(displayTag) + " ") +
player.getName() +
@@ -298,7 +355,7 @@ public class GlobalChat extends Plugin implements Listener {
}
// ===========================
// Server connect (pre-switch suppression)
// Server Connect & Switch
// ===========================
@EventHandler
public void onServerConnect(ServerConnectEvent e) {
@@ -317,14 +374,14 @@ public class GlobalChat extends Plugin implements Listener {
sendSuppressJoinQuit(from, player.getUniqueId());
getLogger().info("Sent suppress quit message for " + player.getName() + " to server " + from.getName());
} catch (Throwable ex) {
getLogger().warning("Fehler beim Senden der Quit-Unterdrückung an " + from.getName() + ": " + ex.getMessage());
getLogger().warning("Fehler beim Senden der Quit-Unterdrückung: " + ex.getMessage());
}
try {
sendSuppressJoinQuit(target, player.getUniqueId());
getLogger().info("Sent suppress join message for " + player.getName() + " to server " + target.getName());
} catch (Throwable ex) {
getLogger().warning("Fehler beim Senden der Join-Unterdrückung an " + target.getName() + ": " + ex.getMessage());
getLogger().warning("Fehler beim Senden der Join-Unterdrückung: " + ex.getMessage());
}
getProxy().getScheduler().schedule(this, () -> {
@@ -333,30 +390,24 @@ public class GlobalChat extends Plugin implements Listener {
}, 2, java.util.concurrent.TimeUnit.SECONDS);
}
// ===========================
// Server switch announcement (RELAY MODE)
// ===========================
@EventHandler
public void onServerSwitch(ServerSwitchEvent e) {
ProxiedPlayer player = e.getPlayer();
ServerInfo from = e.getFrom();
ServerInfo to = player.getServer() != null ? player.getServer().getInfo() : null;
if (to == null) return;
if (from == null) return; // Erster Join
if (to == null || from == null) return;
if (from.getName().equalsIgnoreCase(to.getName())) return;
String fromName = from.getName();
String toName = to.getName();
String fromDisplay = getDisplayName(fromName);
// NEU: Aliase nutzen
String fromDisplay = getServerDisplayName(fromName);
String toDisplay = getServerDisplayName(toName);
String toName = to.getName();
String toDisplay = getDisplayName(toName);
String[] ps = getPrefixSuffix(player);
String prefix = ps[0] == null ? "" : ps[0].trim();
String suffix = ps[1] == null ? "" : ps[1].trim();
String prefix = ps[0];
String suffix = ps[1];
String displayTag = "";
if (!prefix.isEmpty()) displayTag = prefix;
@@ -365,15 +416,16 @@ public class GlobalChat extends Plugin implements Listener {
if (!displayTag.isEmpty() && !displayTag.endsWith(" ")) displayTag = displayTag + " ";
StringBuilder msg = new StringBuilder();
msg.append("§7[").append(toDisplay).append("] "); // NEU: toDisplay
msg.append("§7[").append(toDisplay).append("§r§7] "); // FIX: Reset vor der Klammer
if (!displayTag.isEmpty()) msg.append(displayTag);
msg.append(player.getName());
msg.append(" §7hat den Server gewechselt: §e")
.append(fromDisplay).append(" §7→ §e").append(toDisplay).append("§7."); // NEU: Displays
.append(fromDisplay).append(" §7→ §e").append(toDisplay).append("§7.");
String finalMsg = msg.toString();
// NEU: Switch Nachricht auch als JSON relays
TextComponent switchComponent = new TextComponent(finalMsg);
String jsonMessage = ComponentSerializer.toString(switchComponent);
byte[] data = jsonMessage.getBytes(StandardCharsets.UTF_8);
@@ -401,7 +453,7 @@ public class GlobalChat extends Plugin implements Listener {
out.writeUTF(playerId.toString());
server.sendData(CHANNEL_CONTROL, baos.toByteArray());
} catch (IOException ex) {
getLogger().warning("Fehler beim Senden der suppress-Nachricht an " + server.getName() + ": " + ex.getMessage());
getLogger().warning("Fehler beim Senden der suppress-Nachricht: " + ex.getMessage());
}
}
@@ -412,45 +464,90 @@ public class GlobalChat extends Plugin implements Listener {
}
// ===========================
// Prefix/Suffix via LuckPerms
// Prefix/Suffix (Logic: UUID Override > LuckPerms > Perm)
// ===========================
private String[] getPrefixSuffix(ProxiedPlayer player) {
String prefix = "";
String suffix = "";
String playerColor = "§f";
String chatColor = "§f";
String groupName = "spieler";
// 0. UUID Override aus bungee.yml
// DEBUG LOG zum Finden des Fehlers:
// getLogger().info("DEBUG: Suche Override für UUID: " + player.getUniqueId().toString());
if (manualRanks.containsKey(player.getUniqueId().toString())) {
groupName = manualRanks.get(player.getUniqueId().toString());
// getLogger().info("DEBUG: Override gefunden -> " + groupName);
}
// 1. LuckPerms via Reflection
else {
String lpGroup = getLuckPermsGroup(player);
if (lpGroup != null && !lpGroup.isEmpty() && !lpGroup.equalsIgnoreCase("default")) {
groupName = lpGroup.toLowerCase();
}
}
// 2. FALLBACK: Permission-Check
if (groupName == null || groupName.equalsIgnoreCase("default") || groupName.equalsIgnoreCase("Spieler")) {
if (player.hasPermission("group.owner")) groupName = "Owner";
else if (player.hasPermission("group.admin")) groupName = "Admin";
else if (player.hasPermission("group.developer")) groupName = "Developer";
else if (player.hasPermission("group.premium")) groupName = "Premium";
else groupName = "Spieler";
}
// 3. Farben aus bungee.yml anwenden
if (groupName != null && groupFormats.containsKey(groupName)) {
String rawFormat = groupFormats.get(groupName);
if (rawFormat.contains(" || ")) {
String[] parts = rawFormat.split(" \\|\\| ");
prefix = ChatColor.translateAlternateColorCodes('&', parts[0]);
playerColor = ChatColor.translateAlternateColorCodes('&', parts[1]);
chatColor = ChatColor.translateAlternateColorCodes('&', parts[2]);
suffix = "";
} else if (rawFormat.contains(": ")) {
String[] parts = rawFormat.split(": ", 2);
prefix = ChatColor.translateAlternateColorCodes('&', parts[0]);
chatColor = ChatColor.translateAlternateColorCodes('&', parts[1]);
playerColor = "§f";
suffix = "";
} else {
prefix = ChatColor.translateAlternateColorCodes('&', rawFormat);
suffix = "";
playerColor = "§f";
chatColor = "§f";
}
return new String[]{prefix, suffix, playerColor, chatColor};
}
// 4. LuckPerms Meta Fallback
try {
LuckPerms lp = LuckPermsProvider.get();
if (lp != null) {
User user = lp.getUserManager().getUser(player.getUniqueId());
if (user == null) {
try {
user = lp.getUserManager().loadUser(player.getUniqueId()).join();
} catch (Exception ignored) {
user = null;
try { user = lp.getUserManager().loadUser(player.getUniqueId()).join(); } catch (Exception ignored) {}
}
}
if (user != null) {
CachedMetaData meta = user.getCachedData().getMetaData();
if (meta != null) {
String p = meta.getPrefix();
String s = meta.getSuffix();
if (p != null) prefix = p;
if (s != null) suffix = s;
if (p != null) prefix = ChatColor.translateAlternateColorCodes('&', p);
if (s != null) suffix = ChatColor.translateAlternateColorCodes('&', s);
}
}
}
} catch (Throwable ignored) {
}
if (prefix != null && !prefix.isEmpty()) prefix = ChatColor.translateAlternateColorCodes('&', prefix);
if (suffix != null && !suffix.isEmpty()) suffix = ChatColor.translateAlternateColorCodes('&', suffix);
} catch (Throwable ignored) {}
if (prefix == null) prefix = "";
if (suffix == null) suffix = "";
return new String[]{prefix, suffix};
return new String[]{prefix, suffix, playerColor, chatColor};
}
private String stripColor(String s) {
@@ -462,17 +559,16 @@ public class GlobalChat extends Plugin implements Listener {
// Filter einlesen
// ===========================
private void loadFilter() {
File file = new File(getDataFolder(), "filter.yml");
String fileName = "filter.yml";
File file = new File(getDataFolder(), fileName);
if (!file.exists()) {
try {
getDataFolder().mkdirs();
file.createNewFile();
try (PrintWriter out = new PrintWriter(file)) {
out.println("badwords:");
out.println(" - arsch");
out.println(" - hurensohn");
out.println(" - scheiße");
}
} catch (IOException e) {
e.printStackTrace();
}
@@ -521,6 +617,9 @@ public class GlobalChat extends Plugin implements Listener {
}
}
// ===========================
// Staff-Check
// ===========================
private boolean isStaff(ProxiedPlayer p) {
if (p == null) return false;
Boolean reportedOp = playerIsOp.get(p.getUniqueId());
@@ -541,15 +640,18 @@ public class GlobalChat extends Plugin implements Listener {
}
// ===========================
// Commands
// Commands (Inner Classes)
// ===========================
public class ReloadCommand extends Command {
public ReloadCommand() { super("globalreload", "globalchat.reload"); }
@Override
public void execute(CommandSender sender, String[] args) {
loadFilter();
loadServerAliases(); // NEU: Aliase neu laden
sender.sendMessage(new TextComponent("§aFilter und Server-Aliase wurden neu geladen!"));
loadConfigData();
loadServerAliases();
loadGroupFormats();
loadManualRanks(); // NEU
sender.sendMessage(new TextComponent("§aFilter, Server-Aliase, Group-Formate und UUID-Overrides wurden neu geladen!"));
}
}
@@ -582,11 +684,10 @@ public class GlobalChat extends Plugin implements Listener {
}
String msg = String.join(" ", args);
String serverRaw = player.getServer().getInfo().getName();
String serverDisplay = getDisplayName(serverRaw);
String serverName = player.getServer().getInfo().getName();
String serverDisplay = getServerDisplayName(serverName); // NEU: Alias
TextComponent supportMsg = new TextComponent("§7[Support] §b" + player.getName() + " §7vom Server §e" + serverDisplay + " §7: §f" + msg); // NEU: Display
TextComponent supportMsg = new TextComponent("§7[Support] §b" + player.getName() + " §7vom Server §e" + serverDisplay + " §7: §f" + msg);
supportMsg.setHoverEvent(new HoverEvent(Action.SHOW_TEXT, new ComponentBuilder("Klicke, um /reply " + player.getName() + " zu schreiben").create()));
supportMsg.setClickEvent(new net.md_5.bungee.api.chat.ClickEvent(net.md_5.bungee.api.chat.ClickEvent.Action.SUGGEST_COMMAND, "/reply " + player.getName() + " "));
@@ -598,7 +699,7 @@ public class GlobalChat extends Plugin implements Listener {
}
player.sendMessage(new TextComponent("§aDeine Support-Nachricht wurde gesendet."));
logMessage("[Support][" + serverName + "] " + player.getName() + ": " + msg);
logMessage("[Support][" + serverRaw + "] " + player.getName() + ": " + msg);
}
}
@@ -670,4 +771,33 @@ public class GlobalChat extends Plugin implements Listener {
}
}
}
// HELPER: LuckPerms Group via Reflection
private String getLuckPermsGroup(ProxiedPlayer player) {
try {
if (getProxy().getPluginManager().getPlugin("LuckPerms") == null) return null;
Class<?> providerClass = Class.forName("net.luckperms.api.LuckPermsProvider");
Method getMethod = providerClass.getMethod("get");
Object api = getMethod.invoke(null);
if (api != null) {
Method getUserManagerMethod = api.getClass().getMethod("getUserManager");
Object userManager = getUserManagerMethod.invoke(api);
Method loadUserMethod = userManager.getClass().getMethod("loadUser", UUID.class);
Object userFuture = loadUserMethod.invoke(userManager, player.getUniqueId());
Method joinMethod = userFuture.getClass().getMethod("join");
Object user = joinMethod.invoke(userFuture);
if (user != null) {
Method getPrimaryGroupMethod = user.getClass().getMethod("getPrimaryGroup");
return (String) getPrimaryGroupMethod.invoke(user);
}
}
} catch (ClassNotFoundException e) { return null; }
catch (Exception e) { return null; }
return null;
}
}