Add license header

Author: Paldiu

build.gradle

@@ -25,7 +25,7 @@ dependencies {
 }
 
 shadowJar {
-    relocate('reactor', "io.github.simplex.reactor")
+    relocate('reactor', "io.github.simplexdevelopment.reactor")
     exclude('io.github.simplexdevelopment.impl')
 }
 

src/main/java/io/github/simplexdevelopment/api/Context.java

@@ -1,3 +1,27 @@
+/*
+ * MIT License
+ *
+ * Copyright (c) 2022 SimplexDevelopment
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy
+ * of this software and associated documentation files (the "Software"), to deal
+ * in the Software without restriction, including without limitation the rights
+ * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+ * copies of the Software, and to permit persons to whom the Software is
+ * furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+ * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+ * SOFTWARE.
+ */
+
 package io.github.simplexdevelopment.api;
 
 import org.jetbrains.annotations.NotNull;
@@ -8,6 +32,12 @@
 import java.util.Collection;
 import java.util.Objects;
 
+/**
+ * A glorified wrapper class which collects an element and abstracts it behind the Reactor API.
+ *
+ * @param <S> Any object type to wrap with this class.
+ * @author SimplexDevelopment
+ */
 public interface Context<S> {
     /**
      * @return A Mono object which contains a single element represented by the definer of this Context class.

src/main/java/io/github/simplexdevelopment/api/ISchedule.java

@@ -1,10 +1,40 @@
+/*
+ * MIT License
+ *
+ * Copyright (c) 2022 SimplexDevelopment
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy
+ * of this software and associated documentation files (the "Software"), to deal
+ * in the Software without restriction, including without limitation the rights
+ * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+ * copies of the Software, and to permit persons to whom the Software is
+ * furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+ * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+ * SOFTWARE.
+ */
+
 package io.github.simplexdevelopment.api;
 
+import io.github.simplexdevelopment.scheduler.SchedulingSystem;
 import io.github.simplexdevelopment.scheduler.ServiceManager;
 import org.jetbrains.annotations.NotNull;
 import reactor.core.Disposable;
 import reactor.core.publisher.Mono;
 
+/**
+ * This interface contains surface level methods for the {@link SchedulingSystem} to use.
+ *
+ * @author SimplexDevelopment
+ */
 public interface ISchedule {
 
     /**

src/main/java/io/github/simplexdevelopment/api/IService.java

@@ -1,9 +1,41 @@
+/*
+ * MIT License
+ *
+ * Copyright (c) 2022 SimplexDevelopment
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy
+ * of this software and associated documentation files (the "Software"), to deal
+ * in the Software without restriction, including without limitation the rights
+ * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+ * copies of the Software, and to permit persons to whom the Software is
+ * furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+ * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+ * SOFTWARE.
+ */
+
 package io.github.simplexdevelopment.api;
 
 import io.github.simplexdevelopment.scheduler.ServicePool;
 import org.bukkit.plugin.java.JavaPlugin;
 import reactor.core.publisher.Mono;
 
+/**
+ * Represents a service that can be registered to a {@link ServicePool}.
+ * <p>
+ * This interface provides surface level methods to be used by the {@link ServicePool}
+ * associated to each service.
+ *
+ * @author SimplexDevelopment
+ */
 public interface IService extends Runnable, Identifier {
 
     /**

src/main/java/io/github/simplexdevelopment/api/Identifier.java

@@ -1,7 +1,36 @@
+/*
+ * MIT License
+ *
+ * Copyright (c) 2022 SimplexDevelopment
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy
+ * of this software and associated documentation files (the "Software"), to deal
+ * in the Software without restriction, including without limitation the rights
+ * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+ * copies of the Software, and to permit persons to whom the Software is
+ * furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+ * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+ * SOFTWARE.
+ */
+
 package io.github.simplexdevelopment.api;
 
 import java.util.UUID;
 
+/**
+ * This interface provides a method for retrieving a name, unique identifier, and numerical id for a class.
+ *
+ * @author SimplexDevelopment
+ */
 public interface Identifier {
     /**
      * @return The name of the identifiable object in a readable format.

src/main/java/io/github/simplexdevelopment/api/ServiceException.java

@@ -1,7 +1,38 @@
+/*
+ * MIT License
+ *
+ * Copyright (c) 2022 SimplexDevelopment
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy
+ * of this software and associated documentation files (the "Software"), to deal
+ * in the Software without restriction, including without limitation the rights
+ * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+ * copies of the Software, and to permit persons to whom the Software is
+ * furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+ * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+ * SOFTWARE.
+ */
+
 package io.github.simplexdevelopment.api;
 
 import java.util.function.Supplier;
 
+/**
+ * This class is used to represent a service exception.
+ * When a {@link IService} is called that has not been registered with a {@link io.github.simplexdevelopment.scheduler.ServicePool},
+ * this exception will be thrown.
+ *
+ * @author SimplexDevelopment
+ */
 public class ServiceException extends RuntimeException {
     /**
      * Constructs a new service exception which states the service is not present within any service pools.

src/main/java/io/github/simplexdevelopment/api/ServicePoolException.java

@@ -1,10 +1,43 @@
+/*
+ * MIT License
+ *
+ * Copyright (c) 2022 SimplexDevelopment
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy
+ * of this software and associated documentation files (the "Software"), to deal
+ * in the Software without restriction, including without limitation the rights
+ * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+ * copies of the Software, and to permit persons to whom the Software is
+ * furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+ * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+ * SOFTWARE.
+ */
+
 package io.github.simplexdevelopment.api;
 
+import io.github.simplexdevelopment.scheduler.ServicePool;
 import org.jetbrains.annotations.Contract;
 import org.jetbrains.annotations.NotNull;
 
 import java.util.function.Supplier;
 
+/**
+ * This class is used to represent a service pool exception.
+ * This exception is thrown when a {@link ServicePool} is not found,
+ * when {@link ServicePool#queueService(IService)} is called but the service is not registered with this pool,
+ * or if the service pool is empty and {@link ServicePool#queueServices()} is called.
+ *
+ * @author SimplexDevelopment
+ */
 public class ServicePoolException extends RuntimeException {
     /**
      * Constructs a new generic service pool exception.

src/main/java/io/github/simplexdevelopment/impl/Main.java

@@ -1,8 +1,32 @@
+/*
+ * MIT License
+ *
+ * Copyright (c) 2022 SimplexDevelopment
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy
+ * of this software and associated documentation files (the "Software"), to deal
+ * in the Software without restriction, including without limitation the rights
+ * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+ * copies of the Software, and to permit persons to whom the Software is
+ * furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+ * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+ * SOFTWARE.
+ */
+
 package io.github.simplexdevelopment.impl;
 
 import io.github.simplexdevelopment.scheduler.SchedulingSystem;
+import io.github.simplexdevelopment.scheduler.ServicePool;
 import org.bukkit.plugin.java.JavaPlugin;
-import org.jetbrains.annotations.NotNull;
 import reactor.core.Disposable;
 import reactor.core.publisher.Flux;
 
@@ -19,8 +43,15 @@ public void onEnable() {
         // Plugin startup logic
         // Create a new instance of the scheduling system.
         this.scheduler = new SchedulingSystem<>(this);
+
+        // Creates new service pools.
+        getScheduler().getServiceManager().subscribe(a -> {
+            a.emptyBukkitServicePool("main_pool", this).subscribe();
+            a.emptyServicePool("off_loader", true).subscribe();
+        });
+
         // This will register all the services and set our Flux<Disposable> object above.
-        registerServices(new PoolHolder(this));
+        registerServices("main_pool");
     }
 
     @Override
@@ -34,22 +65,32 @@ public void onDisable() {
         });
     }
 
-    public void registerServices(@NotNull PoolHolder poolHolder) {
+    public void registerServices(String poolName) {
         // This set will be used to set the Flux<Disposable> object
         // that will be used to stop the services when the plugin is disabled.
         Set<Disposable> dispos = new HashSet<>();
 
+        // Find the service pool we want to register our services to.
+        ServicePool pool = scheduler.getServiceManager().map(a -> a.getServicePools()
+                        .filter(b -> b.getName().equalsIgnoreCase(poolName))
+                        .blockFirst())
+                .block();
+
+        // Make sure the pool isn't null.
+        if (pool == null) pool = new ServicePool(poolName, this);
+
         // Register services here
-        ServiceImpl impl = new ServiceImpl(this, poolHolder.getContext().block());
+        ServiceImpl impl = new ServiceImpl(this, pool);
 
         // This will register the service to the service pool.
         dispos.add(scheduler.getMainScheduler().schedule(impl));
         // OR
         scheduler.queue(impl).subscribe(dispos::add);
         // OR
         scheduler.getServiceManager()
-                .flatMap(manager -> manager.createServicePool("newPool", impl))
-                .subscribe(p -> p.queueService(impl).subscribe(dispos::add));
+                .flatMap(manager -> manager.emptyBukkitServicePool("backup", this))
+                .doOnNext(pool_a -> pool_a.getAssociatedServices().add(impl))
+                .subscribe(pool_b -> pool_b.queueService(impl).subscribe(dispos::add));
 
         // This will set the Flux<Disposable> object on our previously made set, so that we can use it later on.
         disposables = Flux.fromIterable(dispos);