Update table name provided by database loader class

Author: kpscyber

config/workflow_loader.php

@@ -10,6 +10,6 @@
                 'workflow_state_transitions' => 'workflow_state_transitions',
             ],
             'class' => \Soap\WorkflowLoader\DatabaseLoader::class,
-        ]
+        ],
     ],
-];
+];

database/migrations/wf1_create_workflows_table.php

@@ -8,20 +8,23 @@
 {
     public function up()
     {
-        Schema::create('workflows', function (Blueprint $table) {
+        $tableName = app(\Soap\WorkflowLoader\DatabaseLoader::class)->getWorkflowTableName();
+        Schema::create($tableName, function (Blueprint $table) {
             $table->id();
             $table->string('name');
             $table->text('marking_store')->nullable()->comment('marking store as array');
             $table->string('type')->default('workflow')->comment('workflow or state_machine');
             $table->text('description')->nullable();
             $table->json('supports')->nullable()->comment('support models');
             $table->json('metadata')->nullable()->comment('metadata');
+            $table->boolean('active')->default(true);
             $table->timestamps();
         });
     }
 
     public function down()
     {
-        Schema::dropIfExists('workflows');
+        $tableName = app(\Soap\WorkflowLoader\DatabaseLoader::class)->getWorkflowTableName();
+        Schema::dropIfExists($tableName);
     }
 };

database/migrations/wf2_create_workflow_states_table.php

@@ -8,7 +8,8 @@
 {
     public function up()
     {
-        Schema::create('workflow_states', function (Blueprint $table) {
+        $tableName = app(\Soap\WorkflowLoader\DatabaseLoader::class)->getWorkflowStateTableName();
+        Schema::create($tableName, function (Blueprint $table) {
             $table->id();
             $table->string('name');
             $table->tinyInteger('initial_state')->default(0)->comment('initial state');
@@ -21,6 +22,7 @@ public function up()
 
     public function down()
     {
-        Schema::dropIfExists('workflow_states');
+        $tableName = app(\Soap\WorkflowLoader\DatabaseLoader::class)->getWorkflowStateTableName();
+        Schema::dropIfExists($tableName);
     }
 };

database/migrations/wf3_create_workflow_transitions_table.php

@@ -8,7 +8,8 @@
 {
     public function up()
     {
-        Schema::create('workflow_transitions', function (Blueprint $table) {
+        $tableName = app(\Soap\WorkflowLoader\DatabaseLoader::class)->getWorkflowTransitionTableName();
+        Schema::create($tableName, function (Blueprint $table) {
             $table->id();
             $table->string('name');
             $table->foreignId('to_state_id')->constrained('workflow_states')->onDelete('cascade');
@@ -20,6 +21,7 @@ public function up()
 
     public function down()
     {
-        Schema::dropIfExists('workflow_transitions');
+        $tableName = app(\Soap\WorkflowLoader\DatabaseLoader::class)->getWorkflowTransitionTableName();
+        Schema::dropIfExists($tableName);
     }
 };

database/migrations/wf4_create_workflow_state_transitions_table.php

@@ -8,7 +8,8 @@
 {
     public function up()
     {
-        Schema::create('workflow_state_transitions', function (Blueprint $table) {
+        $tableName = app(\Soap\WorkflowLoader\DatabaseLoader::class)->getWorkflowStateTransitionTableName();
+        Schema::create($tableName, function (Blueprint $table) {
             $table->id();
             $table->foreignId('workflow_transition_id')->constrained('workflow_transitions')->onDelete('cascade');
             $table->foreignId('from_state_id')->constrained('workflow_states')->onDelete('cascade');
@@ -19,6 +20,7 @@ public function up()
 
     public function down()
     {
-        Schema::dropIfExists('workflow_state_transitions');
+        $tableName = app(\Soap\WorkflowLoader\DatabaseLoader::class)->getWorkflowStateTransitionTableName();
+        Schema::dropIfExists($tableName);
     }
 };

resources/stubs/WorkflowServiceProvider.php.stub

@@ -3,21 +3,17 @@
 namespace App\Providers;
 
 use Illuminate\Support\ServiceProvider;
-use Soap\WorkflowLoader\DatabaseLoader;
 
 class WorkflowServiceProvider extends ServiceProvider
 {
-    public function register()
-    {
-
-    }
+    public function register() {}
 
     public function boot()
     {
-        $registy = app()->make('workflow');
-        $workflowLoader = app()->make('workflow-loader');
-        foreach ($wokflowLoader->all() as $workflow => $config) {
-            $registy->addFromArray($workflow, $config);
+        $registry = app()->make('workflow');
+        $workflowLoaderRegistry = app()->make('workflowLoaderRegistry');   
+        foreach ($workflowLoaderRegistry->all() as $workflow => $config) {
+            $registry->addFromArray($workflow, $config);
         }
     }
 }

src/DatabaseLoader.php

@@ -14,12 +14,15 @@ class DatabaseLoader implements WorkflowDatabaseLoader
      */
     protected $config;
 
-    public function __construct(?array $config)
+    protected $repo;
+
+    public function __construct(?array $config, WorkflowRepository $repo)
     {
         if (! isset($config[self::KEY_TABLE_NAMES])) {
             throw new \InvalidArgumentException('Table names not found in config');
         }
         $this->config = $config;
+        $this->repo = $repo;
     }
 
     public function getTableNames(): array
@@ -54,15 +57,15 @@ public function getWorkflowStateTransitionTableName(): string
 
     public function load(string $workflowName): array
     {
-        $repo = app()->make(WorkflowRepository::class);
+        //$repo = app()->make(WorkflowRepository::class);
 
-        return $repo->findByName($workflowName);
+        return $this->repo->findByName($workflowName);
     }
 
     public function all(): array
     {
-        $repo = app()->make(WorkflowRepository::class);
+        //$repo = app()->make(WorkflowRepository::class);
 
-        return $repo->all();
+        return $this->repo->all();
     }
 }

src/Facades/WorkflowLoaderRegistry.php

@@ -7,10 +7,10 @@
 /**
  * @see \Soap\WorkflowLoader\WorkflowLoader
  */
-class WorkflowLoader extends Facade
+class WorkflowLoaderRegistry extends Facade
 {
     protected static function getFacadeAccessor(): string
     {
-        return \Soap\WorkflowLoader\WorkflowLoaderRegistry::class;
+        return 'workflowLoaderRegistry';
     }
 }

src/Repositories/WorkflowRepository.php

@@ -50,20 +50,19 @@ protected function makeWorkflowCofig($workflow): array
             return $state->name;
         })->toArray();
 
-        $transitions = $workflow->transitions->map(function ($transition) {
-            return [
-                $transition->name => [
-                    'from' => $transition->fromStates->map(function ($transitionState) {
-                        return $transitionState->fromState->name;
-                    })->toArray(),
-                    'to' => $transition->toState->name,
-                ],
+        $transitions = [];
+        foreach ($workflow->transitions as $transition) {
+            $transitions[$transition->name] = [
+                'from' => $transition->fromStates->map(function ($transitionState) {
+                    return $transitionState->fromState->name;
+                })->toArray(),
+                'to' => $transition->toState->name,
             ];
-        })->toArray();
+        }
 
         return [
             $workflow->name => [
-                'marking_store' => $workflow->marking_store,
+                'marking_store' => $workflow->marking_store ?? [],
                 'type' => $workflow->type ? $workflow->type->value : 'workflow',
                 'metadata' => $workflow->metadata,
                 'supports' => $workflow->supports,

src/WorkflowLoaderRegistry.php

@@ -11,20 +11,20 @@ class WorkflowLoaderRegistry
     public function __construct(array $loaders)
     {
         foreach ($loaders as $key => $loader) {
-            if (!isset($loader['class'])) {
+            if (! isset($loader['class'])) {
                 throw new \Exception("Key 'class' configuration not found in {$key} loader");
             }
 
-            if (!class_exists($loader['class'])) {
+            if (! class_exists($loader['class'])) {
                 throw new \Exception("Class {$loader['class']} not found");
             }
-            $this->registerLoader($key, $loader->class);
+            $this->registerLoader($key, app()->make($loader['class']));
         }
     }
 
     public function registerLoader(string $name, WorkflowLoaderContract $loader)
     {
-        $this->loaders[$name] = app()->make($loader);
+        $this->loaders[$name] = $loader;
     }
 
     public function getLoaders(): array
@@ -34,10 +34,10 @@ public function getLoaders(): array
 
     public function getLoader(string $name): WorkflowLoaderContract
     {
-        if (!isset($this->loaders[$name])) {
+        if (! isset($this->loaders[$name])) {
             throw new \Exception("Loader {$name} not found");
         }
-        
+
         return $this->loaders[$name];
     }
 
@@ -47,11 +47,13 @@ public function all(): array
             return [];
         }
 
-        $workflows = collect([]);
+        $workflows = [];
         foreach ($this->loaders as $name => $loader) {
-            $workflows = $workflows->merge(collect($loader->all()));
+            foreach ($loader->all() as $workflow => $config) {
+                $workflows[$workflow] = $config;
+            }
         }
 
-        return $workflows->toArray();
+        return $workflows;
     }
 }