Compare commits
10
Commits
matrix
...
8546bda28a
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
8546bda28a | ||
|
|
28894ef245 | ||
|
|
5a508fdf28 | ||
|
|
dc513ac2f0 | ||
|
|
c48d4f5c86 | ||
|
|
7f00bc104b | ||
|
|
133cebd1ec | ||
|
|
fc20c9a276 | ||
|
|
ea8e952108 | ||
|
|
3d010e4139 |
@@ -3,6 +3,9 @@ plugins {
|
||||
}
|
||||
|
||||
dependencies {
|
||||
implementation(project(":web-api")) // Web-API
|
||||
compileOnly("org.projectlombok:lombok:1.18.46")
|
||||
annotationProcessor("org.projectlombok:lombok:1.18.46")
|
||||
// Cosmos
|
||||
compileOnly("com.alttd.cosmos:cosmos-api:1.21.8-R0.1-SNAPSHOT") {
|
||||
isChanging = true
|
||||
|
||||
@@ -38,9 +38,9 @@ public final class Config {
|
||||
CONFIGPATH = new File(File.separator + "mnt" + File.separator + "configs" + File.separator + "ChatPlugin");
|
||||
CONFIG_FILE = new File(CONFIGPATH, "config.yml");
|
||||
configLoader = YamlConfigurationLoader.builder()
|
||||
.file(CONFIG_FILE)
|
||||
.nodeStyle(NodeStyle.BLOCK)
|
||||
.build();
|
||||
.file(CONFIG_FILE)
|
||||
.nodeStyle(NodeStyle.BLOCK)
|
||||
.build();
|
||||
if (!CONFIG_FILE.getParentFile().exists()) {
|
||||
if (!CONFIG_FILE.getParentFile().mkdirs()) {
|
||||
return;
|
||||
@@ -183,11 +183,15 @@ public final class Config {
|
||||
private static void settings() {
|
||||
PREFIXGROUPS = getList("settings.prefix-groups",
|
||||
Lists.newArrayList("discord", "socialmedia", "eventteam", "eventleader", "youtube", "twitch",
|
||||
"developer"));
|
||||
"developer"
|
||||
)
|
||||
);
|
||||
CONFLICTINGPREFIXGROUPS = getList("settings.prefix-conflicts-groups",
|
||||
Lists.newArrayList("eventteam", "eventleader"));
|
||||
Lists.newArrayList("eventteam", "eventleader")
|
||||
);
|
||||
STAFFGROUPS = getList("settings.staff-groups",
|
||||
Lists.newArrayList("trainee", "moderator", "headmod", "admin", "manager", "owner"));
|
||||
Lists.newArrayList("trainee", "moderator", "headmod", "admin", "manager", "owner")
|
||||
);
|
||||
CONSOLENAME = getString("settings.console-name", CONSOLENAME);
|
||||
CONSOLEUUID = UUID.fromString(getString("settings.console-uuid", CONSOLEUUID.toString()));
|
||||
MINIMIUMSTAFFRANK = getString("settings.minimum-staff-rank", MINIMIUMSTAFFRANK);
|
||||
@@ -282,7 +286,7 @@ public final class Config {
|
||||
public static String NO_PERMISSION = "<red>You don't have permission to use this command.</red>";
|
||||
public static String NO_CONSOLE = "<red>This command can not be used by console</red>";
|
||||
public static String CREATED_PARTY = "<green>You created a chat party called: " +
|
||||
"'<gold><party_name></gold>' with the password: '<gold><party_password></gold>'</green>";
|
||||
"'<gold><party_name></gold>' with the password: '<gold><party_password></gold>'</green>";
|
||||
public static String NOT_IN_A_PARTY = "<red>You're not in a chat party.</red>";
|
||||
public static String NOT_YOUR_PARTY = "<red>You don't own this chat party.</red>";
|
||||
public static String NOT_A_PARTY = "<red>This chat party does not exist.</red>";
|
||||
@@ -307,14 +311,14 @@ public final class Config {
|
||||
public static String ALREADY_IN_THIS_PARTY = "<red>You're already in <party>!</red>";
|
||||
public static String SENT_PARTY_INV = "<green>You send a chat party invite to <player>!</green>";
|
||||
public static String JOIN_PARTY_CLICK_MESSAGE = "<click:run_command:'/party join <party> <party_password>'>" +
|
||||
"<dark_aqua>You received an invite to join <party>, click this message to accept.</dark_aqua></click>";
|
||||
"<dark_aqua>You received an invite to join <party>, click this message to accept.</dark_aqua></click>";
|
||||
public static String PARTY_MEMBER_LOGGED_ON = "<dark_aqua>[ChatParty] <player> joined Altitude...</dark_aqua>";
|
||||
public static String PARTY_MEMBER_LOGGED_OFF = "<dark_aqua>[ChatParty] <player> left Altitude...</dark_aqua>";
|
||||
public static String RENAMED_PARTY =
|
||||
"<dark_aqua>[ChatParty] <owner> changed the party name from <old_name> to <new_name>!</dark_aqua>";
|
||||
public static String CHANGED_PASSWORD = "<green>Password was set to <password></green>";
|
||||
public static String DISBAND_PARTY_CONFIRM = "<green><bold>Are you sure you want to disband your party?</bold> " +
|
||||
"Type <gold>/party disband confirm <party></gold> to confirm.";
|
||||
"Type <gold>/party disband confirm <party></gold> to confirm.";
|
||||
public static String DISBANDED_PARTY =
|
||||
"<dark_aqua>[ChatParty] <owner> has disbanded <party>, everyone has been removed.</dark_aqua>";
|
||||
public static String PARTY_INFO = """
|
||||
@@ -413,7 +417,8 @@ public final class Config {
|
||||
ConfigurationNode node = getNode("chat-channels");
|
||||
if (node.empty()) {
|
||||
getString("chat-channels.ac.format",
|
||||
"<white><gray><sender></gray> <hover:show_text:on <server>><yellow>to <channel></yellow></hover><gray>: <message>");
|
||||
"<white><gray><sender></gray> <hover:show_text:on <server>><yellow>to <channel></yellow></hover><gray>: <message>"
|
||||
);
|
||||
getList("chat-channels.ac.servers", List.of("lobby"));
|
||||
getBoolean("chat-channels.ac.proxy", false);
|
||||
node = getNode("chat-channels");
|
||||
@@ -617,11 +622,15 @@ public final class Config {
|
||||
NICK_WAIT_TIME = getLong("nicknames.wait-time", NICK_WAIT_TIME);
|
||||
NICK_ITEM_LORE = getList("nicknames.item-lore",
|
||||
List.of("<aqua>New nick: <newnick>", "<aqua>Old nick: <oldnick>", "<aqua>Last changed: <lastchanged>",
|
||||
"<green>Left click to Accept <light_purple>| <red>Right click to Deny"));
|
||||
"<green>Left click to Accept <light_purple>| <red>Right click to Deny"
|
||||
)
|
||||
);
|
||||
NICK_BLOCKED_COLOR_CODESLIST = getList("nicknames.blocked-color-codes", List.of("&k", "&l", "&n", "&m", "&o"));
|
||||
NICK_ALLOWED_COLOR_CODESLIST = getList("nicknames.allowed-color-codes",
|
||||
List.of("&0", "&1", "&2", "&3", "&4", "&5", "&6", "&7", "&8", "&9", "&a", "&b", "&c", "&d", "&e", "&f",
|
||||
"&r"));
|
||||
"&r"
|
||||
)
|
||||
);
|
||||
NICK_CURRENT = getString("nicknames.messages.nick-current", NICK_CURRENT);
|
||||
}
|
||||
|
||||
@@ -641,4 +650,10 @@ public final class Config {
|
||||
CHAT_LOG_DELETE_OLDER_THAN_DAYS = getLong("chat-log.delete-older-than-days", CHAT_LOG_DELETE_OLDER_THAN_DAYS);
|
||||
CHAT_LOG_SAVE_DELAY_MINUTES = getLong("chat-log.save-delay-minutes", CHAT_LOG_SAVE_DELAY_MINUTES);
|
||||
}
|
||||
|
||||
public static String CHAT_WEB_SERVER_BASE_URL = "http://10.0.0.121:8080";
|
||||
|
||||
private static void webServerSettings() {
|
||||
CHAT_WEB_SERVER_BASE_URL = getString("web-server.base-url", CHAT_WEB_SERVER_BASE_URL);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -15,15 +15,22 @@ import java.util.concurrent.CompletionException;
|
||||
public class ChatLogQueries {
|
||||
|
||||
protected static void createChatLogTable() {
|
||||
String nicknamesTableQuery = "CREATE TABLE IF NOT EXISTS chat_log("
|
||||
+ "uuid CHAR(48) NOT NULL,"
|
||||
+ "time_stamp TIMESTAMP(6) NOT NULL, "
|
||||
+ "server VARCHAR(50) NOT NULL, "
|
||||
+ "chat_message VARCHAR(300) NOT NULL, "
|
||||
+ "blocked BIT(1) NOT NULL DEFAULT 0"
|
||||
+ ")";
|
||||
String nicknamesTableQuery = """
|
||||
CREATE TABLE chat_log (
|
||||
id BIGINT AUTO_INCREMENT PRIMARY KEY,
|
||||
uuid CHAR(36) NOT NULL,
|
||||
time_stamp TIMESTAMP(6) NOT NULL,
|
||||
server VARCHAR(50) NOT NULL,
|
||||
chat_message VARCHAR(300) NOT NULL,
|
||||
mini_message JSON,
|
||||
blocked BOOLEAN NOT NULL DEFAULT FALSE,
|
||||
|
||||
INDEX idx_time_stamp (time_stamp)
|
||||
)
|
||||
""";
|
||||
|
||||
try (PreparedStatement preparedStatement = DatabaseConnection.getConnection().prepareStatement(nicknamesTableQuery)) {
|
||||
try (PreparedStatement preparedStatement = DatabaseConnection.getConnection().prepareStatement(
|
||||
nicknamesTableQuery)) {
|
||||
preparedStatement.executeUpdate();
|
||||
} catch (Throwable throwable) {
|
||||
ALogger.error("Failed to create chat log table", throwable);
|
||||
@@ -31,7 +38,7 @@ public class ChatLogQueries {
|
||||
}
|
||||
|
||||
public static @NotNull CompletableFuture<Boolean> storeMessages(HashMap<UUID, List<ChatLog>> chatMessages) {
|
||||
String insertQuery = "INSERT INTO chat_log (uuid, time_stamp, server, chat_message, blocked) VALUES (?, ?, ?, ?, ?)";
|
||||
String insertQuery = "INSERT INTO chat_log (uuid, time_stamp, server, chat_message, mini_message, blocked) VALUES (?, ?, ?, ?, ?, ?)";
|
||||
return CompletableFuture.supplyAsync(() -> {
|
||||
try (Connection connection = DatabaseConnection.createTransactionConnection()) {
|
||||
PreparedStatement preparedStatement = connection.prepareStatement(insertQuery);
|
||||
@@ -76,7 +83,9 @@ public class ChatLogQueries {
|
||||
return chatLogs;
|
||||
} catch (SQLException sqlException) {
|
||||
ALogger.error(String.format("Failed to retrieve messages for user %s", uuid), sqlException);
|
||||
throw new CompletionException(String.format("Failed to retrieve messages for user %s", uuid), sqlException);
|
||||
throw new CompletionException(String.format("Failed to retrieve messages for user %s", uuid),
|
||||
sqlException
|
||||
);
|
||||
}
|
||||
});
|
||||
}
|
||||
@@ -90,8 +99,13 @@ public class ChatLogQueries {
|
||||
preparedStatement.setTimestamp(1, Timestamp.from(Instant.now().minus(duration)));
|
||||
return preparedStatement.execute();
|
||||
} catch (SQLException sqlException) {
|
||||
ALogger.error(String.format("Failed to delete messages older than %s days", duration.toDays()), sqlException);
|
||||
throw new CompletionException(String.format("Failed to delete messages older than %s days", duration.toDays()), sqlException);
|
||||
ALogger.error(String.format("Failed to delete messages older than %s days", duration.toDays()),
|
||||
sqlException
|
||||
);
|
||||
throw new CompletionException(String.format("Failed to delete messages older than %s days",
|
||||
duration.toDays()
|
||||
), sqlException
|
||||
);
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
@@ -1,6 +1,11 @@
|
||||
package com.alttd.chat.objects.chat_log;
|
||||
|
||||
import com.alttd.altitudeweb.model.ChatMessageDto;
|
||||
import com.alttd.chat.objects.BatchInsertable;
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Getter;
|
||||
import net.kyori.adventure.text.Component;
|
||||
import net.kyori.adventure.text.serializer.gson.GsonComponentSerializer;
|
||||
import org.jetbrains.annotations.NotNull;
|
||||
|
||||
import java.sql.PreparedStatement;
|
||||
@@ -9,44 +14,44 @@ import java.sql.Timestamp;
|
||||
import java.time.Instant;
|
||||
import java.util.UUID;
|
||||
|
||||
@AllArgsConstructor
|
||||
public class ChatLog implements BatchInsertable {
|
||||
|
||||
@Getter
|
||||
private final UUID uuid;
|
||||
@Getter
|
||||
private final Instant timestamp;
|
||||
private final String server;
|
||||
@Getter
|
||||
private final String message;
|
||||
@Getter
|
||||
private final Component miniMessage;
|
||||
@Getter
|
||||
private final boolean blocked;
|
||||
|
||||
protected ChatLog(UUID uuid, Instant timestamp, String server, String message, boolean blocked) {
|
||||
this.uuid = uuid;
|
||||
this.timestamp = timestamp;
|
||||
this.server = server;
|
||||
this.message = message;
|
||||
this.blocked = blocked;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void prepareStatement(@NotNull PreparedStatement preparedStatement) throws SQLException {
|
||||
preparedStatement.setString(1, uuid.toString());
|
||||
preparedStatement.setTimestamp(2, Timestamp.from(timestamp));
|
||||
preparedStatement.setString(3, server);
|
||||
preparedStatement.setString(4, message);
|
||||
preparedStatement.setInt(5, blocked ? 1 : 0);
|
||||
preparedStatement.setString(5,
|
||||
miniMessage == null ? null : GsonComponentSerializer.gson().serialize(miniMessage)
|
||||
);
|
||||
preparedStatement.setInt(6, blocked ? 1 : 0);
|
||||
}
|
||||
|
||||
public UUID getUuid() {
|
||||
return uuid;
|
||||
}
|
||||
|
||||
public Instant getTimestamp() {
|
||||
return timestamp;
|
||||
}
|
||||
|
||||
public String getMessage() {
|
||||
return message;
|
||||
}
|
||||
|
||||
public boolean isBlocked() {
|
||||
return blocked;
|
||||
public ChatMessageDto toDto() {
|
||||
ChatMessageDto chatMessageDto = new ChatMessageDto();
|
||||
if (miniMessage == null) {
|
||||
throw new IllegalArgumentException("MiniMessage cannot be null");
|
||||
}
|
||||
chatMessageDto.setMessage(GsonComponentSerializer.gson().serialize(miniMessage));
|
||||
chatMessageDto.setChannel(ChatMessageDto.ChannelEnum.CHAT);
|
||||
chatMessageDto.setServer(server);
|
||||
chatMessageDto.setTimestamp(timestamp);
|
||||
chatMessageDto.setUuid(uuid);
|
||||
chatMessageDto.setBlocked(blocked);
|
||||
return chatMessageDto;
|
||||
}
|
||||
}
|
||||
|
||||
@@ -3,6 +3,8 @@ package com.alttd.chat.objects.chat_log;
|
||||
import com.alttd.chat.config.Config;
|
||||
import com.alttd.chat.database.ChatLogQueries;
|
||||
import com.alttd.chat.util.ALogger;
|
||||
import net.kyori.adventure.text.Component;
|
||||
import net.kyori.adventure.text.serializer.gson.GsonComponentSerializer;
|
||||
import org.jetbrains.annotations.NotNull;
|
||||
|
||||
import java.sql.ResultSet;
|
||||
@@ -14,12 +16,14 @@ import java.util.concurrent.*;
|
||||
|
||||
public class ChatLogHandler {
|
||||
|
||||
private final ChatLogWebHandler chatLogWebHandler = new ChatLogWebHandler();
|
||||
private static ChatLogHandler instance = null;
|
||||
private ScheduledExecutorService executorService = null;
|
||||
|
||||
public static ChatLogHandler getInstance(boolean enableLogging) {
|
||||
if (instance == null)
|
||||
if (instance == null) {
|
||||
instance = new ChatLogHandler(enableLogging);
|
||||
}
|
||||
return instance;
|
||||
}
|
||||
|
||||
@@ -35,23 +39,30 @@ public class ChatLogHandler {
|
||||
Duration deleteThreshold = Duration.ofDays(Config.CHAT_LOG_DELETE_OLDER_THAN_DAYS);
|
||||
ChatLogQueries.deleteOldMessages(deleteThreshold).thenAccept(success -> {
|
||||
if (success) {
|
||||
ALogger.info(String.format("Deleted all messages older than %s days from chat log database.", deleteThreshold.toDays()));
|
||||
ALogger.info(String.format("Deleted all messages older than %s days from chat log database.",
|
||||
deleteThreshold.toDays()
|
||||
));
|
||||
} else {
|
||||
ALogger.warn(String.format("Failed to delete all messages older than %s days from chat log database.", deleteThreshold.toDays()));
|
||||
ALogger.warn(String.format("Failed to delete all messages older than %s days from chat log database.",
|
||||
deleteThreshold.toDays()
|
||||
));
|
||||
}
|
||||
});
|
||||
executorService = Executors.newSingleThreadScheduledExecutor();
|
||||
executorService.scheduleAtFixedRate(() -> {
|
||||
saveToDatabase(false);
|
||||
ALogger.info(String.format("Running scheduler to save messages with a %d delay", Config.CHAT_LOG_SAVE_DELAY_MINUTES));
|
||||
ALogger.info(String.format("Running scheduler to save messages with a %d delay",
|
||||
Config.CHAT_LOG_SAVE_DELAY_MINUTES
|
||||
));
|
||||
},
|
||||
Config.CHAT_LOG_SAVE_DELAY_MINUTES, Config.CHAT_LOG_SAVE_DELAY_MINUTES, TimeUnit.MINUTES);
|
||||
Config.CHAT_LOG_SAVE_DELAY_MINUTES, Config.CHAT_LOG_SAVE_DELAY_MINUTES, TimeUnit.MINUTES
|
||||
);
|
||||
ALogger.info("Logging has started!");
|
||||
}
|
||||
|
||||
/**
|
||||
* Shuts down the executor service and saves the chat logs to the database.
|
||||
* Will throw an error if called on a ChatLogHandler that was started without logging
|
||||
* Shuts down the executor service and saves the chat logs to the database. Will throw an error if called on a
|
||||
* ChatLogHandler that was started without logging
|
||||
*/
|
||||
public void shutDown() {
|
||||
executorService.shutdown();
|
||||
@@ -66,7 +77,7 @@ public class ChatLogHandler {
|
||||
return isSaving;
|
||||
}
|
||||
|
||||
public synchronized void addLog(ChatLog chatLog) {
|
||||
private synchronized void addLog(ChatLog chatLog) {
|
||||
if (isBlocked()) {
|
||||
chatLogQueue.add(chatLog);
|
||||
} else {
|
||||
@@ -105,12 +116,17 @@ public class ChatLogHandler {
|
||||
Instant chatTimestamp = resultSet.getTimestamp("time_stamp").toInstant();
|
||||
String server = resultSet.getString("server");
|
||||
String chatMessage = resultSet.getString("chat_message");
|
||||
String stringMiniMessage = resultSet.getString("mini_message");
|
||||
Component miniMessage = stringMiniMessage == null ? null : GsonComponentSerializer.gson().deserialize(
|
||||
stringMiniMessage);
|
||||
boolean chatMessageBlocked = resultSet.getInt("blocked") == 1;
|
||||
return new ChatLog(chatLogUUID, chatTimestamp, server, chatMessage, chatMessageBlocked);
|
||||
return new ChatLog(chatLogUUID, chatTimestamp, server, chatMessage, miniMessage, chatMessageBlocked);
|
||||
}
|
||||
|
||||
public void addChatLog(UUID uuid, String server, String message, boolean blocked) {
|
||||
addLog(new ChatLog(uuid, Instant.now(), server, message, blocked));
|
||||
public void addChatLog(UUID uuid, String server, String message, Component miniMessage, boolean blocked) {
|
||||
ChatLog chatLog = new ChatLog(uuid, Instant.now(), server, message, miniMessage, blocked);
|
||||
addLog(chatLog);
|
||||
chatLogWebHandler.forwardChatLogToWeb(chatLog);
|
||||
}
|
||||
|
||||
public CompletableFuture<List<ChatLog>> retrieveChatLogs(UUID uuid, Duration duration, String server) {
|
||||
|
||||
@@ -0,0 +1,97 @@
|
||||
package com.alttd.chat.objects.chat_log;
|
||||
|
||||
import com.alttd.altitudeweb.api.ChatApi;
|
||||
import com.alttd.altitudeweb.invoker.ApiClient;
|
||||
import com.alttd.altitudeweb.invoker.ApiException;
|
||||
import com.alttd.altitudeweb.model.ChatMessageDto;
|
||||
import com.alttd.chat.config.Config;
|
||||
import com.alttd.chat.util.ALogger;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.Queue;
|
||||
import java.util.concurrent.ConcurrentLinkedQueue;
|
||||
import java.util.concurrent.ExecutorService;
|
||||
import java.util.concurrent.Executors;
|
||||
|
||||
public class ChatLogWebHandler {
|
||||
|
||||
private static final int MAX_QUEUE_SIZE = 100;
|
||||
private static final Logger log = LoggerFactory.getLogger(ChatLogWebHandler.class);
|
||||
|
||||
private final Queue<ChatLog> queue = new ConcurrentLinkedQueue<>();
|
||||
private final ExecutorService executor = Executors.newSingleThreadExecutor();
|
||||
|
||||
private final ChatApi chatApi;
|
||||
|
||||
public ChatLogWebHandler() {
|
||||
ApiClient apiClient = new ApiClient();
|
||||
apiClient.setBasePath(Config.CHAT_WEB_SERVER_BASE_URL);
|
||||
|
||||
chatApi = new ChatApi(apiClient);
|
||||
}
|
||||
|
||||
private volatile boolean sending;
|
||||
|
||||
public void forwardChatLogToWeb(ChatLog chatLog) {
|
||||
if (queue.size() >= MAX_QUEUE_SIZE) {
|
||||
queue.clear();
|
||||
log.error("Chat log queue overflow, is the web backend still running?");
|
||||
}
|
||||
|
||||
queue.add(chatLog);
|
||||
triggerSend();
|
||||
}
|
||||
|
||||
private void triggerSend() {
|
||||
if (sending) {
|
||||
return;
|
||||
}
|
||||
|
||||
synchronized (this) {
|
||||
if (sending || queue.isEmpty()) {
|
||||
return;
|
||||
}
|
||||
|
||||
sending = true;
|
||||
}
|
||||
|
||||
executor.execute(this::sendBatch);
|
||||
}
|
||||
|
||||
private void sendBatch() {
|
||||
try {
|
||||
ArrayList<ChatLog> chatLogList = new ArrayList<>();
|
||||
|
||||
ChatLog log;
|
||||
while ((log = queue.poll()) != null) {
|
||||
if (log.getMiniMessage() == null) {
|
||||
ALogger.warn("No mini message for message, skipping");
|
||||
continue;
|
||||
}
|
||||
chatLogList.add(log);
|
||||
}
|
||||
|
||||
List<ChatMessageDto> batch = chatLogList.stream().map(ChatLog::toDto).toList();
|
||||
|
||||
if (!chatLogList.isEmpty()) {
|
||||
try {
|
||||
chatApi.sendChatMessages(batch);
|
||||
} catch (ApiException e) {
|
||||
ALogger.error("Failed to send chat messages to web backend, " +
|
||||
"adding messages back to queue for another try", e
|
||||
);
|
||||
queue.addAll(chatLogList);
|
||||
}
|
||||
}
|
||||
} finally {
|
||||
synchronized (this) {
|
||||
sending = false;
|
||||
}
|
||||
|
||||
triggerSend();
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -3,14 +3,20 @@ plugins {
|
||||
id("io.github.goooler.shadow")
|
||||
}
|
||||
|
||||
val nexusUser = providers.gradleProperty("alttdSnapshotUsername").orNull ?: System.getenv("NEXUS_USERNAME")
|
||||
val nexusPass = providers.gradleProperty("alttdSnapshotPassword").orNull ?: System.getenv("NEXUS_PASSWORD")
|
||||
|
||||
dependencies {
|
||||
implementation(project(":api")) // API
|
||||
compileOnly("com.alttd.cosmos:cosmos-api:1.21.8-R0.1-SNAPSHOT") {
|
||||
isChanging = true
|
||||
}
|
||||
compileOnly("org.projectlombok:lombok:1.18.46")
|
||||
annotationProcessor("org.projectlombok:lombok:1.18.46")
|
||||
compileOnly("com.gitlab.ruany:LiteBansAPI:0.6.1") // move to proxy
|
||||
compileOnly("org.apache.commons:commons-lang3:3.17.0") // needs an alternative, already removed from upstream api and will be removed in server
|
||||
compileOnly("net.luckperms:api:5.5") // Luckperms
|
||||
implementation("com.alttd.inventory_gui:InventoryGUI:1.1.5-SNAPSHOT")
|
||||
}
|
||||
|
||||
tasks {
|
||||
|
||||
@@ -55,7 +55,9 @@ public class ChatListener implements Listener {
|
||||
}
|
||||
|
||||
Component formatComponent = Component.text("%message%");
|
||||
ComponentLike message = parseMessageContent(event.player(), plainTextComponentSerializer.serialize(event.originalMessage()));
|
||||
ComponentLike message = parseMessageContent(event.player(),
|
||||
plainTextComponentSerializer.serialize(event.originalMessage())
|
||||
);
|
||||
|
||||
event.result(formatComponent.replaceText(TextReplacementConfig.builder().match("%message%").replacement(message).build()));
|
||||
}
|
||||
@@ -67,7 +69,9 @@ public class ChatListener implements Listener {
|
||||
}
|
||||
|
||||
Component formatComponent = Component.text("%message%");
|
||||
ComponentLike message = parseMessageContent(event.player(), plainTextComponentSerializer.serialize(event.originalMessage()));
|
||||
ComponentLike message = parseMessageContent(event.player(),
|
||||
plainTextComponentSerializer.serialize(event.originalMessage())
|
||||
);
|
||||
|
||||
event.result(formatComponent.replaceText(TextReplacementConfig.builder().match("%message%").replacement(message).build()));
|
||||
}
|
||||
@@ -92,27 +96,31 @@ public class ChatListener implements Listener {
|
||||
UUID uuid = player.getUniqueId();
|
||||
|
||||
ComponentLike input = event.message().colorIfAbsent(NamedTextColor.WHITE);
|
||||
Component inputComponent = input.asComponent();
|
||||
|
||||
ModifiableString modifiableString = new ModifiableString(input.asComponent());
|
||||
ModifiableString modifiableString = new ModifiableString(inputComponent);
|
||||
|
||||
// todo a better way for this
|
||||
if (!RegexManager.filterText(player.getName(), uuid, modifiableString, true, "chat", filterType -> {
|
||||
if (!filterType.equals(FilterType.PUNISH)) {
|
||||
ALogger.warn("Received another FilterType than punish when filtering chat and executing a filter action");
|
||||
return;
|
||||
}
|
||||
ByteArrayDataOutput out = ByteStreams.newDataOutput();
|
||||
out.writeUTF("punish");
|
||||
out.writeUTF(player.getName());
|
||||
out.writeUTF(uuid.toString());
|
||||
out.writeUTF(modifiableString.string());
|
||||
player.sendPluginMessage(ChatPlugin.getInstance(), Config.MESSAGECHANNEL, out.toByteArray());
|
||||
})) {
|
||||
if (!filterType.equals(FilterType.PUNISH)) {
|
||||
ALogger.warn("Received another FilterType than punish when filtering chat and executing a filter action");
|
||||
return;
|
||||
}
|
||||
ByteArrayDataOutput out = ByteStreams.newDataOutput();
|
||||
out.writeUTF("punish");
|
||||
out.writeUTF(player.getName());
|
||||
out.writeUTF(uuid.toString());
|
||||
out.writeUTF(modifiableString.string());
|
||||
player.sendPluginMessage(ChatPlugin.getInstance(), Config.MESSAGECHANNEL, out.toByteArray());
|
||||
}
|
||||
)) {
|
||||
event.setCancelled(true);
|
||||
GalaxyUtility.sendBlockedNotification("Language", player,
|
||||
modifiableString.component(),
|
||||
"");
|
||||
chatLogHandler.addChatLog(uuid, ServerName.getServerName(), PlainTextComponentSerializer.plainText().serialize(input.asComponent()), true);
|
||||
modifiableString.component(),
|
||||
""
|
||||
);
|
||||
String originalMessage = PlainTextComponentSerializer.plainText().serialize(inputComponent);
|
||||
chatLogHandler.addChatLog(uuid, ServerName.getServerName(), originalMessage, inputComponent, true);
|
||||
return; // the message was blocked
|
||||
}
|
||||
|
||||
@@ -120,7 +128,8 @@ public class ChatListener implements Listener {
|
||||
.map(audience -> (Player) audience);
|
||||
|
||||
if (!player.hasPermission("chat.ignorebypass")) {
|
||||
stream = stream.filter(receiver -> !ChatUserManager.getChatUser(receiver.getUniqueId()).getIgnoredPlayers().contains(uuid)
|
||||
stream = stream.filter(receiver -> !ChatUserManager.getChatUser(receiver.getUniqueId()).getIgnoredPlayers().contains(
|
||||
uuid)
|
||||
|| receiver.hasPermission("chat.ignorebypass"));
|
||||
}
|
||||
Set<Player> receivers = stream.collect(Collectors.toSet());
|
||||
@@ -135,8 +144,13 @@ public class ChatListener implements Listener {
|
||||
for (Player pingPlayer : playersToPing) {
|
||||
pingPlayer.playSound(pingPlayer.getLocation(), Sound.BLOCK_NOTE_BLOCK_BASS, 1, 1);
|
||||
}
|
||||
chatLogHandler.addChatLog(uuid, ServerName.getServerName(), modifiableString.string(), false);
|
||||
ALogger.info(PlainTextComponentSerializer.plainText().serialize(input.asComponent()));
|
||||
chatLogHandler.addChatLog(uuid,
|
||||
ServerName.getServerName(),
|
||||
modifiableString.string(),
|
||||
modifiableString.component(),
|
||||
false
|
||||
);
|
||||
ALogger.info(PlainTextComponentSerializer.plainText().serialize(inputComponent));
|
||||
}
|
||||
|
||||
private void pingPlayers(Set<Player> playersToPing, ModifiableString modifiableString, Player player) {
|
||||
@@ -152,10 +166,10 @@ public class ChatListener implements Listener {
|
||||
ChatUser onlinePlayerUser = ChatUserManager.getChatUser(onlinePlayer.getUniqueId());
|
||||
if (namePattern.matcher(modifiableString.string()).find()) {
|
||||
modifiableString.replace(TextReplacementConfig.builder()
|
||||
.once()
|
||||
.match(namePattern)
|
||||
.replacement(mention.append(onlinePlayerUser.getDisplayName()))
|
||||
.build());
|
||||
.once()
|
||||
.match(namePattern)
|
||||
.replacement(mention.append(onlinePlayerUser.getDisplayName()))
|
||||
.build());
|
||||
//TODO replace all instances of \name with just name but using the match result so the capitalization doesn't change
|
||||
// modifiableString.replace(TextReplacementConfig.builder()
|
||||
// .once()
|
||||
@@ -171,10 +185,10 @@ public class ChatListener implements Listener {
|
||||
}
|
||||
} else if (nickPattern.matcher(modifiableString.string()).find()) {
|
||||
modifiableString.replace(TextReplacementConfig.builder()
|
||||
.once()
|
||||
.match(nickPattern)
|
||||
.replacement(mention.append(onlinePlayerUser.getDisplayName()))
|
||||
.build());
|
||||
.once()
|
||||
.match(nickPattern)
|
||||
.replacement(mention.append(onlinePlayerUser.getDisplayName()))
|
||||
.build());
|
||||
if (!ChatUserManager.getChatUser(onlinePlayer.getUniqueId()).getIgnoredPlayers().contains(player.getUniqueId())
|
||||
|| player.hasPermission("chat.ignorebypass")) {
|
||||
playersToPing.add(onlinePlayer);
|
||||
@@ -192,7 +206,7 @@ public class ChatListener implements Listener {
|
||||
Placeholder.component("prefixall", user.getPrefixAll()),
|
||||
Placeholder.component("staffprefix", user.getStaffPrefix()),
|
||||
Placeholder.component("message", message)
|
||||
);
|
||||
);
|
||||
|
||||
return Utility.parseMiniMessage(Config.CHATFORMAT, placeholders);
|
||||
}
|
||||
|
||||
@@ -45,89 +45,98 @@ public class Nicknames implements CommandExecutor, TabCompleter {
|
||||
|
||||
@Override
|
||||
public boolean onCommand(@NotNull CommandSender sender, @NotNull Command cmd, @NotNull String label, String[] args) {
|
||||
if (sender instanceof Player player) {
|
||||
if (args.length == 0) {
|
||||
sender.sendRichMessage(helpMessage(sender, HelpType.ALL));
|
||||
return true;
|
||||
}
|
||||
switch (args[0].toLowerCase()) {
|
||||
case "set":
|
||||
if (args.length == 2 && hasPermission(sender, "chat.command.nick.set")) {
|
||||
handleNick(player, player, args[1]);
|
||||
} else if (args.length == 3 && hasPermission(sender, "chat.command.nick.set.others")) {
|
||||
OfflinePlayer offlinePlayer = sender.getServer().getOfflinePlayer(args[1]);
|
||||
|
||||
if (offlinePlayer.isOnline() || offlinePlayer.hasPlayedBefore()) {
|
||||
handleNick(player, offlinePlayer, args[2]);
|
||||
} else {
|
||||
sender.sendRichMessage(helpMessage(sender, HelpType.SET_OTHERS));
|
||||
}
|
||||
} else if (args.length > 3) {
|
||||
sender.sendRichMessage(helpMessage(sender, HelpType.SET_SELF, HelpType.SET_OTHERS));
|
||||
}
|
||||
break;
|
||||
case "review":
|
||||
if (args.length == 1 && hasPermission(sender, "chat.command.nick.review")) {
|
||||
NicknamesGui nicknamesGui = new NicknamesGui();
|
||||
ChatPlugin.getInstance().getServer().getPluginManager().registerEvents(nicknamesGui, ChatPlugin.getInstance());
|
||||
nicknamesGui.openInventory(player);
|
||||
} else {
|
||||
sender.sendRichMessage(helpMessage(sender, HelpType.REVIEW));
|
||||
}
|
||||
break;
|
||||
case "request":
|
||||
if (args.length == 2 && hasPermission(sender, "chat.command.nick.request")) {
|
||||
new BukkitRunnable() {
|
||||
@Override
|
||||
public void run() {
|
||||
handleNickRequest(player, args[1]);
|
||||
}
|
||||
}.runTaskAsynchronously(ChatPlugin.getInstance());
|
||||
} else {
|
||||
sender.sendRichMessage(helpMessage(sender, HelpType.REQUEST));
|
||||
}
|
||||
break;
|
||||
case "try":
|
||||
if (args.length == 2 && hasPermission(sender, "chat.command.nick.try")) {
|
||||
LuckPerms api = ChatAPI.get().getLuckPerms();
|
||||
if (api != null) {
|
||||
if (NickUtilities.validNick(player, player, args[1])) {
|
||||
sender.sendRichMessage(Config.NICK_TRYOUT,
|
||||
Placeholder.component("prefix", Utility.applyColor(api.getUserManager().getUser(player.getUniqueId())
|
||||
.getCachedData().getMetaData().getPrefix())), // TODO pull this from chatuser?
|
||||
Placeholder.component("nick", Utility.applyColor(args[1])),
|
||||
Placeholder.unparsed("nickrequest", args[1]));
|
||||
}
|
||||
} else {
|
||||
sender.sendRichMessage(Config.NICK_NO_LUCKPERMS);
|
||||
}
|
||||
} else {
|
||||
sender.sendRichMessage(helpMessage(sender, HelpType.TRY));
|
||||
}
|
||||
break;
|
||||
case "current":
|
||||
if (hasPermission(sender, "chat.command.nick.current")) {
|
||||
ChatUser chatUser = ChatUserManager.getChatUser(player.getUniqueId());
|
||||
TagResolver placeholders = TagResolver.resolver(
|
||||
Placeholder.component("nickname", chatUser.getDisplayName()),
|
||||
Placeholder.parsed("currentnickname", chatUser.getNickNameString())
|
||||
);
|
||||
player.sendRichMessage(Config.NICK_CURRENT, placeholders);
|
||||
}
|
||||
break;
|
||||
case "help":
|
||||
sender.sendRichMessage(helpMessage(sender, HelpType.ALL)
|
||||
+ "For more info on nicknames and how to use rgb colors go to: <aqua>https://alttd.com/nicknames<white>");
|
||||
break;
|
||||
default:
|
||||
sender.sendRichMessage(helpMessage(sender, HelpType.ALL));
|
||||
}
|
||||
} else {
|
||||
if (!(sender instanceof Player player)) {
|
||||
sender.sendMessage("Console commands are disabled.");
|
||||
return true;
|
||||
}
|
||||
if (args.length == 0) {
|
||||
sender.sendRichMessage(helpMessage(sender, HelpType.ALL));
|
||||
return true;
|
||||
}
|
||||
switch (args[0].toLowerCase()) {
|
||||
case "set" -> setNickname(sender, args, player);
|
||||
case "review" -> reviewNickname(sender, args, player);
|
||||
case "request" -> requestNickname(sender, args, player);
|
||||
case "try" -> tryNickname(sender, args, player);
|
||||
case "current" -> showCurrentNickname(sender, player);
|
||||
case "help" ->
|
||||
sender.sendRichMessage(helpMessage(sender, HelpType.ALL) + "For more info on nicknames and how to use rgb colors go to: <aqua>https://alttd.com/nicknames<white>");
|
||||
default -> sender.sendRichMessage(helpMessage(sender, HelpType.ALL));
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
||||
private void showCurrentNickname(@NotNull CommandSender sender, Player player) {
|
||||
if (!hasPermission(sender, "chat.command.nick.current")) {
|
||||
return;
|
||||
}
|
||||
ChatUser chatUser = ChatUserManager.getChatUser(player.getUniqueId());
|
||||
TagResolver placeholders = TagResolver.resolver(
|
||||
Placeholder.component("nickname", chatUser.getDisplayName()),
|
||||
Placeholder.parsed("currentnickname", chatUser.getNickNameString())
|
||||
);
|
||||
player.sendRichMessage(Config.NICK_CURRENT, placeholders);
|
||||
}
|
||||
|
||||
private void tryNickname(@NotNull CommandSender sender, String[] args, Player player) {
|
||||
if (args.length != 2 || !hasPermission(sender, "chat.command.nick.try")) {
|
||||
sender.sendRichMessage(helpMessage(sender, HelpType.TRY));
|
||||
return;
|
||||
}
|
||||
LuckPerms api = ChatAPI.get().getLuckPerms();
|
||||
if (api == null) {
|
||||
sender.sendRichMessage(Config.NICK_NO_LUCKPERMS);
|
||||
return;
|
||||
}
|
||||
if (!NickUtilities.validNick(player, player, args[1])) {
|
||||
return;
|
||||
}
|
||||
sender.sendRichMessage(Config.NICK_TRYOUT,
|
||||
Placeholder.component("prefix", Utility.applyColor(api.getUserManager().getUser(player.getUniqueId())
|
||||
.getCachedData().getMetaData().getPrefix())), // TODO pull this from chatuser?
|
||||
Placeholder.component("nick", Utility.applyColor(args[1])),
|
||||
Placeholder.unparsed("nickrequest", args[1]));
|
||||
}
|
||||
|
||||
private void requestNickname(@NotNull CommandSender sender, String[] args, Player player) {
|
||||
if (args.length != 2 || !hasPermission(sender, "chat.command.nick.request")) {
|
||||
sender.sendRichMessage(helpMessage(sender, HelpType.REQUEST));
|
||||
return;
|
||||
}
|
||||
new BukkitRunnable() {
|
||||
@Override
|
||||
public void run() {
|
||||
handleNickRequest(player, args[1]);
|
||||
}
|
||||
}.runTaskAsynchronously(ChatPlugin.getInstance());
|
||||
}
|
||||
|
||||
private void reviewNickname(@NotNull CommandSender sender, String[] args, Player player) {
|
||||
if (args.length != 1 || !hasPermission(sender, "chat.command.nick.review")) {
|
||||
sender.sendRichMessage(helpMessage(sender, HelpType.REVIEW));
|
||||
return;
|
||||
}
|
||||
NicknamesGui nicknamesGui = new NicknamesGui(player);
|
||||
ChatPlugin.getInstance().getServer().getPluginManager().registerEvents(nicknamesGui, ChatPlugin.getInstance());
|
||||
nicknamesGui.openInventory(player);
|
||||
}
|
||||
|
||||
private void setNickname(@NotNull CommandSender sender, String[] args, Player player) {
|
||||
if (args.length == 2 && hasPermission(sender, "chat.command.nick.set")) {
|
||||
handleNick(player, player, args[1]);
|
||||
} else if (args.length == 3 && hasPermission(sender, "chat.command.nick.set.others")) {
|
||||
OfflinePlayer offlinePlayer = sender.getServer().getOfflinePlayer(args[1]);
|
||||
|
||||
if (offlinePlayer.isOnline() || offlinePlayer.hasPlayedBefore()) {
|
||||
handleNick(player, offlinePlayer, args[2]);
|
||||
} else {
|
||||
sender.sendRichMessage(helpMessage(sender, HelpType.SET_OTHERS));
|
||||
}
|
||||
} else if (args.length > 3) {
|
||||
sender.sendRichMessage(helpMessage(sender, HelpType.SET_SELF, HelpType.SET_OTHERS));
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<String> onTabComplete(CommandSender sender, @NotNull Command command, @NotNull String label, String[] args) {
|
||||
List<String> completions = new ArrayList<>();
|
||||
@@ -136,49 +145,58 @@ public class Nicknames implements CommandExecutor, TabCompleter {
|
||||
}
|
||||
|
||||
if (args.length == 1) {
|
||||
List<String> choices = new ArrayList<>();
|
||||
if (sender.hasPermission("chat.command.nick.set")) {
|
||||
choices.add("set");
|
||||
}
|
||||
if (sender.hasPermission("chat.command.nick.review")) {
|
||||
choices.add("review");
|
||||
}
|
||||
if (sender.hasPermission("chat.command.nick.request")) {
|
||||
choices.add("request");
|
||||
}
|
||||
if (sender.hasPermission("chat.command.nick.try")) {
|
||||
choices.add("try");
|
||||
}
|
||||
if (sender.hasPermission("chat.command.nick.current")) {
|
||||
choices.add("current");
|
||||
}
|
||||
choices.add("help");
|
||||
|
||||
for (String s : choices) {
|
||||
if (s.startsWith(args[0])) {
|
||||
completions.add(s);
|
||||
}
|
||||
}
|
||||
tabCompleteArgLengthOne(sender, args, completions);
|
||||
} else if (args.length == 2) {
|
||||
if (args[0].equalsIgnoreCase("set")) {
|
||||
List<String> choices = new ArrayList<>();
|
||||
List<String> onlinePlayers = new ArrayList<>();
|
||||
Bukkit.getOnlinePlayers().forEach(a -> onlinePlayers.add(a.getName()));
|
||||
|
||||
if (sender.hasPermission("chat.command.nick.set.others")) {
|
||||
choices.addAll(onlinePlayers);
|
||||
}
|
||||
|
||||
for (String s : choices) {
|
||||
if (s.startsWith(args[1])) {
|
||||
completions.add(s);
|
||||
}
|
||||
}
|
||||
}
|
||||
tabCompleteArgLengthTwo(sender, args, completions);
|
||||
}
|
||||
return completions;
|
||||
}
|
||||
|
||||
private static void tabCompleteArgLengthTwo(CommandSender sender, String[] args, List<String> completions) {
|
||||
if (!args[0].equalsIgnoreCase("set")) {
|
||||
return;
|
||||
}
|
||||
List<String> choices = new ArrayList<>();
|
||||
List<String> onlinePlayers = new ArrayList<>();
|
||||
Bukkit.getOnlinePlayers().forEach(a -> onlinePlayers.add(a.getName()));
|
||||
|
||||
if (sender.hasPermission("chat.command.nick.set.others")) {
|
||||
choices.addAll(onlinePlayers);
|
||||
}
|
||||
|
||||
for (String s : choices) {
|
||||
if (s.startsWith(args[1])) {
|
||||
completions.add(s);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private static void tabCompleteArgLengthOne(CommandSender sender, String[] args, List<String> completions) {
|
||||
List<String> choices = new ArrayList<>();
|
||||
if (sender.hasPermission("chat.command.nick.set")) {
|
||||
choices.add("set");
|
||||
}
|
||||
if (sender.hasPermission("chat.command.nick.review")) {
|
||||
choices.add("review");
|
||||
}
|
||||
if (sender.hasPermission("chat.command.nick.request")) {
|
||||
choices.add("request");
|
||||
}
|
||||
if (sender.hasPermission("chat.command.nick.try")) {
|
||||
choices.add("try");
|
||||
}
|
||||
if (sender.hasPermission("chat.command.nick.current")) {
|
||||
choices.add("current");
|
||||
}
|
||||
choices.add("help");
|
||||
|
||||
for (String s : choices) {
|
||||
if (s.startsWith(args[0])) {
|
||||
completions.add(s);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private void handleNickRequest(Player player, String nickName) {
|
||||
if (!NickUtilities.validNick(player, player, nickName)) {
|
||||
return;
|
||||
@@ -261,69 +279,75 @@ public class Nicknames implements CommandExecutor, TabCompleter {
|
||||
|
||||
private void handleNick(Player sender, OfflinePlayer target, final String nickName) {
|
||||
if (nickName.equalsIgnoreCase("off")) {
|
||||
|
||||
try {
|
||||
if (target.isOnline()) {
|
||||
resetNick(Objects.requireNonNull(target.getPlayer()));
|
||||
}
|
||||
Queries.removePlayerFromDataBase(target.getUniqueId());
|
||||
NickCache.remove(target.getUniqueId());
|
||||
nickCacheUpdate.add(target.getUniqueId());
|
||||
} catch (SQLException e) {
|
||||
ALogger.error("Failed to remove nickname from database", e);
|
||||
}
|
||||
|
||||
if (!sender.equals(target)) {
|
||||
sender.sendRichMessage(Config.NICK_RESET_OTHERS,
|
||||
Placeholder.unparsed("player", Objects.requireNonNull(target.getName())));
|
||||
}
|
||||
|
||||
if (target.isOnline() && target.getPlayer() != null) {
|
||||
target.getPlayer().sendRichMessage(Config.NICK_RESET);
|
||||
}
|
||||
|
||||
NickEvent nickEvent = new NickEvent(sender.getName(), target.getName(), null, NickEvent.NickEventType.RESET);
|
||||
nickEvent.callEvent();
|
||||
|
||||
handleNickOff(sender, target);
|
||||
} else if (NickUtilities.validNick(sender, target, nickName)) {
|
||||
if (target.isOnline()) {
|
||||
setNick(target.getPlayer(), nickName);
|
||||
} else {
|
||||
NickUtilities.bungeeMessageHandled(target.getUniqueId(), sender, "Set");
|
||||
}
|
||||
|
||||
Queries.setNicknameInDatabase(target.getUniqueId(), nickName);
|
||||
NickEvent nickEvent = new NickEvent(sender.getName(), target.getName(), nickName, NickEvent.NickEventType.SET);
|
||||
nickEvent.callEvent();
|
||||
|
||||
if (NickCache.containsKey(target.getUniqueId())) {
|
||||
Nick nick = NickCache.get(target.getUniqueId());
|
||||
nick.setCurrentNick(nickName);
|
||||
nick.setLastChangedDate(new Date().getTime());
|
||||
setNick(target.getPlayer(), nickName);
|
||||
} else {
|
||||
NickCache.put(target.getUniqueId(), new Nick(target.getUniqueId(), nickName, new Date().getTime()));
|
||||
}
|
||||
|
||||
if (!sender.equals(target)) {
|
||||
sender.sendMessage(Utility.parseMiniMessage(Config.NICK_CHANGED_OTHERS,
|
||||
Placeholder.unparsed("targetplayer", Objects.requireNonNull(target.getName())),
|
||||
Placeholder.unparsed("nickname", nickName)));
|
||||
if (target.isOnline()) {
|
||||
Objects.requireNonNull(target.getPlayer())
|
||||
.sendRichMessage(Config.NICK_TARGET_NICK_CHANGE,
|
||||
Placeholder.unparsed("nickname", getNick(target.getPlayer())),
|
||||
Placeholder.unparsed("sendernick", getNick(sender)),
|
||||
Placeholder.unparsed("player", target.getName()));
|
||||
}
|
||||
} else if (target.isOnline()) {
|
||||
Objects.requireNonNull(target.getPlayer())
|
||||
.sendRichMessage(Config.NICK_CHANGED,
|
||||
Placeholder.unparsed("nickname", getNick(target.getPlayer())));
|
||||
}
|
||||
setValidNick(sender, target, nickName);
|
||||
}
|
||||
}
|
||||
|
||||
private void setValidNick(Player sender, OfflinePlayer target, String nickName) {
|
||||
if (target.isOnline()) {
|
||||
setNick(target.getPlayer(), nickName);
|
||||
} else {
|
||||
NickUtilities.bungeeMessageHandled(target.getUniqueId(), sender, "Set");
|
||||
}
|
||||
|
||||
Queries.setNicknameInDatabase(target.getUniqueId(), nickName);
|
||||
NickEvent nickEvent = new NickEvent(sender.getName(), target.getName(), nickName, NickEvent.NickEventType.SET);
|
||||
nickEvent.callEvent();
|
||||
|
||||
if (NickCache.containsKey(target.getUniqueId())) {
|
||||
Nick nick = NickCache.get(target.getUniqueId());
|
||||
nick.setCurrentNick(nickName);
|
||||
nick.setLastChangedDate(new Date().getTime());
|
||||
setNick(target.getPlayer(), nickName);
|
||||
} else {
|
||||
NickCache.put(target.getUniqueId(), new Nick(target.getUniqueId(), nickName, new Date().getTime()));
|
||||
}
|
||||
|
||||
if (!sender.equals(target)) {
|
||||
sender.sendMessage(Utility.parseMiniMessage(Config.NICK_CHANGED_OTHERS,
|
||||
Placeholder.unparsed("targetplayer", Objects.requireNonNull(target.getName())),
|
||||
Placeholder.unparsed("nickname", nickName)));
|
||||
if (target.isOnline()) {
|
||||
Objects.requireNonNull(target.getPlayer())
|
||||
.sendRichMessage(Config.NICK_TARGET_NICK_CHANGE,
|
||||
Placeholder.unparsed("nickname", getNick(target.getPlayer())),
|
||||
Placeholder.unparsed("sendernick", getNick(sender)),
|
||||
Placeholder.unparsed("player", target.getName()));
|
||||
}
|
||||
} else if (target.isOnline()) {
|
||||
Objects.requireNonNull(target.getPlayer())
|
||||
.sendRichMessage(Config.NICK_CHANGED,
|
||||
Placeholder.unparsed("nickname", getNick(target.getPlayer())));
|
||||
}
|
||||
}
|
||||
|
||||
private void handleNickOff(Player sender, OfflinePlayer target) {
|
||||
try {
|
||||
if (target.isOnline()) {
|
||||
resetNick(Objects.requireNonNull(target.getPlayer()));
|
||||
}
|
||||
Queries.removePlayerFromDataBase(target.getUniqueId());
|
||||
NickCache.remove(target.getUniqueId());
|
||||
nickCacheUpdate.add(target.getUniqueId());
|
||||
} catch (SQLException e) {
|
||||
ALogger.error("Failed to remove nickname from database", e);
|
||||
}
|
||||
|
||||
if (!sender.equals(target)) {
|
||||
sender.sendRichMessage(Config.NICK_RESET_OTHERS,
|
||||
Placeholder.unparsed("player", Objects.requireNonNull(target.getName())));
|
||||
}
|
||||
|
||||
if (target.isOnline() && target.getPlayer() != null) {
|
||||
target.getPlayer().sendRichMessage(Config.NICK_RESET);
|
||||
}
|
||||
|
||||
NickEvent nickEvent = new NickEvent(sender.getName(), target.getName(), null, NickEvent.NickEventType.RESET);
|
||||
nickEvent.callEvent();
|
||||
}
|
||||
|
||||
private String helpMessage(final CommandSender sender, final HelpType... helpTypes) {
|
||||
StringBuilder message = new StringBuilder();
|
||||
for (HelpType helpType : helpTypes) {
|
||||
|
||||
@@ -5,24 +5,22 @@ import com.alttd.chat.config.Config;
|
||||
import com.alttd.chat.database.Queries;
|
||||
import com.alttd.chat.events.NickEvent;
|
||||
import com.alttd.chat.objects.Nick;
|
||||
import com.alttd.chat.util.ALogger;
|
||||
import com.alttd.chat.util.Utility;
|
||||
import com.alttd.inventory_gui.click.GuiItem;
|
||||
import com.alttd.inventory_gui.gui.InventoryGui;
|
||||
import net.kyori.adventure.text.Component;
|
||||
import net.kyori.adventure.text.ComponentLike;
|
||||
import net.kyori.adventure.text.minimessage.MiniMessage;
|
||||
import net.kyori.adventure.text.minimessage.tag.resolver.Placeholder;
|
||||
import net.kyori.adventure.text.minimessage.tag.resolver.TagResolver;
|
||||
import net.kyori.adventure.text.serializer.plain.PlainTextComponentSerializer;
|
||||
import org.bukkit.Bukkit;
|
||||
import org.bukkit.Material;
|
||||
import org.bukkit.OfflinePlayer;
|
||||
import org.bukkit.entity.HumanEntity;
|
||||
import org.bukkit.entity.Player;
|
||||
import org.bukkit.event.EventHandler;
|
||||
import org.bukkit.event.EventPriority;
|
||||
import org.bukkit.event.Listener;
|
||||
import org.bukkit.event.inventory.InventoryClickEvent;
|
||||
import org.bukkit.event.inventory.InventoryDragEvent;
|
||||
import org.bukkit.inventory.Inventory;
|
||||
import org.bukkit.inventory.ItemStack;
|
||||
import org.bukkit.inventory.meta.ItemMeta;
|
||||
import org.bukkit.inventory.meta.SkullMeta;
|
||||
@@ -31,39 +29,45 @@ import org.bukkit.scheduler.BukkitRunnable;
|
||||
import java.util.Arrays;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
import java.util.UUID;
|
||||
import java.util.stream.Collectors;
|
||||
|
||||
public class NicknamesGui implements Listener {
|
||||
|
||||
private final Inventory inv;
|
||||
public static final String UNKNOWN_PLAYER_NAME = "UNKNOWN PLAYER NAME";
|
||||
private final int currentPage;
|
||||
private final ChatPlugin plugin = ChatPlugin.getInstance();
|
||||
private final InventoryGui nicknamesGui;
|
||||
|
||||
public NicknamesGui() {
|
||||
// Create a new inventory, with no owner (as this isn't a real inventory)
|
||||
inv = Bukkit.createInventory(null, 36, Utility.parseMiniMessage("Nicknames GUI").asComponent());
|
||||
|
||||
// Put the items into the inventory
|
||||
public NicknamesGui(Player player) {
|
||||
nicknamesGui = InventoryGui.builder()
|
||||
.plugin(plugin)
|
||||
.title(Component.text("Nicknames GUI"))
|
||||
.rows(6)
|
||||
.build();
|
||||
currentPage = 1;
|
||||
setItems(currentPage);
|
||||
setItems(currentPage, player);
|
||||
}
|
||||
|
||||
public void setItems(int currentPage) {
|
||||
public void setItems(int currentPage, Player player) {
|
||||
new BukkitRunnable() {
|
||||
@Override
|
||||
public void run() {
|
||||
inv.clear();
|
||||
NickUtilities.updateCache();
|
||||
boolean hasNextPage = false;
|
||||
int i = (currentPage - 1) * 27; //TODO set to 1 or 2 to test
|
||||
int limit = i / 27;
|
||||
MiniMessage miniMessage = MiniMessage.miniMessage();
|
||||
|
||||
for (Nick nick : Nicknames.getInstance().NickCache.values()) {
|
||||
if (nick.hasRequest()) {
|
||||
if (limit >= i / 27) {
|
||||
inv.setItem(i % 27, createPlayerSkull(nick, Config.NICK_ITEM_LORE));
|
||||
ItemStack playerSkull = createPlayerSkull(nick, Config.NICK_ITEM_LORE);
|
||||
nicknamesGui.getRoot().setItem(i % 27, GuiItem.clickable(playerSkull, inventoryClickEvent ->
|
||||
handleInventoryClick(nick, inventoryClickEvent, miniMessage, playerSkull)));
|
||||
ALogger.info("Added nick " + i + " to gui: " + nick.getUuid());
|
||||
i++;
|
||||
} else {
|
||||
ALogger.info("Reached end of nicknames gui page");
|
||||
hasNextPage = true;
|
||||
break;
|
||||
}
|
||||
@@ -71,20 +75,137 @@ public class NicknamesGui implements Listener {
|
||||
}
|
||||
|
||||
if (currentPage != 1) {
|
||||
inv.setItem(28, createGuiItem(Material.PAPER, "§bPrevious page",
|
||||
"§aCurrent page: %page%".replace("%page%", String.valueOf(currentPage)),
|
||||
"§aPrevious page: %previousPage%".replace("%previousPage%", String.valueOf(currentPage - 1))));
|
||||
ItemStack itemStack = createGuiItem(Material.PAPER, "§bPrevious page",
|
||||
"§aCurrent page: %page%".replace("%page%", String.valueOf(currentPage)),
|
||||
"§aPrevious page: %previousPage%".replace("%previousPage%", String.valueOf(currentPage - 1)));
|
||||
GuiItem previousPage = GuiItem.clickable(itemStack, e -> setItems(currentPage - 1, player));
|
||||
nicknamesGui.getRoot().setItem(28, previousPage);
|
||||
}
|
||||
|
||||
if (hasNextPage) {
|
||||
inv.setItem(36, createGuiItem(Material.PAPER, "§bNext page",
|
||||
"§aCurrent page: %page%".replace("%page%", String.valueOf(currentPage)),
|
||||
"§aNext page: §b%nextPage%".replace("%nextPage%", String.valueOf(currentPage + 1))));
|
||||
ItemStack itemStack = createGuiItem(Material.PAPER, "§bNext page",
|
||||
"§aCurrent page: %page%".replace("%page%", String.valueOf(currentPage)),
|
||||
"§aNext page: §b%nextPage%".replace("%nextPage%", String.valueOf(currentPage + 1)));
|
||||
GuiItem nextPage = GuiItem.clickable(itemStack, e -> setItems(currentPage + 1, player));
|
||||
nicknamesGui.getRoot().setItem(36, nextPage);
|
||||
}
|
||||
|
||||
nicknamesGui.render(player);
|
||||
}
|
||||
}.runTaskAsynchronously(ChatPlugin.getInstance());
|
||||
}
|
||||
|
||||
private void handleInventoryClick(Nick nick, InventoryClickEvent inventoryClickEvent, MiniMessage miniMessage, ItemStack playerSkull) {
|
||||
final Player playerWhoClicked = (Player) inventoryClickEvent.getWhoClicked();
|
||||
OfflinePlayer offlinePlayer = Bukkit.getOfflinePlayer(nick.getUuid());
|
||||
Component offlinePlayerName = miniMessage.deserialize(getOfflinePlayerName(offlinePlayer));
|
||||
if (!nick.hasRequest()) {
|
||||
playerWhoClicked.sendRichMessage(Config.NICK_ALREADY_HANDLED,
|
||||
Placeholder.component("targetplayer", offlinePlayerName));
|
||||
return;
|
||||
}
|
||||
if (inventoryClickEvent.isLeftClick()) {
|
||||
handleLeftClickPlayerSkull(nick, inventoryClickEvent, offlinePlayer, playerWhoClicked, offlinePlayerName, playerSkull);
|
||||
} else if (inventoryClickEvent.isRightClick()) {
|
||||
handleRightClickPlayerSkull(nick, inventoryClickEvent, offlinePlayer, playerWhoClicked, offlinePlayerName, playerSkull);
|
||||
}
|
||||
//TODO what do we do no click?
|
||||
}
|
||||
|
||||
private void handleRightClickPlayerSkull(Nick nick, InventoryClickEvent inventoryClickEvent, OfflinePlayer offlinePlayer, Player playerWhoClicked, Component offlinePlayerName, ItemStack playerSkull) {
|
||||
Queries.denyNewNickname(nick.getUuid());
|
||||
|
||||
String newNick = nick.getNewNick();
|
||||
|
||||
new BukkitRunnable() {
|
||||
@Override
|
||||
public void run() {
|
||||
NickEvent nickEvent = new NickEvent(inventoryClickEvent.getWhoClicked().getName(), getOfflinePlayerName(offlinePlayer), newNick, NickEvent.NickEventType.DENIED);
|
||||
nickEvent.callEvent();
|
||||
}
|
||||
}.runTask(ChatPlugin.getInstance());
|
||||
|
||||
playerWhoClicked.sendRichMessage(Config.NICK_DENIED,
|
||||
Placeholder.unparsed("targetplayer", getOfflinePlayerName(offlinePlayer)),
|
||||
Placeholder.component("newnick", Utility.applyColor(nick.getNewNick())),
|
||||
Placeholder.component("oldnick", Utility.applyColor(nick.getCurrentNick() == null ? getOfflinePlayerName(offlinePlayer) : nick.getCurrentNick())));
|
||||
|
||||
if (Nicknames.getInstance().NickCache.containsKey(nick.getUuid())
|
||||
&& Nicknames.getInstance().NickCache.get(nick.getUuid()).getCurrentNick() != null) {
|
||||
nick.setNewNick(null);
|
||||
nick.setRequestedDate(0);
|
||||
Nicknames.getInstance().NickCache.put(nick.getUuid(), nick);
|
||||
} else {
|
||||
Nicknames.getInstance().NickCache.remove(nick.getUuid());
|
||||
}
|
||||
|
||||
if (offlinePlayer.isOnline() && offlinePlayer.getPlayer() != null) {
|
||||
Nicknames.getInstance().setNick(offlinePlayer.getPlayer(), nick.getCurrentNick() == null ? getOfflinePlayerName(offlinePlayer) : nick.getCurrentNick());
|
||||
offlinePlayer.getPlayer().sendRichMessage(Config.NICK_NOT_CHANGED);
|
||||
}
|
||||
|
||||
NickUtilities.bungeeMessageHandled(nick.getUuid(), inventoryClickEvent.getWhoClicked().getServer().getPlayer(inventoryClickEvent.getWhoClicked().getName()), "Denied");
|
||||
final ComponentLike messageDenied = MiniMessage.miniMessage().deserialize("<red><name>'s nickname was denied!",
|
||||
Placeholder.unparsed("name", getOfflinePlayerName(offlinePlayer)));
|
||||
ChatPlugin.getInstance().getServer().getOnlinePlayers().stream()
|
||||
.filter(player -> player.hasPermission("chat.command.nick.review"))
|
||||
.forEach(player -> player.sendMessage(messageDenied));
|
||||
|
||||
ItemStack completedNickRequestItem = createCompletedNickRequestItem(offlinePlayerName, playerSkull);
|
||||
inventoryClickEvent.getInventory().setItem(inventoryClickEvent.getSlot(), completedNickRequestItem);
|
||||
nicknamesGui.render(playerWhoClicked);
|
||||
}
|
||||
|
||||
private void handleLeftClickPlayerSkull(Nick nick, InventoryClickEvent inventoryClickEvent, OfflinePlayer offlinePlayer, Player playerWhoClicked, Component offlinePlayerName, ItemStack playerSkull) {
|
||||
Queries.acceptNewNickname(nick.getUuid(), nick.getNewNick());
|
||||
|
||||
String newNick = nick.getNewNick();
|
||||
|
||||
new BukkitRunnable() {
|
||||
@Override
|
||||
public void run() {
|
||||
NickEvent nickEvent = new NickEvent(inventoryClickEvent.getWhoClicked().getName(), getOfflinePlayerName(offlinePlayer), newNick, NickEvent.NickEventType.ACCEPTED);
|
||||
nickEvent.callEvent();
|
||||
}
|
||||
}.runTask(ChatPlugin.getInstance());
|
||||
|
||||
playerWhoClicked.sendRichMessage(Config.NICK_ACCEPTED,
|
||||
Placeholder.component("targetplayer", offlinePlayerName),
|
||||
Placeholder.component("newnick", Utility.applyColor(nick.getNewNick())),
|
||||
Placeholder.component("oldnick", nick.getCurrentNick() == null ? offlinePlayerName : Utility.applyColor(nick.getCurrentNick())));
|
||||
|
||||
Player affectedPlayer = offlinePlayer.getPlayer();
|
||||
if (offlinePlayer.isOnline() && affectedPlayer != null) {
|
||||
Nicknames.getInstance().setNick(affectedPlayer, nick.getNewNick());
|
||||
}
|
||||
|
||||
NickUtilities.bungeeMessageHandled(nick.getUuid(), inventoryClickEvent.getWhoClicked().getServer().getPlayer(inventoryClickEvent.getWhoClicked().getName()), "Accepted");
|
||||
|
||||
nick.setCurrentNick(nick.getNewNick());
|
||||
nick.setLastChangedDate(new Date().getTime());
|
||||
nick.setNewNick(null);
|
||||
nick.setRequestedDate(0);
|
||||
|
||||
Nicknames.getInstance().NickCache.put(nick.getUuid(), nick);
|
||||
|
||||
ItemStack completedNickRequestItem = createCompletedNickRequestItem(offlinePlayerName, playerSkull);
|
||||
inventoryClickEvent.getInventory().setItem(inventoryClickEvent.getSlot(), completedNickRequestItem);
|
||||
nicknamesGui.render(playerWhoClicked);
|
||||
}
|
||||
|
||||
private static ItemStack createCompletedNickRequestItem(Component offlinePlayerName, ItemStack playerSkull) {
|
||||
ItemStack itemStack = new ItemStack(Material.SKELETON_SKULL);
|
||||
ItemMeta itemMeta = itemStack.getItemMeta();
|
||||
itemMeta.displayName(offlinePlayerName);
|
||||
itemMeta.lore(playerSkull.lore());
|
||||
itemStack.setItemMeta(itemMeta);
|
||||
return itemStack;
|
||||
}
|
||||
|
||||
private static String getOfflinePlayerName(OfflinePlayer offlinePlayer) {
|
||||
return offlinePlayer.getName() == null ? UNKNOWN_PLAYER_NAME : offlinePlayer.getName();
|
||||
}
|
||||
|
||||
private ItemStack createPlayerSkull(Nick nick, List<String> lore) {
|
||||
MiniMessage miniMessage = MiniMessage.miniMessage();
|
||||
ItemStack playerHead = new ItemStack(Material.PLAYER_HEAD);
|
||||
@@ -94,9 +215,9 @@ public class NicknamesGui implements Listener {
|
||||
meta.setOwningPlayer(offlinePlayer);
|
||||
String name = offlinePlayer.getName();
|
||||
if (name == null) {
|
||||
meta.displayName(miniMessage.deserialize("UNKNOWN PLAYER NAME"));
|
||||
meta.displayName(miniMessage.deserialize("<red>" + getOfflinePlayerName(offlinePlayer) + "</red>"));
|
||||
} else {
|
||||
meta.displayName(miniMessage.deserialize(offlinePlayer.getName()));
|
||||
meta.displayName(miniMessage.deserialize(getOfflinePlayerName(offlinePlayer)));
|
||||
}
|
||||
|
||||
TagResolver resolver = TagResolver.resolver(
|
||||
@@ -128,185 +249,6 @@ public class NicknamesGui implements Listener {
|
||||
|
||||
// You can open the inventory with this
|
||||
public void openInventory(final HumanEntity ent) {//Possibly with a boolean to show if it should get from cache or update cache
|
||||
ent.openInventory(inv);
|
||||
}
|
||||
|
||||
// Check for clicks on items
|
||||
@EventHandler(ignoreCancelled = true, priority = EventPriority.HIGHEST)
|
||||
public void onInventoryClick(InventoryClickEvent e) {
|
||||
if (e.getInventory() != inv) {
|
||||
return;
|
||||
}
|
||||
|
||||
e.setCancelled(true);
|
||||
|
||||
final ItemStack clickedItem = e.getCurrentItem();
|
||||
|
||||
if (clickedItem == null || clickedItem.getType() == Material.AIR) {
|
||||
return;
|
||||
}
|
||||
|
||||
final Player p = (Player) e.getWhoClicked();
|
||||
|
||||
if (clickedItem.getType().equals(Material.PAPER)) {
|
||||
Component component = clickedItem.getItemMeta().displayName();
|
||||
if (component == null) {
|
||||
throw new IllegalStateException("Nicknames GUI: Item with no display name clicked!");
|
||||
}
|
||||
String serialize = PlainTextComponentSerializer.plainText().serialize(component);
|
||||
if (serialize.equals("Next Page")) {
|
||||
setItems(currentPage + 1);
|
||||
}
|
||||
} else if (clickedItem.getType().equals(Material.PLAYER_HEAD)) {
|
||||
ItemMeta itemMeta = clickedItem.getItemMeta();
|
||||
if (itemMeta == null) {
|
||||
return;
|
||||
}
|
||||
SkullMeta meta = (SkullMeta) itemMeta;
|
||||
if (meta.hasEnchants()) {
|
||||
return;
|
||||
}
|
||||
OfflinePlayer owningPlayer = meta.getOwningPlayer();
|
||||
|
||||
if (owningPlayer == null) {
|
||||
p.sendRichMessage(Config.NICK_USER_NOT_FOUND);
|
||||
return;
|
||||
}
|
||||
|
||||
new BukkitRunnable() {
|
||||
@Override
|
||||
public void run() {
|
||||
NickUtilities.updateCache();
|
||||
|
||||
Nick nick;
|
||||
UUID uniqueId = owningPlayer.getUniqueId();
|
||||
if (Nicknames.getInstance().NickCache.containsKey(uniqueId)) {
|
||||
nick = Nicknames.getInstance().NickCache.get(uniqueId);
|
||||
} else {
|
||||
nick = Queries.getNick(uniqueId);
|
||||
}
|
||||
Component itemDisplayName = itemMeta.displayName();
|
||||
if (itemDisplayName == null) {
|
||||
return;
|
||||
}
|
||||
|
||||
if (nick == null || !nick.hasRequest()) {
|
||||
p.sendRichMessage(Config.NICK_ALREADY_HANDLED,
|
||||
Placeholder.component("targetplayer", itemDisplayName))
|
||||
;
|
||||
return;
|
||||
}
|
||||
|
||||
if (e.isLeftClick()) {
|
||||
if (owningPlayer.hasPlayedBefore()) {
|
||||
Queries.acceptNewNickname(uniqueId, nick.getNewNick());
|
||||
|
||||
String newNick = nick.getNewNick();
|
||||
|
||||
new BukkitRunnable() {
|
||||
@Override
|
||||
public void run() {
|
||||
NickEvent nickEvent = new NickEvent(e.getWhoClicked().getName(), itemMeta.getDisplayName(), newNick, NickEvent.NickEventType.ACCEPTED);
|
||||
nickEvent.callEvent();
|
||||
}
|
||||
}.runTask(ChatPlugin.getInstance());
|
||||
|
||||
p.sendRichMessage(Config.NICK_ACCEPTED,
|
||||
Placeholder.component("targetplayer", itemDisplayName),
|
||||
Placeholder.component("newnick", Utility.applyColor(nick.getNewNick())),
|
||||
Placeholder.component("oldnick", Utility.applyColor(nick.getCurrentNick() == null ? itemMeta.getDisplayName() : nick.getCurrentNick())));
|
||||
|
||||
if (owningPlayer.isOnline() && owningPlayer.getPlayer() != null) {
|
||||
Nicknames.getInstance().setNick(owningPlayer.getPlayer(), nick.getNewNick());
|
||||
}
|
||||
|
||||
NickUtilities.bungeeMessageHandled(uniqueId, e.getWhoClicked().getServer().getPlayer(e.getWhoClicked().getName()), "Accepted");
|
||||
|
||||
nick.setCurrentNick(nick.getNewNick());
|
||||
nick.setLastChangedDate(new Date().getTime());
|
||||
nick.setNewNick(null);
|
||||
nick.setRequestedDate(0);
|
||||
|
||||
Nicknames.getInstance().NickCache.put(uniqueId, nick);
|
||||
|
||||
ItemStack itemStack = new ItemStack(Material.SKELETON_SKULL);
|
||||
ItemMeta itemMeta = itemStack.getItemMeta();
|
||||
itemMeta.displayName(itemMeta.displayName());
|
||||
itemMeta.lore(clickedItem.lore());
|
||||
itemStack.setItemMeta(itemMeta);
|
||||
e.getInventory().setItem(e.getSlot(), itemStack);
|
||||
p.updateInventory();
|
||||
} else {
|
||||
p.sendRichMessage(Config.NICK_PLAYER_NOT_ONLINE, Placeholder.component("player", itemDisplayName));
|
||||
}
|
||||
|
||||
} else if (e.isRightClick()) {
|
||||
if (owningPlayer.hasPlayedBefore()) {
|
||||
Queries.denyNewNickname(uniqueId);
|
||||
|
||||
String newNick = nick.getNewNick();
|
||||
|
||||
new BukkitRunnable() {
|
||||
@Override
|
||||
public void run() {
|
||||
NickEvent nickEvent = new NickEvent(e.getWhoClicked().getName(), itemMeta.getDisplayName(), newNick, NickEvent.NickEventType.DENIED);
|
||||
nickEvent.callEvent();
|
||||
}
|
||||
}.runTask(ChatPlugin.getInstance());
|
||||
|
||||
p.sendMessage(MiniMessage.miniMessage().deserialize(Config.NICK_DENIED,
|
||||
Placeholder.unparsed("targetplayer", owningPlayer.getName()),
|
||||
Placeholder.component("newnick", Utility.applyColor(nick.getNewNick())),
|
||||
Placeholder.component("oldnick", Utility.applyColor(nick.getCurrentNick() == null ? owningPlayer.getName() : nick.getCurrentNick()))));
|
||||
|
||||
if (Nicknames.getInstance().NickCache.containsKey(uniqueId)
|
||||
&& Nicknames.getInstance().NickCache.get(uniqueId).getCurrentNick() != null) {
|
||||
nick.setNewNick(null);
|
||||
nick.setRequestedDate(0);
|
||||
Nicknames.getInstance().NickCache.put(uniqueId, nick);
|
||||
} else {
|
||||
Nicknames.getInstance().NickCache.remove(uniqueId);
|
||||
}
|
||||
|
||||
if (owningPlayer.isOnline() && owningPlayer.getPlayer() != null) {
|
||||
Nicknames.getInstance().setNick(owningPlayer.getPlayer(), nick.getCurrentNick() == null ? owningPlayer.getName() : nick.getCurrentNick());
|
||||
owningPlayer.getPlayer().sendRichMessage(Config.NICK_NOT_CHANGED);
|
||||
}
|
||||
|
||||
NickUtilities.bungeeMessageHandled(uniqueId, e.getWhoClicked().getServer().getPlayer(e.getWhoClicked().getName()), "Denied");
|
||||
final ComponentLike messageDenied = MiniMessage.miniMessage().deserialize("<red><name>'s nickname was denied!",
|
||||
Placeholder.unparsed("name", owningPlayer.getName()));
|
||||
ChatPlugin.getInstance().getServer().getOnlinePlayers().forEach(p -> {
|
||||
if (p.hasPermission("chat.command.nick.review")) {
|
||||
p.sendMessage(messageDenied);
|
||||
}
|
||||
});
|
||||
|
||||
ItemStack itemStack = new ItemStack(Material.SKELETON_SKULL);
|
||||
ItemMeta itemMeta = itemStack.getItemMeta();
|
||||
itemMeta.displayName(itemDisplayName);
|
||||
itemMeta.lore(clickedItem.lore());
|
||||
itemStack.setItemMeta(itemMeta);
|
||||
e.getInventory().setItem(e.getSlot(), itemStack);
|
||||
p.updateInventory();
|
||||
} else {
|
||||
if (itemDisplayName == null) {
|
||||
p.sendRichMessage(Config.NICK_PLAYER_NOT_ONLINE, Placeholder.parsed("player", "UNKNOWN PLAYER NAME"));
|
||||
} else {
|
||||
p.sendRichMessage(Config.NICK_PLAYER_NOT_ONLINE, Placeholder.component("player", itemDisplayName));
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}.runTaskAsynchronously(ChatPlugin.getInstance());
|
||||
}
|
||||
}
|
||||
|
||||
// Cancel dragging in our inventory
|
||||
@EventHandler(ignoreCancelled = true, priority = EventPriority.HIGHEST)
|
||||
public void onInventoryClick(InventoryDragEvent e) {
|
||||
if (e.getInventory() == inv) {
|
||||
e.setCancelled(true);
|
||||
}
|
||||
nicknamesGui.open(ent);
|
||||
}
|
||||
}
|
||||
|
||||
+4
-3
@@ -9,13 +9,12 @@ val nexusPass = providers.gradleProperty("alttdSnapshotPassword").get()
|
||||
|
||||
dependencyResolutionManagement {
|
||||
repositories {
|
||||
// mavenLocal()
|
||||
mavenLocal()
|
||||
mavenCentral()
|
||||
maven("https://repo.alttd.com/snapshots") // Altitude - Galaxy
|
||||
maven("https://oss.sonatype.org/content/groups/public/") // Adventure
|
||||
maven("https://oss.sonatype.org/content/repositories/snapshots/") // Minimessage
|
||||
maven("https://nexus.velocitypowered.com/repository/") // Velocity
|
||||
maven("https://nexus.velocitypowered.com/repository/maven-public/") // Velocity
|
||||
maven("https://repo.papermc.io/repository/maven-public/")
|
||||
maven("https://repo.spongepowered.org/maven") // Configurate
|
||||
maven("https://repo.extendedclip.com/content/repositories/placeholderapi/") // Papi
|
||||
maven("https://jitpack.io")
|
||||
@@ -36,3 +35,5 @@ pluginManagement {
|
||||
gradlePluginPortal()
|
||||
}
|
||||
}
|
||||
|
||||
include("web-api")
|
||||
@@ -5,8 +5,10 @@ plugins {
|
||||
|
||||
dependencies {
|
||||
implementation(project(":api")) // API
|
||||
compileOnly("com.velocitypowered:velocity-api:3.2.0-SNAPSHOT")
|
||||
annotationProcessor("com.velocitypowered:velocity-api:3.2.0-SNAPSHOT")
|
||||
compileOnly("org.projectlombok:lombok:1.18.46")
|
||||
annotationProcessor("org.projectlombok:lombok:1.18.46")
|
||||
compileOnly("com.velocitypowered:velocity-api:3.5.0-SNAPSHOT")
|
||||
annotationProcessor("com.velocitypowered:velocity-api:3.5.0-SNAPSHOT")
|
||||
implementation("mysql:mysql-connector-java:8.0.33") // mysql
|
||||
implementation("org.spongepowered", "configurate-yaml", "4.2.0")
|
||||
compileOnly("net.kyori:adventure-text-minimessage:4.23.0")
|
||||
|
||||
@@ -5,7 +5,6 @@ import com.alttd.chat.util.Utility;
|
||||
import com.alttd.velocitychat.VelocityChat;
|
||||
import com.alttd.velocitychat.events.GlobalAdminChatEvent;
|
||||
import com.velocitypowered.api.command.CommandSource;
|
||||
import com.velocitypowered.api.event.PostOrder;
|
||||
import com.velocitypowered.api.event.Subscribe;
|
||||
import com.velocitypowered.api.proxy.Player;
|
||||
import net.kyori.adventure.text.ComponentLike;
|
||||
@@ -19,7 +18,7 @@ public class ChatListener {
|
||||
plugin = VelocityChat.getPlugin();
|
||||
}
|
||||
|
||||
@Subscribe(order = PostOrder.FIRST)
|
||||
@Subscribe(priority = 0)
|
||||
public void onGlobalStaffChat(GlobalAdminChatEvent event) {
|
||||
String senderName = Config.CONSOLENAME;
|
||||
String serverName = "Altitude";
|
||||
|
||||
@@ -11,7 +11,6 @@ import com.alttd.velocitychat.VelocityChat;
|
||||
import com.alttd.velocitychat.commands.vote_to_mute.ActiveVoteToMute;
|
||||
import com.alttd.velocitychat.data.ServerWrapper;
|
||||
import com.alttd.velocitychat.handlers.ServerHandler;
|
||||
import com.velocitypowered.api.event.PostOrder;
|
||||
import com.velocitypowered.api.event.Subscribe;
|
||||
import com.velocitypowered.api.event.connection.DisconnectEvent;
|
||||
import com.velocitypowered.api.event.connection.LoginEvent;
|
||||
@@ -34,7 +33,7 @@ import java.util.concurrent.TimeUnit;
|
||||
|
||||
public class ProxyPlayerListener {
|
||||
|
||||
@Subscribe(order = PostOrder.FIRST)
|
||||
@Subscribe(priority = 0)
|
||||
public void onPlayerLogin(LoginEvent event) {
|
||||
Player player = event.getPlayer();
|
||||
UUID uuid = player.getUniqueId();
|
||||
@@ -57,7 +56,7 @@ public class ProxyPlayerListener {
|
||||
ServerHandler.addPlayerUUID(player.getUsername(), uuid);
|
||||
}
|
||||
|
||||
@Subscribe(order = PostOrder.LAST)
|
||||
@Subscribe(priority = 4)
|
||||
public void afterPlayerLogin(ServerPostConnectEvent event) {
|
||||
Player player = event.getPlayer();
|
||||
RegisteredServer previousServer = event.getPreviousServer();
|
||||
|
||||
@@ -0,0 +1,69 @@
|
||||
plugins {
|
||||
java
|
||||
id("org.openapi.generator") version "7.12.0"
|
||||
}
|
||||
|
||||
group = "com.alttd.chat"
|
||||
version = "2.0.0-SNAPSHOT"
|
||||
|
||||
dependencies {
|
||||
implementation("io.swagger.core.v3:swagger-annotations:2.2.28")
|
||||
|
||||
implementation("com.squareup.okhttp3:okhttp:4.12.0")
|
||||
implementation("com.squareup.okhttp3:logging-interceptor:4.12.0")
|
||||
|
||||
implementation("com.google.code.gson:gson:2.12.1")
|
||||
implementation("io.gsonfire:gson-fire:1.9.0")
|
||||
|
||||
implementation("javax.annotation:javax.annotation-api:1.3.2")
|
||||
implementation("jakarta.annotation:jakarta.annotation-api:2.1.1")
|
||||
}
|
||||
|
||||
sourceSets {
|
||||
main {
|
||||
java {
|
||||
srcDir("${projectDir}/build/generated-sources/client/src/main/java")
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
tasks.named<org.openapitools.generator.gradle.plugin.tasks.GenerateTask>("openApiGenerate") {
|
||||
generatorName.set("java")
|
||||
inputSpec.set("${projectDir}/src/main/resources/chat-api.yml")
|
||||
configFile.set("${projectDir}/src/main/resources/config_backend.json")
|
||||
outputDir.set("${projectDir}/build/generated-sources/client")
|
||||
|
||||
apiPackage.set("com.alttd.altitudeweb.api")
|
||||
modelPackage.set("com.alttd.altitudeweb.model")
|
||||
|
||||
modelNameSuffix.set("Dto")
|
||||
|
||||
additionalProperties.set(
|
||||
mapOf(
|
||||
"dateLibrary" to "java8",
|
||||
"library" to "okhttp-gson"
|
||||
)
|
||||
)
|
||||
|
||||
typeMappings.set(mapOf("OffsetDateTime" to "Instant"))
|
||||
importMappings.set(mapOf("OffsetDateTime" to "java.time.Instant"))
|
||||
|
||||
generateApiTests.set(false)
|
||||
generateApiDocumentation.set(false)
|
||||
generateModelTests.set(false)
|
||||
generateModelDocumentation.set(false)
|
||||
|
||||
generateAliasAsModel.set(true)
|
||||
}
|
||||
|
||||
sourceSets {
|
||||
main {
|
||||
java {
|
||||
srcDir(layout.buildDirectory.dir("generated/openapi/src/main/java"))
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
tasks.compileJava {
|
||||
dependsOn("openApiGenerate")
|
||||
}
|
||||
@@ -0,0 +1,135 @@
|
||||
openapi: 3.0.3
|
||||
|
||||
info:
|
||||
title: Minecraft Network API
|
||||
version: 1.0.0
|
||||
|
||||
servers:
|
||||
- url: http://localhost:8080/api
|
||||
|
||||
tags:
|
||||
- name: chat
|
||||
description: Data for displaying Chat messages to clients
|
||||
|
||||
paths:
|
||||
/chat/send/chat/message:
|
||||
post:
|
||||
tags:
|
||||
- chat
|
||||
summary: Sends one or more chat messages
|
||||
operationId: sendChatMessages
|
||||
requestBody:
|
||||
required: true
|
||||
content:
|
||||
application/json:
|
||||
schema:
|
||||
type: array
|
||||
items:
|
||||
$ref: "#/components/schemas/ChatMessage"
|
||||
responses:
|
||||
"202":
|
||||
description: Accepted
|
||||
|
||||
/chat/send/servers/state:
|
||||
post:
|
||||
tags:
|
||||
- chat
|
||||
summary: Update server states
|
||||
operationId: updateServerStates
|
||||
requestBody:
|
||||
required: true
|
||||
content:
|
||||
application/json:
|
||||
schema:
|
||||
$ref: "#/components/schemas/ServerState"
|
||||
responses:
|
||||
"202":
|
||||
description: Accepted
|
||||
|
||||
components:
|
||||
schemas:
|
||||
User:
|
||||
type: object
|
||||
required:
|
||||
- uuid
|
||||
- name
|
||||
- styledName
|
||||
|
||||
properties:
|
||||
uuid:
|
||||
type: string
|
||||
format: uuid
|
||||
name:
|
||||
type: string
|
||||
styledName:
|
||||
type: string
|
||||
|
||||
ChatMessage:
|
||||
type: object
|
||||
required:
|
||||
- uuid
|
||||
- message
|
||||
- channel
|
||||
- server
|
||||
- timestamp
|
||||
- blocked
|
||||
properties:
|
||||
uuid:
|
||||
type: string
|
||||
format: uuid
|
||||
channel:
|
||||
type: string
|
||||
enum:
|
||||
- CHAT
|
||||
- PARTY
|
||||
- AC
|
||||
- GAC
|
||||
message:
|
||||
type: string
|
||||
server:
|
||||
type: string
|
||||
timestamp:
|
||||
type: string
|
||||
format: date-time
|
||||
blocked:
|
||||
type: boolean
|
||||
|
||||
PrivateMessage:
|
||||
type: object
|
||||
required:
|
||||
- sender
|
||||
- receiver
|
||||
- message
|
||||
- senderServer
|
||||
- receiverServer
|
||||
properties:
|
||||
sender:
|
||||
type: string
|
||||
format: uuid
|
||||
receiver:
|
||||
type: string
|
||||
format: uuid
|
||||
message:
|
||||
type: string
|
||||
senderServer:
|
||||
type: string
|
||||
receiverServer:
|
||||
type: string
|
||||
|
||||
Server:
|
||||
type: object
|
||||
properties:
|
||||
name:
|
||||
type: string
|
||||
players:
|
||||
type: array
|
||||
items:
|
||||
$ref: "#/components/schemas/User"
|
||||
|
||||
ServerState:
|
||||
type: object
|
||||
properties:
|
||||
servers:
|
||||
type: array
|
||||
items:
|
||||
$ref: "#/components/schemas/Server"
|
||||
@@ -0,0 +1,22 @@
|
||||
{
|
||||
"library": "okhttp-gson",
|
||||
"hideGenerationTimestamp": true,
|
||||
"modelPackage": "com.alttd.altitudeweb.model",
|
||||
"apiPackage": "com.alttd.altitudeweb.api",
|
||||
"invokerPackage": "com.alttd.altitudeweb.invoker",
|
||||
"serializableModel": true,
|
||||
"openApiNullable": false,
|
||||
"useTags": true,
|
||||
"generateApis": true,
|
||||
"generateApiTests": false,
|
||||
"generateApiDocumentation": false,
|
||||
"generateModels": true,
|
||||
"generateModelTests": false,
|
||||
"generateSupportingFiles": true,
|
||||
"modelNameSuffix": "Dto",
|
||||
"generateTests": false,
|
||||
"dateLibrary": "java8",
|
||||
"enumUnknownDefaultCase": true,
|
||||
"disallowAdditionalPropertiesIfNotPresent": false,
|
||||
"useJakartaEe": true
|
||||
}
|
||||
Reference in New Issue
Block a user