/* * Iris is a World Generator for Minecraft Bukkit Servers * Copyright (c) 2021 Arcane Arts (Volmit Software) * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see . */ package com.volmit.iris; import com.google.gson.Gson; import com.volmit.iris.core.IrisSettings; import com.volmit.iris.core.command.CommandIris; import com.volmit.iris.core.command.PermissionIris; import com.volmit.iris.core.command.studio.CommandIrisStudio; import com.volmit.iris.core.link.IrisPapiExpansion; import com.volmit.iris.core.link.MultiverseCoreLink; import com.volmit.iris.core.link.MythicMobsLink; import com.volmit.iris.core.link.OraxenLink; import com.volmit.iris.core.nms.INMS; import com.volmit.iris.core.project.loader.IrisData; import com.volmit.iris.core.service.StudioSVC; import com.volmit.iris.engine.object.biome.IrisBiome; import com.volmit.iris.engine.object.biome.IrisBiomeCustom; import com.volmit.iris.engine.object.common.IrisWorld; import com.volmit.iris.engine.object.compat.IrisCompat; import com.volmit.iris.engine.object.dimensional.IrisDimension; import com.volmit.iris.engine.platform.BukkitChunkGenerator; import com.volmit.iris.engine.platform.DummyChunkGenerator; import com.volmit.iris.util.collection.KList; import com.volmit.iris.util.collection.KMap; import com.volmit.iris.util.collection.KSet; import com.volmit.iris.util.format.C; import com.volmit.iris.util.format.Form; import com.volmit.iris.util.function.NastyRunnable; import com.volmit.iris.util.io.FileWatcher; import com.volmit.iris.util.io.IO; import com.volmit.iris.util.io.InstanceState; import com.volmit.iris.util.io.JarScanner; import com.volmit.iris.util.math.M; import com.volmit.iris.util.math.RNG; import com.volmit.iris.util.parallel.BurstExecutor; import com.volmit.iris.util.parallel.MultiBurst; import com.volmit.iris.util.plugin.*; import com.volmit.iris.util.reflect.ShadeFix; import com.volmit.iris.util.scheduling.*; import io.papermc.lib.PaperLib; import net.kyori.adventure.platform.bukkit.BukkitAudiences; import net.kyori.adventure.text.serializer.ComponentSerializer; import org.bukkit.Bukkit; import org.bukkit.command.Command; import org.bukkit.command.CommandSender; import org.bukkit.entity.Player; import org.bukkit.event.Event; import org.bukkit.event.HandlerList; import org.bukkit.event.Listener; import org.bukkit.generator.ChunkGenerator; import org.bukkit.plugin.Plugin; import java.io.*; import java.lang.annotation.Annotation; import java.net.URL; import java.util.Date; import java.util.Map; @SuppressWarnings("CanBeFinal") public class Iris extends VolmitPlugin implements Listener { private KMap, IrisService> services; public static Iris instance; public static BukkitAudiences audiences; public static MultiverseCoreLink linkMultiverseCore; public static OraxenLink linkOraxen; public static MythicMobsLink linkMythicMobs; private static final Queue syncJobs = new ShurikenQueue<>(); public static IrisCompat compat; public static FileWatcher configWatcher; private static VolmitSender sender; private final KList postShutdown = new KList<>(); @Permission public static PermissionIris perm; @com.volmit.iris.util.plugin.Command public CommandIris commandIris; @com.volmit.iris.util.plugin.Command public CommandIrisStudio commandStudio; public static VolmitSender getSender() { return sender; } private void preEnable() { instance = this; services = new KMap<>(); initialize("com.volmit.iris.core.service").forEach((i) -> services.put((Class) i.getClass(), (IrisService) i)); INMS.get(); IO.delete(new File("iris")); installDataPacks(); fixShading(); } @SuppressWarnings("unchecked") private void enable() { audiences = BukkitAudiences.create(this); sender = new VolmitSender(Bukkit.getConsoleSender()); sender.setTag(getTag()); instance = this; compat = IrisCompat.configured(getDataFile("compat.json")); linkMultiverseCore = new MultiverseCoreLink(); linkOraxen = new OraxenLink(); linkMythicMobs = new MythicMobsLink(); configWatcher = new FileWatcher(getDataFile("settings.json")); services.values().forEach(IrisService::onEnable); services.values().forEach(this::registerListener); } public void postShutdown(Runnable r) { postShutdown.add(r); } private void postEnable() { J.a(() -> PaperLib.suggestPaper(this)); J.a(() -> IO.delete(getTemp())); J.a(this::bstats); J.ar(this::checkConfigHotload, 60); J.sr(this::tickQueue, 0); J.s(this::setupPapi); J.a(this::verifyDataPacksPost, 20); splash(); } @SuppressWarnings("unchecked") public static T service(Class c) { return (T) instance.services.get(c); } public Iris() { preEnable(); } @SuppressWarnings("unchecked") public void onEnable() { enable(); super.onEnable(); Bukkit.getPluginManager().registerEvents(this, this); J.s(this::postEnable); } public void onDisable() { services.values().forEach(IrisService::onDisable); Bukkit.getScheduler().cancelTasks(this); HandlerList.unregisterAll((Plugin) this); postShutdown.forEach(Runnable::run); services.clear(); MultiBurst.burst.close(); super.onDisable(); } public static void callEvent(Event e) { if (!e.isAsynchronous()) { J.s(() -> Bukkit.getPluginManager().callEvent(e)); } else { Bukkit.getPluginManager().callEvent(e); } } public static KList initialize(String s, Class slicedClass) { JarScanner js = new JarScanner(instance.getJarFile(), s); KList v = new KList<>(); J.attempt(js::scan); for (Class i : js.getClasses()) { if (slicedClass == null || i.isAnnotationPresent(slicedClass)) { try { v.add(i.getDeclaredConstructor().newInstance()); } catch (Throwable ignored) { } } } return v; } public static KList initialize(String s) { return initialize(s, null); } private void fixShading() { ShadeFix.fix(ComponentSerializer.class); } private void setupPapi() { if (Bukkit.getPluginManager().getPlugin("PlaceholderAPI") != null) { new IrisPapiExpansion().register(); } } public File getDatapacksFolder() { if (!IrisSettings.get().getGeneral().forceMainWorld.isEmpty()) { return new File(IrisSettings.get().getGeneral().forceMainWorld + "/datapacks"); } File props = new File("server.properties"); if (props.exists()) { try { KList m = new KList<>(IO.readAll(props).split("\\Q\n\\E")); for (String i : m) { if (i.trim().startsWith("level-name=")) { return new File(i.trim().split("\\Q=\\E")[1] + "/datapacks"); } } } catch (IOException e) { Iris.reportError(e); e.printStackTrace(); } } return null; } public void installDataPacks() { Iris.info("Checking Data Packs..."); boolean reboot = false; File packs = new File("plugins/Iris/packs"); File dpacks = getDatapacksFolder(); if (dpacks == null) { Iris.error("Cannot find the datapacks folder! Please try generating a default world first maybe? Is this a new server?"); return; } if (packs.exists()) { for (File i : packs.listFiles()) { if (i.isDirectory()) { Iris.verbose("Checking Pack: " + i.getPath()); IrisData data = IrisData.get(i); File dims = new File(i, "dimensions"); if (dims.exists()) { for (File j : dims.listFiles()) { if (j.getName().endsWith(".json")) { IrisDimension dim = data.getDimensionLoader().load(j.getName().split("\\Q.\\E")[0]); Iris.verbose(" Checking Dimension " + dim.getLoadFile().getPath()); if (dim.installDataPack(() -> data, dpacks)) { reboot = true; } } } } } } } Iris.info("Data Packs Setup!"); } @Override public void start() { } @Override public void stop() { } @Override public String getTag(String subTag) { return C.BOLD + "" + C.DARK_GRAY + "[" + C.BOLD + "" + C.IRIS + "Iris" + C.BOLD + C.DARK_GRAY + "]" + C.RESET + "" + C.GRAY + ": "; } private void checkConfigHotload() { if (configWatcher.checkModified()) { IrisSettings.invalidate(); IrisSettings.get(); configWatcher.checkModified(); Iris.info("Hotloaded settings.json"); } } public static void sq(Runnable r) { synchronized (syncJobs) { syncJobs.queue(r); } } private void tickQueue() { synchronized (Iris.syncJobs) { if (!Iris.syncJobs.hasNext()) { return; } long ms = M.ms(); while (Iris.syncJobs.hasNext() && M.ms() - ms < 25) { try { Iris.syncJobs.next().run(); } catch (Throwable e) { e.printStackTrace(); Iris.reportError(e); } } } } private void bstats() { if (IrisSettings.get().getGeneral().isPluginMetrics()) { J.s(() -> new Metrics(Iris.instance, 8757)); } } public static File getTemp() { return instance.getDataFolder("cache", "temp"); } public void verifyDataPacksPost() { File packs = new File("plugins/Iris/packs"); File dpacks = getDatapacksFolder(); if (dpacks == null) { Iris.error("Cannot find the datapacks folder! Please try generating a default world first maybe? Is this a new server?"); return; } boolean bad = false; if (packs.exists()) { for (File i : packs.listFiles()) { if (i.isDirectory()) { Iris.verbose("Checking Pack: " + i.getPath()); IrisData data = IrisData.get(i); File dims = new File(i, "dimensions"); if (dims.exists()) { for (File j : dims.listFiles()) { if (j.getName().endsWith(".json")) { IrisDimension dim = data.getDimensionLoader().load(j.getName().split("\\Q.\\E")[0]); if (!verifyDataPackInstalled(dim)) { bad = true; } } } } } } } if (bad && INMS.get().supportsDataPacks()) { Iris.error("============================================================================"); Iris.error(C.ITALIC + "You need to restart your server to properly generate custom biomes."); Iris.error(C.ITALIC + "By continuing, Iris will use backup biomes in place of the custom biomes."); Iris.error("----------------------------------------------------------------------------"); Iris.error(C.UNDERLINE + "IT IS HIGHLY RECOMMENDED YOU RESTART THE SERVER BEFORE GENERATING!"); Iris.error("============================================================================"); for (Player i : Bukkit.getOnlinePlayers()) { if (i.isOp() || Iris.perm.has(i)) { VolmitSender sender = new VolmitSender(i, getTag("WARNING")); sender.sendMessage("There are some Iris Packs that have custom biomes in them"); sender.sendMessage("You need to restart your server to use these packs."); } } } } public boolean verifyDataPackInstalled(IrisDimension dimension) { IrisData idm = IrisData.get(getDataFolder("packs", dimension.getLoadKey())); KSet keys = new KSet<>(); boolean warn = false; for (IrisBiome i : dimension.getAllBiomes(() -> idm)) { if (i.isCustom()) { for (IrisBiomeCustom j : i.getCustomDerivitives()) { keys.add(dimension.getLoadKey() + ":" + j.getId()); } } } if (!INMS.get().supportsDataPacks()) { if (!keys.isEmpty()) { Iris.warn("==================================================================================="); Iris.warn("Pack " + dimension.getLoadKey() + " has " + keys.size() + " custom biome(s). "); Iris.warn("Your server version does not yet support datapacks for iris."); Iris.warn("The world will generate these biomes as backup biomes."); Iris.warn("===================================================================================="); } return true; } for (String i : keys) { Object o = INMS.get().getCustomBiomeBaseFor(i); if (o == null) { Iris.warn("The Biome " + i + " is not registered on the server."); warn = true; } } if (warn) { Iris.error("The Pack " + dimension.getLoadKey() + " is INCAPABLE of generating custom biomes, restart your server before generating with this pack!"); } return !warn; } @Override public boolean onCommand(CommandSender sender, Command command, String label, String[] args) { return super.onCommand(sender, command, label, args); } public void imsg(CommandSender s, String msg) { s.sendMessage(C.IRIS + "[" + C.DARK_GRAY + "Iris" + C.IRIS + "]" + C.GRAY + ": " + msg); } @Override public ChunkGenerator getDefaultWorldGenerator(String worldName, String id) { if(worldName.equals("test")) { try { throw new RuntimeException(); } catch(Throwable e) { Iris.info(e.getStackTrace()[1].getClassName()); if(e.getStackTrace()[1].getClassName().contains("com.onarandombox.MultiverseCore")) { Iris.debug("MVC Test detected, Quick! Send them the dummy!"); return new DummyChunkGenerator(); } } } IrisDimension dim; if (id == null || id.isEmpty()) { dim = IrisData.loadAnyDimension(IrisSettings.get().getGenerator().getDefaultWorldType()); } else { dim = IrisData.loadAnyDimension(id); } Iris.debug("Generator ID: " + id + " requested by bukkit/plugin"); if (dim == null) { Iris.warn("Unable to find dimension type " + id + " Looking for online packs..."); service(StudioSVC.class).downloadSearch(new VolmitSender(Bukkit.getConsoleSender()), id, true); dim = IrisData.loadAnyDimension(id); if (dim == null) { throw new RuntimeException("Can't find dimension " + id + "!"); } else { Iris.info("Resolved missing dimension, proceeding with generation."); } } Iris.debug("Assuming IrisDimension: " + dim.getName()); IrisWorld w = IrisWorld.builder() .name(worldName) .seed(RNG.r.lmax()) .environment(dim.getEnvironment()) .worldFolder(new File(worldName)) .minHeight(0) .maxHeight(256) .build(); Iris.debug("Generator Config: " + w.toString()); File ff = new File(w.worldFolder(), "iris/pack"); if(!ff.exists() || ff.listFiles().length == 0) { ff.mkdirs(); service(StudioSVC.class).installIntoWorld(sender, dim.getLoadKey(), ff.getParentFile()); } return new BukkitChunkGenerator(w, false, ff, dim.getLoadKey()); } public static void msg(String string) { try { sender.sendMessage(string); } catch (Throwable e) { try { System.out.println(instance.getTag() + string.replaceAll("(<([^>]+)>)", "")); } catch (Throwable ignored1) { } } } public static File getCached(String name, String url) { String h = IO.hash(name + "@" + url); File f = Iris.instance.getDataFile("cache", h.substring(0, 2), h.substring(3, 5), h); if (!f.exists()) { try (BufferedInputStream in = new BufferedInputStream(new URL(url).openStream()); FileOutputStream fileOutputStream = new FileOutputStream(f)) { byte[] dataBuffer = new byte[1024]; int bytesRead; while ((bytesRead = in.read(dataBuffer, 0, 1024)) != -1) { fileOutputStream.write(dataBuffer, 0, bytesRead); Iris.verbose("Aquiring " + name); } } catch (IOException e) { Iris.reportError(e); } } return f.exists() ? f : null; } public static String getNonCached(String name, String url) { String h = IO.hash(name + "*" + url); File f = Iris.instance.getDataFile("cache", h.substring(0, 2), h.substring(3, 5), h); try (BufferedInputStream in = new BufferedInputStream(new URL(url).openStream()); FileOutputStream fileOutputStream = new FileOutputStream(f)) { byte[] dataBuffer = new byte[1024]; int bytesRead; while ((bytesRead = in.read(dataBuffer, 0, 1024)) != -1) { fileOutputStream.write(dataBuffer, 0, bytesRead); } } catch (IOException e) { Iris.reportError(e); } try { return IO.readAll(f); } catch (IOException e) { Iris.reportError(e); } return ""; } public static File getNonCachedFile(String name, String url) { String h = IO.hash(name + "*" + url); File f = Iris.instance.getDataFile("cache", h.substring(0, 2), h.substring(3, 5), h); Iris.verbose("Download " + name + " -> " + url); try (BufferedInputStream in = new BufferedInputStream(new URL(url).openStream()); FileOutputStream fileOutputStream = new FileOutputStream(f)) { byte[] dataBuffer = new byte[1024]; int bytesRead; while ((bytesRead = in.read(dataBuffer, 0, 1024)) != -1) { fileOutputStream.write(dataBuffer, 0, bytesRead); } } catch (IOException e) { e.printStackTrace(); Iris.reportError(e); } return f; } public static void warn(String string) { msg(C.YELLOW + string); } public static void error(String string) { msg(C.RED + string); } public static void debug(String string) { if (!IrisSettings.get().getGeneral().isDebug()) { return; } try { throw new RuntimeException(); } catch (Throwable e) { try { String[] cc = e.getStackTrace()[1].getClassName().split("\\Q.\\E"); if (cc.length > 5) { debug(cc[3] + "/" + cc[4] + "/" + cc[cc.length - 1], e.getStackTrace()[1].getLineNumber(), string); } else { debug(cc[3] + "/" + cc[4], e.getStackTrace()[1].getLineNumber(), string); } } catch (Throwable ex) { debug("Origin", -1, string); } } } public static void debug(String category, int line, String string) { if (!IrisSettings.get().getGeneral().isDebug()) { return; } msg("" + category + " <#bf3b76>" + line + " " + C.LIGHT_PURPLE + string.replaceAll("\\Q<\\E", "[").replaceAll("\\Q>\\E", "]")); } public static void verbose(String string) { debug(string); } public static void success(String string) { msg(C.IRIS + string); } public static void info(String string) { msg(C.WHITE + string); } public void splash() { if (!IrisSettings.get().getGeneral().isSplashLogoStartup()) { return; } // @NoArgsConstructor String padd = Form.repeat(" ", 8); String padd2 = Form.repeat(" ", 4); String[] info = {"", "", "", "", "", padd2 + C.IRIS + " Iris", padd2 + C.GRAY + " by " + "Volmit Software", padd2 + C.GRAY + " v" + C.IRIS + getDescription().getVersion(), }; String[] splash = {padd + C.GRAY + " @@@@@@@@@@@@@@" + C.DARK_GRAY + "@@@", padd + C.GRAY + " @@&&&&&&&&&" + C.DARK_GRAY + "&&&&&&" + C.IRIS + " .(((()))). ", padd + C.GRAY + "@@@&&&&&&&&" + C.DARK_GRAY + "&&&&&" + C.IRIS + " .((((((())))))). ", padd + C.GRAY + "@@@&&&&&" + C.DARK_GRAY + "&&&&&&&" + C.IRIS + " ((((((((())))))))) " + C.GRAY + " @", padd + C.GRAY + "@@@&&&&" + C.DARK_GRAY + "@@@@@&" + C.IRIS + " ((((((((-))))))))) " + C.GRAY + " @@", padd + C.GRAY + "@@@&&" + C.IRIS + " ((((((({ })))))))) " + C.GRAY + " &&@@@", padd + C.GRAY + "@@" + C.IRIS + " ((((((((-))))))))) " + C.DARK_GRAY + "&@@@@@" + C.GRAY + "&&&&@@@", padd + C.GRAY + "@" + C.IRIS + " ((((((((())))))))) " + C.DARK_GRAY + "&&&&&" + C.GRAY + "&&&&&&&@@@", padd + C.GRAY + "" + C.IRIS + " '((((((()))))))' " + C.DARK_GRAY + "&&&&&" + C.GRAY + "&&&&&&&&@@@", padd + C.GRAY + "" + C.IRIS + " '(((())))' " + C.DARK_GRAY + "&&&&&&&&" + C.GRAY + "&&&&&&&@@", padd + C.GRAY + " " + C.DARK_GRAY + "@@@" + C.GRAY + "@@@@@@@@@@@@@@" }; //@done Iris.info("Server type & version: " + Bukkit.getVersion()); Iris.info("Bukkit version: " + Bukkit.getBukkitVersion()); Iris.info("Java version: " + getJavaVersion()); Iris.info("Custom Biomes: " + INMS.get().countCustomBiomes()); for (int i = 0; i < info.length; i++) { splash[i] += info[i]; } Iris.info("\n\n " + new KList<>(splash).toString("\n") + "\n"); } @SuppressWarnings("deprecation") public static void later(NastyRunnable object) { Bukkit.getScheduler().scheduleAsyncDelayedTask(instance, () -> { try { object.run(); } catch (Throwable e) { e.printStackTrace(); Iris.reportError(e); } }, RNG.r.i(100, 1200)); } public static int jobCount() { return syncJobs.size(); } public static void clearQueues() { synchronized (syncJobs) { syncJobs.clear(); } } private static int getJavaVersion() { String version = System.getProperty("java.version"); if (version.startsWith("1.")) { version = version.substring(2, 3); } else { int dot = version.indexOf("."); if (dot != -1) { version = version.substring(0, dot); } } return Integer.parseInt(version); } public boolean isMCA() { return IrisSettings.get().getGenerator().isHeadlessPregeneration(); } public static void reportErrorChunk(int x, int z, Throwable e, String extra) { if (IrisSettings.get().getGeneral().isDebug()) { File f = instance.getDataFile("debug", "chunk-errors", "chunk." + x + "." + z + ".txt"); if (!f.exists()) { J.attempt(() -> { PrintWriter pw = new PrintWriter(f); pw.println("Thread: " + Thread.currentThread().getName()); pw.println("First: " + new Date(M.ms())); e.printStackTrace(pw); pw.close(); }); } Iris.debug("Chunk " + x + "," + z + " Exception Logged: " + e.getClass().getSimpleName() + ": " + C.RESET + "" + C.LIGHT_PURPLE + e.getMessage()); } } public static synchronized void reportError(Throwable e) { if (IrisSettings.get().getGeneral().isDebug()) { String n = e.getClass().getCanonicalName() + "-" + e.getStackTrace()[0].getClassName() + "-" + e.getStackTrace()[0].getLineNumber(); if (e.getCause() != null) { n += "-" + e.getCause().getStackTrace()[0].getClassName() + "-" + e.getCause().getStackTrace()[0].getLineNumber(); } File f = instance.getDataFile("debug", "caught-exceptions", n + ".txt"); if (!f.exists()) { J.attempt(() -> { PrintWriter pw = new PrintWriter(f); pw.println("Thread: " + Thread.currentThread().getName()); pw.println("First: " + new Date(M.ms())); e.printStackTrace(pw); pw.close(); }); } Iris.debug("Exception Logged: " + e.getClass().getSimpleName() + ": " + C.RESET + "" + C.LIGHT_PURPLE + e.getMessage()); } } static { try { InstanceState.updateInstanceId(); } catch (Throwable ignored) { } } public static void dump() { try { File fi = Iris.instance.getDataFile("dump", "td-" + new java.sql.Date(M.ms()) + ".txt"); FileOutputStream fos = new FileOutputStream(fi ); Map f = Thread.getAllStackTraces(); PrintWriter pw = new PrintWriter(fos); for(Thread i : f.keySet()) { pw.println("========================================"); pw.println("Thread: '" + i.getName() + "' ID: " + i.getId() + " STATUS: " + i.getState().name()); for(StackTraceElement j : f.get(i)) { pw.println(" @ " + j.toString()); } pw.println("========================================"); pw.println(); pw.println(); } pw.close(); System.out.println("DUMPED! See " + fi.getAbsolutePath()); } catch(Throwable e) { e.printStackTrace(); } } }