aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/de/hype/bbsentials
diff options
context:
space:
mode:
authorHacktheTime <l4bg0jb7@duck.com>2023-08-09 20:46:00 +0200
committerHacktheTime <l4bg0jb7@duck.com>2023-08-09 20:46:00 +0200
commit2cd5f8e6bd42a084022028adcc24ef566fddab95 (patch)
treee06a18df40629371c33b9efce971489812696ac0 /src/main/java/de/hype/bbsentials
downloadBBsentials-2cd5f8e6bd42a084022028adcc24ef566fddab95.tar.gz
BBsentials-2cd5f8e6bd42a084022028adcc24ef566fddab95.tar.bz2
BBsentials-2cd5f8e6bd42a084022028adcc24ef566fddab95.zip
Initial commit
Diffstat (limited to 'src/main/java/de/hype/bbsentials')
-rw-r--r--src/main/java/de/hype/bbsentials/api/Discord.java70
-rw-r--r--src/main/java/de/hype/bbsentials/api/ISimpleOption.java5
-rw-r--r--src/main/java/de/hype/bbsentials/api/Options.java13
-rw-r--r--src/main/java/de/hype/bbsentials/chat/Chat.java579
-rw-r--r--src/main/java/de/hype/bbsentials/chat/Sender.java106
-rw-r--r--src/main/java/de/hype/bbsentials/client/BBsentials.java174
-rw-r--r--src/main/java/de/hype/bbsentials/client/Commands/CommandsOLD.java308
-rw-r--r--src/main/java/de/hype/bbsentials/client/Config.java266
-rw-r--r--src/main/java/de/hype/bbsentials/communication/BBsentialConnection.java340
-rw-r--r--src/main/java/de/hype/bbsentials/mixins/ClientCommandSourceMixin.java56
-rw-r--r--src/main/java/de/hype/bbsentials/mixins/ItemRendererMixin.java43
-rw-r--r--src/main/java/de/hype/bbsentials/mixins/ScreenMixin.java26
-rw-r--r--src/main/java/de/hype/bbsentials/mixins/SimpleOptionMixin.java33
13 files changed, 2019 insertions, 0 deletions
diff --git a/src/main/java/de/hype/bbsentials/api/Discord.java b/src/main/java/de/hype/bbsentials/api/Discord.java
new file mode 100644
index 0000000..e8c8887
--- /dev/null
+++ b/src/main/java/de/hype/bbsentials/api/Discord.java
@@ -0,0 +1,70 @@
+package de.hype.bbsentials.api;
+
+import de.hype.bbsentials.chat.Chat;
+import de.hype.bbsentials.client.BBsentials;
+import org.apache.http.HttpEntity;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.nio.charset.StandardCharsets;
+
+public class Discord {
+ public static void sendWebhookMessage(String message) {
+ Thread thread = new Thread(new Runnable() {
+ @Override
+ public void run() {
+ sendWebhookMessageNoThread(message);
+ }
+ });
+ thread.start();
+ }
+
+
+ public static void sendWebhookMessageNoThread(String message) {
+ CloseableHttpClient httpClient = HttpClients.createDefault();
+ String WEBHOOK_URL = "https://discord.com/api/v8/webhooks/1127524566407860276/" + BBsentials.getConfig().getApiKey();
+
+
+ try {
+ HttpPost httpPost = new HttpPost(WEBHOOK_URL);
+
+ StringEntity jsonEntity = new StringEntity("{\"content\": \"" + message + "\"}", StandardCharsets.UTF_8);
+ jsonEntity.setContentType("application/json");
+ httpPost.setEntity(jsonEntity);
+
+ CloseableHttpResponse response = httpClient.execute(httpPost);
+ HttpEntity responseEntity = response.getEntity();
+
+ if (responseEntity != null) {
+ InputStream inputStream = responseEntity.getContent();
+ BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
+
+ String line;
+ StringBuilder responseBuilder = new StringBuilder();
+ while ((line = reader.readLine()) != null) {
+ responseBuilder.append(line);
+ }
+
+ String responseString = responseBuilder.toString();
+ Chat.sendPrivateMessageToSelf(responseString);
+ }
+
+ response.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ } finally {
+ try {
+ httpClient.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+ }
+}
diff --git a/src/main/java/de/hype/bbsentials/api/ISimpleOption.java b/src/main/java/de/hype/bbsentials/api/ISimpleOption.java
new file mode 100644
index 0000000..c6e1158
--- /dev/null
+++ b/src/main/java/de/hype/bbsentials/api/ISimpleOption.java
@@ -0,0 +1,5 @@
+package de.hype.bbsentials.api;
+
+public interface ISimpleOption {
+ void set(Object value);
+}
diff --git a/src/main/java/de/hype/bbsentials/api/Options.java b/src/main/java/de/hype/bbsentials/api/Options.java
new file mode 100644
index 0000000..7dc4b0d
--- /dev/null
+++ b/src/main/java/de/hype/bbsentials/api/Options.java
@@ -0,0 +1,13 @@
+package de.hype.bbsentials.api;
+
+import net.minecraft.client.MinecraftClient;
+
+public class Options{
+ public static void setFov(int value) {
+ ((ISimpleOption) (Object) MinecraftClient.getInstance().options.getFov()).set(value);
+ }
+ public static void setGamma(double value) {
+ ((ISimpleOption) (Object) MinecraftClient.getInstance().options.getGamma()).set(value);
+ }
+}
+
diff --git a/src/main/java/de/hype/bbsentials/chat/Chat.java b/src/main/java/de/hype/bbsentials/chat/Chat.java
new file mode 100644
index 0000000..780baa5
--- /dev/null
+++ b/src/main/java/de/hype/bbsentials/chat/Chat.java
@@ -0,0 +1,579 @@
+package de.hype.bbsentials.chat;
+
+import de.hype.bbsentials.client.BBsentials;
+import de.hype.bbsentials.client.Config;
+import net.fabricmc.fabric.api.client.message.v1.ClientReceiveMessageEvents;
+import net.fabricmc.fabric.api.client.message.v1.ClientSendMessageEvents;
+import net.minecraft.client.MinecraftClient;
+import net.minecraft.text.Text;
+import net.minecraft.util.Formatting;
+
+import javax.sound.sampled.AudioInputStream;
+import javax.sound.sampled.AudioSystem;
+import javax.sound.sampled.Clip;
+import java.io.IOException;
+import java.io.InputStream;
+import java.lang.reflect.Field;
+import java.lang.reflect.InvocationTargetException;
+import java.lang.reflect.Modifier;
+import java.time.Instant;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.Callable;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.FutureTask;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+import static de.hype.bbsentials.client.BBsentials.config;
+import static de.hype.bbsentials.client.BBsentials.getConfig;
+
+public class Chat {
+ public Chat() {
+ init();
+ }
+
+ public static String[] getVariableInfo(String packageName, String className) {
+ List<String> variableInfoList = new ArrayList<>();
+
+ // Combine the class name with the package name
+ String fullClassName = packageName + "." + className;
+
+ // Load the class
+ Class<?> clazz = null;
+ try {
+ clazz = Class.forName(fullClassName);
+ } catch (ClassNotFoundException e) {
+ e.printStackTrace();
+ }
+
+ // Extract fields of the class
+ Field[] fields = clazz.getDeclaredFields();
+
+ // Collect information for each field
+ for (Field field : fields) {
+ // Exclude transient fields
+ if (java.lang.reflect.Modifier.isTransient(field.getModifiers())) {
+ continue;
+ }
+
+ String variableName = field.getName();
+ String variablePackageName = clazz.getPackage().getName();
+ String variableClassName = clazz.getSimpleName();
+
+ String variableInfo = variableName;
+ variableInfoList.add(variableInfo);
+ }
+
+ return variableInfoList.toArray(new String[variableInfoList.size()]);
+ }
+
+ public static void setVariableValue(Object obj, String variableName, String value) throws ClassNotFoundException, NoSuchFieldException, IllegalAccessException, InstantiationException, InvocationTargetException, NoSuchMethodException {
+ if (value == null) {
+ // Handle null value case
+ sendPrivateMessageToSelf(Formatting.RED + "Invalid value: null");
+ return;
+ }
+
+ Class<?> objClass = obj.getClass();
+ Field field = objClass.getDeclaredField(variableName);
+ field.setAccessible(true);
+
+ // Get the type of the field
+ Class<?> fieldType = field.getType();
+
+ // Convert the value to the appropriate type
+ Object convertedValue = parseValue(value, fieldType);
+
+ if (Modifier.isStatic(field.getModifiers())) {
+ // If the field is static
+ field.set(null, convertedValue);
+ }
+ else {
+ field.set(obj, convertedValue);
+ }
+
+ // Check and output the value of the variable
+ sendPrivateMessageToSelf(Formatting.GREEN + "The variable " + field.getName() + " is now: " + field.get(obj));
+ }
+
+ private static Object parseValue(String value, Class<?> targetType) {
+ if (targetType == int.class || targetType == Integer.class) {
+ return Integer.parseInt(value);
+ }
+ else if (targetType == double.class || targetType == Double.class) {
+ return Double.parseDouble(value);
+ }
+ else if (targetType == float.class || targetType == Float.class) {
+ return Float.parseFloat(value);
+ }
+ else if (targetType == long.class || targetType == Long.class) {
+ return Long.parseLong(value);
+ }
+ else if (targetType == boolean.class || targetType == Boolean.class) {
+ return Boolean.parseBoolean(value);
+ }
+ else {
+ // For other types, return the original string value
+ return value;
+ }
+ }
+
+ public static void getVariableValue(Object object, String variableName) throws NoSuchFieldException, IllegalAccessException {
+ Class<?> objClass = object.getClass();
+ Field field = objClass.getDeclaredField(variableName);
+ field.setAccessible(true);
+ sendPrivateMessageToSelf(Formatting.GREEN + "The variable " + field.getName() + " is: " + field.get(object));
+ }
+
+ private void init() {
+ // Register a callback for a custom message type
+ ClientReceiveMessageEvents.CHAT.register((message, signedMessage, sender, params, receptionTimestamp) -> {
+ onEvent(message);
+ });
+ ClientReceiveMessageEvents.MODIFY_GAME.register((message, overlay) -> (onEvent(message)));
+ ClientSendMessageEvents.CHAT.register(message -> {
+ if (message.startsWith("/")) {
+ System.out.println("Sent command: " + message);
+ }
+ });
+ }
+
+ private Text onEvent(Text message) {
+ Callable<Text> callable = () -> {
+ if (!isSpam(message.toString())) {
+ if (getConfig().isDetailedDevModeEnabled()) {
+ System.out.println("got a message: " + Text.Serializer.toJson(message));
+ }
+ return handleInClient(message);
+ }
+ return message; // Return the original message if it is spam
+ };
+
+ FutureTask<Text> future = new FutureTask<>(callable);
+ Thread thread = new Thread(future);
+ thread.start();
+
+ try {
+ return future.get(); // Retrieve the result from the background thread
+ } catch (InterruptedException | ExecutionException e) {
+ // Handle exceptions, if needed
+ e.printStackTrace();
+ }
+
+ return message; // Return the original message if an exception occurred
+ }
+
+ //Handle in client
+ public Text handleInClient(Text messageOriginal) {
+ String message = extractPlainText(messageOriginal.toString()).trim();
+ if (getConfig().messageFromAlreadyReported(message) && getPlayerNameFromMessage(message) != " " && getPlayerNameFromMessage(message) != "") {
+ System.out.println("Message: " + message);
+ sendPrivateMessageToSelf(Formatting.RED + "B: " + message);
+ return null;
+ }
+ if (getConfig().isDevModeEnabled()) {
+ System.out.println("Got message to analyse internally: " + message);
+ }
+ //party accepter
+ if (message != null) {
+ if (message.contains("party")) {
+ if (message.contains("disbanded the party")) {
+ lastPartyDisbandedMessage = message;
+ partyDisbandedMap.put(getPlayerNameFromMessage(message), Instant.now());
+ if (getConfig().isDevModeEnabled()) {
+ sendPrivateMessageToSelf("Watching next 20 Sec for invite: " + getPlayerNameFromMessage(message));
+ }
+ }
+ else if (message.contains("invited you to join their party")) {
+ if (lastPartyDisbandedMessage != null && partyDisbandedMap != null) {
+ Instant lastDisbandedInstant = partyDisbandedMap.get(getPlayerNameFromMessage(lastPartyDisbandedMessage));
+ if (lastDisbandedInstant != null && lastDisbandedInstant.isAfter(Instant.now().minusSeconds(20)) && (getPlayerNameFromMessage(message).equals(getPlayerNameFromMessage(lastPartyDisbandedMessage)))) {
+ sendCommand("/p accept " + getPlayerNameFromMessage(lastPartyDisbandedMessage));
+ }
+ }
+ if (!MinecraftClient.getInstance().isWindowFocused()) {
+ sendNotification("BBsentials Party Notifier", "You got invited too a party by: " + getPlayerNameFromMessage(message));
+ }
+
+ }
+ else if (message.equals("Party > " + BBsentials.getConfig().getUsername() + ": rp")) {
+ sendCommand("/pl");
+ repartyActive = true;
+ }
+ else if (message.startsWith("Party Members (")) {
+ Config.partyMembers = new ArrayList<String>();
+ }
+ else if (message.startsWith("Party Moderators:") && repartyActive) {
+ message = message.replace("Party Moderators:", "").replace(" ●", "").replaceAll("\\s*\\[[^\\]]+\\]", "").trim();
+ if (message.contains(",")) {
+ for (int i = 0; i < message.split(",").length; i++) {
+ Config.partyMembers.add(message.split(",")[i - 1]);
+ }
+ }
+ else {
+ Config.partyMembers.add(message);
+ }
+ }
+ else if (message.startsWith("Party Members:")) {
+ message = message.replace("Party Members:", "").replace(" ●", "").replaceAll("\\s*\\[[^\\]]+\\]", "").trim();
+ if (message.contains(",")) {
+ for (int i = 0; i < message.split(",").length; i++) {
+ System.out.println("Added to plist: " + (message.split(",")[i - 1]));
+ Config.partyMembers.add(message.split(",")[i - 1]);
+ }
+ }
+ else {
+ Config.partyMembers.add(message);
+ }
+ if (repartyActive) {
+ repartyActive = false;
+ sendCommand("/p disband");
+ for (int i = 0; i < Integer.max(4, getConfig().getPlayersInParty().length); i++) {
+ if (i < getConfig().getPlayersInParty().length) {
+ sendCommand("/p invite " + getConfig().getPlayersInParty()[i]);
+ }
+ }
+ }
+ }
+ else if (message.endsWith("bb:party me") && message.startsWith("From ")) {
+ if (BBsentials.getConfig().allowBBinviteMe()) {
+ sendCommand("/p " + getPlayerNameFromMessage(message.replace("From ", "")));
+ }
+ }
+
+ } //Everything containing party is processed differently (split so fewer checks)
+ else if (message.contains("unlocked Wither Essence") && message.startsWith(getConfig().getUsername())) {
+ if (BBsentials.getConfig().isLeader()) {
+ repartyActive = true;
+ sendCommand("/pl");
+ }
+ else {
+ System.out.println("No Reparty because not leader");
+ }
+ if (getConfig().isLeaveDungeonAutomatically()) {
+ config.sender.addSendTask("/warp dhub", 3);
+ }
+ }
+ else if (message.contains("unlocked Crimson Essence") && message.startsWith(getConfig().getUsername())) {
+ if (BBsentials.getConfig().isLeader()) {
+ repartyActive = true;
+ sendCommand("/pl");
+ }
+ else {
+ System.out.println("No Reparty because not leader");
+ }
+ try {
+ Thread.sleep(3000);
+ } catch (InterruptedException e) {
+ throw new RuntimeException(e);
+ }
+ if (getConfig().isLeaveKuudraAutomatically()) {
+ sendCommand("/warp kuudra");
+ }
+ }
+ else if (message.contains("bb:test")) {
+ sendPrivateMessageToSelf(test());
+ }
+ else if ((message.endsWith("is visiting Your Garden !") || message.endsWith("is visiting Your Island !")) && !MinecraftClient.getInstance().isWindowFocused()) {
+ sendNotification("BBsentials Visit-Watcher", message);
+ }
+ else if (message.equals("Please type /report confirm to log your report for staff review.")) {
+ sendCommand("/report confirm");
+ }
+ else if (message.contains(":") && !MinecraftClient.getInstance().isWindowFocused()) {
+ if (message.startsWith("Party >")) {
+ String partyMessage = message.replaceFirst("Party >", "").trim();
+ messageOriginal = replaceAllForText(messageOriginal, "\"action\":\"run_command\",\"value\":\"/viewprofile", "\"action\":\"run_command\",\"value\":\"/hci menu pcm " + partyMessage);
+ if (partyMessage.split(":", 2)[1].toLowerCase().contains(getConfig().getUsername().toLowerCase()) || (partyMessage.toLowerCase().contains(getConfig().getNickname().toLowerCase() + " ") && getConfig().getNotifForParty().toLowerCase().equals("nick")) || getConfig().getNotifForParty().toLowerCase().equals("all")) {
+ sendNotification("BBsentials Party Chat Notification", partyMessage);
+ }
+ }
+ else if (message.startsWith("From ")) {
+ String sender = getPlayerNameFromMessage(message.replaceFirst("From", "").trim());
+ String content = message.split(":", 2)[1];
+ sendNotification("BBsentials Message Notifier", sender + " sent you the following message: " + content);
+ }
+ else if (message.toLowerCase().contains("party")) {
+ if ((message.contains("Party Leader:") && !message.contains(getConfig().getUsername())) || message.equals("You are not currently in a party.") || (message.contains("warped the party into a Skyblock Dungeon") && !message.startsWith(getConfig().getUsername()) || (!message.startsWith("The party was transferred to " + getConfig().getUsername()) && message.startsWith("The party was transferred to"))) || message.equals(getConfig().getUsername() + " is now a Party Moderator") || (message.equals("The party was disbanded because all invites expired and the party was empty.")) || (message.contains("You have joined ") && message.contains("'s party!")) || (message.contains("Party Leader, ") && message.contains(" , summoned you to their server.")) || (message.contains("warped to your dungeon"))) {
+ BBsentials.getConfig().setIsLeader(false);
+ if (getConfig().isDetailedDevModeEnabled()) {
+ sendPrivateMessageToSelf("Leader: " + getConfig().isLeader());
+ }
+ }
+ if ((message.equals("Party Leader: " + getConfig().getUsername() + " ●")) || (message.contains(getConfig().getUsername() + " warped the party to a SkyBlock dungeon!")) || message.startsWith("The party was transferred to " + getConfig().getUsername()) || message.equals("Raul_J has promoted " + getConfig().getUsername() + " to Party Leader") || (message.contains("warped to your dungeon"))) {
+ BBsentials.getConfig().setIsLeader(true);
+ if (getConfig().isDetailedDevModeEnabled()) {
+ sendPrivateMessageToSelf("Leader: " + getConfig().isLeader());
+ }
+ }
+ else if (repartyActive && !BBsentials.getConfig().isLeader()) {
+ repartyActive = false;
+ sendPrivateMessageToSelf("Resetted Reparty is Active since you are not leader ");
+ }
+ }
+ else {
+ String[] temp = message.split(":", 2);
+ String content = temp[temp.length - 1];
+ if (temp.length == 2 && (content.toLowerCase().contains(getConfig().getUsername().toLowerCase()) || content.toLowerCase().contains(config.getNickname().toLowerCase() + " "))) {
+ sendNotification("BBsentials Notifier", "You got mentioned in chat! " + content);
+ }
+ }
+ }
+ else if (message.equals("You laid an Egg!")) {
+ Thread eggThread = new Thread(() -> {
+ try {
+ Thread.sleep(21000); // Wait for 21 seconds (in milliseconds)
+ sendPrivateMessageToSelf("Chicken Head is ready");
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+ });
+
+ eggThread.start();
+ }
+ else if (message.contains("[OPEN MENU]") || message.contains("YES")) {
+ setChatPromtId(messageOriginal.toString());
+ }
+
+ }
+ return messageOriginal;
+ }
+
+ //{"strikethrough":false,"extra":[{"strikethrough":false,"clickEvent":{"action":"run_command","value":"/viewprofile 4fa1228c-8dd6-47c4-8fe3-b04b580311b8"},"hoverEvent":{"action":"show_text","contents":{"strikethrough":false,"text":"§eClick here to view §bHype_the_Time§e's profile"}},"text":"§9Party §8> §b[MVP§2+§b] Hype_the_Time§f: "},{"bold":false,"italic":false,"underlined":false,"strikethrough":false,"obfuscated":false,"text":"h:test"}],"text":""}// {"strikethrough":false,"extra":[{"strikethrough":false,"clickEvent":{"action":"run_command","value":"/viewprofile f772b2c7-bd2a-46e1-b1a2-41fa561157d6"},"hoverEvent":{"action":"show_text","contents":{"strikethrough":false,"text":"§eClick here to view §bShourtu§e's profile"}},"text":"§9Party §8> §b[MVP§c+§b] Shourtu§f: "},{"bold":false,"italic":false,"underlined":false,"strikethrough":false,"obfuscated":false,"text":"Hype_the_Time TEST"}],"text":""}
+ //{"strikethrough":false,"extra":[{"strikethrough":false,"clickEvent":{"action":"run_command","value":"/viewprofile 4fa1228c-8dd6-47c4-8fe3-b04b580311b8"},"hoverEvent":{"action":"show_text","contents":{"strikethrough":false,"text":"§eClick here to view §bHype_the_Time§e's profile"}},"text":"§9Party §8> §b[MVP§2+§b] Hype_the_Time§f: "},{"bold":false,"italic":false,"underlined":false,"strikethrough":false,"obfuscated":false,"text":"h:test"}],"text":""}
+ private final Map<String, Instant> partyDisbandedMap = new HashMap<>();
+ private String lastPartyDisbandedMessage = null;
+
+ public static String getPlayerNameFromMessage(String message) {
+ message = message.replaceAll("\\[.*?\\]", "").trim();
+ message = message.replaceAll("-----------------------------------------------------", "").replaceAll(":", "");
+ String[] temp = message.split(" ");
+ String playerName = "";
+
+ for (int i = 0; i < temp.length; i++) {
+ if (!temp[i].equals(" ") && !temp[i].equals("")) {
+ playerName = temp[i];
+ break; // Stop looping after finding the first non-empty value
+ }
+ }
+
+ // Remove the rank from the player name, if it exists
+ Pattern rankPattern = Pattern.compile("\\s*\\[[^\\]]+\\]");
+ playerName = rankPattern.matcher(playerName).replaceAll(" ");
+
+ return playerName;
+ }
+
+ public String extractPlainText(String input) {
+ String returns = "";
+ String[] literals = input.split("literal\\{");
+ if (!input.startsWith("literal")) {
+ literals[0] = "";
+ }
+ for (int i = 0; i < literals.length; i++) {
+ if (dontExclude(literals, i) && !literals[i].equals("")) {
+ String literal = literals[i].split("}")[0];
+
+ if (!literal.isEmpty()) {
+ returns = returns + literal;
+ }
+ }
+ }
+ // Remove § formatting
+ returns = returns.replaceAll("§.", "");
+ // Remove brackets that contain only uppercase letters or pluses
+ returns = returns.replaceAll("\\[[A-Z+]+\\]", "");
+ returns = returns.replaceAll("\\[[0-9]+\\]", "");
+ returns = returns.trim();
+ returns = returns.replaceAll("\\s+", " ");
+
+ return returns;
+ }
+
+ private boolean dontExclude(String[] s, int i) {
+ if ((i - 1) < 0) {
+ return true;
+ }
+ else {
+ if (s[i - 1].endsWith("value='")) {
+ return false;
+ }
+ else {
+ return true;
+ }
+ }
+ }
+
+ public boolean isSpam(String message) {
+ if (message.contains("Mana")) return true;
+ if (message.contains("Achievement Points")) return true;
+ return false;
+ }
+
+ private boolean repartyActive = false;
+
+ public String test() {
+ //put test code here
+ sendNotification("test", "This is an example which was run of the h:test test");
+ return new String();
+ }
+
+ private static String removeMultipleSpaces(String input) {
+ return input.replaceAll("\\s+", " ");
+ }
+
+ public static void sendPrivateMessageToSelf(String message) {
+ MinecraftClient client = MinecraftClient.getInstance();
+ if (client.player != null) {
+ client.player.sendMessage(Text.of((Formatting.RED + message.formatted(Formatting.RED))));
+ }
+ }
+
+ public static void sendPrivateMessageToSelfText(Text message) {
+ MinecraftClient client = MinecraftClient.getInstance();
+ if (client.player != null) {
+ client.player.sendMessage(message);
+ }
+ }
+
+ public static void sendCommand(String s) {
+ getConfig().sender.addSendTask(s);
+ }
+
+ public void sendNotification(String title, String text) {
+ Thread soundThread = new Thread(() -> {
+ try {
+ InputStream inputStream = getClass().getResourceAsStream("/sounds/mixkit-sci-fi-confirmation-914.wav");
+ AudioInputStream audioInputStream = AudioSystem.getAudioInputStream(inputStream);
+ Clip clip = AudioSystem.getClip();
+ clip.open(audioInputStream);
+ clip.start();
+ Thread.sleep(clip.getMicrosecondLength() / 1000);
+ clip.close();
+ audioInputStream.close();
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ });
+
+ soundThread.start();
+
+ List<String> argsList = new ArrayList<>();
+ argsList.add("--title");
+ argsList.add(title);
+ argsList.add("--passivepopup");
+ argsList.add(text);
+ argsList.add("5");
+
+ try {
+ ProcessBuilder processBuilder = new ProcessBuilder();
+ processBuilder.command("kdialog");
+ processBuilder.command().addAll(argsList);
+
+ Process process = processBuilder.start();
+ process.waitFor();
+ } catch (IOException | InterruptedException e) {
+ e.printStackTrace();
+ }
+ }
+
+ public static Text createClientSideTellraw(String tellrawInput) {
+ Text formattedMessage = null;
+ try {
+ formattedMessage = Text.Serializer.fromJson(tellrawInput);
+ } catch (Exception e) {
+ e.printStackTrace();
+ System.out.println("Invalid Json: \n" + tellrawInput);
+ }
+ return formattedMessage;
+ }
+
+ public static void followMenu(String menu, String message) {
+ // Check the "menu" argument and execute the appropriate logic
+ String command;
+ String username = getPlayerNameFromMessage(message);
+ if (message.contains(":")) {
+ message = message.split(":", 2)[1].trim();
+ if (menu.equalsIgnoreCase("pcm")) {
+ command = "[\"\",{\"text\":\"@@username\",\"color\":\"gray\",\"clickEvent\":{\"action\":\"suggest_command\",\"value\":\"/pc @username\"}},{\"text\":\" [Copy_Message]\",\"color\":\"blue\",\"clickEvent\":{\"action\":\"copy_to_clipboard\",\"value\":\"Copy-Text-Message\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[\"Copy the message the Player send without their name into the clipboard.\"]}},{\"text\":\" [Kick_Player]\",\"color\":\"dark_red\",\"clickEvent\":{\"action\":\"run_command\",\"value\":\"/p kick @username\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[\"Kick the player from the party\"]}},{\"text\":\" [Promote_Player]\",\"color\":\"dark_green\",\"clickEvent\":{\"action\":\"run_command\",\"value\":\"/p promote @username\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[\"Promote the player\"]}},{\"text\":\" [Demote_Player]\",\"color\":\"red\",\"clickEvent\":{\"action\":\"run_command\",\"value\":\"/p demote @username\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[\"Demote the player\"]}},{\"text\":\" [Transfer_to_Player]\",\"color\":\"gold\",\"clickEvent\":{\"action\":\"run_command\",\"value\":\"/p transfer @username\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[\"Transfer the Party to the player\"]}},{\"text\":\" [Mute/Unmute_Party]\",\"color\":\"dark_aqua\",\"clickEvent\":{\"action\":\"run_command\",\"value\":\"/p mute @username\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[\"Mutes the ENTIRE party but party moderators or Hypixel Staff can still type.\"]}}]";
+ //{"jformat":8,"jobject":[{"bold":false,"italic":false,"underlined":false,"strikethrough":false,"obfuscated":false,"font":null,"color":"gray","insertion":"","click_event_type":"suggest_command","click_event_value":"/pc @username","hover_event_type":"none","hover_event_value":"","hover_event_object":{},"hover_event_children":[],"text":"@username"},{"bold":false,"italic":false,"underlined":false,"strikethrough":false,"obfuscated":false,"font":null,"color":"blue","insertion":"","click_event_type":"copy_to_clipboard","click_event_value":"Copy-Text-Message","hover_event_type":"show_text","hover_event_value":"","hover_event_object":{},"hover_event_children":[{"bold":false,"italic":false,"underlined":false,"strikethrough":false,"obfuscated":false,"font":null,"color":"none","insertion":"","click_event_type":"none","click_event_value":"","hover_event_type":"none","hover_event_value":"","hover_event_object":{},"hover_event_children":[],"text":"Copy the message the Player send without their name into the clipboard."}],"text":" [Copy_Message]"},{"bold":false,"italic":false,"underlined":false,"strikethrough":false,"obfuscated":false,"font":null,"color":"dark_red","insertion":"","click_event_type":"run_command","click_event_value":"/p kick @username","hover_event_type":"show_text","hover_event_value":"","hover_event_object":{},"hover_event_children":[{"bold":false,"italic":false,"underlined":false,"strikethrough":false,"obfuscated":false,"font":null,"color":"none","insertion":"","click_event_type":"none","click_event_value":"","hover_event_type":"none","hover_event_value":"","hover_event_object":{},"hover_event_children":[],"text":"Kick the player from the party"}],"text":" [Kick_Player]"},{"bold":false,"italic":false,"underlined":false,"strikethrough":false,"obfuscated":false,"font":null,"color":"dark_green","insertion":"","click_event_type":"run_command","click_event_value":"/p promote @username","hover_event_type":"show_text","hover_event_value":"","hover_event_object":{},"hover_event_children":[{"bold":false,"italic":false,"underlined":false,"strikethrough":false,"obfuscated":false,"font":null,"color":"none","insertion":"","click_event_type":"none","click_event_value":"","hover_event_type":"none","hover_event_value":"","hover_event_object":{},"hover_event_children":[],"text":"Promote the player"}],"text":" [Promote_Player]"},{"bold":false,"italic":false,"underlined":false,"strikethrough":false,"obfuscated":false,"font":null,"color":"red","insertion":"","click_event_type":"run_command","click_event_value":"/p demote @username","hover_event_type":"show_text","hover_event_value":"","hover_event_object":{},"hover_event_children":[{"bold":false,"italic":false,"underlined":false,"strikethrough":false,"obfuscated":false,"font":null,"color":"none","insertion":"","click_event_type":"none","click_event_value":"","hover_event_type":"none","hover_event_value":"","hover_event_object":{},"hover_event_children":[],"text":"Demote the player"}],"text":" [Demote_Player]"},{"bold":false,"italic":false,"underlined":false,"strikethrough":false,"obfuscated":false,"font":null,"color":"gold","insertion":"","click_event_type":"run_command","click_event_value":"/p transfer @username","hover_event_type":"show_text","hover_event_value":"","hover_event_object":{},"hover_event_children":[{"bold":false,"italic":false,"underlined":false,"strikethrough":false,"obfuscated":false,"font":null,"color":"none","insertion":"","click_event_type":"none","click_event_value":"","hover_event_type":"none","hover_event_value":"","hover_event_object":{},"hover_event_children":[],"text":"Transfer the Party to the player"}],"text":" [Transfer_to_Player]"},{"bold":false,"italic":false,"underlined":false,"strikethrough":false,"obfuscated":false,"font":null,"color":"dark_aqua","insertion":"","click_event_type":"run_command","click_event_value":"/p mute @username","hover_event_type":"show_text","hover_event_value":"","hover_event_object":{},"hover_event_children":[{"bold":false,"italic":false,"underlined":false,"strikethrough":false,"obfuscated":false,"font":null,"color":"none","insertion":"","click_event_type":"none","click_event_value":"","hover_event_type":"none","hover_event_value":"","hover_event_object":{},"hover_event_children":[],"text":"Mutes the ENTIRE party but party moderators or Hypixel Staff can still type."}],"text":" [Mute/Unmute_Party]"}],"command":"%s","jtemplate":"tellraw"}
+ }
+ else if (menu.equalsIgnoreCase("sbacm")) {
+ command = "[\"\",\"\\n\",{\"text\":\"@@username\",\"color\":\"gray\",\"clickEvent\":{\"action\":\"suggest_command\",\"value\":\"@username\"}},{\"text\":\" [Party_Player]\",\"color\":\"gold\",\"clickEvent\":{\"action\":\"run_command\",\"value\":\"/p invite @username\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[\"Invite the player to the party\"]}},{\"text\":\" [Ignore_Player]\",\"color\":\"yellow\",\"clickEvent\":{\"action\":\"suggest_command\",\"value\":\"/ignore add @username\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[\"Add the player to your ignore list.\"]}},{\"text\":\" [Chat_Report_Player]\",\"color\":\"dark_red\",\"clickEvent\":{\"action\":\"suggest_command\",\"value\":\"/creport @username\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[\"Chat report the user with /creport.\"]}},{\"text\":\" [Visit_Player]\",\"color\":\"dark_green\",\"insertion\":\" \",\"clickEvent\":{\"action\":\"run_command\",\"value\":\"/visit @username\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[]}},{\"text\":\" [/Invite_Player]\",\"color\":\"green\",\"insertion\":\" \",\"clickEvent\":{\"action\":\"run_command\",\"value\":\"/invite @username\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[\"/invite the player to visit your Island / Garden.\"]}},{\"text\":\" [Copy_Message] \",\"color\":\"blue\",\"clickEvent\":{\"action\":\"copy_to_clipboard\",\"value\":\"Copy-Text-Message\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[\"Copy the message the user send without their prefixes nor their username\"]}},{\"text\":\" [Copy_Username]\",\"color\":\"dark_aqua\",\"insertion\":\" \",\"clickEvent\":{\"action\":\"copy_to_clipboard\",\"value\":\"@username\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[\"Copy the players username into the clipboard.\"]}},{\"text\":\" [/msg_Chat_Player]\",\"color\":\"light_purple\",\"clickEvent\":{\"action\":\"run_command\",\"value\":\"/msg @username\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[\"/msg the Player. the chat will be set to message them. This means you do not need to type /msg upfront. To return to normal do /chat a\"]}},{\"text\":\" [Sky_shiiyu_player]\",\"color\":\"aqua\",\"clickEvent\":{\"action\":\"open_url\",\"value\":\"https://sky.shiiyu.moe/stats/@username\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[\"Opens the players Skyblock Profile in Sky Crypt (sky.shiiyu.moe)\"]}},\"\\n\"]";
+ }
+ else if (menu.equalsIgnoreCase("acm")) {
+ command = "[\"\",\"\\n\",{\"text\":\"@@username\",\"color\":\"gray\",\"clickEvent\":{\"action\":\"suggest_command\",\"value\":\"@username\"}},{\"text\":\" [Party_Player]\",\"color\":\"gold\",\"clickEvent\":{\"action\":\"run_command\",\"value\":\"/p invite @username\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[\"Invite the player to the party\"]}},{\"text\":\" [Ignore_Player]\",\"color\":\"yellow\",\"clickEvent\":{\"action\":\"suggest_command\",\"value\":\"/ignore add @username\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[\"Add the player to your ignore list.\"]}},{\"text\":\" [Chat_Report_Player]\",\"color\":\"dark_red\",\"clickEvent\":{\"action\":\"suggest_command\",\"value\":\"/creport @username\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[\"Chat report the user with /creport.\"]}},{\"text\":\" [Copy_Message] \",\"color\":\"blue\",\"clickEvent\":{\"action\":\"copy_to_clipboard\",\"value\":\"Copy-Text-Message\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[\"Copy the message the user send without their prefixes nor their username\"]}},{\"text\":\" [Copy_Username]\",\"color\":\"dark_aqua\",\"insertion\":\" \",\"clickEvent\":{\"action\":\"copy_to_clipboard\",\"value\":\"@username\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[\"Copy the players username into the clipboard.\"]}},{\"text\":\" [/msg_Chat_Player]\",\"color\":\"light_purple\",\"clickEvent\":{\"action\":\"run_command\",\"value\":\"/msg @username\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[\"/msg the Player. the chat will be set to message them. This means you do not need to type /msg upfront. To return to normal do /chat a\"]}}";
+ }
+ else {
+ // Handle unrecognized menu argument
+ sendPrivateMessageToSelf(Formatting.RED + "Unrecognized menu argument! Do not use this command unless you know exactly what you are doing aka only use it as a developer!");
+ return;
+ }
+ command = command.replaceAll("@username", username);
+ command = command.replaceAll("Copy-Text-Message", message);
+ sendPrivateMessageToSelfText(createClientSideTellraw(command));
+ }
+ else {
+ sendPrivateMessageToSelf("Invalid message!: " + message);
+ }
+ }
+
+ public static void setChatPromtId(String logMessage) {
+ String cbUUIDPattern = "/cb ([a-fA-F0-9-]+)";
+ Pattern cbPattern = Pattern.compile(cbUUIDPattern);
+ Matcher cbMatcher = cbPattern.matcher(logMessage);
+
+ String yesClickAction = "/chatprompt ([a-fA-F0-9-]+) YES";
+ Pattern yesPattern = Pattern.compile(yesClickAction);
+ Matcher yesMatcher = yesPattern.matcher(logMessage);
+ String lastPrompt = null;
+ if (cbMatcher.find()) {
+ lastPrompt = cbMatcher.group(1);
+ String finalLastPrompt1 = lastPrompt;
+ new Thread(new Runnable() {
+ @Override
+ public void run() {
+ BBsentials.getConfig().setLastChatPromptAnswer("/cb " + finalLastPrompt1);
+ try {
+ Thread.sleep(10 * 1000);
+ } catch (InterruptedException e) {
+ throw new RuntimeException(e);
+ }
+ BBsentials.getConfig().setLastChatPromptAnswer(null);
+ return;
+ }
+ }).start();
+ }
+ if (yesMatcher.find()) {
+ lastPrompt = yesMatcher.group(1);
+ String finalLastPrompt = lastPrompt;
+ new Thread(new Runnable() {
+ @Override
+ public void run() {
+ BBsentials.getConfig().setLastChatPromptAnswer("/chatprompt " + finalLastPrompt + " YES");
+ try {
+ Thread.sleep(10 * 1000);
+ } catch (InterruptedException e) {
+ throw new RuntimeException(e);
+ }
+ BBsentials.getConfig().setLastChatPromptAnswer(null);
+ return;
+ }
+ }).start();
+
+ }
+ }
+
+ public static Text replaceAllForText(Text input, String replace, String replaceWith) {
+ String text = Text.Serializer.toJson(input);
+ if (text.contains(replace)) {
+ text = text.replaceAll("\\w{8}-\\w{4}-\\w{4}-\\w{4}-\\w{12}", "");
+ }
+ text = text.replace(replace, replaceWith);
+ Text output = Text.Serializer.fromJson(text);
+ return output;
+ }
+} \ No newline at end of file
diff --git a/src/main/java/de/hype/bbsentials/chat/Sender.java b/src/main/java/de/hype/bbsentials/chat/Sender.java
new file mode 100644
index 0000000..4590b5f
--- /dev/null
+++ b/src/main/java/de/hype/bbsentials/chat/Sender.java
@@ -0,0 +1,106 @@
+package de.hype.bbsentials.chat;
+
+import net.minecraft.client.MinecraftClient;
+import net.minecraft.text.Text;
+import net.minecraft.util.Formatting;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import static de.hype.bbsentials.chat.Chat.sendPrivateMessageToSelf;
+import static de.hype.bbsentials.chat.Chat.sendPrivateMessageToSelfText;
+
+public class Sender {
+ private final List<String> sendQueue;
+ private final List<Double> sendQueueTiming;
+ private final List<Boolean> hidden;
+
+
+ public Sender() {
+ this.sendQueue = new ArrayList<>();
+ this.sendQueueTiming = new ArrayList<>();
+ this.hidden = new ArrayList<>();
+ startSendingThread();
+ }
+
+ public void addSendTask(String task, double timing) {
+ synchronized (sendQueue) {
+ sendPrivateMessageToSelfText(Text.literal(Formatting.GREEN + "Scheduled send-task (as " + sendQueueTiming.size() + " in line): " + task + " | Delay: " + timing));
+ sendQueueTiming.add(timing);
+ sendQueue.add(task);
+ hidden.add(false);
+ sendQueue.notify(); // Notify the waiting thread that a new String has been added
+ }
+ }
+
+ public void addHiddenSendTask(String task, double timing) {
+ synchronized (sendQueue) {
+ sendQueueTiming.add(timing);
+ sendQueue.add(task);
+ hidden.add(true);
+
+ sendQueue.notify(); // Notify the waiting thread that a new String has been added
+ }
+ }
+
+ public void addImmediateSendTask(String task) {
+ synchronized (sendQueue) {
+ sendQueueTiming.add(0, 0.0);
+ sendQueue.add(0, task);
+ hidden.add(false);
+
+ sendQueue.notify(); // Notify the waiting thread that a new String has been added
+ }
+ }
+
+ public void addSendTask(String task) {
+ addSendTask(task, 1);
+ }
+
+ public void startSendingThread() {
+ Thread sendingThread = new Thread(new SendingRunnable());
+ sendingThread.start();
+ }
+
+ private class SendingRunnable implements Runnable {
+ @Override
+ public void run() {
+ while (true) {
+ String task = getNextTask();
+ if (task != null) {
+ send(task, sendQueueTiming.remove(0), hidden.remove(0));
+ }
+ else {
+ synchronized (sendQueue) {
+ try {
+ sendQueue.wait(); // Wait for new Send
+ } catch (InterruptedException e) {
+ throw new RuntimeException(e);
+ }
+ }
+ }
+ }
+ }
+
+ private String getNextTask() {
+ synchronized (sendQueue) {
+ if (!sendQueue.isEmpty()) {
+ return sendQueue.remove(0);
+ }
+ return null;
+ }
+ }
+
+ private void send(String toSend, double timing, boolean hidden) {
+ try {
+ Thread.sleep((long) (timing * 1000)); // Simulate the send operation
+ } catch (InterruptedException e) {
+ throw new RuntimeException(e);
+ }
+ MinecraftClient.getInstance().getNetworkHandler().sendChatMessage(toSend);
+ if (!hidden) {
+ sendPrivateMessageToSelf("Sent Command to Server: " + toSend);
+ }
+ }
+ }
+}
diff --git a/src/main/java/de/hype/bbsentials/client/BBsentials.java b/src/main/java/de/hype/bbsentials/client/BBsentials.java
new file mode 100644
index 0000000..596d194
--- /dev/null
+++ b/src/main/java/de/hype/bbsentials/client/BBsentials.java
@@ -0,0 +1,174 @@
+package de.hype.bbsentials.client;
+
+import com.mojang.brigadier.arguments.StringArgumentType;
+import de.hype.bbsentials.api.Options;
+import de.hype.bbsentials.chat.Chat;
+import de.hype.bbsentials.client.Commands.CommandsOLD;
+import de.hype.bbsentials.communication.BBsentialConnection;
+import net.fabricmc.api.ClientModInitializer;
+import net.fabricmc.fabric.api.client.command.v2.ClientCommandManager;
+import net.fabricmc.fabric.api.client.command.v2.ClientCommandRegistrationCallback;
+import net.fabricmc.fabric.api.client.event.lifecycle.v1.ClientTickEvents;
+import net.fabricmc.fabric.api.client.keybinding.v1.KeyBindingHelper;
+import net.fabricmc.fabric.api.client.networking.v1.ClientPlayConnectionEvents;
+import net.minecraft.client.MinecraftClient;
+import net.minecraft.client.option.KeyBinding;
+import net.minecraft.client.util.InputUtil;
+import net.minecraft.command.CommandSource;
+import net.minecraft.util.Formatting;
+import org.lwjgl.glfw.GLFW;
+
+import java.lang.reflect.InvocationTargetException;
+import java.util.ArrayList;
+import java.util.List;
+
+import static de.hype.bbsentials.chat.Chat.*;
+
+public class BBsentials implements ClientModInitializer {
+ private boolean initialised = false;
+ public static Config config;
+ public static BBsentialConnection bbserver;
+ public static CommandsOLD coms;
+
+ /**
+ * Runs the mod initializer on the client environment.
+ */
+ @Override
+ public void onInitializeClient() {
+ ClientPlayConnectionEvents.JOIN.register((a, b, c) -> {
+ if (!initialised) {
+ config = Config.load();
+ Options.setGamma(10);
+ Chat chat = new Chat();
+ if (Config.isBingoTime() || config.overrideBingoTime()) {
+ connectToBBserver();
+ }
+ initialised = true;
+ }
+ }
+ );
+ KeyBinding promptKeyBind = new KeyBinding("Chat Prompt Yes / Open Menu", InputUtil.Type.KEYSYM, GLFW.GLFW_KEY_R, "BBsentials");
+ KeyBindingHelper.registerKeyBinding(promptKeyBind);
+ ClientTickEvents.END_CLIENT_TICK.register(client -> {
+ if (promptKeyBind.wasPressed()) {
+ if (config.getLastChatPromptAnswer() != null) {
+ if (config.isDetailedDevModeEnabled()){
+ Chat.sendPrivateMessageToSelf(config.getLastChatPromptAnswer());}
+ MinecraftClient.getInstance().getNetworkHandler().sendChatMessage(config.getLastChatPromptAnswer());
+ }
+ config.setLastChatPromptAnswer(null);
+ }
+ });
+ }
+
+ public static Config getConfig() {
+ return config;
+ }
+
+ public static void connectToBBserver() {
+ if (bbserver != null) {
+ bbserver.sendHiddenMessage("exit");
+ }
+ bbserver = new BBsentialConnection();
+ bbserver.setMessageReceivedCallback(message -> bbserver.onMessageReceived(message));
+ bbserver.connect(config.getBBServerURL(), 5000);
+ ClientCommandRegistrationCallback.EVENT.register((dispatcher, registryAccess) -> {
+ dispatcher.register(ClientCommandManager.literal("bbi")
+ .then(ClientCommandManager.literal("reconnect")
+ .executes((context) -> {
+ connectToBBserver();
+ return 1;
+ }))
+ .then(ClientCommandManager.literal("config")
+ .then(ClientCommandManager.argument("category", StringArgumentType.string())
+ .suggests((context, builder) -> {
+ // Provide tab-completion options for config subfolder
+ return CommandSource.suggestMatching(new String[]{"save", "reset", "load"}, builder);
+ }).executes((context) -> {
+ String category = StringArgumentType.getString(context, "category");
+ switch (category) {
+ case "save":
+ getConfig().save();
+ sendPrivateMessageToSelf(Formatting.GREEN + "Saved config successfully");
+ break;
+ case "load":
+ BBsentials.config = Config.load();
+ break;
+ case "reset":
+ // Reset logic here
+ break;
+ }
+ return 1;
+ }))
+ .then(ClientCommandManager.literal("set-value")
+ .then(ClientCommandManager.argument("className", StringArgumentType.string())
+ .suggests((context, builder) -> {
+ // Provide tab-completion options for classes
+ ArrayList<String> classNames = new ArrayList<>();
+ classNames.add("Config");
+ // Replace with your own logic to retrieve class names
+ return CommandSource.suggestMatching(classNames, builder);
+ })
+ .then(ClientCommandManager.argument("variableName", StringArgumentType.string())
+ .suggests((context, builder) -> {
+ // Provide tab-completion options for variable names
+ List<String> variableNames;
+ variableNames = List.of(getVariableInfo("de.hype.bbsentials.client", "Config"));
+ return CommandSource.suggestMatching(variableNames, builder);
+ })
+ .then(ClientCommandManager.argument("variableValue", StringArgumentType.string())
+ .executes((context) -> {
+ // Handle "variableName" and "variableValue" logic here
+ String variableName = StringArgumentType.getString(context, "variableName");
+ String variableValue = StringArgumentType.getString(context, "variableValue");
+ try {
+ if (!variableName.contains("dev")||config.bbsentialsRoles.contains("dev")){
+ setVariableValue(getConfig(), variableName, variableValue);}
+ getConfig().save();
+ } catch (ClassNotFoundException | NoSuchFieldException |
+ IllegalAccessException |
+ InstantiationException |
+ InvocationTargetException |
+ NoSuchMethodException e) {
+ Chat.sendPrivateMessageToSelf("§cInvalid variable or value");
+ }
+ return 1;
+ })))))
+ .then(ClientCommandManager.literal("get-value")
+ .then(ClientCommandManager.argument("className", StringArgumentType.string())
+ .suggests((context, builder) -> {
+ // Provide tab-completion options for classes
+ ArrayList<String> classNames = new ArrayList<>();
+ classNames.add("Config");
+ // Replace with your own logic to retrieve class names
+ return CommandSource.suggestMatching(classNames, builder);
+ })
+ .then(ClientCommandManager.argument("variableName", StringArgumentType.string())
+ .suggests((context, builder) -> {
+ // Provide tab-completion options for variable names
+ List<String> variableNames;
+ variableNames = List.of(getVariableInfo("de.hype.bbsentials.client", "Config"));
+ return CommandSource.suggestMatching(variableNames, builder);
+ }).executes((context) -> {
+ // Handle "variableName" and "variableValue" logic here
+ String variableName = StringArgumentType.getString(context, "variableName");
+ try {
+ Chat.getVariableValue(getConfig(), variableName);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return 1;
+ }))).executes((context) -> {
+ // Handle the case when "config" argument is not provided
+ // ...
+ return 1;
+ })))
+ );
+ }); //bbi}
+ }
+
+ public static void refreshCommands() {
+ coms = new CommandsOLD();
+ }
+
+} \ No newline at end of file
diff --git a/src/main/java/de/hype/bbsentials/client/Commands/CommandsOLD.java b/src/main/java/de/hype/bbsentials/client/Commands/CommandsOLD.java
new file mode 100644
index 0000000..bdb7478
--- /dev/null
+++ b/src/main/java/de/hype/bbsentials/client/Commands/CommandsOLD.java
@@ -0,0 +1,308 @@
+package de.hype.bbsentials.client.Commands;
+
+import com.mojang.brigadier.arguments.IntegerArgumentType;
+import com.mojang.brigadier.arguments.StringArgumentType;
+import de.hype.bbsentials.client.BBsentials;
+import de.hype.bbsentials.communication.BBsentialConnection;
+import net.fabricmc.fabric.api.client.command.v2.ClientCommandManager;
+import net.fabricmc.fabric.api.client.command.v2.ClientCommandRegistrationCallback;
+import net.minecraft.command.CommandSource;
+
+import static de.hype.bbsentials.client.BBsentials.*;
+
+public class CommandsOLD {
+ public CommandsOLD() {
+ ClientCommandRegistrationCallback.EVENT.register((dispatcher, registryAccess) -> {
+ dispatcher.register(ClientCommandManager.literal("warp").then(ClientCommandManager.argument("destination", StringArgumentType.string()).suggests((context, builder) -> {
+ // Provide tab-completion options for menu subfolder
+ return CommandSource.suggestMatching(new String[]{"desert", "hub", "dhub", "nether", "isle", "wizard", "portal", "mines", "forge", "ch", "crystals", "nucleus", "end", "drag", "void", "castle", "howl", "park", "jungle", "nest", "arachne", "spider", "deep", "barn", "home", "kuurda", "wasteland", "dragontail", "scarleton", "smold", "garden", "da", "crypt", "museum", "trapper", "dungeon_hub"}, builder);
+ }).executes((context) -> {
+ // Handle "variableName" and "variableValue" logic here
+ String destination = StringArgumentType.getString(context, "destination");
+ getConfig().sender.addSendTask("/warp " + destination, 0);
+ return 1;
+ })));
+ }); //warp test
+ ClientCommandRegistrationCallback.EVENT.register((dispatcher, registryAccess) -> {
+ dispatcher.register(ClientCommandManager.literal("creport")
+ .then(ClientCommandManager.argument("Player_Name", StringArgumentType.string())
+ .executes((context) -> {
+ String playerName = StringArgumentType.getString(context, "Player_Name");
+ getConfig().sender.addSendTask("/creport " + playerName, 0);
+ getConfig().addReported(playerName);
+ return 1;
+ })));
+ });//creport helper → no double report during same launch
+ ClientCommandRegistrationCallback.EVENT.register((dispatcher, registryAccess) -> {
+ dispatcher.register(ClientCommandManager.literal("hp").then(ClientCommandManager.literal("accept").then(ClientCommandManager.argument("player", StringArgumentType.string()).executes((context) -> {
+ String player = StringArgumentType.getString(context, "player");
+ getConfig().sender.addImmediateSendTask("/party accept " + player);
+ return 1;
+ }))).then(ClientCommandManager.literal("chat").executes((context) -> {
+ getConfig().sender.addImmediateSendTask("/party chat");
+ return 1;
+ })).then(ClientCommandManager.literal("demote").then(ClientCommandManager.argument("player", StringArgumentType.string()).suggests((context, builder) -> {
+ // Provide tab-completion options for menu subfolder
+ return CommandSource.suggestMatching(getConfig().getPlayersInParty(), builder);
+ }).executes((context) -> {
+ String player = StringArgumentType.getString(context, "player");
+ getConfig().sender.addImmediateSendTask("/party demote " + player);
+ return 1;
+ }))).then(ClientCommandManager.literal("disband").executes((context) -> {
+ getConfig().sender.addImmediateSendTask("/party disband");
+ return 1;
+ })).then(ClientCommandManager.literal("kick").then(ClientCommandManager.argument("player", StringArgumentType.string()).suggests((context, builder) -> {
+ // Provide tab-completion options for menu subfolder
+ return CommandSource.suggestMatching(getConfig().getPlayersInParty(), builder);
+ }).executes((context) -> {
+ String player = StringArgumentType.getString(context, "player");
+ getConfig().sender.addImmediateSendTask("/party kick " + player);
+ return 1;
+ }))).then(ClientCommandManager.literal("kickoffline").executes((context) -> {
+ getConfig().sender.addImmediateSendTask("/party kickoffline");
+ return 1;
+ })).then(ClientCommandManager.literal("leave").executes((context) -> {
+ getConfig().sender.addImmediateSendTask("/party leave");
+ return 1;
+ })).then(ClientCommandManager.literal("list").executes((context) -> {
+ getConfig().sender.addImmediateSendTask("/party list");
+ return 1;
+ })).then(ClientCommandManager.literal("mute").executes((context) -> {
+ getConfig().sender.addImmediateSendTask("/party mute");
+ return 1;
+ })).then(ClientCommandManager.literal("poll").then(ClientCommandManager.argument("question/answer/answer/answer", StringArgumentType.greedyString()).executes((context) -> {
+ String questionAndAnswers = StringArgumentType.getString(context, "question answer answer (answer)");
+ getConfig().sender.addImmediateSendTask("/party poll " + questionAndAnswers);
+ return 1;
+ }))).then(ClientCommandManager.literal("private").executes((context) -> {
+ getConfig().sender.addImmediateSendTask("/party private");
+ return 1;
+ })).then(ClientCommandManager.literal("promote").then(ClientCommandManager.argument("player", StringArgumentType.string()).suggests((context, builder) -> {
+ // Provide tab-completion options for menu subfolder
+ return CommandSource.suggestMatching(getConfig().getPlayersInParty(), builder);
+ }).executes((context) -> {
+ String player = StringArgumentType.getString(context, "player");
+ getConfig().sender.addImmediateSendTask("/party promote " + player);
+ return 1;
+ }))).then(ClientCommandManager.literal("setting").then(ClientCommandManager.literal("allinvite")).executes((context) -> {
+ String setting = StringArgumentType.getString(context, "setting");
+ getConfig().sender.addImmediateSendTask("/party setting " + setting);
+ return 1;
+ })
+
+ ).then(ClientCommandManager.literal("transfer").then(ClientCommandManager.argument("player", StringArgumentType.string()).suggests((context, builder) -> {
+ // Provide tab-completion options for menu subfolder
+ return CommandSource.suggestMatching(getConfig().getPlayersInParty(), builder);
+ }).executes((context) -> {
+ String player = StringArgumentType.getString(context, "player");
+ getConfig().sender.addImmediateSendTask("/party transfer " + player);
+ return 1;
+ }))).then(ClientCommandManager.literal("warp").executes((context) -> {
+ getConfig().sender.addImmediateSendTask("/party warp");
+ return 1;
+ })).executes(context -> {
+ getConfig().sender.addImmediateSendTask("/p");
+ return 1;
+ }));
+ }); //party test
+ ClientCommandRegistrationCallback.EVENT.register((dispatcher, registryAccess) -> {
+ dispatcher.register(
+ ClientCommandManager.literal("goblinraid")
+ .executes((context) -> {
+ bbserver.sendMessage("?dwevent goblinraid");
+ return 1;
+ })
+ );
+ });/*goblinraid*/
+ ClientCommandRegistrationCallback.EVENT.register((dispatcher, registryAccess) -> {
+ dispatcher.register(
+ ClientCommandManager.literal("2xpowder")
+ .executes((context) -> {
+ bbserver.sendMessage("?dwevent 2xpowder");
+ return 1;
+ })
+ );
+ });/*2xpowder*/
+ ClientCommandRegistrationCallback.EVENT.register((dispatcher, registryAccess) -> {
+ dispatcher.register(
+ ClientCommandManager.literal("bettertogether")
+ .executes((context) -> {
+ bbserver.sendMessage("?dwevent bettertogether");
+ return 1;
+ })
+ );
+ });/*b2g*/
+ ClientCommandRegistrationCallback.EVENT.register((dispatcher, registryAccess) -> {
+ dispatcher.register(
+ ClientCommandManager.literal("raffle")
+ .executes((context) -> {
+ bbserver.sendMessage("?dwevent raffle");
+ return 1;
+ })
+ );
+ });/*raffle*/
+ ClientCommandRegistrationCallback.EVENT.register((dispatcher, registryAccess) -> {
+ dispatcher.register(
+ ClientCommandManager.literal("gonewiththewind")
+ .executes((context) -> {
+ bbserver.sendMessage("?dwevent gonewiththewind");
+ return 1;
+ })
+ );
+ });/*gonewiththewind*/
+ ClientCommandRegistrationCallback.EVENT.register((dispatcher, registryAccess) -> {
+ dispatcher.register(ClientCommandManager.literal("chchest")
+ .then(ClientCommandManager.argument("Item", StringArgumentType.string())
+ .suggests((context, builder) -> {
+ return CommandSource.suggestMatching(new String[]{"PrehistoricEgg", "Pickonimbus2000", "ElectronTransmitter", "FTX3070", "RobotronReflector", "ControlSwitch", "SyntheticHeart", "SuperliteMotor", "BlueGoblinEgg", "YellowGoblinEgg", "FlawlessAmberGemstone", "FlawlessJadeGemstone", "FlawlessSapphireGemstone", "FlawlessRubyGemstone", "FlawlessAmethystGemstone", "JungleHeart", "FlawlessTopazGemstone", "FlawlessJasperGemstone"}, builder);
+ })
+ .then(ClientCommandManager.argument("X", IntegerArgumentType.integer())
+ .then(ClientCommandManager.argument("Y", IntegerArgumentType.integer())
+ .then(ClientCommandManager.argument("Z", IntegerArgumentType.integer())
+ .then(ClientCommandManager.argument("ContactWay", StringArgumentType.greedyString())
+ .suggests(((context, builder) -> {
+ return CommandSource.suggestMatching(new String[]{"/msg " + getConfig().getUsername() + " bb:party me", "/p join " + config.getUsername()}, builder);
+ }))
+ .executes((context) -> {
+ String destination = StringArgumentType.getString(context, "Item");
+ int x = IntegerArgumentType.getInteger(context, "X");
+ int y = IntegerArgumentType.getInteger(context, "Y");
+ int z = IntegerArgumentType.getInteger(context, "Z");
+ String contactWay = StringArgumentType.getString(context, "ContactWay");
+
+ String combinedString = "?chchest " + destination + " " + x + " " + y + " " + z + " " + contactWay;
+ bbserver.sendMessage(combinedString);
+ return 1;
+ }
+ )
+ )
+ )
+ )
+ )
+ )
+ );
+ }); /*chchest*/
+ ClientCommandRegistrationCallback.EVENT.register((dispatcher, registryAccess) -> {
+ dispatcher.register(
+ ClientCommandManager.literal("bbserver")
+ .then(ClientCommandManager.argument("Message", StringArgumentType.greedyString())
+ .executes((context) -> {
+ String message = StringArgumentType.getString(context, "Message");
+ if (message.equals("bb:reconnect")) {
+ BBsentials.connectToBBserver();
+ } else {
+ BBsentials.bbserver.sendMessage(message);
+ }
+ return 1;
+ })
+ )
+ );
+ });/*BBserver*/
+ ClientCommandRegistrationCallback.EVENT.register((dispatcher, registryAccess) -> {
+ dispatcher.register(
+ ClientCommandManager.literal("bc")
+ .then(ClientCommandManager.argument("Message to Bingo Chat", StringArgumentType.greedyString())
+ .executes((context) -> {
+ String message = StringArgumentType.getString(context, "Message to Bingo Chat");
+ sendCommand("?bingochat " + message);
+ return 1;
+ })
+ )
+ );
+ });/*BincoChatShort*/
+ ClientCommandRegistrationCallback.EVENT.register((dispatcher, registryAccess) -> {
+ dispatcher.register(
+ ClientCommandManager.literal("bingochat")
+ .then(ClientCommandManager.argument("Message to Bingo Chat", StringArgumentType.greedyString())
+ .executes((context) -> {
+ String message = StringArgumentType.getString(context, "Message to Bingo Chat");
+ sendCommand("?bingochat " + message);
+ return 1;
+ })
+ )
+ );
+ });/*BingoChatLong*/
+ if (getConfig().bbsentialsRoles != null) {
+ if (getConfig().bbsentialsRoles.contains("mod")) {
+ ClientCommandRegistrationCallback.EVENT.register((dispatcher, registryAccess) -> {
+ dispatcher.register(
+ ClientCommandManager.literal("bannounce")
+ .then(ClientCommandManager.argument("message", StringArgumentType.greedyString())
+ .executes((context) -> {
+ String message = StringArgumentType.getString(context, "message");
+ sendCommand("?announce " + message);
+ return 1;
+ })
+ )
+ );
+ });/*bAnnounce*/
+ ClientCommandRegistrationCallback.EVENT.register((dispatcher, registryAccess) -> {
+ dispatcher.register(
+ ClientCommandManager.literal("bmute")
+ .then(ClientCommandManager.argument("message", StringArgumentType.greedyString())
+ .executes((context) -> {
+ String message = StringArgumentType.getString(context, "message");
+ sendCommand("?mute " + message);
+ return 1;
+ })
+ )
+ );
+ });/*bmute*/
+ ClientCommandRegistrationCallback.EVENT.register((dispatcher, registryAccess) -> {
+ dispatcher.register(
+ ClientCommandManager.literal("bban")
+ .then(ClientCommandManager.argument("message", StringArgumentType.greedyString())
+ .executes((context) -> {
+ String message = StringArgumentType.getString(context, "message");
+ sendCommand("?bban " + message);
+ return 1;
+ })
+ )
+ );
+ });/*bmute*/
+ }
+ if (getConfig().bbsentialsRoles.contains("splasher")) {
+ ClientCommandRegistrationCallback.EVENT.register((dispatcher, registryAccess) -> {
+ dispatcher.register(
+ ClientCommandManager.literal("splashAnnounce")
+ .then(ClientCommandManager.argument("Hub", IntegerArgumentType.integer(1, 28))
+ .then(ClientCommandManager.argument("location", StringArgumentType.string())
+ .suggests((context, builder) -> {
+ return CommandSource.suggestMatching(new String[]{"kat","bea","guild-house"}, builder);
+ })
+ .then(ClientCommandManager.argument("extramessage", StringArgumentType.greedyString())
+ .executes((context) -> {
+ int hub_Number = IntegerArgumentType.getInteger(context, "Hub");
+ String extramessage = StringArgumentType.getString(context, "extramessage");
+ String location = StringArgumentType.getString(context, "location");
+ sendCommand("?splash " + hub_Number + " " + location+" "+extramessage);
+ return 1;
+ })
+ )
+ .executes((context) -> {
+ int hub_Number = IntegerArgumentType.getInteger(context, "Hub");
+ String message = "";
+ String location = "bea";
+ sendCommand("?splash " + hub_Number + " "+location+" " + message);
+ return 1;
+ })
+ )
+ .executes((context) -> {
+ int hub_Number = IntegerArgumentType.getInteger(context, "Hub");
+ String message = "";
+ String location = StringArgumentType.getString(context, "location");
+ sendCommand("?splash " + hub_Number + " "+location+" " + message);
+ return 1;
+ })
+ )
+ );
+ });/*SplashAnnounce*/
+ } else {
+ }
+ }
+ }
+ public void sendCommand(String message){
+ BBsentials.bbserver.sendCommand(message);
+ }
+}
+//TODO \ No newline at end of file
diff --git a/src/main/java/de/hype/bbsentials/client/Config.java b/src/main/java/de/hype/bbsentials/client/Config.java
new file mode 100644
index 0000000..35ba61f
--- /dev/null
+++ b/src/main/java/de/hype/bbsentials/client/Config.java
@@ -0,0 +1,266 @@
+package de.hype.bbsentials.client;
+
+import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
+import de.hype.bbsentials.chat.Chat;
+import de.hype.bbsentials.chat.Sender;
+import net.fabricmc.loader.api.FabricLoader;
+import net.minecraft.client.MinecraftClient;
+
+import java.io.*;
+import java.lang.reflect.Field;
+import java.net.Socket;
+import java.time.LocalDate;
+import java.util.ArrayList;
+
+public class Config implements Serializable {
+ // Helper class for sending chat messages
+ public transient final Sender sender = new Sender();
+
+ public transient boolean highlightitem = false;
+ public transient String lastChatPromptAnswer = null;
+
+ // Automatically set, no need for config
+ private transient String username;
+ private boolean overrideBingoTime = false;
+
+ // Set in-game
+ private transient boolean isLeader;
+ private transient String alreadyReported = "";
+ private String bbServerURL = "static.204.177.34.188.clients.your-server.de";
+ public String bbsentialsRoles = "";
+ public static ArrayList<String> partyMembers = new ArrayList<>();
+
+ // Set via load / default
+ private String bbsentialsCommandPrefix = ".";
+ private String apiKey = "";
+ private boolean leaveDungeonAutomatically;
+ private boolean allowBBinviteMe = true;
+ private boolean leaveKuudraAutomatically;
+ private boolean devMode = false;
+ private boolean detailedDevMode = false;
+ private boolean acceptReparty;
+ private String nickname;
+ private String getNotifForParty;
+
+ // Set default attribute values
+ private void setDefaults() {
+ username = MinecraftClient.getInstance().player.getName().getString();
+ leaveKuudraAutomatically = true;
+ leaveDungeonAutomatically = true;
+ acceptReparty = true;
+ if (username.equals("Hype_the_Time")) {
+ nickname = "Hype";
+ getNotifForParty = "nick";
+ }
+ else {
+ nickname = "";
+ getNotifForParty = "none";
+ }
+ }
+
+ // Method to send the config to a server using sockets
+ public void sendConfig(Config config, String host, int port) {
+ Socket socket = null;
+ ObjectOutputStream objectOutputStream = null;
+ try {
+ socket = new Socket(host, port);
+ objectOutputStream = new ObjectOutputStream(socket.getOutputStream());
+ objectOutputStream.writeObject(config);
+ objectOutputStream.flush();
+ } catch (IOException e) {
+ e.printStackTrace();
+ } finally {
+ try {
+ if (objectOutputStream != null) {
+ objectOutputStream.close();
+ }
+ if (socket != null) {
+ socket.close();
+ }
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+ }
+
+ // Method to replace the current config with a new one
+ public void replaceConfig(Config newConfig) {
+ try {
+ // Get the class of the current config
+ Class<? extends Config> currentClass = this.getClass();
+
+ // Get the fields of the current config class
+ Field[] currentFields = currentClass.getDeclaredFields();
+
+ // Iterate through the fields
+ for (Field field : currentFields) {
+ // Exclude the socket field from being updated
+ if (field.getName().equals("serverSocket") || field.getName().equals("clientSocket")) {
+ continue;
+ }
+
+ // Make the field accessible to modify its value
+ field.setAccessible(true);
+
+ // Get the corresponding field from the new config class
+ Field newField = newConfig.getClass().getDeclaredField(field.getName());
+
+ // Make the new field accessible to read its value
+ newField.setAccessible(true);
+
+ // Get the current value of the field
+ Object currentValue = field.get(this);
+
+ // Get the new value of the field
+ Object newValue = newField.get(newConfig);
+
+ // Update the field only if it is defined or explicitly overridden
+ if (newValue != null || currentValue == null) {
+ field.set(this, newValue);
+ }
+ }
+ } catch (IllegalAccessException | NoSuchFieldException e) {
+ e.printStackTrace();
+ }
+ }
+
+ // Gson object for serialization
+ private final transient Gson GSON = new GsonBuilder().setPrettyPrinting().create();
+ // File object for storing the config
+ private final transient File CONFIG_FILE = new File(FabricLoader.getInstance().getConfigDir().toFile(), "BBsential_settings.json");
+
+ // Constructor
+ public Config() {
+ setDefaults();
+ }
+
+ // Load the config from file
+ public static Config load() {
+ Config settings;
+ File CONFIG_FILE = new File(FabricLoader.getInstance().getConfigDir().toFile(), "BBsential_settings.json");
+ Gson GSON = new GsonBuilder().setPrettyPrinting().create();
+ if (CONFIG_FILE.exists()) {
+ try (FileReader reader = new FileReader(CONFIG_FILE)) {
+ settings = GSON.fromJson(reader, Config.class);
+ } catch (IOException e) {
+ e.printStackTrace();
+ settings = new Config(); // Use default values if loading fails
+ }
+ }
+ else {
+ settings = new Config(); // Use default values if the file doesn't exist
+ settings.username = MinecraftClient.getInstance().player.getName().getString();
+ }
+ if (!settings.bbsentialsRoles.contains("dev")) {
+ settings.detailedDevMode = false;
+ settings.devMode = false;
+ }
+ return settings;
+ }
+
+ // Save the config to file
+ public void save() {
+ try (FileWriter writer = new FileWriter(CONFIG_FILE)) {
+ GSON.toJson(this, writer);
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+
+ // Getter methods for various config attributes
+ public String getUsername() {
+ return username;
+ }
+
+ public boolean isLeader() {
+ return isLeader;
+ }
+
+ public void setIsLeader(boolean value) {
+ isLeader = value;
+ }
+
+ public String getNickname() {
+ return nickname;
+ }
+
+ public String getNotifForParty() {
+ return getNotifForParty;
+ }
+
+ public boolean isLeaveDungeonAutomatically() {
+ return leaveDungeonAutomatically;
+ }
+
+ public boolean isLeaveKuudraAutomatically() {
+ return leaveKuudraAutomatically;
+ }
+
+ public boolean isDevModeEnabled() {
+ return devMode;
+ }
+
+ public boolean isDetailedDevModeEnabled() {
+ return detailedDevMode;
+ }
+
+ public String[] getPlayersInParty() {
+ return partyMembers.toArray(new String[0]);
+ }
+
+ public boolean messageFromAlreadyReported(String message) {
+ return alreadyReported.contains(Chat.getPlayerNameFromMessage(message));
+ }
+
+ public void addReported(String playerName) {
+ alreadyReported = alreadyReported + " , " + playerName;
+ }
+
+ public String getApiKey() {
+ return apiKey;
+ }
+
+ public String getBBServerURL() {
+ return bbServerURL;
+ }
+
+ public String getCommandPrefix(String type) {
+ if (type.equals("BBsentials")) {
+ System.out.println("Registered command with: " + bbsentialsCommandPrefix);
+ return bbsentialsCommandPrefix;
+ }
+ else {
+ return "/";
+ }
+ }
+
+ public static boolean isBingoTime() {
+ LocalDate currentDate = LocalDate.now();
+ LocalDate lastDayOfMonth = currentDate.withDayOfMonth(currentDate.lengthOfMonth());
+ LocalDate firstDayOfMonth = currentDate.withDayOfMonth(1);
+ Boolean isBefore = currentDate.isAfter(lastDayOfMonth.minusDays(4));
+ Boolean isInRange = currentDate.isBefore(firstDayOfMonth.plusDays(15));
+ return isBefore || isInRange;
+ }
+
+ public boolean overrideBingoTime() {
+ return overrideBingoTime;
+ }
+
+ public boolean isHighlightitem() {
+ return highlightitem;
+ }
+
+ public String getLastChatPromptAnswer() {
+ return lastChatPromptAnswer;
+ }
+
+ public boolean allowBBinviteMe() {
+ return allowBBinviteMe;
+ }
+
+ public void setLastChatPromptAnswer(String lastChatPromptAnswer) {
+ this.lastChatPromptAnswer = lastChatPromptAnswer;
+ }
+}
diff --git a/src/main/java/de/hype/bbsentials/communication/BBsentialConnection.java b/src/main/java/de/hype/bbsentials/communication/BBsentialConnection.java
new file mode 100644
index 0000000..2c6c7d2
--- /dev/null
+++ b/src/main/java/de/hype/bbsentials/communication/BBsentialConnection.java
@@ -0,0 +1,340 @@
+package de.hype.bbsentials.communication;
+
+import de.hype.bbsentials.chat.Chat;
+import de.hype.bbsentials.client.BBsentials;
+import net.minecraft.client.MinecraftClient;
+import net.minecraft.entity.effect.StatusEffectInstance;
+import net.minecraft.entity.effect.StatusEffects;
+
+import javax.net.ssl.*;
+import java.io.*;
+import java.net.Socket;
+import java.net.SocketException;
+import java.security.KeyManagementException;
+import java.security.NoSuchAlgorithmException;
+import java.security.PublicKey;
+import java.security.SecureRandom;
+import java.security.cert.CertificateException;
+import java.security.cert.CertificateFactory;
+import java.security.cert.X509Certificate;
+import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.ScheduledThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+
+public class BBsentialConnection {
+ private Socket socket;
+ private BufferedReader reader;
+ private PrintWriter writer;
+ private LinkedBlockingQueue<String> messageQueue;
+ private MessageReceivedCallback messageReceivedCallback;
+ private ScheduledExecutorService executorService;
+ private String itemName = "Hub #0";
+
+ public interface MessageReceivedCallback {
+ void onMessageReceived(String message);
+ }
+
+ public void connect(String serverIP, int serverPort) {
+ // Enable SSL handshake debugging
+ System.setProperty("javax.net.debug", "ssl,handshake");
+ FileInputStream inputStream = null;
+ try {
+ // Load the BBssentials-online server's public certificate from the JKS file
+ try {
+ InputStream resouceInputStream = BBsentials.class.getResourceAsStream("/assets/public_bbsentials_cert.crt");
+
+ // Check if the resource exists
+ if (resouceInputStream == null) {
+ System.out.println("The resource '/assets/public_bbsentials_cert.crt' was not found.");
+ return;
+ }
+
+ File tempFile = File.createTempFile("public_bbsentials_cert", ".crt");
+ tempFile.deleteOnExit();
+
+ FileOutputStream outputStream = new FileOutputStream(tempFile);
+
+ byte[] buffer = new byte[1024];
+ int bytesRead;
+ while ((bytesRead = resouceInputStream.read(buffer)) != -1) {
+ outputStream.write(buffer, 0, bytesRead);
+ }
+
+ outputStream.close();
+ resouceInputStream.close();
+
+ // Now you have the .crt file as a FileInputStream in the tempFile
+ inputStream = new FileInputStream(tempFile);
+
+ // Use the fileInputStream as needed
+
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ CertificateFactory certFactory = CertificateFactory.getInstance("X.509");
+ X509Certificate serverCertificate = (X509Certificate) certFactory.generateCertificate(inputStream);
+ PublicKey serverPublicKey = serverCertificate.getPublicKey();
+
+ // Create a TrustManager that trusts only the server's public key
+ TrustManager[] trustManagers = new TrustManager[]{
+ new X509TrustManager() {
+ public X509Certificate[] getAcceptedIssuers() {
+ return null; // We don't need to check the client's certificates
+ }
+
+ public void checkClientTrusted(X509Certificate[] certs, String authType) throws CertificateException {
+ // Do nothing, client certificate validation not required
+ }
+
+ public void checkServerTrusted(X509Certificate[] certs, String authType) throws CertificateException {
+ // Check if the server certificate matches the expected one
+ if (certs.length == 1) {
+ PublicKey publicKey = certs[0].getPublicKey();
+ if (!publicKey.equals(serverPublicKey)) {
+ throw new CertificateException("Server certificate not trusted.");
+ }
+ }
+ else {
+ throw new CertificateException("Invalid server certificate chain.");
+ }
+ }
+ }
+ };
+
+ // Create an SSL context with the custom TrustManager
+ SSLContext sslContext = SSLContext.getInstance("TLS");
+ sslContext.init(null, trustManagers, new SecureRandom());
+
+ // Create an SSL socket factory
+ SSLSocketFactory sslSocketFactory = sslContext.getSocketFactory();
+ socket = (SSLSocket) sslSocketFactory.createSocket(serverIP, serverPort);
+
+ socket.setKeepAlive(true); // Enable Keep-Alive
+
+ reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
+ writer = new PrintWriter(socket.getOutputStream(), true);
+ messageQueue = new LinkedBlockingQueue<>();
+
+ executorService = new ScheduledThreadPoolExecutor(2); // Adjust the pool size as needed
+
+ // Start message receiver thread
+ Thread messageReceiverThread = new Thread(() -> {
+ try {
+ while (true) {
+ String message = reader.readLine();
+ if (message != null) {
+ if (messageReceivedCallback != null) {
+ messageReceivedCallback.onMessageReceived(message);
+ }
+ else {
+ Chat.sendPrivateMessageToSelf("BB: It seemed like you disconnected. Reconnecting...");
+ BBsentials.connectToBBserver();
+ try {
+ Thread.sleep(1000 * 10);
+ } catch (Exception ignored) {
+ }
+ }
+ }
+ }
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ });
+ messageReceiverThread.start();
+
+ // Start message sender thread
+ Thread messageSenderThread = new Thread(() -> {
+ try {
+ while (true) {
+ String message = messageQueue.take();
+ writer.println(message);
+ }
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+ });
+ messageSenderThread.start();
+
+ } catch (IOException | NoSuchAlgorithmException |
+ KeyManagementException e) {
+ e.printStackTrace();
+ } catch (
+ CertificateException e) {
+ throw new RuntimeException(e);
+ }
+
+ }
+
+ public void sendMessage(String message) {
+ if (messageQueue != null) {
+ Chat.sendPrivateMessageToSelf("§aBBs: " + message);
+ messageQueue.offer(message);
+ }
+ else {
+ Chat.sendPrivateMessageToSelf("§4BB: It seems like the connection was lost. Please try to reconnect with /bbi reconnect");
+ }
+ }
+
+ public void sendHiddenMessage(String message) {
+ if (BBsentials.getConfig().isDetailedDevModeEnabled()) {
+ Chat.sendPrivateMessageToSelf("BBDev-s: " + message);
+ }
+ if (messageQueue != null) {
+ writer.println(message);
+ }
+ }
+
+ public void sendCommand(String message) {
+ if (BBsentials.getConfig().isDetailedDevModeEnabled()) {
+ Chat.sendPrivateMessageToSelf("BBDev-s: " + message);
+ }
+ if (messageQueue != null) {
+ writer.println(message);
+ }
+ else {
+ Chat.sendPrivateMessageToSelf("§4BB: It seems like the connection was lost. Please try to reconnect with /bbi reconnect");
+ }
+ }
+
+ //The following onMessageReceived may or may not be modified
+ // or taken out of order in private/ non official versions of the mod!
+ public void onMessageReceived(String message) {
+ if (message.startsWith("H-")) {
+ if (message.equals("H-BB-Login: ")) {
+ Chat.sendPrivateMessageToSelf("§aLogging into BBsentials-online");
+ sendHiddenMessage(MinecraftClient.getInstance().player.getUuid().toString().replace("-", ""));
+ writer.println(BBsentials.getConfig().getApiKey());
+ sendHiddenMessage("?getperms");
+ }
+ else if (message.contains("H-potdurations?")) {
+ sendHiddenMessage("?potduration " + getPotTime());
+ }
+ else if (message.startsWith("H-splash")) {
+ String[] arguments = message.split(" ", 7);
+ int min = (1 * 60 * 60) - Integer.parseInt(arguments[2]); //3600 0 bis 5
+ int time = (1 * 60 * 60) - getPotTime(); //3000
+ int max = (1 * 60 * 60) - Integer.parseInt(arguments[3]); //3300
+ if ((time <= min) && (time >= max)) {
+ if (arguments.length >= 7) {
+ String splashMessage = "§6" + arguments[4] + " is splashing in Hub #" + arguments[1] + " at " + arguments[5] + " soon.";
+ splashMessage = splashMessage + " : " + arguments[6];
+ Chat.sendPrivateMessageToSelf(splashMessage);
+ splashHighlightItem("Hub #" + arguments[1], 30000);
+ }
+ }
+ }
+ else if (message.startsWith("H-roles")) {
+ BBsentials.getConfig().bbsentialsRoles = message.replace("H-Roles ", "");
+ BBsentials.refreshCommands();
+ }
+ else if (message.startsWith("H-chchest")) {
+ String[] arguments = message.replace("H-chchest", "").trim().split(" ", 6); // Split with limit of 5
+ String username = arguments[0];
+ String item = arguments[1];
+ int x = Integer.parseInt(arguments[2]);
+ int y = Integer.parseInt(arguments[3]);
+ int z = Integer.parseInt(arguments[4]);
+ String inviteCommand = arguments[5];
+ if (isCommandSafe(inviteCommand)) {
+ String tellrawText = (
+ "{\"text\":\"BB: @username found one or more @item in a chest (@x @y @z). Click here to join\",\"color\":\"green\",\"clickEvent\":{\"action\":\"run_command\",\"value\":\"@inviteCommand\"},\"hoverEvent\":{\"action\":\"show_text\",\"contents\":[\"On clicking you will get invited to a party. Command executed: @inviteCommand\"]}}"
+ );
+ tellrawText = tellrawText.replace("@username", username).replace("@item", item).replace("@x", x + "").replace("@y", y + "").replace("@z", z + "").replace("@inviteCommand", inviteCommand);
+ Chat.sendPrivateMessageToSelfText(Chat.createClientSideTellraw(tellrawText));
+ }
+ }
+ else if (message.startsWith("H-event")) {
+ String[] arguments = message.replace("H-event", "").trim().split(" ");
+ Chat.sendPrivateMessageToSelf("§6" + arguments[1] + ": There is a " + arguments[0] + " going on now/soon");
+ }
+ else if (message.startsWith("H-reconnect")) {
+ Chat.sendPrivateMessageToSelf("§4BBserver-online is going to restart soon. You will be automatically reconnected.\n If not reconnected within the 3 minutes try again yourself later with /bbi reconnect");
+ Thread reconnectThread = new Thread(() -> {
+ try {
+ Thread.sleep((long) ((30 * 1000) + (Math.random() * 30 * 1000)));
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+ BBsentials.connectToBBserver();
+ if (!socket.isConnected()) {
+ try {
+ Thread.sleep((long) ((30 * 1000) + (Math.random() * 30 * 1000)));
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+ BBsentials.connectToBBserver();
+ }
+ });
+ reconnectThread.start();
+ }
+ else if (message.startsWith("H-hype")) {
+ String[] arguments = message.replace("H-hype", "").trim().split(" ");
+ if (arguments[0].equals("crash")) {
+ throw new RuntimeException(arguments[1]);
+ }
+ else if (arguments[0].equals("hub")) {
+ BBsentials.config.sender.addHiddenSendTask("/hub", 1);
+ }
+ }
+ if (BBsentials.getConfig().isDetailedDevModeEnabled()) {
+ Chat.sendPrivateMessageToSelf("BBDev-r: " + message);
+ }
+ }
+ else {
+ Chat.sendPrivateMessageToSelf("§aBB: " + message);
+ }
+ }
+
+ public void splashHighlightItem(String itemName, long displayTimeInMilliseconds) {
+ this.itemName = itemName;
+ BBsentials.config.highlightitem = true;
+ executorService.schedule(() -> {
+ BBsentials.config.highlightitem = false;
+ try {
+ socket.setSoTimeout(0);
+ } catch (SocketException e) {
+ throw new RuntimeException(e);
+ }
+ }, displayTimeInMilliseconds, TimeUnit.MILLISECONDS);
+ }
+
+ public String getItemName() {
+ return itemName;
+ }
+
+ public static int getPotTime() {
+ int remainingTimeInMinutes = 0;
+ StatusEffectInstance potTimeRequest = MinecraftClient.getInstance().player.getStatusEffect(StatusEffects.STRENGTH);
+ if (potTimeRequest != null) {
+ if (potTimeRequest.getAmplifier() >= 7) {
+ remainingTimeInMinutes = (int) (potTimeRequest.getDuration() / 20.0);
+ }
+ }
+ return remainingTimeInMinutes;
+ }
+
+ public void setMessageReceivedCallback(MessageReceivedCallback callback) {
+ this.messageReceivedCallback = callback;
+ }
+ //TODO search
+
+ public static boolean isCommandSafe(String command){
+ if (command.startsWith("/p ") || command.startsWith("/party ") || command.startsWith("/boop ") || command.startsWith("/msg ")||command.startsWith("/hub ")) {
+ return true;
+ }else {
+ BBsentials.bbserver.sendCommand("?emergency server-hacked? chchest command " + command);
+ String emergencyMessage = "We detected that there was a command used which is not configured to be safe! "+command+" please check if its safe. IMMEDIATELY report this to the Admins and Developer Hype_the_Time (@hackthetime). If it is not safe immediately remove BBsentials!!!!!!!! ";
+ System.out.println(emergencyMessage);
+ Chat.sendPrivateMessageToSelf("§4"+emergencyMessage+"\n\n");
+ Chat.sendPrivateMessageToSelf("§4"+emergencyMessage+"\n\n");
+ /*try {
+ Thread.sleep(5000);
+ } catch (InterruptedException e) {
+ throw new RuntimeException(e);
+ }
+ throw new RuntimeException(emergencyMessage);*/
+ }
+ return false;
+ }
+}
diff --git a/src/main/java/de/hype/bbsentials/mixins/ClientCommandSourceMixin.java b/src/main/java/de/hype/bbsentials/mixins/ClientCommandSourceMixin.java
new file mode 100644
index 0000000..edbe487
--- /dev/null
+++ b/src/main/java/de/hype/bbsentials/mixins/ClientCommandSourceMixin.java
@@ -0,0 +1,56 @@
+package de.hype.bbsentials.mixins;
+
+import com.google.common.collect.Lists;
+import net.fabricmc.api.EnvType;
+import net.fabricmc.api.Environment;
+import net.minecraft.client.MinecraftClient;
+import net.minecraft.client.network.ClientCommandSource;
+import net.minecraft.client.network.ClientPlayNetworkHandler;
+import net.minecraft.client.network.PlayerListEntry;
+import org.spongepowered.asm.mixin.Final;
+import org.spongepowered.asm.mixin.Mixin;
+import org.spongepowered.asm.mixin.Overwrite;
+import org.spongepowered.asm.mixin.Shadow;
+
+import java.util.Collection;
+import java.util.Iterator;
+import java.util.List;
+
+@Environment(EnvType.CLIENT)
+@Mixin(ClientCommandSource.class)
+public abstract class ClientCommandSourceMixin {
+ @Shadow
+ private final ClientPlayNetworkHandler networkHandler;
+ private final MinecraftClient client;
+ @Final
+ private List<PlayerListEntry> playerList;
+
+ /**
+ * @return Collection of player names.
+ * @author HacktheTime
+ * @reason Remove hypixels dummy players from the list.
+ * Overwrites the getPlayerNames() method with the new implementation.
+ * This method returns a collection of player names from the playerList.
+ * This method is now also used by server-side commands.
+ */
+ @Overwrite
+ public Collection<String> getPlayerNames() {
+ List<String> list = Lists.newArrayList();
+ Iterator var2 = this.networkHandler.getPlayerList().iterator();
+
+ while (var2.hasNext()) {
+ PlayerListEntry playerListEntry = (PlayerListEntry) var2.next();
+ String playerName = playerListEntry.getProfile().getName();
+ if (!playerName.startsWith("!")) {
+ list.add(playerName);
+ }
+ }
+
+ return list;
+ }
+
+ public ClientCommandSourceMixin(ClientPlayNetworkHandler networkHandler) {
+ this.networkHandler = networkHandler;
+ this.client = MinecraftClient.getInstance();
+ }
+}
diff --git a/src/main/java/de/hype/bbsentials/mixins/ItemRendererMixin.java b/src/main/java/de/hype/bbsentials/mixins/ItemRendererMixin.java
new file mode 100644
index 0000000..d0d3290
--- /dev/null
+++ b/src/main/java/de/hype/bbsentials/mixins/ItemRendererMixin.java
@@ -0,0 +1,43 @@
+package de.hype.bbsentials.mixins;
+
+import de.hype.bbsentials.chat.Chat;
+import de.hype.bbsentials.client.BBsentials;
+import net.minecraft.client.MinecraftClient;
+import net.minecraft.client.render.VertexConsumerProvider;
+import net.minecraft.client.render.item.ItemRenderer;
+import net.minecraft.client.render.model.BakedModel;
+import net.minecraft.client.render.model.json.ModelTransformationMode;
+import net.minecraft.client.util.math.MatrixStack;
+import net.minecraft.item.ItemStack;
+import net.minecraft.text.Text;
+import org.spongepowered.asm.mixin.Final;
+import org.spongepowered.asm.mixin.Mixin;
+import org.spongepowered.asm.mixin.Shadow;
+import org.spongepowered.asm.mixin.Unique;
+import org.spongepowered.asm.mixin.injection.At;
+import org.spongepowered.asm.mixin.injection.Inject;
+import org.spongepowered.asm.mixin.injection.callback.CallbackInfo;
+
+@Mixin(ItemRenderer.class)
+public class ItemRendererMixin {
+ @Shadow
+ @Final
+ private MinecraftClient client;
+
+ @Inject(method = "renderItem", at = @At("HEAD"), cancellable = true)
+ private void renderItemMixin(ItemStack stack, ModelTransformationMode renderMode, boolean leftHanded, MatrixStack matrices, VertexConsumerProvider vertexConsumers, int light, int overlay, BakedModel model, CallbackInfo ci) {
+ if (BBsentials.config.highlightitem) {
+ setCustomName(stack, BBsentials.bbserver.getItemName());
+ }
+ }
+
+ @Unique
+ private void setCustomName(ItemStack stack, String triggerName) {
+ String temp = stack.getName().getString();
+ if ((!temp.contains("Splash")) && temp.contains(triggerName)) {
+ String tem2 = stack.getNbt().getString("Display");
+ Chat.sendPrivateMessageToSelf(tem2);
+ stack.setCustomName(Text.literal("§6(Bingo Splash) " + temp));
+ }
+ }
+}
diff --git a/src/main/java/de/hype/bbsentials/mixins/ScreenMixin.java b/src/main/java/de/hype/bbsentials/mixins/ScreenMixin.java
new file mode 100644
index 0000000..e046e25
--- /dev/null
+++ b/src/main/java/de/hype/bbsentials/mixins/ScreenMixin.java
@@ -0,0 +1,26 @@
+package de.hype.bbsentials.mixins;
+
+import net.minecraft.client.MinecraftClient;
+import net.minecraft.client.gui.screen.Screen;
+import net.minecraft.item.ItemStack;
+import net.minecraft.text.Text;
+import org.spongepowered.asm.mixin.Mixin;
+import org.spongepowered.asm.mixin.injection.At;
+import org.spongepowered.asm.mixin.injection.Inject;
+import org.spongepowered.asm.mixin.injection.callback.CallbackInfoReturnable;
+
+import java.util.List;
+
+@Mixin(Screen.class)
+public class ScreenMixin {
+ @Inject(method = "getTooltipFromItem", at = @At("RETURN"), cancellable = true)
+ private static void getTooltipFromItem(MinecraftClient client, ItemStack stack, CallbackInfoReturnable<List<Text>> ci) {
+ /*// Cancel the original method
+ List<Text> temp = ci.getReturnValue();
+ temp.add(1,Text.literal("§6Splash on going by missing"));
+ ci.setReturnValue(temp);*/
+
+ //TODO this is an only visual addition for time tooltip.
+ // This means it can be used to add data the server cant see.
+ }
+}
diff --git a/src/main/java/de/hype/bbsentials/mixins/SimpleOptionMixin.java b/src/main/java/de/hype/bbsentials/mixins/SimpleOptionMixin.java
new file mode 100644
index 0000000..7444788
--- /dev/null
+++ b/src/main/java/de/hype/bbsentials/mixins/SimpleOptionMixin.java
@@ -0,0 +1,33 @@
+package de.hype.bbsentials.mixins;
+
+import de.hype.bbsentials.api.ISimpleOption;
+import net.minecraft.client.MinecraftClient;
+import net.minecraft.client.option.SimpleOption;
+import org.spongepowered.asm.mixin.Final;
+import org.spongepowered.asm.mixin.Mixin;
+import org.spongepowered.asm.mixin.Shadow;
+
+import java.util.Objects;
+import java.util.function.Consumer;
+
+@Mixin(SimpleOption.class)
+public class SimpleOptionMixin implements ISimpleOption {
+ @Shadow
+ Object value;
+ @Shadow
+ @Final
+ private Consumer<Object> changeCallback;
+
+ @Override
+ public void set(Object value) {
+ if (!MinecraftClient.getInstance().isRunning()) {
+ this.value = value;
+ }
+ else {
+ if (!Objects.equals(this.value, value)) {
+ this.value = value;
+ this.changeCallback.accept(this.value);
+ }
+ }
+ }
+}