Update API with reachable override

Author: EliXorZz

api/src/main/java/fr/epsilon/api/EpsilonAPI.java

@@ -65,6 +65,13 @@ public static EpsilonAPI get() {
      */
     public abstract EQueueModule queueModule();
 
+    /**
+     * Get if server is reachable
+     *
+     * @return boolean
+     */
+    public abstract boolean isReachable();
+
     public EpsilonAPI() {
         singleton = this;
     }

common/src/main/java/fr/epsilon/common/Epsilon.java

@@ -124,4 +124,9 @@ public InstanceModule instanceModule() {
     public QueueModule queueModule() {
         return queueModule;
     }
+
+    @Override
+    public boolean isReachable() {
+        return true;
+    }
 }

proxy/src/main/java/fr/epsilon/exporter/EpsilonExporter.java

@@ -5,11 +5,6 @@
 import fr.epsilon.exporter.listener.EpsilonRegister;
 import net.md_5.bungee.api.plugin.Plugin;
 
-import java.io.IOException;
-import java.nio.file.Files;
-import java.nio.file.Path;
-import java.nio.file.Paths;
-
 public class EpsilonExporter extends Plugin {
     private Epsilon epsilon;
     private EpsilonRegister register;
@@ -32,12 +27,7 @@ public void onEnable() {
 
         EpsilonEventStream.init(this);
 
-        try {
-            Path path = Paths.get("epsilon_start");
-            Files.createFile(path);
-        } catch (IOException e) {
-            e.printStackTrace();
-        }
+        EpsilonReachTask.init(this);
     }
 
     public Epsilon getEpsilon() {

proxy/src/main/java/fr/epsilon/exporter/EpsilonReachTask.java

@@ -0,0 +1,34 @@
+package fr.epsilon.exporter;
+
+import fr.epsilon.common.Epsilon;
+import net.md_5.bungee.api.scheduler.ScheduledTask;
+
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+import java.util.concurrent.TimeUnit;
+
+public class EpsilonReachTask {
+    private static ScheduledTask task;
+
+    public static void init(EpsilonExporter main)
+    {
+        task = main.getProxy().getScheduler().schedule(main, () ->
+        {
+            boolean reachable = Epsilon.get().isReachable();
+
+            if (!reachable)
+                return;
+
+            try {
+                Path path = Paths.get("epsilon_start");
+                Files.createFile(path);
+
+                task.cancel();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }, 0, 100, TimeUnit.MILLISECONDS);
+    }
+}

server/src/main/java/fr/epsilon/exporter/EpsilonExporter.java

@@ -4,12 +4,8 @@
 import fr.epsilon.common.template.Template;
 import org.bukkit.plugin.java.JavaPlugin;
 
-import java.io.IOException;
 import java.lang.reflect.Field;
 import java.lang.reflect.Method;
-import java.nio.file.Files;
-import java.nio.file.Path;
-import java.nio.file.Paths;
 
 public class EpsilonExporter extends JavaPlugin {
     @Override
@@ -37,12 +33,7 @@ public void onEnable() {
             mapIgniter.load();
             getServer().getLogger().info("Load maps ...");
 
-            try {
-                Path path = Paths.get("epsilon_start");
-                Files.createFile(path);
-            } catch (IOException e) {
-                e.printStackTrace();
-            }
+            EpsilonReachTask.init(this);
         });
     }
 

server/src/main/java/fr/epsilon/exporter/EpsilonReachTask.java

@@ -0,0 +1,33 @@
+package fr.epsilon.exporter;
+
+import fr.epsilon.common.Epsilon;
+import org.bukkit.scheduler.BukkitTask;
+
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+
+public class EpsilonReachTask {
+    private static BukkitTask task;
+
+    public static void init(EpsilonExporter main)
+    {
+        task = main.getServer().getScheduler().runTaskTimer(main, () ->
+        {
+            boolean reachable = Epsilon.get().isReachable();
+
+            if (!reachable)
+                return;
+
+            try {
+                Path path = Paths.get("epsilon_start");
+                Files.createFile(path);
+
+                task.cancel();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }, 0, 10);
+    }
+}