317 lines
18 KiB
Java
317 lines
18 KiB
Java
package lol.pyr.znpcsplus;
|
|
|
|
import com.github.retrooper.packetevents.PacketEvents;
|
|
import com.github.retrooper.packetevents.PacketEventsAPI;
|
|
import com.github.retrooper.packetevents.event.PacketListenerPriority;
|
|
import com.github.retrooper.packetevents.manager.server.ServerVersion;
|
|
import io.github.retrooper.packetevents.factory.spigot.SpigotPacketEventsBuilder;
|
|
import lol.pyr.director.adventure.command.CommandContext;
|
|
import lol.pyr.director.adventure.command.CommandManager;
|
|
import lol.pyr.director.adventure.command.MultiCommand;
|
|
import lol.pyr.director.adventure.parse.primitive.BooleanParser;
|
|
import lol.pyr.director.adventure.parse.primitive.DoubleParser;
|
|
import lol.pyr.director.adventure.parse.primitive.IntegerParser;
|
|
import lol.pyr.director.common.message.Message;
|
|
import lol.pyr.znpcsplus.api.NpcApiProvider;
|
|
import lol.pyr.znpcsplus.api.interaction.InteractionType;
|
|
import lol.pyr.znpcsplus.commands.*;
|
|
import lol.pyr.znpcsplus.commands.action.ActionAddCommand;
|
|
import lol.pyr.znpcsplus.commands.action.ActionDeleteCommand;
|
|
import lol.pyr.znpcsplus.commands.action.ActionEditCommand;
|
|
import lol.pyr.znpcsplus.commands.action.ActionListCommand;
|
|
import lol.pyr.znpcsplus.commands.hologram.*;
|
|
import lol.pyr.znpcsplus.commands.property.PropertyRemoveCommand;
|
|
import lol.pyr.znpcsplus.commands.property.PropertySetCommand;
|
|
import lol.pyr.znpcsplus.commands.storage.ImportCommand;
|
|
import lol.pyr.znpcsplus.commands.storage.LoadAllCommand;
|
|
import lol.pyr.znpcsplus.commands.storage.SaveAllCommand;
|
|
import lol.pyr.znpcsplus.config.ConfigManager;
|
|
import lol.pyr.znpcsplus.conversion.DataImporterRegistry;
|
|
import lol.pyr.znpcsplus.entity.EntityPropertyImpl;
|
|
import lol.pyr.znpcsplus.entity.EntityPropertyRegistryImpl;
|
|
import lol.pyr.znpcsplus.interaction.ActionRegistry;
|
|
import lol.pyr.znpcsplus.interaction.InteractionPacketListener;
|
|
import lol.pyr.znpcsplus.npc.*;
|
|
import lol.pyr.znpcsplus.packets.PacketFactory;
|
|
import lol.pyr.znpcsplus.packets.V1_17PacketFactory;
|
|
import lol.pyr.znpcsplus.packets.V1_19PacketFactory;
|
|
import lol.pyr.znpcsplus.packets.V1_8PacketFactory;
|
|
import lol.pyr.znpcsplus.parsers.*;
|
|
import lol.pyr.znpcsplus.scheduling.FoliaScheduler;
|
|
import lol.pyr.znpcsplus.scheduling.SpigotScheduler;
|
|
import lol.pyr.znpcsplus.scheduling.TaskScheduler;
|
|
import lol.pyr.znpcsplus.skin.cache.MojangSkinCache;
|
|
import lol.pyr.znpcsplus.skin.cache.SkinCacheCleanTask;
|
|
import lol.pyr.znpcsplus.tasks.HologramRefreshTask;
|
|
import lol.pyr.znpcsplus.tasks.NpcProcessorTask;
|
|
import lol.pyr.znpcsplus.updater.UpdateChecker;
|
|
import lol.pyr.znpcsplus.updater.UpdateNotificationListener;
|
|
import lol.pyr.znpcsplus.user.UserListener;
|
|
import lol.pyr.znpcsplus.user.UserManager;
|
|
import lol.pyr.znpcsplus.util.*;
|
|
import net.kyori.adventure.platform.bukkit.BukkitAudiences;
|
|
import net.kyori.adventure.text.Component;
|
|
import net.kyori.adventure.text.format.NamedTextColor;
|
|
import net.kyori.adventure.text.format.TextColor;
|
|
import net.kyori.adventure.text.minimessage.MiniMessage;
|
|
import net.kyori.adventure.text.serializer.legacy.LegacyComponentSerializer;
|
|
import org.bstats.bukkit.Metrics;
|
|
import org.bukkit.*;
|
|
import org.bukkit.plugin.Plugin;
|
|
import org.bukkit.plugin.PluginManager;
|
|
import org.bukkit.plugin.java.JavaPlugin;
|
|
|
|
import java.io.File;
|
|
import java.io.IOException;
|
|
import java.io.PrintWriter;
|
|
import java.io.Reader;
|
|
import java.nio.file.Files;
|
|
import java.nio.file.StandardOpenOption;
|
|
import java.util.ArrayList;
|
|
import java.util.Collection;
|
|
import java.util.HashMap;
|
|
import java.util.List;
|
|
|
|
public class ZNpcsPlus extends JavaPlugin {
|
|
private final LegacyComponentSerializer textSerializer = LegacyComponentSerializer.builder()
|
|
.character('&')
|
|
.hexCharacter('#')
|
|
.hexColors().build();
|
|
|
|
private final List<Runnable> shutdownTasks = new ArrayList<>();
|
|
private PacketEventsAPI<Plugin> packetEvents;
|
|
|
|
@Override
|
|
public void onLoad() {
|
|
packetEvents = SpigotPacketEventsBuilder.build(this);
|
|
PacketEvents.setAPI(packetEvents);
|
|
packetEvents.getSettings().checkForUpdates(false);
|
|
packetEvents.load();
|
|
}
|
|
|
|
private void log(String str) {
|
|
Bukkit.getConsoleSender().sendMessage(str);
|
|
}
|
|
|
|
@Override
|
|
public void onEnable() {
|
|
getDataFolder().mkdirs();
|
|
|
|
log(ChatColor.YELLOW + " ___ __ __ __");
|
|
log(ChatColor.YELLOW + " _/ |\\ | |__) | (__` " + ChatColor.GOLD + "__|__ " + ChatColor.YELLOW + getDescription().getName() + " " + ChatColor.GOLD + "v" + getDescription().getVersion());
|
|
log(ChatColor.YELLOW + " /__ | \\| | |__ .__) " + ChatColor.GOLD + " | " + ChatColor.GRAY + "Maintained with " + ChatColor.RED + "\u2764 " + ChatColor.GRAY + " by Pyr#6969");
|
|
log("");
|
|
|
|
PluginManager pluginManager = Bukkit.getPluginManager();
|
|
long before = System.currentTimeMillis();
|
|
|
|
boolean legacy = new File(getDataFolder(), "data.json").isFile() && !new File(getDataFolder(), "data").isDirectory();
|
|
if (legacy) try {
|
|
Files.move(getDataFolder().toPath(), new File(getDataFolder().getParentFile(), "ZNPCsPlusLegacy").toPath());
|
|
} catch (IOException e) {
|
|
log(ChatColor.RED + " * Moving legacy files to subfolder failed, plugin will shut down.");
|
|
e.printStackTrace();
|
|
pluginManager.disablePlugin(this);
|
|
return;
|
|
}
|
|
|
|
log(ChatColor.WHITE + " * Initializing libraries...");
|
|
|
|
packetEvents.init();
|
|
|
|
BukkitAudiences adventure = BukkitAudiences.create(this);
|
|
shutdownTasks.add(adventure::close);
|
|
|
|
log(ChatColor.WHITE + " * Initializing components...");
|
|
|
|
TaskScheduler scheduler = FoliaUtil.isFolia() ? new FoliaScheduler(this) : new SpigotScheduler(this);
|
|
shutdownTasks.add(scheduler::cancelAll);
|
|
|
|
ConfigManager configManager = new ConfigManager(getDataFolder());
|
|
MojangSkinCache skinCache = new MojangSkinCache(configManager);
|
|
EntityPropertyRegistryImpl propertyRegistry = new EntityPropertyRegistryImpl(skinCache);
|
|
PacketFactory packetFactory = setupPacketFactory(scheduler, propertyRegistry);
|
|
propertyRegistry.registerTypes(packetFactory);
|
|
BungeeConnector bungeeConnector = new BungeeConnector(this);
|
|
|
|
ActionRegistry actionRegistry = new ActionRegistry();
|
|
NpcTypeRegistryImpl typeRegistry = new NpcTypeRegistryImpl();
|
|
NpcRegistryImpl npcRegistry = new NpcRegistryImpl(configManager, this, packetFactory, actionRegistry,
|
|
scheduler, typeRegistry, propertyRegistry, textSerializer);
|
|
shutdownTasks.add(npcRegistry::unload);
|
|
|
|
UserManager userManager = new UserManager();
|
|
shutdownTasks.add(userManager::shutdown);
|
|
|
|
DataImporterRegistry importerRegistry = new DataImporterRegistry(configManager, adventure, bungeeConnector,
|
|
scheduler, packetFactory, textSerializer, typeRegistry, getDataFolder().getParentFile(),
|
|
propertyRegistry, skinCache);
|
|
|
|
log(ChatColor.WHITE + " * Registerring components...");
|
|
|
|
typeRegistry.registerDefault(packetEvents, propertyRegistry);
|
|
actionRegistry.registerTypes(scheduler, adventure, bungeeConnector, textSerializer);
|
|
packetEvents.getEventManager().registerListener(new InteractionPacketListener(userManager, npcRegistry), PacketListenerPriority.MONITOR);
|
|
new Metrics(this, 18244);
|
|
pluginManager.registerEvents(new UserListener(userManager), this);
|
|
getServer().getMessenger().registerOutgoingPluginChannel(this, "BungeeCord");
|
|
|
|
registerCommands(npcRegistry, skinCache, adventure, actionRegistry,
|
|
typeRegistry, propertyRegistry, importerRegistry, configManager);
|
|
|
|
log(ChatColor.WHITE + " * Starting tasks...");
|
|
if (configManager.getConfig().checkForUpdates()) {
|
|
UpdateChecker updateChecker = new UpdateChecker(this.getDescription());
|
|
scheduler.runDelayedTimerAsync(updateChecker, 5L, 6000L);
|
|
pluginManager.registerEvents(new UpdateNotificationListener(this, adventure, updateChecker), this);
|
|
}
|
|
|
|
scheduler.runDelayedTimerAsync(new NpcProcessorTask(npcRegistry, configManager, propertyRegistry), 60L, 3L);
|
|
scheduler.runDelayedTimerAsync(new HologramRefreshTask(npcRegistry), 60L, 20L);
|
|
scheduler.runDelayedTimerAsync(new SkinCacheCleanTask(skinCache), 1200, 1200);
|
|
|
|
log(ChatColor.WHITE + " * Loading data...");
|
|
npcRegistry.reload();
|
|
if (configManager.getConfig().autoSaveEnabled()) shutdownTasks.add(npcRegistry::save);
|
|
|
|
if (legacy) {
|
|
log(ChatColor.WHITE + " * Converting legacy data...");
|
|
try {
|
|
Collection<NpcEntryImpl> entries = importerRegistry.getImporter("znpcsplus_legacy").importData();
|
|
npcRegistry.registerAll(entries);
|
|
} catch (Exception exception) {
|
|
log(ChatColor.RED + " * Legacy data conversion failed! Check conversion.log for more info.");
|
|
try (PrintWriter writer = new PrintWriter(Files.newBufferedWriter(new File(getDataFolder(), "conversion.log").toPath(), StandardOpenOption.CREATE_NEW))) {
|
|
exception.printStackTrace(writer);
|
|
} catch (IOException e) {
|
|
log(ChatColor.DARK_RED + " * Critical error! Writing to conversion.log failed.");
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
}
|
|
|
|
NpcApiProvider.register(this, new ZNpcsPlusApi(npcRegistry, typeRegistry, propertyRegistry, skinCache));
|
|
log(ChatColor.WHITE + " * Loading complete! (" + (System.currentTimeMillis() - before) + "ms)");
|
|
log("");
|
|
|
|
if (configManager.getConfig().debugEnabled()) {
|
|
World world = Bukkit.getWorld("world");
|
|
if (world == null) world = Bukkit.getWorlds().get(0);
|
|
int i = 0;
|
|
for (NpcTypeImpl type : typeRegistry.getAllImpl()) {
|
|
NpcEntryImpl entry = npcRegistry.create("debug_npc_" + i, world, type, new NpcLocation(i * 3, 200, 0, 0, 0));
|
|
entry.setProcessed(true);
|
|
NpcImpl npc = entry.getNpc();
|
|
npc.getHologram().addTextLineComponent(Component.text("Hello, World!", TextColor.color(255, 0, 0)));
|
|
npc.getHologram().addTextLineComponent(Component.text("Hello, World!", TextColor.color(0, 255, 0)));
|
|
npc.getHologram().addTextLineComponent(Component.text("Hello, World!", TextColor.color(0, 0, 255)));
|
|
i++;
|
|
}
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public void onDisable() {
|
|
NpcApiProvider.unregister();
|
|
for (Runnable runnable : shutdownTasks) runnable.run();
|
|
shutdownTasks.clear();
|
|
PacketEvents.getAPI().terminate();
|
|
}
|
|
|
|
private PacketFactory setupPacketFactory(TaskScheduler scheduler, EntityPropertyRegistryImpl propertyRegistry) {
|
|
HashMap<ServerVersion, LazyLoader<? extends PacketFactory>> versions = new HashMap<>();
|
|
versions.put(ServerVersion.V_1_8, LazyLoader.of(() -> new V1_8PacketFactory(scheduler, packetEvents, propertyRegistry, textSerializer)));
|
|
versions.put(ServerVersion.V_1_17, LazyLoader.of(() -> new V1_17PacketFactory(scheduler, packetEvents, propertyRegistry, textSerializer)));
|
|
versions.put(ServerVersion.V_1_19, LazyLoader.of(() -> new V1_19PacketFactory(scheduler, packetEvents, propertyRegistry, textSerializer)));
|
|
|
|
ServerVersion version = packetEvents.getServerManager().getVersion();
|
|
if (versions.containsKey(version)) return versions.get(version).get();
|
|
for (ServerVersion v : ServerVersion.reversedValues()) {
|
|
if (v.isNewerThan(version)) continue;
|
|
if (!versions.containsKey(v)) continue;
|
|
return versions.get(v).get();
|
|
}
|
|
throw new RuntimeException("Unsupported version!");
|
|
}
|
|
|
|
private void registerCommands(NpcRegistryImpl npcRegistry, MojangSkinCache skinCache, BukkitAudiences adventure,
|
|
ActionRegistry actionRegistry, NpcTypeRegistryImpl typeRegistry,
|
|
EntityPropertyRegistryImpl propertyRegistry, DataImporterRegistry importerRegistry,
|
|
ConfigManager configManager) {
|
|
|
|
Message<CommandContext> incorrectUsageMessage = context -> context.send(Component.text("Incorrect usage: /" + context.getUsage(), NamedTextColor.RED));
|
|
CommandManager manager = new CommandManager(this, adventure, incorrectUsageMessage);
|
|
|
|
manager.registerParser(NpcTypeImpl.class, new NpcTypeParser(incorrectUsageMessage, typeRegistry));
|
|
manager.registerParser(NpcEntryImpl.class, new NpcEntryParser(npcRegistry, incorrectUsageMessage));
|
|
manager.registerParser(EntityPropertyImpl.class, new EntityPropertyParser(incorrectUsageMessage, propertyRegistry));
|
|
manager.registerParser(Integer.class, new IntegerParser(incorrectUsageMessage));
|
|
manager.registerParser(Double.class, new DoubleParser(incorrectUsageMessage));
|
|
manager.registerParser(Boolean.class, new BooleanParser(incorrectUsageMessage));
|
|
manager.registerParser(NamedTextColor.class, new NamedTextColorParser(incorrectUsageMessage));
|
|
manager.registerParser(InteractionType.class, new InteractionTypeParser(incorrectUsageMessage));
|
|
manager.registerParser(Color.class, new ColorParser(incorrectUsageMessage));
|
|
manager.registerParser(Vector3f.class, new Vector3fParser(incorrectUsageMessage));
|
|
|
|
registerEnumParser(manager, NpcPose.class, incorrectUsageMessage);
|
|
registerEnumParser(manager, DyeColor.class, incorrectUsageMessage);
|
|
registerEnumParser(manager, CatVariant.class, incorrectUsageMessage);
|
|
registerEnumParser(manager, CreeperState.class, incorrectUsageMessage);
|
|
registerEnumParser(manager, ParrotVariant.class, incorrectUsageMessage);
|
|
registerEnumParser(manager, SpellType.class, incorrectUsageMessage);
|
|
registerEnumParser(manager, FoxVariant.class, incorrectUsageMessage);
|
|
registerEnumParser(manager, FrogVariant.class, incorrectUsageMessage);
|
|
registerEnumParser(manager, VillagerType.class, incorrectUsageMessage);
|
|
registerEnumParser(manager, VillagerProfession.class, incorrectUsageMessage);
|
|
registerEnumParser(manager, VillagerLevel.class, incorrectUsageMessage);
|
|
registerEnumParser(manager, AxolotlVariant.class, incorrectUsageMessage);
|
|
|
|
manager.registerCommand("npc", new MultiCommand(loadHelpMessage("root"))
|
|
.addSubcommand("create", new CreateCommand(npcRegistry, typeRegistry))
|
|
.addSubcommand("reloadconfig", new ReloadConfigCommand(configManager))
|
|
.addSubcommand("toggle", new ToggleCommand(npcRegistry))
|
|
.addSubcommand("skin", new SkinCommand(skinCache, npcRegistry, typeRegistry, propertyRegistry))
|
|
.addSubcommand("delete", new DeleteCommand(npcRegistry, adventure))
|
|
.addSubcommand("move", new MoveCommand(npcRegistry))
|
|
.addSubcommand("teleport", new TeleportCommand(npcRegistry))
|
|
.addSubcommand("list", new ListCommand(npcRegistry))
|
|
.addSubcommand("near", new NearCommand(npcRegistry))
|
|
.addSubcommand("type", new TypeCommand(npcRegistry, typeRegistry))
|
|
.addSubcommand("property", new MultiCommand(loadHelpMessage("property"))
|
|
.addSubcommand("set", new PropertySetCommand(npcRegistry))
|
|
.addSubcommand("remove", new PropertyRemoveCommand(npcRegistry)))
|
|
.addSubcommand("storage", new MultiCommand(loadHelpMessage("storage"))
|
|
.addSubcommand("save", new SaveAllCommand(npcRegistry))
|
|
.addSubcommand("reload", new LoadAllCommand(npcRegistry))
|
|
.addSubcommand("import", new ImportCommand(npcRegistry, importerRegistry)))
|
|
.addSubcommand("holo", new MultiCommand(loadHelpMessage("holo"))
|
|
.addSubcommand("add", new HoloAddCommand(npcRegistry))
|
|
.addSubcommand("additem", new HoloAddItemCommand(npcRegistry))
|
|
.addSubcommand("delete", new HoloDeleteCommand(npcRegistry))
|
|
.addSubcommand("info", new HoloInfoCommand(npcRegistry))
|
|
.addSubcommand("insert", new HoloInsertCommand(npcRegistry))
|
|
.addSubcommand("insertitem", new HoloInsertItemCommand(npcRegistry))
|
|
.addSubcommand("set", new HoloSetCommand(npcRegistry))
|
|
.addSubcommand("setitem", new HoloSetItemCommand(npcRegistry))
|
|
.addSubcommand("offset", new HoloOffsetCommand(npcRegistry))
|
|
.addSubcommand("refreshdelay", new HoloRefreshDelayCommand(npcRegistry)))
|
|
.addSubcommand("action", new MultiCommand(loadHelpMessage("action"))
|
|
.addSubcommand("add", new ActionAddCommand(npcRegistry, actionRegistry))
|
|
.addSubcommand("delete", new ActionDeleteCommand(npcRegistry))
|
|
.addSubcommand("edit", new ActionEditCommand(npcRegistry, actionRegistry))
|
|
.addSubcommand("list", new ActionListCommand(npcRegistry)))
|
|
);
|
|
}
|
|
|
|
private <T extends Enum<T>> void registerEnumParser(CommandManager manager, Class<T> clazz, Message<CommandContext> message) {
|
|
manager.registerParser(clazz, new EnumParser<>(clazz, message));
|
|
}
|
|
|
|
private Message<CommandContext> loadHelpMessage(String name) {
|
|
Reader reader = getTextResource("help-messages/" + name + ".txt");
|
|
if (reader == null) throw new RuntimeException(name + ".txt is missing from the help-messages folder in the ZNPCsPlus jar!");
|
|
Component component = MiniMessage.miniMessage().deserialize(FileUtil.dumpReaderAsString(reader));
|
|
return context -> context.send(component);
|
|
}
|
|
}
|