Compare commits
15 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| bce695829e | |||
| d3796a3ed9 | |||
| eb77726f83 | |||
| 0c3f91fa16 | |||
| 8277758e90 | |||
| 36363f09c2 | |||
| 14b5a08fe2 | |||
| c549df684c | |||
| 422cb9c352 | |||
| e60bff9c6d | |||
| 59944ece4e | |||
| b29f2e2db3 | |||
| f37cff83fc | |||
| 2384178a3a | |||
| 5558b237bb |
217
README.md
217
README.md
@@ -1,105 +1,160 @@
|
|||||||
# StatusAPI
|
# StatusAPI
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
Ein modulares und mächtiges Plugin für BungeeCord, das einen zentralen JSON-Status, ein globales Chat-System, WordPress-Verifizierung und dynamische Server-Navigation bereitstellt.
|
Ein modulares und leistungsstarkes Plugin für **BungeeCord**, das einen zentralen JSON-Status, globalen Chat, WordPress-Verifizierung, Server-Navigation und optionale Sicherheitsmodule bereitstellt.
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
## ⚡ Features
|
## ⚡ Features
|
||||||
|
|
||||||
- **Modulares System**: Aktiviere nur die Features, die du brauchst (Chat, Stats, Verify)
|
- **Modulares System**
|
||||||
- **JSON API**: Liefert Echtzeit-Server-Statistiken (Spieleranzahl, Motd, Versionen) für deine Webseite (Port 9191)
|
Aktiviere nur die Module, die du benötigst (Chat, Navigation, Verify, Security).
|
||||||
- **Global Chat**: Ein einheitlicher Chat über alle Server hinweg mit Badword-Filter und LuckPerms-Support
|
|
||||||
- **Server Navigation**: Automatische Generierung von Befehlen basierend auf deiner Config (z.B. `/survival` statt `/server survival`)
|
- **JSON Status API**
|
||||||
- **WordPress Verify**: Verifiziere Spieler direkt mit deiner WordPress-Seite (CPT Integration)
|
Liefert Echtzeit-Serverdaten für Webseiten oder externe Dienste (Port `9191`).
|
||||||
- **Auto-Updater**: Prüft automatisch auf Updates und lädt diese herunter
|
|
||||||
- **Logging**: Speichert den kompletten Chatverlauf in Dateien
|
- **Global Chat**
|
||||||
|
Serverübergreifender Chat mit Badword-Filter, LuckPerms-Unterstützung und Logging.
|
||||||
|
|
||||||
|
- **Server Navigation**
|
||||||
|
Automatische Generierung von Server-Befehlen (z. B. `/survival` statt `/server survival`).
|
||||||
|
|
||||||
|
- **WordPress Verify**
|
||||||
|
Spieler-Verifizierung über WordPress (Token-basiert, CPT-kompatibel).
|
||||||
|
|
||||||
|
- **CommandBlocker (Security Modul)**
|
||||||
|
Zentrale Blockierung von Commands auf Netzwerkebene inkl. Admin-Bypass.
|
||||||
|
|
||||||
|
- **Auto-Updater**
|
||||||
|
Prüft automatisch auf Updates und lädt diese herunter.
|
||||||
|
|
||||||
|
- **Logging**
|
||||||
|
Persistente Speicherung von Chat-Nachrichten mit automatischer Bereinigung.
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
## 📥 Installation
|
## 📥 Installation
|
||||||
|
|
||||||
1. Lade die aktuellste `StatusAPI.jar` herunter
|
1. Lade die aktuelle `StatusAPI.jar`
|
||||||
2. Lege die Datei in den `plugins` Ordner deiner BungeeCord-Installation
|
2. Lege sie in den `plugins/` Ordner deiner BungeeCord-Installation
|
||||||
3. Starte den Server neu
|
3. Starte den Proxy neu
|
||||||
4. Die Config-Dateien werden automatisch erstellt
|
4. Alle Konfigurationsdateien werden automatisch erstellt
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
## ⚙️ Konfiguration
|
## ⚙️ Konfiguration
|
||||||
|
|
||||||
Alle Haupt-Einstellungen werden in der `plugins/StatusAPI/verify.properties` zentral verwaltet.
|
Alle Hauptmodule werden zentral über
|
||||||
|
`plugins/StatusAPI/verify.properties` gesteuert.
|
||||||
|
|
||||||
### verify.properties
|
### verify.properties
|
||||||
|
|
||||||
Hier konfigurierst du Server-Namen, Farben und die Verbindung zu WordPress.
|
|
||||||
```properties
|
```properties
|
||||||
# ===========================
|
# ===========================
|
||||||
# GLOBALE EINSTELLUNGEN
|
# GLOBALE EINSTELLUNGEN
|
||||||
# ===========================
|
# ===========================
|
||||||
|
|
||||||
# Aktiviert oder deaktiviert das globale Chat-Modul
|
|
||||||
chat.enabled=true
|
chat.enabled=true
|
||||||
|
|
||||||
# Aktiviert die automatischen Server-Switch Befehle (z.B. /survival)
|
|
||||||
navigation.enabled=true
|
navigation.enabled=true
|
||||||
|
commandblocker.enabled=true
|
||||||
|
|
||||||
|
# ===========================
|
||||||
|
# WORDPRESS VERIFY
|
||||||
|
# ===========================
|
||||||
|
|
||||||
# URL deiner WordPress-Installation
|
|
||||||
wp_verify_url=https://deine-wordpress-domain.tld
|
wp_verify_url=https://deine-wordpress-domain.tld
|
||||||
|
|
||||||
# ===========================
|
# ===========================
|
||||||
# SERVER KONFIGURATION
|
# SERVER KONFIGURATION
|
||||||
# ===========================
|
# ===========================
|
||||||
|
|
||||||
# Der Key-Name (z.B. bungee-server-1) MUSS exakt mit dem
|
|
||||||
# Namen in deiner BungeeCord config.yml übereinstimmen!
|
|
||||||
#
|
|
||||||
# - server.<Name>=<Anzeigename> -> Wird im Chat und als Befehl genutzt
|
|
||||||
# - server.<Name>.id=<ID> -> WordPress Server ID
|
|
||||||
# - server.<Name>.secret=<Key> -> WordPress Secret
|
|
||||||
|
|
||||||
# Beispiel: Server mit Namen "Lobby"
|
|
||||||
server.lobby=&bLobby
|
server.lobby=&bLobby
|
||||||
server.lobby.id=1606
|
server.lobby.id=1606
|
||||||
server.lobby.secret=DeinSecretHier
|
server.lobby.secret=DeinSecretHier
|
||||||
|
|
||||||
# Beispiel: Server mit Namen "bungee-server-1" (Name aus BungeeConfig)
|
server.survival=&aSurvival
|
||||||
server.bungee-server-1=&aSurvival
|
server.survival.id=2
|
||||||
server.bungee-server-1.id=2
|
server.survival.secret=GeheimesWortFuerSurvival
|
||||||
server.bungee-server-1.secret=GeheimesWortFuerSurvival
|
```
|
||||||
|
## 🔒 CommandBlocker Modul
|
||||||
|
|
||||||
# Beispiel: SkyBlock
|
Das **CommandBlockerModule** blockiert definierte Commands **netzwerkweit**, bevor sie an Backend-Server weitergeleitet werden.
|
||||||
server.skyblock=&dSkyBlock
|
|
||||||
server.skyblock.id=3
|
### Eigenschaften
|
||||||
server.skyblock.secret=GeheimesWortFuerSkyBlock
|
|
||||||
|
- Blockierung auf **BungeeCord-Ebene**
|
||||||
|
- **YAML-basierte** Konfiguration
|
||||||
|
- **Live-Verwaltung** per Command
|
||||||
|
- **Bypass-Permission** für Admins
|
||||||
|
- **Keine Abhängigkeit** von anderen Modulen
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
### Konfigurationsdatei
|
||||||
|
|
||||||
|
**Datei:**
|
||||||
|
`plugins/StatusAPI/blocked-commands.yml`
|
||||||
|
|
||||||
|
```yaml
|
||||||
|
blocked:
|
||||||
|
- plugins
|
||||||
|
- pl
|
||||||
|
- version
|
||||||
|
- about
|
||||||
```
|
```
|
||||||
|
|
||||||
### Weitere Dateien
|
Änderungen können entweder **manuell** oder **per Befehl** vorgenommen werden.
|
||||||
|
|
||||||
- **filter.yml**: Hier trägst du Badwords ein, die im Chat zensiert werden sollen
|
---
|
||||||
- **welcome.yml**: Hier definierst du Willkommensnachrichten für neue Spieler (nur sichtbar, wenn Welcome-Events aktiviert sind)
|
|
||||||
- **plugins/StatusAPI/logs/**: Hier werden alle Chatnachrichten als Textdateien gespeichert (Löschung nach 7 Tagen)
|
|
||||||
|
|
||||||
## 💻 Befehle
|
## Befehle
|
||||||
|
|
||||||
| Befehl | Beschreibung | Permission |
|
| Befehl | Beschreibung | Permission |
|
||||||
|--------|--------------|------------|
|
|------|-------------|------------|
|
||||||
| `/verify <token>` | Verifiziert den Spieler mit der WordPress-Seite | - |
|
| `/cb add <command>` | Blockiert einen Command | `commandblocker.admin` |
|
||||||
| `/survival` / `/lobby` | Führt dich auf den entsprechenden Server um (wird dynamisch erstellt) | - |
|
| `/cb remove <command>` | Entfernt einen Block | `commandblocker.admin` |
|
||||||
| `/globalmute` | Aktiviert oder deaktiviert den globalen Chat | `globalchat.mute` |
|
| `/cb list` | Zeigt alle blockierten Commands | `commandblocker.admin` |
|
||||||
| `/globalreload` | Lädt Filter und Konfigurationen neu | `globalchat.reload` |
|
| `/cb reload` | Lädt die YAML neu | `commandblocker.admin` |
|
||||||
| `/clearchat, cc` | Löscht den Chatverlauf | `globalchat.clear` |
|
|
||||||
| `/togglechat` | schaltet für den Spieler den Chat ab | - |
|
|
||||||
| `/support <msg>` | Sendet eine Nachricht an das Online-Team | - |
|
|
||||||
| `/reply <msg>` | Antwortet auf eine Support-Anfrage | - |
|
|
||||||
| `/info` | Zeigt Plugin-Informationen an | - |
|
|
||||||
|
|
||||||
## 🌐 JSON API (Status)
|
---
|
||||||
|
|
||||||
Die API läuft unter `http://DEINE_IP:9191/`.
|
## Bypass
|
||||||
|
|
||||||
### Beispiel Request
|
Spieler mit folgender Permission umgehen den CommandBlocker vollständig:
|
||||||
```bash
|
|
||||||
curl http://127.0.0.1:9191/
|
```yaml
|
||||||
|
commandblocker.bypass
|
||||||
```
|
```
|
||||||
|
|
||||||
### Beispiel Antwort
|
---
|
||||||
|
|
||||||
|
## 💻 Allgemeine Befehle
|
||||||
|
|
||||||
|
| Befehl | Beschreibung | Permission |
|
||||||
|
|------|-------------|------------|
|
||||||
|
| `/verify <token>` | WordPress-Verifizierung | - |
|
||||||
|
| `/globalmute` | Globalen Chat sperren | `globalchat.mute` |
|
||||||
|
| `/globalreload` | Config neu laden | `globalchat.reload` |
|
||||||
|
| `/clearchat`, `/cc` | Chat leeren | `globalchat.clear` |
|
||||||
|
| `/togglechat` | Chat lokal deaktivieren | - |
|
||||||
|
| `/support <msg>` | Support-Anfrage senden | - |
|
||||||
|
| `/reply <msg>` | Auf Support antworten | - |
|
||||||
|
| `/info` | Plugin-Infos anzeigen | - |
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## 🌐 JSON API
|
||||||
|
|
||||||
|
**Endpoint:**
|
||||||
|
```yaml
|
||||||
|
http://DEINE_IP:9191/
|
||||||
|
```
|
||||||
|
|
||||||
|
|
||||||
|
### Beispiel-Antwort
|
||||||
|
|
||||||
```json
|
```json
|
||||||
{
|
{
|
||||||
"online": true,
|
"online": true,
|
||||||
@@ -117,28 +172,54 @@ curl http://127.0.0.1:9191/
|
|||||||
}
|
}
|
||||||
```
|
```
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
## 🛠️ Für Entwickler
|
## 🛠️ Für Entwickler
|
||||||
|
|
||||||
Die StatusAPI ist modular aufgebaut. Du kannst eigene Module erstellen, ohne den Core-Code zu berühren.
|
Die **StatusAPI** ist vollständig modular aufgebaut und erlaubt die einfache Erweiterung um eigene Module, ohne den Core-Code zu verändern.
|
||||||
|
|
||||||
### Beispiel
|
---
|
||||||
|
|
||||||
|
### Eigenes Modul erstellen
|
||||||
|
|
||||||
|
1. Klasse implementiert das `Module`-Interface
|
||||||
|
2. Optional zusätzlich `Listener` implementieren
|
||||||
|
3. Registrierung im Core (z. B. im ModuleManager):
|
||||||
|
|
||||||
1. Erstelle eine Klasse, die `Module` implementiert
|
|
||||||
2. Registriere sie in der StatusAPI Hauptdatei:
|
|
||||||
```java
|
```java
|
||||||
moduleManager.registerModule(new MeinModul());
|
moduleManager.registerModule(new MeinModul());
|
||||||
```
|
```
|
||||||
|
### Modul-Lifecycle
|
||||||
|
|
||||||
3. Dein Modul hat Zugriff auf `onEnable` und `onDisable` des Haupt-Plugins
|
Jedes Modul besitzt Zugriff auf folgende Lifecycle-Methoden:
|
||||||
|
|
||||||
## 📝 Permissions
|
- `onEnable(Plugin plugin)`
|
||||||
|
- `onDisable(Plugin plugin)`
|
||||||
|
|
||||||
- `globalchat.mute` - Erlaubt das Stummschalten des Chats
|
Diese Methoden werden automatisch beim **Starten** bzw. **Stoppen** des Proxys aufgerufen.
|
||||||
- `globalchat.bypass` - Erlaubt das Schreiben, auch wenn der Chat gemuted ist
|
|
||||||
- `globalchat.reload` - Erlaubt das Neuladen der Konfiguration
|
---
|
||||||
- `globalchat.clear` - Löscht den Kompletten Chatverlauf
|
|
||||||
|
## 📝 Permissions Übersicht
|
||||||
|
|
||||||
|
- `globalchat.mute`
|
||||||
|
- `globalchat.bypass`
|
||||||
|
- `globalchat.reload`
|
||||||
|
- `globalchat.clear`
|
||||||
|
- `commandblocker.admin`
|
||||||
|
- `commandblocker.bypass`
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
## 🤝 Credits
|
## 🤝 Credits
|
||||||
|
|
||||||
Entwickelt von **M_Viper**.
|
---
|
||||||
Unterstützt durch BungeeCord und LuckPerms Community.
|
|
||||||
|
## 📜 Lizenz & Nutzung
|
||||||
|
|
||||||
|
Dieses Projekt sowie alle enthaltenen Module, Quelltexte und Ressourcen dürfen **nicht verändert, kopiert oder weiterverbreitet** werden.
|
||||||
|
|
||||||
|
Jegliche Nutzung, Modifikation oder Weitergabe – ganz oder teilweise – ist **ausschließlich mit vorheriger schriftlicher Genehmigung** des Entwicklers gestattet.
|
||||||
|
|
||||||
|
© Entwickelt von **M_Viper**. Alle Rechte vorbehalten.
|
||||||
|
|
||||||
|
|||||||
2
pom.xml
2
pom.xml
@@ -7,7 +7,7 @@
|
|||||||
|
|
||||||
<groupId>net.viper.bungee</groupId>
|
<groupId>net.viper.bungee</groupId>
|
||||||
<artifactId>StatusAPI</artifactId>
|
<artifactId>StatusAPI</artifactId>
|
||||||
<version>4.0.3</version>
|
<version>4.0.6</version>
|
||||||
<packaging>jar</packaging>
|
<packaging>jar</packaging>
|
||||||
|
|
||||||
<name>StatusAPI</name>
|
<name>StatusAPI</name>
|
||||||
|
|||||||
@@ -10,63 +10,68 @@ import net.viper.status.stats.StatsModule;
|
|||||||
import net.viper.status.modules.verify.VerifyModule;
|
import net.viper.status.modules.verify.VerifyModule;
|
||||||
import net.viper.status.modules.globalchat.GlobalChatModule;
|
import net.viper.status.modules.globalchat.GlobalChatModule;
|
||||||
import net.viper.status.modules.navigation.NavigationModule;
|
import net.viper.status.modules.navigation.NavigationModule;
|
||||||
|
import net.viper.status.modules.commandblocker.CommandBlockerModule;
|
||||||
|
import net.viper.status.modules.broadcast.BroadcastModule;
|
||||||
|
|
||||||
import java.io.BufferedReader;
|
import java.io.BufferedReader;
|
||||||
import java.io.File;
|
import java.io.File;
|
||||||
|
import java.io.FileInputStream;
|
||||||
|
import java.io.FileOutputStream;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.io.InputStreamReader;
|
import java.io.InputStreamReader;
|
||||||
import java.io.OutputStream;
|
import java.io.OutputStream;
|
||||||
|
import java.io.OutputStreamWriter;
|
||||||
import java.io.PrintWriter;
|
import java.io.PrintWriter;
|
||||||
|
import java.io.StringReader;
|
||||||
import java.net.ServerSocket;
|
import java.net.ServerSocket;
|
||||||
import java.net.Socket;
|
import java.net.Socket;
|
||||||
|
import java.nio.charset.StandardCharsets;
|
||||||
|
import java.nio.file.Files;
|
||||||
import java.util.*;
|
import java.util.*;
|
||||||
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.TimeUnit;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* StatusAPI - zentraler Bungee HTTP-Status- und Broadcast-Endpunkt
|
||||||
|
*/
|
||||||
public class StatusAPI extends Plugin implements Runnable {
|
public class StatusAPI extends Plugin implements Runnable {
|
||||||
|
|
||||||
private Thread thread;
|
private Thread thread;
|
||||||
private int port = 9191;
|
private int port = 9191;
|
||||||
|
|
||||||
// Das neue Modul-System
|
|
||||||
private ModuleManager moduleManager;
|
private ModuleManager moduleManager;
|
||||||
|
|
||||||
// Alte Komponenten (UpdateChecker/FileDownloader bleiben hier, da sie Core-Updates steuern)
|
|
||||||
private UpdateChecker updateChecker;
|
private UpdateChecker updateChecker;
|
||||||
private FileDownloader fileDownloader;
|
private FileDownloader fileDownloader;
|
||||||
|
private Properties verifyProperties;
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void onEnable() {
|
public void onEnable() {
|
||||||
getLogger().info("StatusAPI Core wird initialisiert...");
|
getLogger().info("StatusAPI Core wird initialisiert...");
|
||||||
|
|
||||||
// 1. Ordner sicherstellen
|
|
||||||
if (!getDataFolder().exists()) {
|
if (!getDataFolder().exists()) {
|
||||||
getDataFolder().mkdirs();
|
getDataFolder().mkdirs();
|
||||||
}
|
}
|
||||||
|
|
||||||
// 2. Modul-System starten
|
// Config mergen/updaten
|
||||||
|
mergeVerifyConfig();
|
||||||
|
|
||||||
moduleManager = new ModuleManager();
|
moduleManager = new ModuleManager();
|
||||||
|
|
||||||
// 3. MODULE REGISTRIEREN (Hier erweiterst du die API in Zukunft!)
|
// Module registrieren
|
||||||
// Um ein neues Feature hinzuzufügen, erstelle eine Klasse, die 'Module' implementiert
|
moduleManager.registerModule(new StatsModule());
|
||||||
// und füge hier eine Zeile hinzu: moduleManager.registerModule(new MeinNeuesModul());
|
moduleManager.registerModule(new VerifyModule());
|
||||||
|
moduleManager.registerModule(new GlobalChatModule());
|
||||||
|
moduleManager.registerModule(new NavigationModule());
|
||||||
|
moduleManager.registerModule(new BroadcastModule());
|
||||||
|
moduleManager.registerModule(new CommandBlockerModule());
|
||||||
|
|
||||||
moduleManager.registerModule(new StatsModule()); // Statistik System laden
|
|
||||||
|
|
||||||
moduleManager.registerModule(new VerifyModule()); // Verify Modul
|
|
||||||
|
|
||||||
moduleManager.registerModule(new GlobalChatModule()); // GlobalChat
|
|
||||||
|
|
||||||
moduleManager.registerModule(new NavigationModule()); //Server Switcher
|
|
||||||
|
|
||||||
// 4. Alle Module aktivieren
|
|
||||||
moduleManager.enableAll(this);
|
moduleManager.enableAll(this);
|
||||||
|
|
||||||
// 5. WebServer Thread starten
|
// WebServer starten
|
||||||
getLogger().info("Starte Web-Server auf Port " + port + "...");
|
getLogger().info("Starte Web-Server auf Port " + port + "...");
|
||||||
thread = new Thread(this, "StatusAPI-HTTP-Server");
|
thread = new Thread(this, "StatusAPI-HTTP-Server");
|
||||||
thread.start();
|
thread.start();
|
||||||
|
|
||||||
// 6. Update System Initialisieren
|
// Update System
|
||||||
String currentVersion = getDescription() != null ? getDescription().getVersion() : "0.0.0";
|
String currentVersion = getDescription() != null ? getDescription().getVersion() : "0.0.0";
|
||||||
updateChecker = new UpdateChecker(this, currentVersion, 6);
|
updateChecker = new UpdateChecker(this, currentVersion, 6);
|
||||||
fileDownloader = new FileDownloader(this);
|
fileDownloader = new FileDownloader(this);
|
||||||
@@ -74,16 +79,13 @@ public class StatusAPI extends Plugin implements Runnable {
|
|||||||
File pluginFile = getFile();
|
File pluginFile = getFile();
|
||||||
File backupFile = new File(pluginFile.getParentFile(), "StatusAPI.jar.bak");
|
File backupFile = new File(pluginFile.getParentFile(), "StatusAPI.jar.bak");
|
||||||
|
|
||||||
// Backup Cleanup
|
|
||||||
if (backupFile.exists()) {
|
if (backupFile.exists()) {
|
||||||
ProxyServer.getInstance().getScheduler().schedule(this, () -> {
|
ProxyServer.getInstance().getScheduler().schedule(this, () -> {
|
||||||
if (backupFile.exists()) backupFile.delete();
|
if (backupFile.exists()) backupFile.delete();
|
||||||
}, 1, TimeUnit.MINUTES);
|
},1, TimeUnit.MINUTES);
|
||||||
}
|
}
|
||||||
|
|
||||||
// Sofortiger Check
|
|
||||||
checkAndMaybeUpdate();
|
checkAndMaybeUpdate();
|
||||||
// Regelmäßiger Check
|
|
||||||
ProxyServer.getInstance().getScheduler().schedule(this, this::checkAndMaybeUpdate, 6, 6, TimeUnit.HOURS);
|
ProxyServer.getInstance().getScheduler().schedule(this, this::checkAndMaybeUpdate, 6, 6, TimeUnit.HOURS);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -101,7 +103,225 @@ public class StatusAPI extends Plugin implements Runnable {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// --- Update Logik (unverändert) ---
|
/**
|
||||||
|
* Hilfsmethode um Property-Werte zu bereinigen (unescape).
|
||||||
|
* Entfernt z.B. den Backslash vor URLs wie https\://
|
||||||
|
*/
|
||||||
|
private String unescapePropertiesString(String input) {
|
||||||
|
if (input == null) return null;
|
||||||
|
try {
|
||||||
|
Properties p = new Properties();
|
||||||
|
p.load(new StringReader("dummy=" + input));
|
||||||
|
return p.getProperty("dummy");
|
||||||
|
} catch (IOException e) {
|
||||||
|
return input; // Fallback, falls Parsing fehlschlägt
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// --- MERGE LOGIK ---
|
||||||
|
private void mergeVerifyConfig() {
|
||||||
|
try {
|
||||||
|
File file = new File(getDataFolder(), "verify.properties");
|
||||||
|
|
||||||
|
// 1. Das exakte Template definieren
|
||||||
|
List<String> templateLines = Arrays.asList(
|
||||||
|
"# _____ __ __ ___ ____ ____",
|
||||||
|
"# / ___// /_____ _/ /___ _______/ | / __ \\/ _/",
|
||||||
|
"# \\__ \\/ __/ __ `/ __/ / / / ___/ /| | / /_/ // / ",
|
||||||
|
"# ___/ / /_/ /_/ / /_/ /_/ (__ ) ___ |/ ____// / ",
|
||||||
|
"# /____/\\__/\\__,_/\\__/\\__,_/____/_/ |_/_/ /___/ ",
|
||||||
|
" ",
|
||||||
|
"# ===========================",
|
||||||
|
"# GLOBALCHAT AKTIVIERUNG",
|
||||||
|
"# ===========================",
|
||||||
|
"chat.enabled=false",
|
||||||
|
"",
|
||||||
|
"# ------------------------------",
|
||||||
|
"# Broadcast",
|
||||||
|
"# ------------------------------",
|
||||||
|
"",
|
||||||
|
"broadcast.enabled=false",
|
||||||
|
"broadcast.prefix=[Broadcast]",
|
||||||
|
"broadcast.prefix-color=&c",
|
||||||
|
"broadcast.message-color=&f",
|
||||||
|
"broadcast.format=%prefixColored% %messageColored%",
|
||||||
|
"# broadcast.format kann angepasst werden; nutze Platzhalter: %name%, %prefix%, %prefixColored%, %message%, %messageColored%, %type%",
|
||||||
|
"",
|
||||||
|
"# ===========================",
|
||||||
|
"# NAVIGATION / SERVER SWITCHER",
|
||||||
|
"# ===========================",
|
||||||
|
"# Hier kannst du das interne Navigationssystem aktivieren/deaktivieren.",
|
||||||
|
"# Wenn aktiviert, erstellt das Plugin automatisch Befehle basierend auf den Servernamen (z.B. /lobby, /survival).",
|
||||||
|
"navigation.enabled=false",
|
||||||
|
"",
|
||||||
|
"# ===========================",
|
||||||
|
"# WORDPRESS / VERIFY EINSTELLUNGEN",
|
||||||
|
"# ===========================",
|
||||||
|
"wp_verify_url=https://deine-wp-domain.tld",
|
||||||
|
"",
|
||||||
|
"# ===========================",
|
||||||
|
"# SERVER KONFIGURATION",
|
||||||
|
"# ===========================",
|
||||||
|
"# Hier legst du für jeden Server alles fest:",
|
||||||
|
"# 1. Den Anzeigenamen für den Chat (z.B. &bLobby)",
|
||||||
|
"# 2. Die Server ID für WordPress (z.B. id=1)",
|
||||||
|
"# 3. Das Secret für WordPress (z.B. secret=...)",
|
||||||
|
"",
|
||||||
|
"# Server 1: Lobby",
|
||||||
|
"server.lobby=&bLobby",
|
||||||
|
"server.lobby.id=1",
|
||||||
|
"server.lobby.secret=GeheimesWortFuerLobby123",
|
||||||
|
"",
|
||||||
|
"# Server 2: Survival",
|
||||||
|
"server.survival=&aSurvival",
|
||||||
|
"server.survival.id=2",
|
||||||
|
"server.survival.secret=GeheimesWortFuerSurvival456",
|
||||||
|
"",
|
||||||
|
"# Server 3: SkyBlock",
|
||||||
|
"server.skyblock=&dSkyBlock",
|
||||||
|
"server.skyblock.id=3",
|
||||||
|
"server.skyblock.secret=GeheimesWortFuerSkyBlock789",
|
||||||
|
"",
|
||||||
|
"# ===========================",
|
||||||
|
"# Manuelle Ränge (Overrides)",
|
||||||
|
"# ===========================",
|
||||||
|
"# Syntax: override.<Spieler-UUID> = <Gruppenname>",
|
||||||
|
"# WICHTIG: Die Gruppe (z.B. Owner) muss unten bei groupformat definiert sein!",
|
||||||
|
"",
|
||||||
|
"# Beispiel: Deinen UUID hier einfügen",
|
||||||
|
"override.uuid-hier-einfügen = Owner",
|
||||||
|
"override.uuid-hier-einfügen-2 = Admin",
|
||||||
|
"override.uuid-hier-einfügen-3 = Developer",
|
||||||
|
"",
|
||||||
|
"# ===========================",
|
||||||
|
"# Chat-Formate für Gruppen",
|
||||||
|
"# ===========================",
|
||||||
|
"",
|
||||||
|
"# Der Name hinter dem Punkt (z.B. Owner) muss exakt mit der LuckPerms Gruppe übereinstimmen.",
|
||||||
|
"# Nutze & für Farbcodes.",
|
||||||
|
"",
|
||||||
|
"# Ränge mit neuer Syntax: Rank || Spielerfarbe || Chatfarbe",
|
||||||
|
"# Beispiel: Rot (Rang) || Blau (Name) || Lila (Chat)",
|
||||||
|
"groupformat.owner=&c[Owner] || &b || &d",
|
||||||
|
"groupformat.admin=&4[Admin] || &9 || &c",
|
||||||
|
"groupformat.developer=&b[Dev] || &3 || &a",
|
||||||
|
"groupformat.premium=&6[Premium] || &e || &7",
|
||||||
|
"groupformat.spieler=&f[Spieler] || &7 || &8",
|
||||||
|
"",
|
||||||
|
"# ===========================",
|
||||||
|
"# COMMAND BLOCKER",
|
||||||
|
"# ===========================",
|
||||||
|
"commandblocker.enabled=true",
|
||||||
|
"commandblocker.bypass.permission=commandblocker.bypass"
|
||||||
|
);
|
||||||
|
|
||||||
|
// 2. Existierende Werte einlesen
|
||||||
|
Map<String, String> existingValues = new HashMap<>();
|
||||||
|
// Liste für Override-Keys, die nicht im Template stehen
|
||||||
|
List<Map.Entry<String, String>> pendingOverrides = new ArrayList<>();
|
||||||
|
|
||||||
|
if (file.exists()) {
|
||||||
|
List<String> existing = Files.readAllLines(file.toPath(), StandardCharsets.UTF_8);
|
||||||
|
for (String line : existing) {
|
||||||
|
String trimmed = line.trim();
|
||||||
|
if (!trimmed.isEmpty() && !trimmed.startsWith("#") && trimmed.contains("=")) {
|
||||||
|
int idx = trimmed.indexOf('=');
|
||||||
|
String key = trimmed.substring(0, idx).trim();
|
||||||
|
String val = trimmed.substring(idx + 1).trim();
|
||||||
|
// Wert speichern, Escaping entfernen für sauberen Output
|
||||||
|
existingValues.put(key, unescapePropertiesString(val));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// 3. Alle Override-Keys aus der alten Config sammeln
|
||||||
|
for (Map.Entry<String, String> entry : existingValues.entrySet()) {
|
||||||
|
if (entry.getKey().startsWith("override.")) {
|
||||||
|
pendingOverrides.add(entry);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// 4. Datei Zeile für Zeile basierend auf Template schreiben
|
||||||
|
List<String> outputLines = new ArrayList<>();
|
||||||
|
Set<String> usedKeys = new HashSet<>();
|
||||||
|
|
||||||
|
for (int i = 0; i < templateLines.size(); i++) {
|
||||||
|
String line = templateLines.get(i);
|
||||||
|
String trimmed = line.trim();
|
||||||
|
|
||||||
|
// PRÜFUNG: Wenn wir am Anfang des nächsten Abschnitts sind ("Chat-Formate")
|
||||||
|
// Fügen wir die fehlenden Overrides VORHER ein.
|
||||||
|
if (trimmed.startsWith("#") && trimmed.contains("====")) {
|
||||||
|
if (i + 1 < templateLines.size()) {
|
||||||
|
String nextTrimmed = templateLines.get(i + 1).trim();
|
||||||
|
// Wenn wir kurz vor "Chat-Formate" stehen und noch Overrides offen sind -> Einfügen
|
||||||
|
if (nextTrimmed.contains("Chat-Formate") && !pendingOverrides.isEmpty()) {
|
||||||
|
outputLines.add("");
|
||||||
|
for (Map.Entry<String, String> ov : pendingOverrides) {
|
||||||
|
if (!usedKeys.contains(ov.getKey())) {
|
||||||
|
// Bereinigten Wert schreiben
|
||||||
|
outputLines.add(ov.getKey() + "=" + ov.getValue());
|
||||||
|
usedKeys.add(ov.getKey());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
pendingOverrides.clear();
|
||||||
|
outputLines.add("");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// LOGIK: Template Zeile verarbeiten
|
||||||
|
if (!trimmed.startsWith("#") && !trimmed.isEmpty() && trimmed.contains("=")) {
|
||||||
|
String[] parts = trimmed.split("=", 2);
|
||||||
|
String key = parts[0].trim();
|
||||||
|
|
||||||
|
if (existingValues.containsKey(key)) {
|
||||||
|
// Wert aus alter Config übernehmen (bereinigt)
|
||||||
|
String cleanVal = unescapePropertiesString(existingValues.get(key));
|
||||||
|
outputLines.add(key + "=" + cleanVal);
|
||||||
|
usedKeys.add(key);
|
||||||
|
|
||||||
|
pendingOverrides.removeIf(e -> e.getKey().equals(key));
|
||||||
|
} else {
|
||||||
|
// Standardwert aus Template übernehmen
|
||||||
|
outputLines.add(line);
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
outputLines.add(line);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Falls noch was übrig ist, am Ende anhängen
|
||||||
|
if (!pendingOverrides.isEmpty()) {
|
||||||
|
outputLines.add("");
|
||||||
|
for (Map.Entry<String, String> ov : pendingOverrides) {
|
||||||
|
outputLines.add(ov.getKey() + "=" + ov.getValue());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// 5. Datei schreiben
|
||||||
|
Files.write(file.toPath(), outputLines, StandardCharsets.UTF_8);
|
||||||
|
|
||||||
|
// 6. Properties laden
|
||||||
|
verifyProperties = new Properties();
|
||||||
|
try (FileInputStream fis = new FileInputStream(file)) {
|
||||||
|
verifyProperties.load(fis);
|
||||||
|
}
|
||||||
|
|
||||||
|
getLogger().info("verify.properties erfolgreich aktualisiert.");
|
||||||
|
|
||||||
|
} catch (IOException e) {
|
||||||
|
getLogger().severe("Fehler beim Merge der verify.properties: " + e.getMessage());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public Properties getVerifyProperties() {
|
||||||
|
synchronized (this) {
|
||||||
|
return verifyProperties;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// --- Update Logik ---
|
||||||
private void checkAndMaybeUpdate() {
|
private void checkAndMaybeUpdate() {
|
||||||
try {
|
try {
|
||||||
updateChecker.checkNow();
|
updateChecker.checkNow();
|
||||||
@@ -165,7 +385,6 @@ public class StatusAPI extends Plugin implements Runnable {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// --- WebServer & JSON ---
|
// --- WebServer & JSON ---
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void run() {
|
public void run() {
|
||||||
try (ServerSocket serverSocket = new ServerSocket(port)) {
|
try (ServerSocket serverSocket = new ServerSocket(port)) {
|
||||||
@@ -189,11 +408,160 @@ public class StatusAPI extends Plugin implements Runnable {
|
|||||||
OutputStream out = clientSocket.getOutputStream()) {
|
OutputStream out = clientSocket.getOutputStream()) {
|
||||||
|
|
||||||
String inputLine = in.readLine();
|
String inputLine = in.readLine();
|
||||||
|
if (inputLine == null) return;
|
||||||
|
|
||||||
|
String[] reqParts = inputLine.split(" ");
|
||||||
|
if (reqParts.length < 2) return;
|
||||||
|
String method = reqParts[0].trim();
|
||||||
|
String path = reqParts[1].trim();
|
||||||
|
|
||||||
|
Map<String, String> headers = new HashMap<>();
|
||||||
|
String line;
|
||||||
|
while ((line = in.readLine()) != null && !line.isEmpty()) {
|
||||||
|
int idx = line.indexOf(':');
|
||||||
|
if (idx > 0) {
|
||||||
|
String key = line.substring(0, idx).trim().toLowerCase(Locale.ROOT);
|
||||||
|
String val = line.substring(idx + 1).trim();
|
||||||
|
headers.put(key, val);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// --- POST /broadcast/cancel ---
|
||||||
|
if ("POST".equalsIgnoreCase(method) && (path.equalsIgnoreCase("/broadcast/cancel") || path.equalsIgnoreCase("/cancel"))) {
|
||||||
|
int contentLength = 0;
|
||||||
|
if (headers.containsKey("content-length")) {
|
||||||
|
try { contentLength = Integer.parseInt(headers.get("content-length")); } catch (NumberFormatException ignored) {}
|
||||||
|
}
|
||||||
|
char[] bodyChars = new char[Math.max(0, contentLength)];
|
||||||
|
if (contentLength > 0) {
|
||||||
|
int read = 0;
|
||||||
|
while (read < contentLength) {
|
||||||
|
int r = in.read(bodyChars, read, contentLength - read);
|
||||||
|
if (r == -1) break;
|
||||||
|
read += r;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
String body = new String(bodyChars);
|
||||||
|
String clientScheduleId = extractJsonString(body, "clientScheduleId");
|
||||||
|
if (clientScheduleId == null || clientScheduleId.isEmpty()) {
|
||||||
|
sendHttpResponse(out, "{\"success\":false,\"error\":\"missing_clientScheduleId\"}", 400);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
Object mod = moduleManager.getModule("BroadcastModule");
|
||||||
|
if (mod instanceof BroadcastModule) {
|
||||||
|
boolean ok = ((BroadcastModule) mod).cancelScheduled(clientScheduleId);
|
||||||
|
if (ok) sendHttpResponse(out, "{\"success\":true}", 200);
|
||||||
|
else sendHttpResponse(out, "{\"success\":false,\"error\":\"not_found\"}", 404);
|
||||||
|
return;
|
||||||
|
} else {
|
||||||
|
sendHttpResponse(out, "{\"success\":false,\"error\":\"no_broadcast_module\"}", 500);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// --- POST /broadcast ---
|
||||||
|
if ("POST".equalsIgnoreCase(method) && ("/broadcast".equalsIgnoreCase(path) || "/".equals(path) || path.isEmpty())) {
|
||||||
|
int contentLength = 0;
|
||||||
|
if (headers.containsKey("content-length")) {
|
||||||
|
try { contentLength = Integer.parseInt(headers.get("content-length")); } catch (NumberFormatException ignored) {}
|
||||||
|
}
|
||||||
|
|
||||||
|
char[] bodyChars = new char[Math.max(0, contentLength)];
|
||||||
|
if (contentLength > 0) {
|
||||||
|
int read = 0;
|
||||||
|
while (read < contentLength) {
|
||||||
|
int r = in.read(bodyChars, read, contentLength - read);
|
||||||
|
if (r == -1) break;
|
||||||
|
read += r;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
String body = new String(bodyChars);
|
||||||
|
|
||||||
|
String apiKeyHeader = headers.getOrDefault("x-api-key", headers.getOrDefault("x-apikey", ""));
|
||||||
|
|
||||||
|
String message = extractJsonString(body, "message");
|
||||||
|
String type = extractJsonString(body, "type");
|
||||||
|
String prefix = extractJsonString(body, "prefix");
|
||||||
|
String prefixColor = extractJsonString(body, "prefixColor");
|
||||||
|
String bracketColor = extractJsonString(body, "bracketColor");
|
||||||
|
String messageColor = extractJsonString(body, "messageColor");
|
||||||
|
String sourceName = extractJsonString(body, "source");
|
||||||
|
String scheduleTimeStr = extractJsonString(body, "scheduleTime");
|
||||||
|
String recur = extractJsonString(body, "recur");
|
||||||
|
String clientScheduleId = extractJsonString(body, "clientScheduleId");
|
||||||
|
|
||||||
|
if (sourceName == null || sourceName.isEmpty()) sourceName = "PulseCast";
|
||||||
|
if (type == null || type.isEmpty()) type = "global";
|
||||||
|
|
||||||
|
if (scheduleTimeStr != null && !scheduleTimeStr.trim().isEmpty()) {
|
||||||
|
long scheduleMillis = 0L;
|
||||||
|
try {
|
||||||
|
scheduleMillis = Long.parseLong(scheduleTimeStr.trim());
|
||||||
|
if (scheduleMillis < 1_000_000_000_000L) scheduleMillis = scheduleMillis * 1000L;
|
||||||
|
} catch (NumberFormatException ignored) {
|
||||||
|
try {
|
||||||
|
double d = Double.parseDouble(scheduleTimeStr.trim());
|
||||||
|
long v = (long) d;
|
||||||
|
if (v < 1_000_000_000_000L) v = v * 1000L;
|
||||||
|
scheduleMillis = v;
|
||||||
|
} catch (Exception ex) {
|
||||||
|
sendHttpResponse(out, "{\"success\":false,\"error\":\"bad_scheduleTime\"}", 400);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
Object mod = moduleManager.getModule("BroadcastModule");
|
||||||
|
if (mod instanceof BroadcastModule) {
|
||||||
|
BroadcastModule bm = (BroadcastModule) mod;
|
||||||
|
boolean ok = bm.scheduleBroadcast(scheduleMillis, sourceName, message, type, apiKeyHeader,
|
||||||
|
prefix, prefixColor, bracketColor, messageColor, (recur == null ? "none" : recur), (clientScheduleId == null ? null : clientScheduleId));
|
||||||
|
|
||||||
|
if (ok) sendHttpResponse(out, "{\"success\":true}", 200);
|
||||||
|
else sendHttpResponse(out, "{\"success\":false,\"error\":\"rejected\"}", 403);
|
||||||
|
return;
|
||||||
|
} else {
|
||||||
|
sendHttpResponse(out, "{\"success\":false,\"error\":\"no_broadcast_module\"}", 500);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
} catch (Throwable t) {
|
||||||
|
t.printStackTrace();
|
||||||
|
sendHttpResponse(out, "{\"success\":false,\"error\":\"internal\"}", 500);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (message == null || message.isEmpty()) {
|
||||||
|
String resp = "{\"success\":false,\"error\":\"missing_message\"}";
|
||||||
|
sendHttpResponse(out, resp, 400);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
Object mod = moduleManager.getModule("BroadcastModule");
|
||||||
|
if (mod instanceof BroadcastModule) {
|
||||||
|
BroadcastModule bm = (BroadcastModule) mod;
|
||||||
|
boolean ok = bm.handleBroadcast(sourceName, message, type, apiKeyHeader, prefix, prefixColor, bracketColor, messageColor);
|
||||||
|
|
||||||
|
if (ok) sendHttpResponse(out, "{\"success\":true}", 200);
|
||||||
|
else sendHttpResponse(out, "{\"success\":false,\"error\":\"rejected\"}", 403);
|
||||||
|
return;
|
||||||
|
} else {
|
||||||
|
sendHttpResponse(out, "{\"success\":false,\"error\":\"no_broadcast_module\"}", 500);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
} catch (Throwable t) {
|
||||||
|
t.printStackTrace();
|
||||||
|
sendHttpResponse(out, "{\"success\":false,\"error\":\"internal\"}", 500);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// --- GET Handler ---
|
||||||
if (inputLine != null && inputLine.startsWith("GET")) {
|
if (inputLine != null && inputLine.startsWith("GET")) {
|
||||||
Map<String, Object> data = new LinkedHashMap<>();
|
Map<String, Object> data = new LinkedHashMap<>();
|
||||||
data.put("online", true);
|
data.put("online", true);
|
||||||
|
|
||||||
// Version & Info
|
|
||||||
String versionRaw = ProxyServer.getInstance().getVersion();
|
String versionRaw = ProxyServer.getInstance().getVersion();
|
||||||
String versionClean = (versionRaw != null && versionRaw.contains(":")) ? versionRaw.split(":")[2].trim() : versionRaw;
|
String versionClean = (versionRaw != null && versionRaw.contains(":")) ? versionRaw.split(":")[2].trim() : versionRaw;
|
||||||
data.put("version", versionClean);
|
data.put("version", versionClean);
|
||||||
@@ -206,7 +574,6 @@ public class StatusAPI extends Plugin implements Runnable {
|
|||||||
} catch (Exception ignored) {}
|
} catch (Exception ignored) {}
|
||||||
data.put("motd", motd);
|
data.put("motd", motd);
|
||||||
|
|
||||||
// StatsModul holen (Service Locator)
|
|
||||||
StatsModule statsModule = (StatsModule) moduleManager.getModule("StatsModule");
|
StatsModule statsModule = (StatsModule) moduleManager.getModule("StatsModule");
|
||||||
|
|
||||||
boolean luckPermsEnabled = ProxyServer.getInstance().getPluginManager().getPlugin("LuckPerms") != null;
|
boolean luckPermsEnabled = ProxyServer.getInstance().getPluginManager().getPlugin("LuckPerms") != null;
|
||||||
@@ -236,7 +603,6 @@ public class StatusAPI extends Plugin implements Runnable {
|
|||||||
}
|
}
|
||||||
playerInfo.put("prefix", prefix);
|
playerInfo.put("prefix", prefix);
|
||||||
|
|
||||||
// Stats Integration via Modul
|
|
||||||
if (statsModule != null) {
|
if (statsModule != null) {
|
||||||
PlayerStats ps = statsModule.getManager().getIfPresent(p.getUniqueId());
|
PlayerStats ps = statsModule.getManager().getIfPresent(p.getUniqueId());
|
||||||
if (ps != null) {
|
if (ps != null) {
|
||||||
@@ -267,6 +633,58 @@ public class StatusAPI extends Plugin implements Runnable {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private String extractJsonString(String json, String key) {
|
||||||
|
if (json == null || key == null) return null;
|
||||||
|
String search = "\"" + key + "\"";
|
||||||
|
int idx = json.indexOf(search);
|
||||||
|
if (idx < 0) return null;
|
||||||
|
int colon = json.indexOf(':', idx + search.length());
|
||||||
|
if (colon < 0) return null;
|
||||||
|
int i = colon + 1;
|
||||||
|
while (i < json.length() && Character.isWhitespace(json.charAt(i))) i++;
|
||||||
|
if (i >= json.length()) return null;
|
||||||
|
char c = json.charAt(i);
|
||||||
|
if (c == '"') {
|
||||||
|
i++;
|
||||||
|
StringBuilder sb = new StringBuilder();
|
||||||
|
boolean escape = false;
|
||||||
|
while (i < json.length()) {
|
||||||
|
char ch = json.charAt(i++);
|
||||||
|
if (escape) {
|
||||||
|
sb.append(ch);
|
||||||
|
escape = false;
|
||||||
|
} else {
|
||||||
|
if (ch == '\\') escape = true;
|
||||||
|
else if (ch == '"') break;
|
||||||
|
else sb.append(ch);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return sb.toString();
|
||||||
|
} else {
|
||||||
|
StringBuilder sb = new StringBuilder();
|
||||||
|
while (i < json.length()) {
|
||||||
|
char ch = json.charAt(i);
|
||||||
|
if (ch == ',' || ch == '}' || ch == '\n' || ch == '\r') break;
|
||||||
|
sb.append(ch);
|
||||||
|
i++;
|
||||||
|
}
|
||||||
|
return sb.toString().trim();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void sendHttpResponse(OutputStream out, String json, int code) throws IOException {
|
||||||
|
byte[] jsonBytes = json.getBytes(StandardCharsets.UTF_8);
|
||||||
|
StringBuilder response = new StringBuilder();
|
||||||
|
response.append("HTTP/1.1 ").append(code).append(" ").append(code == 200 ? "OK" : "ERROR").append("\r\n");
|
||||||
|
response.append("Content-Type: application/json; charset=UTF-8\r\n");
|
||||||
|
response.append("Access-Control-Allow-Origin: *\r\n");
|
||||||
|
response.append("Content-Length: ").append(jsonBytes.length).append("\r\n");
|
||||||
|
response.append("Connection: close\r\n\r\n");
|
||||||
|
out.write(response.toString().getBytes(StandardCharsets.UTF_8));
|
||||||
|
out.write(jsonBytes);
|
||||||
|
out.flush();
|
||||||
|
}
|
||||||
|
|
||||||
private String buildJsonString(Map<String, Object> data) {
|
private String buildJsonString(Map<String, Object> data) {
|
||||||
StringBuilder sb = new StringBuilder("{");
|
StringBuilder sb = new StringBuilder("{");
|
||||||
boolean first = true;
|
boolean first = true;
|
||||||
|
|||||||
@@ -0,0 +1,381 @@
|
|||||||
|
package net.viper.status.modules.broadcast;
|
||||||
|
|
||||||
|
import net.md_5.bungee.api.ChatColor;
|
||||||
|
import net.md_5.bungee.api.plugin.Plugin;
|
||||||
|
import net.md_5.bungee.api.connection.ProxiedPlayer;
|
||||||
|
import net.md_5.bungee.api.chat.TextComponent;
|
||||||
|
import net.md_5.bungee.api.plugin.Listener;
|
||||||
|
import net.viper.status.module.Module;
|
||||||
|
|
||||||
|
import java.io.*;
|
||||||
|
import java.nio.charset.StandardCharsets;
|
||||||
|
import java.text.SimpleDateFormat;
|
||||||
|
import java.util.*;
|
||||||
|
import java.util.concurrent.ConcurrentHashMap;
|
||||||
|
import java.util.concurrent.TimeUnit;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* BroadcastModule
|
||||||
|
*
|
||||||
|
* Speichert geplante Broadcasts jetzt persistent in 'broadcasts.schedules'.
|
||||||
|
* Beim Neustart werden diese automatisch wieder geladen.
|
||||||
|
*/
|
||||||
|
public class BroadcastModule implements Module, Listener {
|
||||||
|
|
||||||
|
private Plugin plugin;
|
||||||
|
private boolean enabled = true;
|
||||||
|
private String requiredApiKey = "";
|
||||||
|
private String format = "%prefix% %message%";
|
||||||
|
private String fallbackPrefix = "[Broadcast]";
|
||||||
|
private String fallbackPrefixColor = "&c";
|
||||||
|
private String fallbackBracketColor = "&8"; // Neu
|
||||||
|
private String fallbackMessageColor = "&f";
|
||||||
|
|
||||||
|
private final Map<String, ScheduledBroadcast> scheduledByClientId = new ConcurrentHashMap<>();
|
||||||
|
private File schedulesFile;
|
||||||
|
private final SimpleDateFormat dateFormat;
|
||||||
|
|
||||||
|
public BroadcastModule() {
|
||||||
|
dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss z");
|
||||||
|
dateFormat.setTimeZone(TimeZone.getTimeZone("UTC"));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public String getName() {
|
||||||
|
return "BroadcastModule";
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void onEnable(Plugin plugin) {
|
||||||
|
this.plugin = plugin;
|
||||||
|
schedulesFile = new File(plugin.getDataFolder(), "broadcasts.schedules");
|
||||||
|
loadConfig();
|
||||||
|
|
||||||
|
if (!enabled) {
|
||||||
|
plugin.getLogger().info("[BroadcastModule] deaktiviert via verify.properties (broadcast.enabled=false)");
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
plugin.getProxy().getPluginManager().registerListener(plugin, this);
|
||||||
|
} catch (Throwable ignored) {}
|
||||||
|
|
||||||
|
plugin.getLogger().info("[BroadcastModule] aktiviert. Format: " + format);
|
||||||
|
loadSchedules();
|
||||||
|
plugin.getProxy().getScheduler().schedule(plugin, this::processScheduled, 1, 1, TimeUnit.SECONDS);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void onDisable(Plugin plugin) {
|
||||||
|
plugin.getLogger().info("[BroadcastModule] deaktiviert.");
|
||||||
|
saveSchedules();
|
||||||
|
scheduledByClientId.clear();
|
||||||
|
}
|
||||||
|
|
||||||
|
private void loadConfig() {
|
||||||
|
File file = new File(plugin.getDataFolder(), "verify.properties");
|
||||||
|
if (!file.exists()) {
|
||||||
|
enabled = true;
|
||||||
|
requiredApiKey = "";
|
||||||
|
format = "%prefix% %message%";
|
||||||
|
fallbackPrefix = "[Broadcast]";
|
||||||
|
fallbackPrefixColor = "&c";
|
||||||
|
fallbackBracketColor = "&8"; // Neu
|
||||||
|
fallbackMessageColor = "&f";
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
try (InputStream in = new FileInputStream(file)) {
|
||||||
|
Properties props = new Properties();
|
||||||
|
props.load(new InputStreamReader(in, StandardCharsets.UTF_8));
|
||||||
|
enabled = Boolean.parseBoolean(props.getProperty("broadcast.enabled", "true"));
|
||||||
|
requiredApiKey = props.getProperty("broadcast.api_key", "").trim();
|
||||||
|
format = props.getProperty("broadcast.format", format).trim();
|
||||||
|
if (format.isEmpty()) format = "%prefix% %message%";
|
||||||
|
fallbackPrefix = props.getProperty("broadcast.prefix", fallbackPrefix).trim();
|
||||||
|
fallbackPrefixColor = props.getProperty("broadcast.prefix-color", fallbackPrefixColor).trim();
|
||||||
|
fallbackBracketColor = props.getProperty("broadcast.bracket-color", fallbackBracketColor).trim(); // Neu
|
||||||
|
fallbackMessageColor = props.getProperty("broadcast.message-color", fallbackMessageColor).trim();
|
||||||
|
} catch (IOException e) {
|
||||||
|
plugin.getLogger().warning("[BroadcastModule] Fehler beim Laden von verify.properties: " + e.getMessage());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean handleBroadcast(String sourceName, String message, String type, String apiKeyHeader,
|
||||||
|
String prefix, String prefixColor, String bracketColor, String messageColor) {
|
||||||
|
loadConfig();
|
||||||
|
|
||||||
|
if (!enabled) {
|
||||||
|
plugin.getLogger().info("[BroadcastModule] Broadcast abgelehnt: Modul ist deaktiviert.");
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (requiredApiKey != null && !requiredApiKey.isEmpty()) {
|
||||||
|
if (apiKeyHeader == null || !requiredApiKey.equals(apiKeyHeader)) {
|
||||||
|
plugin.getLogger().warning("[BroadcastModule] Broadcast abgelehnt: API-Key fehlt oder inkorrekt.");
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (message == null) message = "";
|
||||||
|
if (sourceName == null || sourceName.isEmpty()) sourceName = "System";
|
||||||
|
if (type == null) type = "global";
|
||||||
|
|
||||||
|
String usedPrefix = (prefix != null && !prefix.trim().isEmpty()) ? prefix.trim() : fallbackPrefix;
|
||||||
|
String usedPrefixColor = (prefixColor != null && !prefixColor.trim().isEmpty()) ? prefixColor.trim() : fallbackPrefixColor;
|
||||||
|
String usedBracketColor = (bracketColor != null && !bracketColor.trim().isEmpty()) ? bracketColor.trim() : fallbackBracketColor; // Neu
|
||||||
|
String usedMessageColor = (messageColor != null && !messageColor.trim().isEmpty()) ? messageColor.trim() : fallbackMessageColor;
|
||||||
|
|
||||||
|
String prefixColorCode = normalizeColorCode(usedPrefixColor);
|
||||||
|
String bracketColorCode = normalizeColorCode(usedBracketColor); // Neu
|
||||||
|
String messageColorCode = normalizeColorCode(usedMessageColor);
|
||||||
|
|
||||||
|
// --- KLAMMER LOGIK ---
|
||||||
|
String finalPrefix;
|
||||||
|
|
||||||
|
// Wenn eine Klammerfarbe gesetzt ist, bauen wir den Prefix neu zusammen
|
||||||
|
// Format: [BracketColor][ [PrefixColor]Text [BracketColor]]
|
||||||
|
if (!bracketColorCode.isEmpty()) {
|
||||||
|
String textContent = usedPrefix;
|
||||||
|
// Entferne manuelle Klammern, falls der User [Broadcast] in das Textfeld geschrieben hat
|
||||||
|
if (textContent.startsWith("[")) textContent = textContent.substring(1);
|
||||||
|
if (textContent.endsWith("]")) textContent = textContent.substring(0, textContent.length() - 1);
|
||||||
|
|
||||||
|
finalPrefix = bracketColorCode + "[" + prefixColorCode + textContent + bracketColorCode + "]" + ChatColor.RESET;
|
||||||
|
} else {
|
||||||
|
// Altes Verhalten: Ganzen String einfärben
|
||||||
|
finalPrefix = prefixColorCode + usedPrefix + ChatColor.RESET;
|
||||||
|
}
|
||||||
|
// ---------------------
|
||||||
|
|
||||||
|
String coloredMessage = (messageColorCode.isEmpty() ? "" : messageColorCode) + message;
|
||||||
|
|
||||||
|
String out = format.replace("%name%", sourceName)
|
||||||
|
.replace("%prefix%", finalPrefix) // Neu verwendete Variable
|
||||||
|
.replace("%prefixColored%", finalPrefix) // Fallback
|
||||||
|
.replace("%message%", message)
|
||||||
|
.replace("%messageColored%", coloredMessage)
|
||||||
|
.replace("%type%", type);
|
||||||
|
|
||||||
|
if (!out.contains("%prefixColored%") && !out.contains("%messageColored%") && !out.contains("%prefix%") && !out.contains("%message%")) {
|
||||||
|
out = finalPrefix + " " + coloredMessage;
|
||||||
|
}
|
||||||
|
|
||||||
|
TextComponent tc = new TextComponent(out);
|
||||||
|
int sent = 0;
|
||||||
|
for (ProxiedPlayer p : plugin.getProxy().getPlayers()) {
|
||||||
|
try { p.sendMessage(tc); sent++; } catch (Throwable ignored) {}
|
||||||
|
}
|
||||||
|
|
||||||
|
plugin.getLogger().info("[BroadcastModule] Broadcast gesendet (Empfänger=" + sent + "): " + message);
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
private String normalizeColorCode(String code) {
|
||||||
|
if (code == null) return "";
|
||||||
|
code = code.trim();
|
||||||
|
if (code.isEmpty()) return "";
|
||||||
|
return code.contains("&") ? ChatColor.translateAlternateColorCodes('&', code) : code;
|
||||||
|
}
|
||||||
|
|
||||||
|
private void saveSchedules() {
|
||||||
|
Properties props = new Properties();
|
||||||
|
for (Map.Entry<String, ScheduledBroadcast> entry : scheduledByClientId.entrySet()) {
|
||||||
|
String id = entry.getKey();
|
||||||
|
ScheduledBroadcast sb = entry.getValue();
|
||||||
|
props.setProperty(id + ".nextRunMillis", String.valueOf(sb.nextRunMillis));
|
||||||
|
props.setProperty(id + ".sourceName", sb.sourceName);
|
||||||
|
props.setProperty(id + ".message", sb.message);
|
||||||
|
props.setProperty(id + ".type", sb.type);
|
||||||
|
props.setProperty(id + ".prefix", sb.prefix);
|
||||||
|
props.setProperty(id + ".prefixColor", sb.prefixColor);
|
||||||
|
props.setProperty(id + ".bracketColor", sb.bracketColor); // Neu
|
||||||
|
props.setProperty(id + ".messageColor", sb.messageColor);
|
||||||
|
props.setProperty(id + ".recur", sb.recur);
|
||||||
|
}
|
||||||
|
|
||||||
|
try (OutputStream out = new FileOutputStream(schedulesFile)) {
|
||||||
|
props.store(out, "PulseCast Scheduled Broadcasts");
|
||||||
|
} catch (IOException e) {
|
||||||
|
plugin.getLogger().severe("[BroadcastModule] Konnte Schedules nicht speichern: " + e.getMessage());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void loadSchedules() {
|
||||||
|
if (!schedulesFile.exists()) {
|
||||||
|
plugin.getLogger().info("[BroadcastModule] Keine bestehenden Schedules gefunden (Neustart).");
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
Properties props = new Properties();
|
||||||
|
try (InputStream in = new FileInputStream(schedulesFile)) {
|
||||||
|
props.load(in);
|
||||||
|
} catch (IOException e) {
|
||||||
|
plugin.getLogger().severe("[BroadcastModule] Konnte Schedules nicht laden: " + e.getMessage());
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
Map<String, ScheduledBroadcast> loaded = new HashMap<>();
|
||||||
|
for (String key : props.stringPropertyNames()) {
|
||||||
|
if (!key.contains(".")) continue;
|
||||||
|
String[] parts = key.split("\\.");
|
||||||
|
if (parts.length != 2) continue;
|
||||||
|
|
||||||
|
String id = parts[0];
|
||||||
|
String field = parts[1];
|
||||||
|
String value = props.getProperty(key);
|
||||||
|
|
||||||
|
ScheduledBroadcast sb = loaded.get(id);
|
||||||
|
if (sb == null) {
|
||||||
|
sb = new ScheduledBroadcast(id, 0, "", "", "", "", "", "", "", ""); // Ein leerer String mehr für Bracket
|
||||||
|
loaded.put(id, sb);
|
||||||
|
}
|
||||||
|
|
||||||
|
switch (field) {
|
||||||
|
case "nextRunMillis":
|
||||||
|
try { sb.nextRunMillis = Long.parseLong(value); } catch (NumberFormatException ignored) {}
|
||||||
|
break;
|
||||||
|
case "sourceName": sb.sourceName = value; break;
|
||||||
|
case "message": sb.message = value; break;
|
||||||
|
case "type": sb.type = value; break;
|
||||||
|
case "prefix": sb.prefix = value; break;
|
||||||
|
case "prefixColor": sb.prefixColor = value; break;
|
||||||
|
case "bracketColor": sb.bracketColor = value; break; // Neu
|
||||||
|
case "messageColor": sb.messageColor = value; break;
|
||||||
|
case "recur": sb.recur = value; break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
scheduledByClientId.putAll(loaded);
|
||||||
|
plugin.getLogger().info("[BroadcastModule] " + loaded.size() + " geplante Broadcasts aus Datei wiederhergestellt.");
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean scheduleBroadcast(long timestampMillis, String sourceName, String message, String type,
|
||||||
|
String apiKeyHeader, String prefix, String prefixColor, String bracketColor, String messageColor,
|
||||||
|
String recur, String clientScheduleId) {
|
||||||
|
loadConfig();
|
||||||
|
|
||||||
|
if (!enabled) {
|
||||||
|
plugin.getLogger().info("[BroadcastModule] schedule abgelehnt: Modul deaktiviert.");
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (requiredApiKey != null && !requiredApiKey.isEmpty()) {
|
||||||
|
if (apiKeyHeader == null || !requiredApiKey.equals(apiKeyHeader)) {
|
||||||
|
plugin.getLogger().warning("[BroadcastModule] schedule abgelehnt: API-Key fehlt oder inkorrekt.");
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (message == null) message = "";
|
||||||
|
if (sourceName == null || sourceName.isEmpty()) sourceName = "System";
|
||||||
|
if (type == null) type = "global";
|
||||||
|
if (recur == null) recur = "none";
|
||||||
|
|
||||||
|
String id = (clientScheduleId != null && !clientScheduleId.trim().isEmpty()) ? clientScheduleId.trim() : UUID.randomUUID().toString();
|
||||||
|
|
||||||
|
long now = System.currentTimeMillis();
|
||||||
|
String scheduledTimeStr = dateFormat.format(new Date(timestampMillis));
|
||||||
|
|
||||||
|
plugin.getLogger().info("[BroadcastModule] Neue geplante Nachricht registriert: " + id + " @ " + scheduledTimeStr);
|
||||||
|
|
||||||
|
if (timestampMillis <= now) {
|
||||||
|
plugin.getLogger().warning("[BroadcastModule] Geplante Zeit liegt in der Vergangenheit -> sende sofort!");
|
||||||
|
return handleBroadcast(sourceName, message, type, apiKeyHeader, prefix, prefixColor, bracketColor, messageColor);
|
||||||
|
}
|
||||||
|
|
||||||
|
ScheduledBroadcast sb = new ScheduledBroadcast(id, timestampMillis, sourceName, message, type, prefix, prefixColor, bracketColor, messageColor, recur);
|
||||||
|
scheduledByClientId.put(id, sb);
|
||||||
|
saveSchedules();
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean cancelScheduled(String clientScheduleId) {
|
||||||
|
if (clientScheduleId == null || clientScheduleId.trim().isEmpty()) return false;
|
||||||
|
ScheduledBroadcast removed = scheduledByClientId.remove(clientScheduleId);
|
||||||
|
if (removed != null) {
|
||||||
|
plugin.getLogger().info("[BroadcastModule] Geplante Nachricht abgebrochen: id=" + clientScheduleId);
|
||||||
|
saveSchedules();
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
private void processScheduled() {
|
||||||
|
if (scheduledByClientId.isEmpty()) return;
|
||||||
|
|
||||||
|
long now = System.currentTimeMillis();
|
||||||
|
List<String> toRemove = new ArrayList<>();
|
||||||
|
boolean changed = false;
|
||||||
|
|
||||||
|
for (Map.Entry<String, ScheduledBroadcast> entry : scheduledByClientId.entrySet()) {
|
||||||
|
ScheduledBroadcast sb = entry.getValue();
|
||||||
|
|
||||||
|
if (sb.nextRunMillis <= now) {
|
||||||
|
String timeStr = dateFormat.format(new Date(sb.nextRunMillis));
|
||||||
|
plugin.getLogger().info("[BroadcastModule] ⏰ Sende geplante Nachricht (ID: " + entry.getKey() + ", Zeit: " + timeStr + ")");
|
||||||
|
|
||||||
|
handleBroadcast(sb.sourceName, sb.message, sb.type, "", sb.prefix, sb.prefixColor, sb.bracketColor, sb.messageColor);
|
||||||
|
|
||||||
|
if (!"none".equalsIgnoreCase(sb.recur)) {
|
||||||
|
long next = computeNextMillis(sb.nextRunMillis, sb.recur);
|
||||||
|
if (next > 0) {
|
||||||
|
sb.nextRunMillis = next;
|
||||||
|
String nextTimeStr = dateFormat.format(new Date(next));
|
||||||
|
plugin.getLogger().info("[BroadcastModule] Nächste Wiederholung (" + sb.recur + "): " + nextTimeStr);
|
||||||
|
changed = true;
|
||||||
|
} else {
|
||||||
|
toRemove.add(entry.getKey());
|
||||||
|
changed = true;
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
toRemove.add(entry.getKey());
|
||||||
|
changed = true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (changed || !toRemove.isEmpty()) {
|
||||||
|
for (String k : toRemove) {
|
||||||
|
scheduledByClientId.remove(k);
|
||||||
|
plugin.getLogger().info("[BroadcastModule] Schedule entfernt: " + k);
|
||||||
|
}
|
||||||
|
saveSchedules();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private long computeNextMillis(long currentMillis, String recur) {
|
||||||
|
switch (recur.toLowerCase(Locale.ROOT)) {
|
||||||
|
case "hourly": return currentMillis + TimeUnit.HOURS.toMillis(1);
|
||||||
|
case "daily": return currentMillis + TimeUnit.DAYS.toMillis(1);
|
||||||
|
case "weekly": return currentMillis + TimeUnit.DAYS.toMillis(7);
|
||||||
|
default: return -1L;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private static class ScheduledBroadcast {
|
||||||
|
final String clientId;
|
||||||
|
long nextRunMillis;
|
||||||
|
String sourceName;
|
||||||
|
String message;
|
||||||
|
String type;
|
||||||
|
String prefix;
|
||||||
|
String prefixColor;
|
||||||
|
String bracketColor; // Neu
|
||||||
|
String messageColor;
|
||||||
|
String recur;
|
||||||
|
|
||||||
|
ScheduledBroadcast(String clientId, long nextRunMillis, String sourceName, String message, String type,
|
||||||
|
String prefix, String prefixColor, String bracketColor, String messageColor, String recur) {
|
||||||
|
this.clientId = clientId;
|
||||||
|
this.nextRunMillis = nextRunMillis;
|
||||||
|
this.sourceName = sourceName;
|
||||||
|
this.message = message;
|
||||||
|
this.type = type;
|
||||||
|
this.prefix = prefix;
|
||||||
|
this.prefixColor = prefixColor;
|
||||||
|
this.bracketColor = bracketColor; // Neu
|
||||||
|
this.messageColor = messageColor;
|
||||||
|
this.recur = (recur == null ? "none" : recur);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,180 @@
|
|||||||
|
package net.viper.status.modules.commandblocker;
|
||||||
|
|
||||||
|
import net.md_5.bungee.api.ChatColor;
|
||||||
|
import net.md_5.bungee.api.CommandSender;
|
||||||
|
import net.md_5.bungee.api.ProxyServer;
|
||||||
|
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.api.plugin.Plugin;
|
||||||
|
import net.md_5.bungee.event.EventHandler;
|
||||||
|
import net.viper.status.StatusAPI;
|
||||||
|
import net.viper.status.module.Module;
|
||||||
|
|
||||||
|
import java.io.File;
|
||||||
|
import java.io.FileInputStream;
|
||||||
|
import java.io.FileWriter;
|
||||||
|
import java.io.IOException;
|
||||||
|
import java.util.*;
|
||||||
|
import org.yaml.snakeyaml.Yaml;
|
||||||
|
|
||||||
|
@SuppressWarnings({"unchecked", "rawtypes"})
|
||||||
|
public class CommandBlockerModule implements Module, Listener {
|
||||||
|
|
||||||
|
private StatusAPI plugin;
|
||||||
|
private boolean enabled = true; // Standardmäßig aktiv
|
||||||
|
private String bypassPermission = "commandblocker.bypass"; // Standard Permission
|
||||||
|
|
||||||
|
private File file;
|
||||||
|
private Set<String> blocked = new HashSet<>();
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public String getName() {
|
||||||
|
return "CommandBlockerModule";
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void onEnable(Plugin plugin) {
|
||||||
|
if (!(plugin instanceof StatusAPI)) return; // Sicherheit
|
||||||
|
this.plugin = (StatusAPI) plugin;
|
||||||
|
|
||||||
|
// Datei laden
|
||||||
|
file = new File(this.plugin.getDataFolder(), "blocked-commands.yml");
|
||||||
|
loadFile();
|
||||||
|
|
||||||
|
// Listener registrieren
|
||||||
|
ProxyServer.getInstance().getPluginManager().registerListener(this.plugin, this);
|
||||||
|
|
||||||
|
// /cb Befehl registrieren
|
||||||
|
ProxyServer.getInstance().getPluginManager().registerCommand(this.plugin,
|
||||||
|
new net.md_5.bungee.api.plugin.Command("cb", "commandblocker.admin") {
|
||||||
|
@Override
|
||||||
|
public void execute(CommandSender sender, String[] args) {
|
||||||
|
handleCommand(sender, args);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
this.plugin.getLogger().info("[CommandBlocker] aktiviert (" + blocked.size() + " Commands).");
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void onDisable(Plugin plugin) {
|
||||||
|
blocked.clear();
|
||||||
|
}
|
||||||
|
|
||||||
|
@EventHandler
|
||||||
|
public void onCommand(ChatEvent event) {
|
||||||
|
if (!enabled || !event.isCommand()) return;
|
||||||
|
|
||||||
|
if (!(event.getSender() instanceof ProxiedPlayer)) return;
|
||||||
|
ProxiedPlayer player = (ProxiedPlayer) event.getSender();
|
||||||
|
|
||||||
|
if (player.hasPermission(bypassPermission)) return;
|
||||||
|
|
||||||
|
String msg = event.getMessage();
|
||||||
|
if (msg == null || msg.length() <= 1) return;
|
||||||
|
|
||||||
|
String cmd = msg.substring(1).toLowerCase(Locale.ROOT);
|
||||||
|
String base = cmd.split(" ")[0];
|
||||||
|
|
||||||
|
if (blocked.contains(base)) {
|
||||||
|
event.setCancelled(true);
|
||||||
|
player.sendMessage(ChatColor.RED + "Dieser Befehl ist auf diesem Netzwerk blockiert.");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void handleCommand(CommandSender sender, String[] args) {
|
||||||
|
if (args == null || args.length == 0) {
|
||||||
|
sender.sendMessage(ChatColor.YELLOW + "/cb add <command>");
|
||||||
|
sender.sendMessage(ChatColor.YELLOW + "/cb remove <command>");
|
||||||
|
sender.sendMessage(ChatColor.YELLOW + "/cb list");
|
||||||
|
sender.sendMessage(ChatColor.YELLOW + "/cb reload");
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
String action = args[0].toLowerCase();
|
||||||
|
|
||||||
|
switch (action) {
|
||||||
|
case "add":
|
||||||
|
if (args.length < 2) break;
|
||||||
|
blocked.add(args[1].toLowerCase());
|
||||||
|
saveFile();
|
||||||
|
sender.sendMessage(ChatColor.GREEN + "Command blockiert: " + args[1]);
|
||||||
|
break;
|
||||||
|
case "remove":
|
||||||
|
if (args.length < 2) break;
|
||||||
|
blocked.remove(args[1].toLowerCase());
|
||||||
|
saveFile();
|
||||||
|
sender.sendMessage(ChatColor.GREEN + "Command freigegeben: " + args[1]);
|
||||||
|
break;
|
||||||
|
case "list":
|
||||||
|
sender.sendMessage(ChatColor.GOLD + "Blockierte Commands:");
|
||||||
|
for (String c : blocked) {
|
||||||
|
sender.sendMessage(ChatColor.RED + "- " + c);
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
case "reload":
|
||||||
|
loadFile();
|
||||||
|
sender.sendMessage(ChatColor.GREEN + "CommandBlocker neu geladen.");
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
sender.sendMessage(ChatColor.RED + "Unbekannter Unterbefehl.");
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void loadFile() {
|
||||||
|
try {
|
||||||
|
if (!file.exists()) {
|
||||||
|
File parent = file.getParentFile();
|
||||||
|
if (parent != null && !parent.exists()) parent.mkdirs();
|
||||||
|
file.createNewFile();
|
||||||
|
saveFile();
|
||||||
|
}
|
||||||
|
|
||||||
|
Yaml yaml = new Yaml();
|
||||||
|
Map<String, Object> data = null;
|
||||||
|
FileInputStream fis = null;
|
||||||
|
try {
|
||||||
|
fis = new FileInputStream(file);
|
||||||
|
data = yaml.loadAs(fis, Map.class);
|
||||||
|
} finally {
|
||||||
|
if (fis != null) try { fis.close(); } catch (IOException ignored) {}
|
||||||
|
}
|
||||||
|
|
||||||
|
blocked.clear();
|
||||||
|
if (data != null && data.containsKey("blocked")) {
|
||||||
|
Object obj = data.get("blocked");
|
||||||
|
if (obj instanceof List) {
|
||||||
|
List list = (List) obj;
|
||||||
|
for (Object o : list) {
|
||||||
|
if (o != null) blocked.add(String.valueOf(o).toLowerCase());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
} catch (Exception e) {
|
||||||
|
if (plugin != null) plugin.getLogger().severe("[CommandBlocker] Fehler beim Laden: " + e.getMessage());
|
||||||
|
else System.err.println("[CommandBlocker] Fehler beim Laden: " + e.getMessage());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void saveFile() {
|
||||||
|
try {
|
||||||
|
Yaml yaml = new Yaml();
|
||||||
|
Map<String, Object> out = new LinkedHashMap<>();
|
||||||
|
out.put("blocked", new ArrayList<>(blocked));
|
||||||
|
FileWriter fw = null;
|
||||||
|
try {
|
||||||
|
fw = new FileWriter(file);
|
||||||
|
yaml.dump(out, fw);
|
||||||
|
} finally {
|
||||||
|
if (fw != null) try { fw.close(); } catch (IOException ignored) {}
|
||||||
|
}
|
||||||
|
} catch (IOException e) {
|
||||||
|
if (plugin != null) plugin.getLogger().severe("[CommandBlocker] Fehler beim Speichern: " + e.getMessage());
|
||||||
|
else System.err.println("[CommandBlocker] Fehler beim Speichern: " + e.getMessage());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -1,6 +1,6 @@
|
|||||||
name: StatusAPI
|
name: StatusAPI
|
||||||
main: net.viper.status.StatusAPI
|
main: net.viper.status.StatusAPI
|
||||||
version: 4.0.3
|
version: 4.0.6
|
||||||
author: M_Viper
|
author: M_Viper
|
||||||
description: StatusAPI für BungeeCord inkl. Update-Checker und Modul-System
|
description: StatusAPI für BungeeCord inkl. Update-Checker und Modul-System
|
||||||
|
|
||||||
|
|||||||
@@ -1,8 +1,26 @@
|
|||||||
|
# _____ __ __ ___ ____ ____
|
||||||
|
# / ___// /_____ _/ /___ _______/ | / __ \/ _/
|
||||||
|
# \__ \/ __/ __ `/ __/ / / / ___/ /| | / /_/ // /
|
||||||
|
# ___/ / /_/ /_/ / /_/ /_/ (__ ) ___ |/ ____// /
|
||||||
|
# /____/\__/\__,_/\__/\__,_/____/_/ |_/_/ /___/
|
||||||
|
|
||||||
|
|
||||||
# ===========================
|
# ===========================
|
||||||
# GLOBALCHAT AKTIVIERUNG
|
# GLOBALCHAT AKTIVIERUNG
|
||||||
# ===========================
|
# ===========================
|
||||||
chat.enabled=false
|
chat.enabled=false
|
||||||
|
|
||||||
|
# ------------------------------
|
||||||
|
# Broadcast
|
||||||
|
# ------------------------------
|
||||||
|
|
||||||
|
broadcast.enabled=false
|
||||||
|
broadcast.prefix=[Broadcast]
|
||||||
|
broadcast.prefix-color=&c
|
||||||
|
broadcast.message-color=&f
|
||||||
|
broadcast.format=%prefixColored% %messageColored%
|
||||||
|
# broadcast.format kann angepasst werden; nutze Platzhalter: %name%, %prefix%, %prefixColored%, %message%, %messageColored%, %type%
|
||||||
|
|
||||||
# ===========================
|
# ===========================
|
||||||
# NAVIGATION / SERVER SWITCHER
|
# NAVIGATION / SERVER SWITCHER
|
||||||
# ===========================
|
# ===========================
|
||||||
@@ -58,8 +76,14 @@ override.uuid-hier-einfügen = Developer
|
|||||||
|
|
||||||
# Ränge mit neuer Syntax: Rank || Spielerfarbe || Chatfarbe
|
# Ränge mit neuer Syntax: Rank || Spielerfarbe || Chatfarbe
|
||||||
# Beispiel: Rot (Rang) || Blau (Name) || Lila (Chat)
|
# Beispiel: Rot (Rang) || Blau (Name) || Lila (Chat)
|
||||||
groupformat.Owner=&c[Owner] || &b || &d
|
groupformat.owner=&c[Owner] || &b || &d
|
||||||
groupformat.Admin=&4[Admin] || &9 || &c
|
groupformat.admin=&4[Admin] || &9 || &c
|
||||||
groupformat.Developer=&b[Dev] || &3 || &a
|
groupformat.developer=&b[Dev] || &3 || &a
|
||||||
groupformat.Premium=&6[Premium] || &e || &7
|
groupformat.premium=&6[Premium] || &e || &7
|
||||||
groupformat.Spieler=&f[Spieler] || &7 || &8
|
groupformat.spieler=&f[Spieler] || &7 || &8
|
||||||
|
|
||||||
|
# ===========================
|
||||||
|
# COMMAND BLOCKER
|
||||||
|
# ===========================
|
||||||
|
commandblocker.enabled=true
|
||||||
|
commandblocker.bypass.permission=commandblocker.bypass
|
||||||
|
|||||||
88
src/main/resources/verify.template.properties
Normal file
88
src/main/resources/verify.template.properties
Normal file
@@ -0,0 +1,88 @@
|
|||||||
|
# _____ __ __ ___ ____ ____
|
||||||
|
# / ___// /_____ _/ /___ _______/ | / __ \/ _/
|
||||||
|
# \__ \/ __/ __ `/ __/ / / / ___/ /| | / /_/ // /
|
||||||
|
# ___/ / /_/ /_/ / /_/ /_/ (__ ) ___ |/ ____// /
|
||||||
|
# /____/\__/\__,_/\__/\__,_/____/_/ |_/_/ /___/
|
||||||
|
|
||||||
|
|
||||||
|
# ===========================
|
||||||
|
# GLOBALCHAT AKTIVIERUNG
|
||||||
|
# ===========================
|
||||||
|
chat.enabled=false
|
||||||
|
|
||||||
|
# ------------------------------
|
||||||
|
# Broadcast
|
||||||
|
# ------------------------------
|
||||||
|
|
||||||
|
broadcast.enabled=false
|
||||||
|
broadcast.prefix=[Broadcast]
|
||||||
|
broadcast.prefix-color=&c
|
||||||
|
broadcast.message-color=&f
|
||||||
|
broadcast.format=%prefixColored% %messageColored%
|
||||||
|
# broadcast.format kann angepasst werden; nutze Platzhalter: %name%, %prefix%, %prefixColored%, %message%, %messageColored%, %type%
|
||||||
|
|
||||||
|
# ===========================
|
||||||
|
# NAVIGATION / SERVER SWITCHER
|
||||||
|
# ===========================
|
||||||
|
# Hier kannst du das interne Navigationssystem aktivieren/deaktivieren.
|
||||||
|
# Wenn aktiviert, erstellt das Plugin automatisch Befehle basierend auf den Servernamen (z.B. /lobby, /survival).
|
||||||
|
navigation.enabled=false
|
||||||
|
|
||||||
|
# ===========================
|
||||||
|
# WORDPRESS / VERIFY EINSTELLUNGEN
|
||||||
|
# ===========================
|
||||||
|
wp_verify_url=https://deine-wp-domain.tld
|
||||||
|
|
||||||
|
# ===========================
|
||||||
|
# SERVER KONFIGURATION
|
||||||
|
# ===========================
|
||||||
|
# Hier legst du für jeden Server alles fest:
|
||||||
|
# 1. Den Anzeigenamen für den Chat (z.B. &bLobby)
|
||||||
|
# 2. Die Server ID für WordPress (z.B. id=1)
|
||||||
|
# 3. Das Secret für WordPress (z.B. secret=...)
|
||||||
|
|
||||||
|
# Server 1: Lobby
|
||||||
|
server.lobby=&bLobby
|
||||||
|
server.lobby.id=1
|
||||||
|
server.lobby.secret=GeheimesWortFuerLobby123
|
||||||
|
|
||||||
|
# Server 2: Survival
|
||||||
|
server.survival=&aSurvival
|
||||||
|
server.survival.id=2
|
||||||
|
server.survival.secret=GeheimesWortFuerSurvival456
|
||||||
|
|
||||||
|
# Server 3: SkyBlock
|
||||||
|
server.skyblock=&dSkyBlock
|
||||||
|
server.skyblock.id=3
|
||||||
|
server.skyblock.secret=GeheimesWortFuerSkyBlock789
|
||||||
|
|
||||||
|
# ===========================
|
||||||
|
# Manuelle Ränge (Overrides)
|
||||||
|
# ===========================
|
||||||
|
# Syntax: override.<Spieler-UUID> = <Gruppenname>
|
||||||
|
# WICHTIG: Die Gruppe (z.B. Owner) muss unten bei groupformat definiert sein!
|
||||||
|
|
||||||
|
# Beispiel: Deinen UUID hier einfügen
|
||||||
|
# override.uuid-hier-einfügen = Owner
|
||||||
|
|
||||||
|
|
||||||
|
# ===========================
|
||||||
|
# Chat-Formate für Gruppen
|
||||||
|
# ===========================
|
||||||
|
|
||||||
|
# Der Name hinter dem Punkt (z.B. Owner) muss exakt mit der LuckPerms Gruppe übereinstimmen.
|
||||||
|
# Nutze & für Farbcodes.
|
||||||
|
|
||||||
|
# Ränge mit neuer Syntax: Rank || Spielerfarbe || Chatfarbe
|
||||||
|
# Beispiel: Rot (Rang) || Blau (Name) || Lila (Chat)
|
||||||
|
groupformat.owner=&c[Owner] || &b || &d
|
||||||
|
groupformat.admin=&4[Admin] || &9 || &c
|
||||||
|
groupformat.developer=&b[Dev] || &3 || &a
|
||||||
|
groupformat.premium=&6[Premium] || &e || &7
|
||||||
|
groupformat.spieler=&f[Spieler] || &7 || &8
|
||||||
|
|
||||||
|
# ===========================
|
||||||
|
# COMMAND BLOCKER
|
||||||
|
# ===========================
|
||||||
|
commandblocker.enabled=true
|
||||||
|
commandblocker.bypass.permission=commandblocker.bypass
|
||||||
Reference in New Issue
Block a user