package com.volmit.iris; import com.volmit.iris.nms.INMS; import com.volmit.iris.manager.*; import com.volmit.iris.manager.command.CommandIris; import com.volmit.iris.manager.command.PermissionIris; import com.volmit.iris.manager.link.BKLink; import com.volmit.iris.manager.link.CitizensLink; import com.volmit.iris.manager.link.MultiverseCoreLink; import com.volmit.iris.manager.link.MythicMobsLink; import com.volmit.iris.object.IrisCompat; import com.volmit.iris.scaffold.IrisWorldCreator; import com.volmit.iris.scaffold.IrisWorlds; import com.volmit.iris.util.*; import io.papermc.lib.PaperLib; import org.bukkit.Bukkit; import org.bukkit.World; import org.bukkit.command.Command; import org.bukkit.command.CommandSender; import org.bukkit.event.HandlerList; import org.bukkit.generator.ChunkGenerator; import org.bukkit.plugin.Plugin; import java.io.BufferedInputStream; import java.io.File; import java.io.FileOutputStream; import java.io.IOException; import java.net.URL; public class Iris extends VolmitPlugin { public static KList executors = new KList<>(); public static Iris instance; public static ProjectManager proj; public static ConversionManager convert; public static IrisHotloadManager hotloader; public static WandManager wand; public static StructureManager struct; public static EditManager edit; public static IrisBoardManager board; public static BKLink linkBK; public static MultiverseCoreLink linkMultiverseCore; public static MythicMobsLink linkMythicMobs; public static CitizensLink linkCitizens; private static final Queue syncJobs = new ShurikenQueue<>(); public static boolean customModels = doesSupportCustomModels(); public static boolean awareEntities = doesSupportAwareness(); public static boolean biome3d = doesSupport3DBiomes(); public static boolean lowMemoryMode = false; public static IrisCompat compat; @Permission public static PermissionIris perm; @com.volmit.iris.util.Command public CommandIris commandIris; public Iris() { instance = this; INMS.get(); IO.delete(new File("iris")); lowMemoryMode = Runtime.getRuntime().maxMemory() < 4000000000L; // 4 * 1000 * 1000 * 1000 // 4g } public static int getThreadCount() { int tc = IrisSettings.get().forceThreadCount; if(tc <= 0) { int p = Runtime.getRuntime().availableProcessors(); return p > 16 ? 16 : p < 4 ? 4 : p; } return tc; } private static boolean doesSupport3DBiomes() { try { int v = Integer.parseInt(Bukkit.getBukkitVersion().split("\\Q-\\E")[0].split("\\Q.\\E")[1]); return v >= 15; } catch(Throwable e) { } return false; } private static boolean doesSupportCustomModels() { try { int v = Integer.parseInt(Bukkit.getBukkitVersion().split("\\Q-\\E")[0].split("\\Q.\\E")[1]); return v >= 14; } catch(Throwable e) { } return false; } private static boolean doesSupportAwareness() { try { int v = Integer.parseInt(Bukkit.getBukkitVersion().split("\\Q-\\E")[0].split("\\Q.\\E")[1]); return v >= 15; } catch(Throwable e) { } return false; } @Override public void start() { } @Override public void stop() { } @Override public String getTag(String subTag) { return C.BOLD + "" + C.DARK_GRAY + "[" + C.BOLD + "" + C.GREEN + "Iris" + C.BOLD + C.DARK_GRAY + "]" + C.RESET + "" + C.GRAY + ": "; } public void onEnable() { instance = this; compat = IrisCompat.configured(getDataFile("compat.json")); proj = new ProjectManager(); hotloader = new IrisHotloadManager(); convert = new ConversionManager(); wand = new WandManager(); struct = new StructureManager(); board = new IrisBoardManager(); linkMultiverseCore = new MultiverseCoreLink(); linkBK = new BKLink(); linkMythicMobs = new MythicMobsLink(); edit = new EditManager(); J.a(() -> IO.delete(getTemp())); J.a(this::bstats); J.s(this::splash, 20); J.sr(this::tickQueue, 0); PaperLib.suggestPaper(this); super.onEnable(); } public void onDisable() { if(IrisSettings.get().isStudio()) { proj.close(); for(World i : Bukkit.getWorlds()) { if(IrisWorlds.isIrisWorld(i)) { IrisWorlds.access(i).close(); } } for(GroupedExecutor i : executors) { i.close(); } } executors.clear(); board.disable(); Bukkit.getScheduler().cancelTasks(this); HandlerList.unregisterAll((Plugin) this); IrisDataManager.managers.clear(); super.onDisable(); } 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(); } } } } private void bstats() { if(IrisSettings.get().isMetrics()) { J.s(() ->new MetricsLite(Iris.instance, 8757)); } } public static File getTemp() { return instance.getDataFolder("cache", "temp"); } @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.GREEN + "[" + C.DARK_GRAY + "Iris" + C.GREEN + "]" + C.GRAY + ": " + msg); } @Override public ChunkGenerator getDefaultWorldGenerator(String worldName, String id) { return new IrisWorldCreator() .productionMode() .name(worldName) .create().generator(); } public static void msg(String string) { try { if(instance == null) { System.out.println("[Iris]: " + string); return; } String msg = C.GRAY + "[" + C.GREEN + "Iris" + C.GRAY + "]: " + string; Bukkit.getConsoleSender().sendMessage(msg); } catch(Throwable e) { System.out.println("[Iris]: " + string); } } 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 ignored) { } } 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 ignored) { } try { return IO.readAll(f); } catch(IOException ignored) { } 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); 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 ignored) { } 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 verbose(String string) { try { if(IrisSettings.get().verbose) { msg(C.GRAY + string); } } catch(Throwable e) { msg(C.GRAY + string); } } public static void success(String string) { msg(C.GREEN + string); } public static void info(String string) { msg(C.WHITE + string); } public void hit(long hits2) { board.hits.put(hits2); } public void splash() { if(!IrisSettings.get().isSplash()) { return; } // @NoArgsConstructor String padd = Form.repeat(" ", 8); String padd2 = Form.repeat(" ", 4); String[] info = {"", "", "", "", "", padd2 + C.GREEN + " Iris", padd2 + C.GRAY + " by " + C.randomColor() + "V" + C.randomColor() + "o" + C.randomColor() + "l" + C.randomColor() + "m" + C.randomColor() + "i" + C.randomColor() + "t" + C.randomColor() + "S" + C.randomColor() + "o" + C.randomColor() + "f" + C.randomColor() + "t" + C.randomColor() + "w" + C.randomColor() + "a" + C.randomColor() + "r" + C.randomColor() + "e", padd2 + C.GRAY + " v" + getDescription().getVersion(), }; String[] splash = {padd + C.GRAY + " @@@@@@@@@@@@@@" + C.DARK_GRAY + "@@@", padd + C.GRAY + " @@&&&&&&&&&" + C.DARK_GRAY + "&&&&&&" + C.GREEN + " .(((()))). ", padd + C.GRAY + "@@@&&&&&&&&" + C.DARK_GRAY + "&&&&&" + C.GREEN + " .((((((())))))). ", padd + C.GRAY + "@@@&&&&&" + C.DARK_GRAY + "&&&&&&&" + C.GREEN + " ((((((((())))))))) " + C.GRAY + " @", padd + C.GRAY + "@@@&&&&" + C.DARK_GRAY + "@@@@@&" + C.GREEN + " ((((((((-))))))))) " + C.GRAY + " @@", padd + C.GRAY + "@@@&&" + C.GREEN + " ((((((({ })))))))) " + C.GRAY + " &&@@@", padd + C.GRAY + "@@" + C.GREEN + " ((((((((-))))))))) " + C.DARK_GRAY + "&@@@@@" + C.GRAY + "&&&&@@@", padd + C.GRAY + "@" + C.GREEN + " ((((((((())))))))) " + C.DARK_GRAY + "&&&&&" + C.GRAY + "&&&&&&&@@@", padd + C.GRAY + "" + C.GREEN + " '((((((()))))))' " + C.DARK_GRAY + "&&&&&" + C.GRAY + "&&&&&&&&@@@", padd + C.GRAY + "" + C.GREEN + " '(((())))' " + C.DARK_GRAY + "&&&&&&&&" + C.GRAY + "&&&&&&&@@", padd + C.GRAY + " " + C.DARK_GRAY + "@@@" + C.GRAY + "@@@@@@@@@@@@@@" }; //@done Iris.info(Bukkit.getVersion()); Iris.info(Bukkit.getBukkitVersion() + " bk"); for(int i = 0; i < info.length; i++) { splash[i] += info[i]; } Iris.info("\n\n " + new KList<>(splash).toString("\n") + "\n"); if(lowMemoryMode) { Iris.verbose("* Low Memory mode Activated! For better performance, allocate 4gb or more to this server."); } if(!biome3d) { Iris.verbose("* This version of minecraft does not support 3D biomes (1.15 and up). Iris will generate as normal, but biome colors will not vary underground & in the sky."); } if(!customModels) { Iris.verbose("* This version of minecraft does not support custom model data in loot items (1.14 and up). Iris will generate as normal, but loot will not have custom models."); } if(!doesSupportAwareness()) { Iris.verbose("* This version of minecraft does not support entity awareness."); } } @SuppressWarnings("deprecation") public static void later(NastyRunnable object) { Bukkit.getScheduler().scheduleAsyncDelayedTask(instance, () -> { try { object.run(); } catch(Throwable e) { e.printStackTrace(); } }, RNG.r.i(100, 1200)); } public static int jobCount() { return syncJobs.size(); } public static void clearQueues() { synchronized(syncJobs) { syncJobs.clear(); } } }