Merge pull request #4 from Pharaonic/executor-pool

Feat: enable create multiple pools of executors

src/Classes/ExecutorPoolClass.php

@@ -0,0 +1,40 @@
+<?php
+
+namespace Pharaonic\Laravel\Executor\Classes;
+
+class ExecutorPoolClass
+{
+    /**
+     * These paths for all pools of executors.
+     */
+    private array $paths = [];
+
+    public function __construct()
+    {
+        $this->paths = [
+            base_path('executors'),
+        ];
+    }
+
+    /**
+     * Return all pools of executors.
+     * 
+     * @return array
+     */
+    public function getPaths(): array
+    {
+        return $this->paths;
+    }
+
+    /**
+     * Add a new path to executors pools.
+     * 
+     * @param string $path
+     * 
+     * @return void
+     */
+    public function addPath(string $path): void
+    {
+        array_push($this->paths, $path);
+    }
+}

src/ExecutorServiceProvider.php

@@ -3,6 +3,7 @@
 namespace Pharaonic\Laravel\Executor;
 
 use Illuminate\Support\ServiceProvider;
+use Pharaonic\Laravel\Executor\Classes\ExecutorPoolClass;
 use Pharaonic\Laravel\Executor\Console\ExecuteCommand;
 use Pharaonic\Laravel\Executor\Console\ExecuteFreshCommand;
 use Pharaonic\Laravel\Executor\Console\ExecuteMakeCommand;
@@ -11,6 +12,16 @@
 
 class ExecutorServiceProvider extends ServiceProvider
 {
+    /**
+     * Register services.
+     *
+     * @return void
+     */
+    public function register()
+    {
+        $this->app->singleton('pharaonic.executor.executorPool', ExecutorPoolClass::class);
+    }
+
     /**
      * Bootstrap services.
      *

src/Facades/ExecutorPool.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace Pharaonic\Laravel\Executor\Facades;
+
+use Illuminate\Support\Facades\Facade;
+
+class ExecutorPool extends Facade
+{
+    protected static function getFacadeAccessor()
+    {
+        return 'pharaonic.executor.executorPool';
+    }
+}

src/Services/ExecutorService.php

@@ -3,6 +3,7 @@
 namespace Pharaonic\Laravel\Executor\Services;
 
 use Illuminate\Support\Facades\File;
+use Pharaonic\Laravel\Executor\Facades\ExecutorPool;
 use Pharaonic\Laravel\Executor\Models\Executor;
 use ReflectionClass;
 
@@ -61,7 +62,7 @@ protected function prepareExecutors()
                 }
             }
             return $executor;
-        }, File::glob($this->dir . '/*')))->keyBy('name');
+        }, $this->collectAllPaths()))->keyBy('name');
     }
 
 
@@ -102,4 +103,15 @@ protected function getNextBatch()
     {
         return (Executor::orderBy('batch', 'desc')->first()?->batch ?? 0) + 1;
     }
+
+    private function collectAllPaths()
+    {
+        $collectPath = collect([]);
+
+        foreach (ExecutorPool::getPaths() as $path) {
+            $collectPath = $collectPath->merge(File::glob($path . '/*'));
+        }
+
+        return $collectPath->all();
+    }
 }