Compare commits
5 Commits
0521ee688d
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
| b7bc25e168 | |||
| 0a06223f7c | |||
| 578a1d0d55 | |||
| 0e18a64054 | |||
| 062d398d71 |
@@ -15,6 +15,7 @@ allprojects {
|
||||
mavenCentral()
|
||||
maven("https://repo.papermc.io/repository/maven-public/")
|
||||
maven("https://repo.extendedclip.com/releases/") // PlaceholderAPI
|
||||
maven("https://repo.selixe.com/repository/api/") // Atlantis Disguises
|
||||
}
|
||||
}
|
||||
|
||||
@@ -22,9 +23,8 @@ subprojects {
|
||||
apply(plugin = "java")
|
||||
|
||||
java {
|
||||
toolchain {
|
||||
languageVersion.set(JavaLanguageVersion.of(javaVersion.toInt()))
|
||||
}
|
||||
sourceCompatibility = JavaVersion.toVersion(javaVersion.toInt())
|
||||
targetCompatibility = JavaVersion.toVersion(javaVersion.toInt())
|
||||
}
|
||||
|
||||
tasks.withType<JavaCompile> {
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
# Project
|
||||
projectVersion=1.0.0
|
||||
projectVersion=1.0.4
|
||||
projectGroup=com.nickcore
|
||||
|
||||
# Minecraft / Paper
|
||||
|
||||
@@ -16,11 +16,15 @@ dependencies {
|
||||
|
||||
compileOnly("net.luckperms:api:$luckpermsVersion")
|
||||
compileOnly("me.clip:placeholderapi:$placeholderApiVersion")
|
||||
compileOnly("net.atlantismc.disguises:api:1.0")
|
||||
}
|
||||
|
||||
tasks.jar {
|
||||
enabled = false
|
||||
}
|
||||
|
||||
tasks.shadowJar {
|
||||
archiveClassifier.set("")
|
||||
archiveBaseName.set("NickCore-Paper")
|
||||
archiveFileName.set("NickCore-Paper-${project.version}.jar")
|
||||
|
||||
relocate("com.zaxxer.hikari", "com.nickcore.lib.hikari")
|
||||
|
||||
|
||||
@@ -7,6 +7,7 @@ import com.nickcore.common.validation.NicknameValidator;
|
||||
import com.nickcore.paper.cache.ProfileCache;
|
||||
import com.nickcore.paper.command.NickCommand;
|
||||
import com.nickcore.paper.gui.GuiManager;
|
||||
import com.nickcore.paper.integration.AtlantisDisguiseIntegration;
|
||||
import com.nickcore.paper.integration.NickCoreExpansion;
|
||||
import com.nickcore.paper.integration.VelocityMessaging;
|
||||
import com.nickcore.paper.listener.CommandPreprocessListener;
|
||||
@@ -15,7 +16,13 @@ import com.nickcore.paper.listener.TabCompleteListener;
|
||||
import com.nickcore.paper.repository.DatabaseManager;
|
||||
import com.nickcore.paper.repository.SqlNickRepository;
|
||||
import com.nickcore.paper.scheduler.SchedulerAdapter;
|
||||
import com.nickcore.paper.service.*;
|
||||
import com.nickcore.paper.service.ChatService;
|
||||
import com.nickcore.paper.service.NameOverrideService;
|
||||
import com.nickcore.paper.service.NametagService;
|
||||
import com.nickcore.paper.service.NickService;
|
||||
import com.nickcore.paper.service.PlaceholderService;
|
||||
import com.nickcore.paper.service.RankService;
|
||||
import com.nickcore.paper.service.SkinService;
|
||||
|
||||
import org.bukkit.Bukkit;
|
||||
import org.bukkit.configuration.ConfigurationSection;
|
||||
@@ -24,7 +31,11 @@ import org.bukkit.plugin.java.JavaPlugin;
|
||||
|
||||
import java.io.File;
|
||||
import java.time.Instant;
|
||||
import java.util.*;
|
||||
import java.util.ArrayList;
|
||||
import java.util.LinkedHashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.Set;
|
||||
import java.util.logging.Level;
|
||||
|
||||
/**
|
||||
@@ -92,6 +103,9 @@ public final class NickCorePlugin extends JavaPlugin {
|
||||
chatService = new ChatService(profileCache, rankService, getLogger());
|
||||
nameOverrideService = new NameOverrideService(profileCache);
|
||||
|
||||
// Hook into Atlantis Disguises for packet-level nick/skin support
|
||||
hookAtlantisDisguises();
|
||||
|
||||
// Load data files
|
||||
loadNames();
|
||||
loadRanks();
|
||||
@@ -125,7 +139,7 @@ public final class NickCorePlugin extends JavaPlugin {
|
||||
Bukkit.getPluginManager().registerEvents(chatService, this);
|
||||
Bukkit.getPluginManager().registerEvents(guiManager, this);
|
||||
Bukkit.getPluginManager().registerEvents(
|
||||
new CommandPreprocessListener(nameOverrideService, getLogger()), this);
|
||||
new CommandPreprocessListener(nameOverrideService), this);
|
||||
Bukkit.getPluginManager().registerEvents(
|
||||
new TabCompleteListener(nameOverrideService), this);
|
||||
|
||||
@@ -291,6 +305,18 @@ public final class NickCorePlugin extends JavaPlugin {
|
||||
skinService.loadConfiguredSkins(skins);
|
||||
}
|
||||
|
||||
private void hookAtlantisDisguises() {
|
||||
if (Bukkit.getPluginManager().getPlugin("AtlantisDisguises") != null) {
|
||||
AtlantisDisguiseIntegration atlantis = new AtlantisDisguiseIntegration(getLogger());
|
||||
if (atlantis.hook()) {
|
||||
nameOverrideService.setAtlantis(atlantis);
|
||||
getLogger().info("Atlantis Disguises integration enabled — using packet-level disguises");
|
||||
}
|
||||
} else {
|
||||
getLogger().info("Atlantis Disguises not found — using built-in name overrides");
|
||||
}
|
||||
}
|
||||
|
||||
private void registerPlaceholderAPI() {
|
||||
if (Bukkit.getPluginManager().getPlugin("PlaceholderAPI") != null) {
|
||||
placeholderExpansion = new NickCoreExpansion(this, placeholderService);
|
||||
@@ -302,9 +328,11 @@ public final class NickCorePlugin extends JavaPlugin {
|
||||
private void registerVelocityMessaging(NickCoreConfig config) {
|
||||
if (config.velocity().enabled()) {
|
||||
velocityMessaging = new VelocityMessaging(this, profileCache,
|
||||
placeholderService, nametagService, scheduler,
|
||||
getLogger(), config.velocity().serverName());
|
||||
placeholderService, nametagService, nameOverrideService,
|
||||
scheduler, getLogger(), config.velocity().serverName());
|
||||
velocityMessaging.register();
|
||||
// Let NickService auto-sync changes to other servers
|
||||
nickService.setVelocityMessaging(velocityMessaging);
|
||||
getLogger().info("Velocity messaging enabled (server: " + config.velocity().serverName() + ")");
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,6 +1,5 @@
|
||||
package com.nickcore.paper.command;
|
||||
|
||||
import com.nickcore.common.model.NickHistory;
|
||||
import com.nickcore.common.model.NickProfile;
|
||||
import com.nickcore.common.validation.InputSanitizer;
|
||||
import com.nickcore.paper.gui.GuiManager;
|
||||
@@ -23,7 +22,8 @@ import org.bukkit.command.CommandSender;
|
||||
import org.bukkit.command.TabCompleter;
|
||||
import org.bukkit.entity.Player;
|
||||
|
||||
import java.util.*;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.function.Supplier;
|
||||
import java.util.logging.Logger;
|
||||
|
||||
@@ -39,7 +39,6 @@ public final class NickCommand implements CommandExecutor, TabCompleter {
|
||||
private static final String PERM_RESET = "nickcore.reset";
|
||||
private static final String PERM_RANK = "nickcore.rank.select";
|
||||
private static final String PERM_SKIN = "nickcore.skin.select";
|
||||
private static final String PERM_ADMIN = "nickcore.admin";
|
||||
private static final String PERM_RELOAD = "nickcore.reload";
|
||||
private static final String PERM_FORCE = "nickcore.force";
|
||||
private static final String PERM_INFO = "nickcore.info";
|
||||
@@ -172,13 +171,12 @@ public final class NickCommand implements CommandExecutor, TabCompleter {
|
||||
sendMessage(player, "<red>You don't have permission for that rank.");
|
||||
return;
|
||||
}
|
||||
NickProfile profile = profileCache.get(player.getUniqueId())
|
||||
.orElse(NickProfile.empty(player.getUniqueId()));
|
||||
NickProfile updated = profile.withRank(rankId);
|
||||
profileCache.put(updated);
|
||||
sendMessage(player, "<green>Rank set to <white>" +
|
||||
rankService.getRank(rankId).map(r -> r.displayName()).orElse(rankId));
|
||||
applyDisplay(player);
|
||||
// Save rank to DB and sync to Velocity
|
||||
nickService.saveRankChange(player.getUniqueId(), rankId).thenRun(() -> {
|
||||
sendMessage(player, "<green>Rank set to <white>" +
|
||||
rankService.getRank(rankId).map(r -> r.displayName()).orElse(rankId));
|
||||
applyDisplay(player);
|
||||
});
|
||||
}
|
||||
|
||||
private void handleSkin(Player player, String[] args) {
|
||||
|
||||
@@ -10,7 +10,9 @@ import org.bukkit.inventory.InventoryHolder;
|
||||
import org.bukkit.inventory.ItemStack;
|
||||
import org.bukkit.inventory.meta.ItemMeta;
|
||||
|
||||
import java.util.*;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.function.Consumer;
|
||||
|
||||
/**
|
||||
|
||||
@@ -1,7 +1,11 @@
|
||||
package com.nickcore.paper.gui;
|
||||
|
||||
import com.nickcore.paper.cache.ProfileCache;
|
||||
import com.nickcore.paper.service.*;
|
||||
import com.nickcore.paper.service.NickService;
|
||||
import com.nickcore.paper.service.NametagService;
|
||||
import com.nickcore.paper.service.PlaceholderService;
|
||||
import com.nickcore.paper.service.RankService;
|
||||
import com.nickcore.paper.service.SkinService;
|
||||
import org.bukkit.entity.Player;
|
||||
import org.bukkit.event.EventHandler;
|
||||
import org.bukkit.event.Listener;
|
||||
@@ -10,7 +14,7 @@ import org.bukkit.event.inventory.InventoryCloseEvent;
|
||||
import org.bukkit.event.player.PlayerQuitEvent;
|
||||
import org.bukkit.plugin.Plugin;
|
||||
|
||||
import java.util.*;
|
||||
import java.util.UUID;
|
||||
import java.util.concurrent.ConcurrentHashMap;
|
||||
|
||||
/**
|
||||
@@ -53,7 +57,7 @@ public final class GuiManager implements Listener {
|
||||
}
|
||||
|
||||
public void openRankMenu(Player player) {
|
||||
RankMenuGui gui = new RankMenuGui(player, this, rankService, profileCache,
|
||||
RankMenuGui gui = new RankMenuGui(player, this, nickService, rankService,
|
||||
placeholderService, nametagService);
|
||||
openGuis.put(player.getUniqueId(), gui);
|
||||
gui.open();
|
||||
@@ -67,7 +71,7 @@ public final class GuiManager implements Listener {
|
||||
|
||||
@EventHandler
|
||||
public void onInventoryClick(InventoryClickEvent event) {
|
||||
if (!(event.getWhoClicked() instanceof Player player)) return;
|
||||
if (!(event.getWhoClicked() instanceof Player)) return;
|
||||
if (!(event.getInventory().getHolder() instanceof AbstractGui gui)) return;
|
||||
gui.handleClick(event);
|
||||
}
|
||||
|
||||
@@ -1,6 +1,5 @@
|
||||
package com.nickcore.paper.gui;
|
||||
|
||||
import com.nickcore.common.validation.InputSanitizer;
|
||||
import com.nickcore.paper.service.NickService;
|
||||
import net.kyori.adventure.text.Component;
|
||||
import net.kyori.adventure.text.format.NamedTextColor;
|
||||
|
||||
@@ -1,8 +1,7 @@
|
||||
package com.nickcore.paper.gui;
|
||||
|
||||
import com.nickcore.common.model.NickProfile;
|
||||
import com.nickcore.common.model.RankDefinition;
|
||||
import com.nickcore.paper.cache.ProfileCache;
|
||||
import com.nickcore.paper.service.NickService;
|
||||
import com.nickcore.paper.service.NametagService;
|
||||
import com.nickcore.paper.service.PlaceholderService;
|
||||
import com.nickcore.paper.service.RankService;
|
||||
@@ -21,20 +20,20 @@ import java.util.List;
|
||||
public final class RankMenuGui extends AbstractGui {
|
||||
|
||||
private final GuiManager guiManager;
|
||||
private final NickService nickService;
|
||||
private final RankService rankService;
|
||||
private final ProfileCache profileCache;
|
||||
private final PlaceholderService placeholderService;
|
||||
private final NametagService nametagService;
|
||||
private final MiniMessage mm = MiniMessage.miniMessage();
|
||||
private int page = 0;
|
||||
|
||||
public RankMenuGui(Player viewer, GuiManager guiManager, RankService rankService,
|
||||
ProfileCache profileCache, PlaceholderService placeholderService,
|
||||
public RankMenuGui(Player viewer, GuiManager guiManager, NickService nickService,
|
||||
RankService rankService, PlaceholderService placeholderService,
|
||||
NametagService nametagService) {
|
||||
super(viewer, 54, Component.text("Select Rank", NamedTextColor.GOLD, TextDecoration.BOLD));
|
||||
this.guiManager = guiManager;
|
||||
this.nickService = nickService;
|
||||
this.rankService = rankService;
|
||||
this.profileCache = profileCache;
|
||||
this.placeholderService = placeholderService;
|
||||
this.nametagService = nametagService;
|
||||
}
|
||||
@@ -57,14 +56,14 @@ public final class RankMenuGui extends AbstractGui {
|
||||
Component.text("Click to select", NamedTextColor.YELLOW)
|
||||
)),
|
||||
e -> {
|
||||
NickProfile profile = profileCache.get(viewer.getUniqueId())
|
||||
.orElse(NickProfile.empty(viewer.getUniqueId()));
|
||||
profileCache.put(profile.withRank(rank.id()));
|
||||
viewer.closeInventory();
|
||||
viewer.sendMessage(Component.text("Rank set to ", NamedTextColor.GREEN)
|
||||
.append(mm.deserialize(rank.displayName())));
|
||||
placeholderService.invalidate(viewer.getUniqueId(), viewer.getName());
|
||||
nametagService.updateNametag(viewer);
|
||||
// Save to DB and sync via Velocity
|
||||
nickService.saveRankChange(viewer.getUniqueId(), rank.id()).thenRun(() -> {
|
||||
viewer.closeInventory();
|
||||
viewer.sendMessage(Component.text("Rank set to ", NamedTextColor.GREEN)
|
||||
.append(mm.deserialize(rank.displayName())));
|
||||
placeholderService.invalidate(viewer.getUniqueId(), viewer.getName());
|
||||
nametagService.updateNametag(viewer);
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
|
||||
@@ -0,0 +1,129 @@
|
||||
package com.nickcore.paper.integration;
|
||||
|
||||
import net.atlantismc.disguises.api.API;
|
||||
import net.atlantismc.disguises.api.DisguiseProvider;
|
||||
|
||||
import org.bukkit.entity.Player;
|
||||
|
||||
import java.util.Objects;
|
||||
import java.util.logging.Level;
|
||||
import java.util.logging.Logger;
|
||||
|
||||
/**
|
||||
* Integration bridge for the Atlantis Disguises plugin.
|
||||
*
|
||||
* <p>When Atlantis Disguises is present on the server, NickCore delegates
|
||||
* all name-change and skin operations to it. Atlantis handles packet-level
|
||||
* name injection, skin application, and GameProfile rewriting — producing
|
||||
* a much more seamless disguise than NickCore's built-in display-name approach.</p>
|
||||
*
|
||||
* <p>All methods are safe to call even if Atlantis is not loaded; they will
|
||||
* return false/null gracefully.</p>
|
||||
*/
|
||||
public final class AtlantisDisguiseIntegration {
|
||||
|
||||
private final Logger logger;
|
||||
private volatile boolean available;
|
||||
|
||||
public AtlantisDisguiseIntegration(Logger logger) {
|
||||
this.logger = Objects.requireNonNull(logger);
|
||||
this.available = false;
|
||||
}
|
||||
|
||||
/**
|
||||
* Attempts to hook into the Atlantis Disguises API.
|
||||
* Call this during plugin enable after soft-depend loads.
|
||||
*
|
||||
* @return true if the API was successfully hooked
|
||||
*/
|
||||
public boolean hook() {
|
||||
try {
|
||||
API api = DisguiseProvider.get();
|
||||
if (api != null) {
|
||||
available = true;
|
||||
logger.info("[NickCore] Hooked into Atlantis Disguises API");
|
||||
return true;
|
||||
}
|
||||
} catch (NoClassDefFoundError | Exception e) {
|
||||
logger.log(Level.FINE, "Atlantis Disguises not available, using built-in name overrides", e);
|
||||
}
|
||||
available = false;
|
||||
return false;
|
||||
}
|
||||
|
||||
/**
|
||||
* Checks if Atlantis Disguises is available and hooked.
|
||||
*/
|
||||
public boolean isAvailable() {
|
||||
return available;
|
||||
}
|
||||
|
||||
/**
|
||||
* Disguises a player with the given name via Atlantis.
|
||||
* This handles packet-level GameProfile rewriting, skin changes, and
|
||||
* nametag updates — all at the protocol level.
|
||||
*
|
||||
* @param player the player to disguise
|
||||
* @param name the disguise name
|
||||
* @return true if the disguise was applied successfully
|
||||
*/
|
||||
public boolean disguise(Player player, String name) {
|
||||
if (!available || player == null || name == null) return false;
|
||||
try {
|
||||
API api = DisguiseProvider.get();
|
||||
if (api != null) {
|
||||
return api.disguise(player, name);
|
||||
}
|
||||
} catch (Exception e) {
|
||||
logger.log(Level.WARNING, "Failed to apply Atlantis disguise for " + player.getName(), e);
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
/**
|
||||
* Removes a player's disguise via Atlantis.
|
||||
*
|
||||
* @param player the player to undisguise
|
||||
* @return true if the disguise was removed
|
||||
*/
|
||||
public boolean undisguise(Player player) {
|
||||
if (!available || player == null) return false;
|
||||
try {
|
||||
API api = DisguiseProvider.get();
|
||||
if (api != null) {
|
||||
return api.undisguise(player);
|
||||
}
|
||||
} catch (Exception e) {
|
||||
logger.log(Level.WARNING, "Failed to remove Atlantis disguise for " + player.getName(), e);
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
/**
|
||||
* Checks if a player is currently disguised via Atlantis.
|
||||
*/
|
||||
public boolean isDisguised(Player player) {
|
||||
if (!available || player == null) return false;
|
||||
try {
|
||||
API api = DisguiseProvider.get();
|
||||
return api != null && api.isDisguised(player);
|
||||
} catch (Exception e) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Gets the current disguise name for a player via Atlantis.
|
||||
*
|
||||
* @return the disguise name, or null if not disguised
|
||||
*/
|
||||
public String getDisguiseName(Player player) {
|
||||
if (!available || player == null) return null;
|
||||
try {
|
||||
API api = DisguiseProvider.get();
|
||||
return api != null ? api.getDisguise(player) : null;
|
||||
} catch (Exception e) {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -25,7 +25,7 @@ public final class NickCoreExpansion extends PlaceholderExpansion {
|
||||
public @NotNull String getIdentifier() { return "nickcore"; }
|
||||
|
||||
@Override
|
||||
public @NotNull String getAuthor() { return "NickCore Team"; }
|
||||
public @NotNull String getAuthor() { return "BaileyCodes"; }
|
||||
|
||||
@Override
|
||||
public @NotNull String getVersion() { return plugin.getPluginMeta().getVersion(); }
|
||||
|
||||
@@ -3,6 +3,7 @@ package com.nickcore.paper.integration;
|
||||
import com.nickcore.common.dto.NickSyncMessage;
|
||||
import com.nickcore.common.model.NickProfile;
|
||||
import com.nickcore.paper.cache.ProfileCache;
|
||||
import com.nickcore.paper.service.NameOverrideService;
|
||||
import com.nickcore.paper.service.PlaceholderService;
|
||||
import com.nickcore.paper.service.NametagService;
|
||||
import com.nickcore.paper.scheduler.SchedulerAdapter;
|
||||
@@ -19,6 +20,10 @@ import java.util.logging.Logger;
|
||||
/**
|
||||
* Velocity plugin messaging integration.
|
||||
* Sends/receives NickSyncMessages for cross-server nick synchronization.
|
||||
*
|
||||
* <p>When a player switches servers (hub → survival), the Velocity proxy forwards
|
||||
* their profile to the new server. This handler receives that sync and applies
|
||||
* the full name override so the nick persists across servers.</p>
|
||||
*/
|
||||
public final class VelocityMessaging implements PluginMessageListener {
|
||||
|
||||
@@ -26,17 +31,20 @@ public final class VelocityMessaging implements PluginMessageListener {
|
||||
private final ProfileCache profileCache;
|
||||
private final PlaceholderService placeholderService;
|
||||
private final NametagService nametagService;
|
||||
private final NameOverrideService nameOverrideService;
|
||||
private final SchedulerAdapter scheduler;
|
||||
private final Logger logger;
|
||||
private final String serverName;
|
||||
|
||||
public VelocityMessaging(Plugin plugin, ProfileCache profileCache,
|
||||
PlaceholderService placeholderService, NametagService nametagService,
|
||||
SchedulerAdapter scheduler, Logger logger, String serverName) {
|
||||
NameOverrideService nameOverrideService, SchedulerAdapter scheduler,
|
||||
Logger logger, String serverName) {
|
||||
this.plugin = plugin;
|
||||
this.profileCache = profileCache;
|
||||
this.placeholderService = placeholderService;
|
||||
this.nametagService = nametagService;
|
||||
this.nameOverrideService = nameOverrideService;
|
||||
this.scheduler = scheduler;
|
||||
this.logger = logger;
|
||||
this.serverName = serverName;
|
||||
@@ -71,12 +79,34 @@ public final class VelocityMessaging implements PluginMessageListener {
|
||||
}
|
||||
|
||||
/**
|
||||
* Sends a full profile sync for a player.
|
||||
* Sends a full profile sync to Velocity for cross-server propagation.
|
||||
* Called every time a nick/rank/skin changes on this server.
|
||||
*/
|
||||
public void syncProfile(NickProfile profile) {
|
||||
sendSync(NickSyncMessage.fullSync(profile, serverName));
|
||||
}
|
||||
|
||||
/**
|
||||
* Sends a nick update to Velocity.
|
||||
*/
|
||||
public void syncNickUpdate(java.util.UUID uuid, String nickname) {
|
||||
sendSync(NickSyncMessage.nickUpdate(uuid, nickname, serverName));
|
||||
}
|
||||
|
||||
/**
|
||||
* Sends a rank update to Velocity.
|
||||
*/
|
||||
public void syncRankUpdate(java.util.UUID uuid, String rankId) {
|
||||
sendSync(NickSyncMessage.rankUpdate(uuid, rankId, serverName));
|
||||
}
|
||||
|
||||
/**
|
||||
* Sends a reset to Velocity.
|
||||
*/
|
||||
public void syncReset(java.util.UUID uuid) {
|
||||
sendSync(NickSyncMessage.reset(uuid, serverName));
|
||||
}
|
||||
|
||||
@Override
|
||||
public void onPluginMessageReceived(@NotNull String channel, @NotNull Player player, byte @NotNull [] data) {
|
||||
if (!NickSyncMessage.CHANNEL.equals(channel)) return;
|
||||
@@ -109,7 +139,11 @@ public final class VelocityMessaging implements PluginMessageListener {
|
||||
Player player = Bukkit.getPlayer(msg.playerUuid());
|
||||
if (player != null) {
|
||||
placeholderService.invalidate(msg.playerUuid(), player.getName());
|
||||
scheduler.runAtEntity(plugin, player, () -> nametagService.updateNametag(player));
|
||||
scheduler.runAtEntity(plugin, player, () -> {
|
||||
// Apply full name override so the nick appears everywhere on this server
|
||||
nameOverrideService.applyFullOverride(player);
|
||||
nametagService.updateNametag(player);
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
@@ -137,13 +171,24 @@ public final class VelocityMessaging implements PluginMessageListener {
|
||||
private void handleCacheInvalidate(NickSyncMessage msg) {
|
||||
profileCache.remove(msg.playerUuid());
|
||||
placeholderService.remove(msg.playerUuid());
|
||||
Player player = Bukkit.getPlayer(msg.playerUuid());
|
||||
if (player != null) {
|
||||
scheduler.runAtEntity(plugin, player, () -> {
|
||||
nameOverrideService.clearMapping(player);
|
||||
nameOverrideService.applyFullOverride(player);
|
||||
nametagService.updateNametag(player);
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
private void refreshPlayer(java.util.UUID uuid) {
|
||||
Player player = Bukkit.getPlayer(uuid);
|
||||
if (player != null) {
|
||||
placeholderService.invalidate(uuid, player.getName());
|
||||
scheduler.runAtEntity(plugin, player, () -> nametagService.updateNametag(player));
|
||||
scheduler.runAtEntity(plugin, player, () -> {
|
||||
nameOverrideService.applyFullOverride(player);
|
||||
nametagService.updateNametag(player);
|
||||
});
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -9,9 +9,6 @@ import org.bukkit.event.Listener;
|
||||
import org.bukkit.event.player.PlayerCommandPreprocessEvent;
|
||||
|
||||
import java.util.Objects;
|
||||
import java.util.logging.Logger;
|
||||
import java.util.regex.Matcher;
|
||||
import java.util.regex.Pattern;
|
||||
|
||||
/**
|
||||
* Intercepts player commands and replaces nick names with real names before dispatch.
|
||||
@@ -25,14 +22,9 @@ import java.util.regex.Pattern;
|
||||
public final class CommandPreprocessListener implements Listener {
|
||||
|
||||
private final NameOverrideService nameOverrideService;
|
||||
private final Logger logger;
|
||||
|
||||
/** Pattern to split command into parts while preserving structure. */
|
||||
private static final Pattern WORD_BOUNDARY = Pattern.compile("\\s+");
|
||||
|
||||
public CommandPreprocessListener(NameOverrideService nameOverrideService, Logger logger) {
|
||||
public CommandPreprocessListener(NameOverrideService nameOverrideService) {
|
||||
this.nameOverrideService = Objects.requireNonNull(nameOverrideService);
|
||||
this.logger = Objects.requireNonNull(logger);
|
||||
}
|
||||
|
||||
@EventHandler(priority = EventPriority.LOWEST, ignoreCancelled = true)
|
||||
|
||||
@@ -1,11 +1,12 @@
|
||||
package com.nickcore.paper.listener;
|
||||
|
||||
import com.nickcore.common.model.NickProfile;
|
||||
import com.nickcore.common.validation.InputSanitizer;
|
||||
import com.nickcore.paper.service.*;
|
||||
import com.nickcore.paper.service.NameOverrideService;
|
||||
import com.nickcore.paper.service.NametagService;
|
||||
import com.nickcore.paper.service.NickService;
|
||||
import com.nickcore.paper.service.PlaceholderService;
|
||||
import com.nickcore.paper.service.SkinService;
|
||||
import com.nickcore.paper.scheduler.SchedulerAdapter;
|
||||
import net.kyori.adventure.text.Component;
|
||||
import net.kyori.adventure.text.minimessage.MiniMessage;
|
||||
import org.bukkit.entity.Player;
|
||||
import org.bukkit.event.EventHandler;
|
||||
import org.bukkit.event.EventPriority;
|
||||
@@ -29,7 +30,6 @@ public final class PlayerConnectionListener implements Listener {
|
||||
private final NameOverrideService nameOverrideService;
|
||||
private final SchedulerAdapter scheduler;
|
||||
private final Logger logger;
|
||||
private final MiniMessage mm = MiniMessage.miniMessage();
|
||||
|
||||
public PlayerConnectionListener(Plugin plugin, NickService nickService,
|
||||
SkinService skinService, PlaceholderService placeholderService,
|
||||
|
||||
@@ -5,8 +5,6 @@ import com.zaxxer.hikari.HikariConfig;
|
||||
import com.zaxxer.hikari.HikariDataSource;
|
||||
|
||||
import java.io.File;
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
import java.sql.Connection;
|
||||
import java.sql.PreparedStatement;
|
||||
import java.sql.ResultSet;
|
||||
|
||||
@@ -2,9 +2,9 @@ package com.nickcore.paper.service;
|
||||
|
||||
import com.nickcore.common.model.NickProfile;
|
||||
import com.nickcore.paper.cache.ProfileCache;
|
||||
import com.nickcore.paper.integration.AtlantisDisguiseIntegration;
|
||||
|
||||
import net.kyori.adventure.text.Component;
|
||||
import net.kyori.adventure.text.minimessage.MiniMessage;
|
||||
|
||||
import org.bukkit.Bukkit;
|
||||
import org.bukkit.entity.Player;
|
||||
@@ -20,6 +20,10 @@ import java.util.concurrent.ConcurrentHashMap;
|
||||
* tab completion, /tpa, /msg, player list, nametags, and any plugin that resolves
|
||||
* players by display name.
|
||||
*
|
||||
* <p>When Atlantis Disguises is available, delegates to it for packet-level
|
||||
* GameProfile rewriting (the most thorough approach). Otherwise, falls back to
|
||||
* Bukkit display name + custom name overrides.</p>
|
||||
*
|
||||
* <p>Maintains a bidirectional mapping between nick names and real names so that
|
||||
* commands referencing a nick name can be resolved back to the actual player.</p>
|
||||
*
|
||||
@@ -28,7 +32,7 @@ import java.util.concurrent.ConcurrentHashMap;
|
||||
public final class NameOverrideService {
|
||||
|
||||
private final ProfileCache profileCache;
|
||||
private final MiniMessage miniMessage = MiniMessage.miniMessage();
|
||||
private volatile AtlantisDisguiseIntegration atlantis;
|
||||
|
||||
/** nick (lowercase) -> real player UUID */
|
||||
private final ConcurrentHashMap<String, UUID> nickToUuid = new ConcurrentHashMap<>(512);
|
||||
@@ -40,9 +44,21 @@ public final class NameOverrideService {
|
||||
this.profileCache = Objects.requireNonNull(profileCache);
|
||||
}
|
||||
|
||||
/**
|
||||
* Sets the Atlantis Disguises integration. When set and available,
|
||||
* disguise/undisguise operations are delegated to Atlantis for
|
||||
* packet-level name rewriting.
|
||||
*/
|
||||
public void setAtlantis(AtlantisDisguiseIntegration atlantis) {
|
||||
this.atlantis = atlantis;
|
||||
}
|
||||
|
||||
/**
|
||||
* Applies a full name override to a player: display name, player list name,
|
||||
* custom name, and registers the nick in lookup maps.
|
||||
*
|
||||
* <p>If Atlantis Disguises is available, uses its packet-level disguise system
|
||||
* which rewrites the GameProfile and handles skin + nametag automatically.</p>
|
||||
*/
|
||||
public void applyFullOverride(Player player) {
|
||||
NickProfile profile = profileCache.get(player.getUniqueId()).orElse(null);
|
||||
@@ -52,16 +68,21 @@ public final class NameOverrideService {
|
||||
|
||||
if (profile == null || !profile.nicked() || profile.nickname() == null) {
|
||||
// Not nicked — restore real identity
|
||||
player.displayName(Component.text(player.getName()));
|
||||
player.playerListName(Component.text(player.getName()));
|
||||
player.customName(null);
|
||||
undisguisePlayer(player);
|
||||
return;
|
||||
}
|
||||
|
||||
String nick = profile.nickname();
|
||||
Component nickComponent = Component.text(nick);
|
||||
|
||||
// Set all name surfaces
|
||||
// Try Atlantis Disguises first (packet-level, most thorough)
|
||||
boolean atlantisApplied = false;
|
||||
AtlantisDisguiseIntegration atl = this.atlantis;
|
||||
if (atl != null && atl.isAvailable()) {
|
||||
atlantisApplied = atl.disguise(player, nick);
|
||||
}
|
||||
|
||||
// Always set Bukkit-level names as fallback/supplement
|
||||
Component nickComponent = Component.text(nick);
|
||||
player.displayName(nickComponent);
|
||||
player.playerListName(nickComponent);
|
||||
player.customName(nickComponent);
|
||||
@@ -71,6 +92,22 @@ public final class NameOverrideService {
|
||||
realToNick.put(player.getName().toLowerCase(), nick);
|
||||
}
|
||||
|
||||
/**
|
||||
* Removes all name overrides from a player.
|
||||
*/
|
||||
private void undisguisePlayer(Player player) {
|
||||
// Undo Atlantis disguise if active
|
||||
AtlantisDisguiseIntegration atl = this.atlantis;
|
||||
if (atl != null && atl.isAvailable() && atl.isDisguised(player)) {
|
||||
atl.undisguise(player);
|
||||
}
|
||||
|
||||
// Reset Bukkit-level names
|
||||
player.displayName(Component.text(player.getName()));
|
||||
player.playerListName(Component.text(player.getName()));
|
||||
player.customName(null);
|
||||
}
|
||||
|
||||
/**
|
||||
* Clears all name mappings for a player. Called on quit or reset.
|
||||
*/
|
||||
@@ -82,6 +119,15 @@ public final class NameOverrideService {
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Fully resets a player's identity — clears mappings and undisguises.
|
||||
* Called on /nick reset or when a player quits.
|
||||
*/
|
||||
public void resetPlayer(Player player) {
|
||||
clearMapping(player);
|
||||
undisguisePlayer(player);
|
||||
}
|
||||
|
||||
/**
|
||||
* Resolves a player by either their nick name or real name.
|
||||
* This is the key method that allows /tpa, /msg, etc. to work with nicks.
|
||||
|
||||
@@ -5,10 +5,10 @@ import com.nickcore.common.model.NickProfile;
|
||||
import com.nickcore.common.validation.InputSanitizer;
|
||||
import com.nickcore.common.validation.NicknameValidator;
|
||||
import com.nickcore.paper.cache.ProfileCache;
|
||||
import com.nickcore.paper.integration.VelocityMessaging;
|
||||
import com.nickcore.paper.repository.NickRepository;
|
||||
|
||||
import net.kyori.adventure.text.Component;
|
||||
import net.kyori.adventure.text.minimessage.MiniMessage;
|
||||
|
||||
|
||||
import org.bukkit.Bukkit;
|
||||
import org.bukkit.entity.Player;
|
||||
@@ -36,7 +36,6 @@ public final class NickService {
|
||||
private final ProfileCache cache;
|
||||
private final NicknameValidator validator;
|
||||
private final Logger logger;
|
||||
private final MiniMessage miniMessage;
|
||||
|
||||
// Configurable name pool — loaded from names.yml, swapped atomically on reload
|
||||
private volatile List<String> namePool = List.of();
|
||||
@@ -45,13 +44,15 @@ public final class NickService {
|
||||
private volatile boolean allowDuplicateNicks = false;
|
||||
private volatile boolean allowCustomNames = false;
|
||||
|
||||
// Optional: set when Velocity is enabled for cross-server sync
|
||||
private volatile VelocityMessaging velocityMessaging;
|
||||
|
||||
public NickService(NickRepository repository, ProfileCache cache,
|
||||
NicknameValidator validator, Logger logger) {
|
||||
this.repository = Objects.requireNonNull(repository);
|
||||
this.cache = Objects.requireNonNull(cache);
|
||||
this.validator = Objects.requireNonNull(validator);
|
||||
this.logger = Objects.requireNonNull(logger);
|
||||
this.miniMessage = MiniMessage.miniMessage();
|
||||
}
|
||||
|
||||
/**
|
||||
@@ -138,6 +139,11 @@ public final class NickService {
|
||||
return repository.save(newProfile).thenCompose(v -> {
|
||||
cache.put(newProfile);
|
||||
|
||||
// Sync to other servers via Velocity
|
||||
if (velocityMessaging != null) {
|
||||
velocityMessaging.syncProfile(newProfile);
|
||||
}
|
||||
|
||||
// Record history
|
||||
NickHistory history = NickHistory.nickChange(
|
||||
uuid, oldProfile.nickname(), sanitized,
|
||||
@@ -189,6 +195,11 @@ public final class NickService {
|
||||
return repository.save(resetProfile).thenCompose(v -> {
|
||||
cache.put(resetProfile);
|
||||
|
||||
// Sync reset to other servers
|
||||
if (velocityMessaging != null) {
|
||||
velocityMessaging.syncReset(uuid);
|
||||
}
|
||||
|
||||
NickHistory history = NickHistory.reset(
|
||||
uuid, oldProfile.nickname(), oldProfile.rankId(), changedBy
|
||||
);
|
||||
@@ -239,6 +250,28 @@ public final class NickService {
|
||||
return allowCustomNames;
|
||||
}
|
||||
|
||||
/**
|
||||
* Sets the VelocityMessaging instance for cross-server sync.
|
||||
*/
|
||||
public void setVelocityMessaging(VelocityMessaging velocityMessaging) {
|
||||
this.velocityMessaging = velocityMessaging;
|
||||
}
|
||||
|
||||
/**
|
||||
* Saves a rank change to the database and syncs to Velocity.
|
||||
*/
|
||||
public CompletableFuture<Void> saveRankChange(java.util.UUID uuid, String rankId) {
|
||||
NickProfile profile = cache.get(uuid).orElse(NickProfile.empty(uuid));
|
||||
NickProfile updated = profile.withRank(rankId);
|
||||
cache.put(updated);
|
||||
|
||||
if (velocityMessaging != null) {
|
||||
velocityMessaging.syncRankUpdate(uuid, rankId);
|
||||
}
|
||||
|
||||
return repository.save(updated);
|
||||
}
|
||||
|
||||
// ── Result Container ────────────────────────────────────────────────
|
||||
|
||||
/**
|
||||
|
||||
@@ -3,7 +3,6 @@ package com.nickcore.paper.service;
|
||||
import com.nickcore.common.model.NickProfile;
|
||||
import com.nickcore.common.model.RankDefinition;
|
||||
import com.nickcore.paper.cache.ProfileCache;
|
||||
import org.bukkit.entity.Player;
|
||||
|
||||
import java.util.Map;
|
||||
import java.util.Objects;
|
||||
|
||||
@@ -5,7 +5,13 @@ import net.kyori.adventure.text.Component;
|
||||
import net.kyori.adventure.text.minimessage.MiniMessage;
|
||||
import org.bukkit.entity.Player;
|
||||
|
||||
import java.util.*;
|
||||
import java.util.Collection;
|
||||
import java.util.Comparator;
|
||||
import java.util.LinkedHashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.Objects;
|
||||
import java.util.Optional;
|
||||
import java.util.logging.Logger;
|
||||
|
||||
/**
|
||||
|
||||
@@ -6,15 +6,19 @@ import org.bukkit.Bukkit;
|
||||
import org.bukkit.entity.Player;
|
||||
import org.bukkit.plugin.Plugin;
|
||||
|
||||
import java.io.InputStreamReader;
|
||||
import java.net.URI;
|
||||
import java.net.http.HttpClient;
|
||||
import java.net.http.HttpRequest;
|
||||
import java.net.http.HttpResponse;
|
||||
import java.time.Duration;
|
||||
import java.time.Instant;
|
||||
import java.util.*;
|
||||
import java.util.concurrent.*;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.Objects;
|
||||
import java.util.Optional;
|
||||
import java.util.concurrent.CompletableFuture;
|
||||
import java.util.concurrent.ConcurrentHashMap;
|
||||
import java.util.concurrent.Semaphore;
|
||||
import java.util.logging.Level;
|
||||
import java.util.logging.Logger;
|
||||
|
||||
|
||||
@@ -1,10 +1,10 @@
|
||||
name: NickCore
|
||||
version: '1.0.0'
|
||||
version: '1.0.4'
|
||||
main: com.nickcore.paper.NickCorePlugin
|
||||
api-version: '1.21'
|
||||
description: Enterprise Minecraft Nickname Plugin
|
||||
author: NickCore Team
|
||||
website: https://nickcore.com
|
||||
author: BaileyCodes
|
||||
website: https://balls.studio
|
||||
folia-supported: true
|
||||
|
||||
softdepend:
|
||||
@@ -12,6 +12,7 @@ softdepend:
|
||||
- LuckPerms
|
||||
- TAB
|
||||
- Essentials
|
||||
- AtlantisDisguises
|
||||
|
||||
commands:
|
||||
nick:
|
||||
|
||||
@@ -11,9 +11,12 @@ dependencies {
|
||||
annotationProcessor("com.velocitypowered:velocity-api:$velocityApiVersion")
|
||||
}
|
||||
|
||||
tasks.jar {
|
||||
enabled = false
|
||||
}
|
||||
|
||||
tasks.shadowJar {
|
||||
archiveClassifier.set("")
|
||||
archiveBaseName.set("NickCore-Velocity")
|
||||
archiveFileName.set("NickCore-Velocity-${project.version}.jar")
|
||||
minimize()
|
||||
}
|
||||
|
||||
|
||||
@@ -19,7 +19,6 @@ import org.slf4j.Logger;
|
||||
import com.google.inject.Inject;
|
||||
|
||||
import java.util.Map;
|
||||
import java.util.Optional;
|
||||
import java.util.UUID;
|
||||
import java.util.concurrent.ConcurrentHashMap;
|
||||
|
||||
@@ -27,8 +26,8 @@ import java.util.concurrent.ConcurrentHashMap;
|
||||
* NickCore Velocity proxy plugin.
|
||||
* Maintains a cross-server nick profile cache and routes sync messages.
|
||||
*/
|
||||
@Plugin(id = "nickcore", name = "NickCore", version = "1.0.0",
|
||||
authors = {"NickCore Team"}, description = "Enterprise nickname system - Velocity module")
|
||||
@Plugin(id = "nickcore", name = "NickCore", version = "1.0.4",
|
||||
authors = {"BaileyCodes"}, description = "Enterprise nickname system - Velocity module")
|
||||
public final class NickCoreVelocity {
|
||||
|
||||
private static final MinecraftChannelIdentifier CHANNEL =
|
||||
@@ -108,10 +107,12 @@ public final class NickCoreVelocity {
|
||||
(uuid, p) -> p.withNickname(message.nickname()));
|
||||
case RANK_UPDATE -> proxyCache.computeIfPresent(message.playerUuid(),
|
||||
(uuid, p) -> p.withRank(message.rankId()));
|
||||
case SKIN_UPDATE -> proxyCache.computeIfPresent(message.playerUuid(),
|
||||
(uuid, p) -> p.withSkin(message.skinId(), message.skinValue(), message.skinSignature()));
|
||||
case RESET -> proxyCache.computeIfPresent(message.playerUuid(),
|
||||
(uuid, p) -> p.reset());
|
||||
case CACHE_INVALIDATE -> proxyCache.remove(message.playerUuid());
|
||||
default -> { /* ignore */ }
|
||||
default -> { /* PLAYER_JOIN, PLAYER_QUIT — no proxy-side action needed */ }
|
||||
}
|
||||
|
||||
// Forward to all OTHER servers
|
||||
|
||||
Reference in New Issue
Block a user