aboutsummaryrefslogtreecommitdiff
path: root/spark-forge1122/src/main/java
diff options
context:
space:
mode:
authorLuck <git@lucko.me>2021-01-09 23:55:57 +0000
committerLuck <git@lucko.me>2021-01-09 23:55:57 +0000
commit9bec2b79880bf0a814b6a1c8616f6a0c9d03bfc6 (patch)
tree81b9656c7bebd1c7b3c03ef05ba289667ea19c4a /spark-forge1122/src/main/java
parent3fb59ef05e7c7abbf79ba5cfc3c8331b9aacf77a (diff)
downloadspark-9bec2b79880bf0a814b6a1c8616f6a0c9d03bfc6.tar.gz
spark-9bec2b79880bf0a814b6a1c8616f6a0c9d03bfc6.tar.bz2
spark-9bec2b79880bf0a814b6a1c8616f6a0c9d03bfc6.zip
Re-add module for Forge 1.12.2
#26
Diffstat (limited to 'spark-forge1122/src/main/java')
-rw-r--r--spark-forge1122/src/main/java/me/lucko/spark/forge/ForgeCommandSender.java75
-rw-r--r--spark-forge1122/src/main/java/me/lucko/spark/forge/ForgePlatformInfo.java53
-rw-r--r--spark-forge1122/src/main/java/me/lucko/spark/forge/ForgeSparkMod.java73
-rw-r--r--spark-forge1122/src/main/java/me/lucko/spark/forge/ForgeTickHook.java60
-rw-r--r--spark-forge1122/src/main/java/me/lucko/spark/forge/ForgeTickReporter.java72
-rw-r--r--spark-forge1122/src/main/java/me/lucko/spark/forge/plugin/ForgeClientSparkPlugin.java90
-rw-r--r--spark-forge1122/src/main/java/me/lucko/spark/forge/plugin/ForgeServerSparkPlugin.java108
-rw-r--r--spark-forge1122/src/main/java/me/lucko/spark/forge/plugin/ForgeSparkPlugin.java133
8 files changed, 664 insertions, 0 deletions
diff --git a/spark-forge1122/src/main/java/me/lucko/spark/forge/ForgeCommandSender.java b/spark-forge1122/src/main/java/me/lucko/spark/forge/ForgeCommandSender.java
new file mode 100644
index 0000000..3d07a44
--- /dev/null
+++ b/spark-forge1122/src/main/java/me/lucko/spark/forge/ForgeCommandSender.java
@@ -0,0 +1,75 @@
+/*
+ * This file is part of spark.
+ *
+ * Copyright (c) lucko (Luck) <luck@lucko.me>
+ * Copyright (c) contributors
+ *
+ * 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 <http://www.gnu.org/licenses/>.
+ */
+
+package me.lucko.spark.forge;
+
+import me.lucko.spark.common.command.sender.AbstractCommandSender;
+import me.lucko.spark.forge.plugin.ForgeSparkPlugin;
+
+import net.kyori.adventure.text.Component;
+import net.kyori.adventure.text.serializer.gson.GsonComponentSerializer;
+import net.minecraft.command.ICommandSender;
+import net.minecraft.entity.player.EntityPlayer;
+import net.minecraft.network.rcon.RConConsoleSource;
+import net.minecraft.server.MinecraftServer;
+import net.minecraft.util.text.ITextComponent;
+
+import java.util.UUID;
+
+public class ForgeCommandSender extends AbstractCommandSender<ICommandSender> {
+ private final ForgeSparkPlugin plugin;
+
+ public ForgeCommandSender(ICommandSender source, ForgeSparkPlugin plugin) {
+ super(source);
+ this.plugin = plugin;
+ }
+
+ @Override
+ public String getName() {
+ if (super.delegate instanceof EntityPlayer) {
+ return ((EntityPlayer) super.delegate).getGameProfile().getName();
+ } else if (super.delegate instanceof MinecraftServer) {
+ return "Console";
+ } else if (super.delegate instanceof RConConsoleSource) {
+ return "RCON Console";
+ } else {
+ return "unknown:" + super.delegate.getClass().getSimpleName();
+ }
+ }
+
+ @Override
+ public UUID getUniqueId() {
+ if (super.delegate instanceof EntityPlayer) {
+ return ((EntityPlayer) super.delegate).getUniqueID();
+ }
+ return null;
+ }
+
+ @Override
+ public void sendMessage(Component message) {
+ ITextComponent component = ITextComponent.Serializer.jsonToComponent(GsonComponentSerializer.gson().serialize(message));
+ super.delegate.sendMessage(component);
+ }
+
+ @Override
+ public boolean hasPermission(String permission) {
+ return this.plugin.hasPermission(super.delegate, permission);
+ }
+}
diff --git a/spark-forge1122/src/main/java/me/lucko/spark/forge/ForgePlatformInfo.java b/spark-forge1122/src/main/java/me/lucko/spark/forge/ForgePlatformInfo.java
new file mode 100644
index 0000000..128c314
--- /dev/null
+++ b/spark-forge1122/src/main/java/me/lucko/spark/forge/ForgePlatformInfo.java
@@ -0,0 +1,53 @@
+/*
+ * This file is part of spark.
+ *
+ * Copyright (c) lucko (Luck) <luck@lucko.me>
+ * Copyright (c) contributors
+ *
+ * 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 <http://www.gnu.org/licenses/>.
+ */
+
+package me.lucko.spark.forge;
+
+import me.lucko.spark.common.platform.AbstractPlatformInfo;
+
+import net.minecraftforge.common.ForgeVersion;
+
+public class ForgePlatformInfo extends AbstractPlatformInfo {
+ private final Type type;
+
+ public ForgePlatformInfo(Type type) {
+ this.type = type;
+ }
+
+ @Override
+ public Type getType() {
+ return type;
+ }
+
+ @Override
+ public String getName() {
+ return "Forge";
+ }
+
+ @Override
+ public String getVersion() {
+ return ForgeVersion.getVersion();
+ }
+
+ @Override
+ public String getMinecraftVersion() {
+ return ForgeVersion.mcVersion;
+ }
+}
diff --git a/spark-forge1122/src/main/java/me/lucko/spark/forge/ForgeSparkMod.java b/spark-forge1122/src/main/java/me/lucko/spark/forge/ForgeSparkMod.java
new file mode 100644
index 0000000..2c19659
--- /dev/null
+++ b/spark-forge1122/src/main/java/me/lucko/spark/forge/ForgeSparkMod.java
@@ -0,0 +1,73 @@
+/*
+ * This file is part of spark.
+ *
+ * Copyright (c) lucko (Luck) <luck@lucko.me>
+ * Copyright (c) contributors
+ *
+ * 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 <http://www.gnu.org/licenses/>.
+ */
+
+package me.lucko.spark.forge;
+
+import me.lucko.spark.forge.plugin.ForgeClientSparkPlugin;
+import me.lucko.spark.forge.plugin.ForgeServerSparkPlugin;
+
+import net.minecraftforge.fml.common.FMLCommonHandler;
+import net.minecraftforge.fml.common.Mod;
+import net.minecraftforge.fml.common.Mod.EventHandler;
+import net.minecraftforge.fml.common.event.FMLInitializationEvent;
+import net.minecraftforge.fml.common.event.FMLPreInitializationEvent;
+import net.minecraftforge.fml.common.event.FMLServerStartingEvent;
+import net.minecraftforge.fml.relauncher.Side;
+
+import java.nio.file.Path;
+
+@Mod(
+ modid = "spark",
+ name = "spark",
+ version = "@version@",
+ acceptableRemoteVersions = "*"
+)
+public class ForgeSparkMod {
+
+ private Path configDirectory;
+
+ public String getVersion() {
+ return ForgeSparkMod.class.getAnnotation(Mod.class).version();
+ }
+
+ @EventHandler
+ public void preInit(FMLPreInitializationEvent e) {
+ this.configDirectory = e.getModConfigurationDirectory().toPath();
+ }
+
+ @EventHandler
+ public void init(FMLInitializationEvent e) {
+ if (FMLCommonHandler.instance().getSide() == Side.CLIENT) {
+ ForgeClientSparkPlugin.register(this);
+ }
+ }
+
+ @EventHandler
+ public void serverInit(FMLServerStartingEvent e) {
+ ForgeServerSparkPlugin.register(this, e);
+ }
+
+ public Path getConfigDirectory() {
+ if (this.configDirectory == null) {
+ throw new IllegalStateException("Config directory not set");
+ }
+ return this.configDirectory;
+ }
+}
diff --git a/spark-forge1122/src/main/java/me/lucko/spark/forge/ForgeTickHook.java b/spark-forge1122/src/main/java/me/lucko/spark/forge/ForgeTickHook.java
new file mode 100644
index 0000000..56acf47
--- /dev/null
+++ b/spark-forge1122/src/main/java/me/lucko/spark/forge/ForgeTickHook.java
@@ -0,0 +1,60 @@
+/*
+ * This file is part of spark.
+ *
+ * Copyright (c) lucko (Luck) <luck@lucko.me>
+ * Copyright (c) contributors
+ *
+ * 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 <http://www.gnu.org/licenses/>.
+ */
+
+package me.lucko.spark.forge;
+
+import me.lucko.spark.common.sampler.tick.AbstractTickHook;
+import me.lucko.spark.common.sampler.tick.TickHook;
+
+import net.minecraftforge.common.MinecraftForge;
+import net.minecraftforge.fml.common.eventhandler.SubscribeEvent;
+import net.minecraftforge.fml.common.gameevent.TickEvent;
+
+public class ForgeTickHook extends AbstractTickHook implements TickHook {
+ private final TickEvent.Type type;
+
+ public ForgeTickHook(TickEvent.Type type) {
+ this.type = type;
+ }
+
+ @SubscribeEvent
+ public void onTick(TickEvent e) {
+ if (e.phase != TickEvent.Phase.START) {
+ return;
+ }
+
+ if (e.type != this.type) {
+ return;
+ }
+
+ onTick();
+ }
+
+ @Override
+ public void start() {
+ MinecraftForge.EVENT_BUS.register(this);
+ }
+
+ @Override
+ public void close() {
+ MinecraftForge.EVENT_BUS.unregister(this);
+ }
+
+}
diff --git a/spark-forge1122/src/main/java/me/lucko/spark/forge/ForgeTickReporter.java b/spark-forge1122/src/main/java/me/lucko/spark/forge/ForgeTickReporter.java
new file mode 100644
index 0000000..972f5c0
--- /dev/null
+++ b/spark-forge1122/src/main/java/me/lucko/spark/forge/ForgeTickReporter.java
@@ -0,0 +1,72 @@
+/*
+ * This file is part of spark.
+ *
+ * Copyright (c) lucko (Luck) <luck@lucko.me>
+ * Copyright (c) contributors
+ *
+ * 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 <http://www.gnu.org/licenses/>.
+ */
+
+package me.lucko.spark.forge;
+
+import me.lucko.spark.common.sampler.tick.AbstractTickReporter;
+import me.lucko.spark.common.sampler.tick.TickReporter;
+
+import net.minecraftforge.common.MinecraftForge;
+import net.minecraftforge.fml.common.eventhandler.SubscribeEvent;
+import net.minecraftforge.fml.common.gameevent.TickEvent;
+
+public class ForgeTickReporter extends AbstractTickReporter implements TickReporter {
+ private final TickEvent.Type type;
+
+ private long start = 0;
+
+ public ForgeTickReporter(TickEvent.Type type) {
+ this.type = type;
+ }
+
+ @SubscribeEvent
+ public void onTick(TickEvent e) {
+ if (e.type != this.type) {
+ return;
+ }
+
+ switch (e.phase) {
+ case START:
+ this.start = System.nanoTime();
+ break;
+ case END:
+ if (this.start == 0) {
+ return;
+ }
+
+ double duration = (System.nanoTime() - this.start) / 1000000d;
+ onTick(duration);
+ break;
+ default:
+ throw new AssertionError(e.phase);
+ }
+ }
+
+ @Override
+ public void start() {
+ MinecraftForge.EVENT_BUS.register(this);
+ }
+
+ @Override
+ public void close() {
+ MinecraftForge.EVENT_BUS.unregister(this);
+ }
+
+}
diff --git a/spark-forge1122/src/main/java/me/lucko/spark/forge/plugin/ForgeClientSparkPlugin.java b/spark-forge1122/src/main/java/me/lucko/spark/forge/plugin/ForgeClientSparkPlugin.java
new file mode 100644
index 0000000..2e64df8
--- /dev/null
+++ b/spark-forge1122/src/main/java/me/lucko/spark/forge/plugin/ForgeClientSparkPlugin.java
@@ -0,0 +1,90 @@
+/*
+ * This file is part of spark.
+ *
+ * Copyright (c) lucko (Luck) <luck@lucko.me>
+ * Copyright (c) contributors
+ *
+ * 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 <http://www.gnu.org/licenses/>.
+ */
+
+package me.lucko.spark.forge.plugin;
+
+import me.lucko.spark.common.platform.PlatformInfo;
+import me.lucko.spark.common.sampler.tick.TickHook;
+import me.lucko.spark.common.sampler.tick.TickReporter;
+import me.lucko.spark.forge.ForgeCommandSender;
+import me.lucko.spark.forge.ForgePlatformInfo;
+import me.lucko.spark.forge.ForgeSparkMod;
+import me.lucko.spark.forge.ForgeTickHook;
+import me.lucko.spark.forge.ForgeTickReporter;
+
+import net.minecraft.client.Minecraft;
+import net.minecraft.command.ICommandSender;
+import net.minecraftforge.client.ClientCommandHandler;
+import net.minecraftforge.common.MinecraftForge;
+import net.minecraftforge.fml.common.gameevent.TickEvent;
+
+import java.util.stream.Stream;
+
+public class ForgeClientSparkPlugin extends ForgeSparkPlugin {
+
+ public static void register(ForgeSparkMod mod) {
+ ForgeClientSparkPlugin plugin = new ForgeClientSparkPlugin(mod, Minecraft.getMinecraft());
+ plugin.enable();
+
+ // register listeners
+ MinecraftForge.EVENT_BUS.register(plugin);
+
+ // register commands
+ ClientCommandHandler.instance.registerCommand(plugin);
+ }
+
+ private final Minecraft minecraft;
+
+ public ForgeClientSparkPlugin(ForgeSparkMod mod, Minecraft minecraft) {
+ super(mod);
+ this.minecraft = minecraft;
+ }
+
+ @Override
+ public boolean hasPermission(ICommandSender sender, String permission) {
+ return true;
+ }
+
+ @Override
+ public Stream<ForgeCommandSender> getSendersWithPermission(String permission) {
+ return Stream.of(new ForgeCommandSender(this.minecraft.player, this));
+ }
+
+ @Override
+ public TickHook createTickHook() {
+ return new ForgeTickHook(TickEvent.Type.CLIENT);
+ }
+
+ @Override
+ public TickReporter createTickReporter() {
+ return new ForgeTickReporter(TickEvent.Type.CLIENT);
+ }
+
+ @Override
+ public PlatformInfo getPlatformInfo() {
+ return new ForgePlatformInfo(PlatformInfo.Type.CLIENT);
+ }
+
+ @Override
+ public String getCommandName() {
+ return "sparkc";
+ }
+
+}
diff --git a/spark-forge1122/src/main/java/me/lucko/spark/forge/plugin/ForgeServerSparkPlugin.java b/spark-forge1122/src/main/java/me/lucko/spark/forge/plugin/ForgeServerSparkPlugin.java
new file mode 100644
index 0000000..4cf1711
--- /dev/null
+++ b/spark-forge1122/src/main/java/me/lucko/spark/forge/plugin/ForgeServerSparkPlugin.java
@@ -0,0 +1,108 @@
+/*
+ * This file is part of spark.
+ *
+ * Copyright (c) lucko (Luck) <luck@lucko.me>
+ * Copyright (c) contributors
+ *
+ * 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 <http://www.gnu.org/licenses/>.
+ */
+
+package me.lucko.spark.forge.plugin;
+
+
+import me.lucko.spark.common.platform.PlatformInfo;
+import me.lucko.spark.common.sampler.tick.TickHook;
+import me.lucko.spark.common.sampler.tick.TickReporter;
+import me.lucko.spark.forge.ForgeCommandSender;
+import me.lucko.spark.forge.ForgePlatformInfo;
+import me.lucko.spark.forge.ForgeSparkMod;
+import me.lucko.spark.forge.ForgeTickHook;
+import me.lucko.spark.forge.ForgeTickReporter;
+
+import net.minecraft.command.ICommandSender;
+import net.minecraft.entity.player.EntityPlayer;
+import net.minecraft.server.MinecraftServer;
+import net.minecraftforge.common.MinecraftForge;
+import net.minecraftforge.fml.common.event.FMLServerStartingEvent;
+import net.minecraftforge.fml.common.event.FMLServerStoppingEvent;
+import net.minecraftforge.fml.common.eventhandler.SubscribeEvent;
+import net.minecraftforge.fml.common.gameevent.TickEvent;
+import net.minecraftforge.server.permission.DefaultPermissionLevel;
+import net.minecraftforge.server.permission.PermissionAPI;
+
+import java.util.stream.Stream;
+
+public class ForgeServerSparkPlugin extends ForgeSparkPlugin {
+
+ public static void register(ForgeSparkMod mod, FMLServerStartingEvent event) {
+ ForgeServerSparkPlugin plugin = new ForgeServerSparkPlugin(mod, event.getServer());
+ plugin.enable();
+
+ // register listeners
+ MinecraftForge.EVENT_BUS.register(plugin);
+
+ // register commands & permissions
+ event.registerServerCommand(plugin);
+ PermissionAPI.registerNode("spark", DefaultPermissionLevel.OP, "Access to the spark command");
+ }
+
+ private final MinecraftServer server;
+
+ public ForgeServerSparkPlugin(ForgeSparkMod mod, MinecraftServer server) {
+ super(mod);
+ this.server = server;
+ }
+
+ @SubscribeEvent
+ public void onDisable(FMLServerStoppingEvent event) {
+ disable();
+ }
+
+ @Override
+ public boolean hasPermission(ICommandSender sender, String permission) {
+ if (sender instanceof EntityPlayer) {
+ return PermissionAPI.hasPermission((EntityPlayer) sender, permission);
+ } else {
+ return true;
+ }
+ }
+
+ @Override
+ public Stream<ForgeCommandSender> getSendersWithPermission(String permission) {
+ return Stream.concat(
+ this.server.getPlayerList().getPlayers().stream().filter(player -> hasPermission(player, permission)),
+ Stream.of(this.server)
+ ).map(sender -> new ForgeCommandSender(sender, this));
+ }
+
+ @Override
+ public TickHook createTickHook() {
+ return new ForgeTickHook(TickEvent.Type.SERVER);
+ }
+
+ @Override
+ public TickReporter createTickReporter() {
+ return new ForgeTickReporter(TickEvent.Type.SERVER);
+ }
+
+ @Override
+ public PlatformInfo getPlatformInfo() {
+ return new ForgePlatformInfo(PlatformInfo.Type.SERVER);
+ }
+
+ @Override
+ public String getCommandName() {
+ return "spark";
+ }
+}
diff --git a/spark-forge1122/src/main/java/me/lucko/spark/forge/plugin/ForgeSparkPlugin.java b/spark-forge1122/src/main/java/me/lucko/spark/forge/plugin/ForgeSparkPlugin.java
new file mode 100644
index 0000000..0b641c6
--- /dev/null
+++ b/spark-forge1122/src/main/java/me/lucko/spark/forge/plugin/ForgeSparkPlugin.java
@@ -0,0 +1,133 @@
+/*
+ * This file is part of spark.
+ *
+ * Copyright (c) lucko (Luck) <luck@lucko.me>
+ * Copyright (c) contributors
+ *
+ * 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 <http://www.gnu.org/licenses/>.
+ */
+
+package me.lucko.spark.forge.plugin;
+
+import me.lucko.spark.common.SparkPlatform;
+import me.lucko.spark.common.SparkPlugin;
+import me.lucko.spark.common.sampler.ThreadDumper;
+import me.lucko.spark.forge.ForgeCommandSender;
+import me.lucko.spark.forge.ForgeSparkMod;
+
+import net.minecraft.command.ICommand;
+import net.minecraft.command.ICommandSender;
+import net.minecraft.server.MinecraftServer;
+import net.minecraft.util.math.BlockPos;
+
+import java.nio.file.Path;
+import java.util.Collections;
+import java.util.List;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+
+import javax.annotation.Nullable;
+
+public abstract class ForgeSparkPlugin implements SparkPlugin, ICommand {
+
+ private final ForgeSparkMod mod;
+ protected final ScheduledExecutorService scheduler;
+ protected final SparkPlatform platform;
+
+ protected ForgeSparkPlugin(ForgeSparkMod mod) {
+ this.mod = mod;
+ this.scheduler = Executors.newSingleThreadScheduledExecutor(r -> {
+ Thread thread = Executors.defaultThreadFactory().newThread(r);
+ thread.setName("spark-forge-async-worker");
+ thread.setDaemon(true);
+ return thread;
+ });
+ this.platform = new SparkPlatform(this);
+ this.platform.enable();
+ }
+
+ public void enable() {
+ this.platform.enable();
+ }
+
+ public void disable() {
+ this.platform.disable();
+ this.scheduler.shutdown();
+ }
+
+ public abstract boolean hasPermission(ICommandSender sender, String permission);
+
+ @Override
+ public String getVersion() {
+ return this.mod.getVersion();
+ }
+
+ @Override
+ public Path getPluginDirectory() {
+ return this.mod.getConfigDirectory();
+ }
+
+ @Override
+ public void executeAsync(Runnable task) {
+ this.scheduler.execute(task);
+ }
+
+ @Override
+ public ThreadDumper getDefaultThreadDumper() {
+ return new ThreadDumper.Specific(new long[]{Thread.currentThread().getId()});
+ }
+
+ // implement ICommand
+
+ @Override
+ public String getName() {
+ return getCommandName();
+ }
+
+ @Override
+ public String getUsage(ICommandSender iCommandSender) {
+ return "/" + getCommandName();
+ }
+
+ @Override
+ public List<String> getAliases() {
+ return Collections.singletonList(getCommandName());
+ }
+
+ @Override
+ public void execute(MinecraftServer server, ICommandSender sender, String[] args) {
+ this.platform.executeCommand(new ForgeCommandSender(sender, this), args);
+ }
+
+ @Override
+ public List<String> getTabCompletions(MinecraftServer server, ICommandSender sender, String[] args, @Nullable BlockPos blockPos) {
+ return this.platform.tabCompleteCommand(new ForgeCommandSender(sender, this), args);
+ }
+
+ @Override
+ public boolean checkPermission(MinecraftServer minecraftServer, ICommandSender sender) {
+ return hasPermission(sender, "spark");
+ }
+
+ @Override
+ public boolean isUsernameIndex(String[] strings, int i) {
+ return false;
+ }
+
+ @Override
+ public int compareTo(ICommand o) {
+ return getCommandName().compareTo(o.getName());
+ }
+
+}