Update repository and database loader

Author: kpscyber

src/DatabaseLoader.php

@@ -3,6 +3,7 @@
 namespace Soap\WorkflowLoader;
 
 use Soap\WorkflowLoader\Contracts\WorkflowDatabaseLoader;
+use Soap\WorkflowLoader\Repositories\WorkflowRepository;
 
 class DatabaseLoader implements WorkflowDatabaseLoader
 {
@@ -53,13 +54,15 @@ public function getWorkflowStateTransitionTableName(): string
 
     public function load(string $workflowName): array
     {
-        $workflowConfig = [];
+        $repo = app()->make(WorkflowRepository::class);
 
-        return $workflowConfig;
+        return $repo->findByName($workflowName);
     }
 
     public function all(): array
     {
-        return [];
+        $repo = app()->make(WorkflowRepository::class);
+
+        return $repo->all();
     }
 }

src/Repositories/WorkflowRepository.php

@@ -13,12 +13,41 @@ public function __construct(Workflow $model)
         $this->model = $model;
     }
 
+    public function all()
+    {
+        $workflows = $this->model->with(['transitions', 'states'])->get();
+
+        return $workflows->map(function ($workflow) {
+            return $this->makeWorkflowCofig($workflow);
+        })->toArray();
+    }
+
     public function find($id)
     {
         $workflow = $this->model->with(['transitions', 'states'])->find($id);
+        if (! $workflow) {
+            return [];
+        }
+
+        return $this->makeWorkflowCofig($workflow);
+    }
+
+    public function findByName(string $name): array
+    {
+        $workflowId = $this->model->where('name', $name)->first()->id;
+        if (! $workflowId) {
+            return [];
+        }
+
+        return $this->find($workflowId);
+    }
+
+    protected function makeWorkflowCofig($workflow): array
+    {
         $places = $workflow->states->map(function ($state) {
             return $state->name;
         })->toArray();
+
         $transitions = $workflow->transitions->map(function ($transition) {
             return [
                 $transition->name => [
@@ -38,14 +67,4 @@ public function find($id)
             ],
         ];
     }
-
-    public function findByName(string $name): array
-    {
-        $workflowId = $this->model->where('name', $name)->first()->id;
-        if (! $workflowId) {
-            return [];
-        }
-
-        return $this->find($workflowId);
-    }
 }

tests/Feature/WorkflowStorageTest.php

@@ -5,7 +5,6 @@
 use Soap\WorkflowLoader\Repositories\WorkflowRepository;
 
 beforeEach(function () {
-
     $workflow = Workflow::create([
         'name' => 'test_workflow',
         'type' => 'workflow',

tests/Unit/DatabaseLoaderTest.php

@@ -0,0 +1 @@
+<?php

tests/Unit/DatabaseStorageTest.php

@@ -0,0 +1,87 @@
+<?php
+
+beforeEach(function () {
+    $workflow = Workflow::create([
+        'name' => 'test_workflow',
+        'type' => 'workflow',
+        'description' => 'Test Workflow Description',
+        'supports' => ['App\Models\Article'],
+        'metadata' => [],
+    ]);
+
+    $draftState = $workflow->states()->create([
+        'name' => 'draft',
+        'metadata' => [],
+    ]);
+
+    $onReviewState = $workflow->states()->create([
+        'name' => 'on review',
+        'metadata' => [],
+    ]);
+
+    $approvedState = $workflow->states()->create([
+        'name' => 'approved',
+        'metadata' => [],
+    ]);
+
+    $rejectedState = $workflow->states()->create([
+        'name' => 'rejected',
+        'metadata' => [],
+    ]);
+
+    $onReviewTransition = $workflow->transitions()->create([
+        'name' => 'submit',
+        'to_state_id' => $onReviewState->id,
+        'metadata' => [],
+    ]);
+
+    $onReviewTransition->fromStates()->create([
+        'from_state_id' => $draftState->id,
+    ]);
+
+    $orderWorkflow = Workflow::create([
+        'name' => 'order_process',
+        'type' => 'workflow',
+        'description' => 'Test Workflow Description',
+        'supports' => ['App\Models\Order'],
+        'metadata' => [],
+    ]);
+
+    $pendingState = $orderWorkflow->states()->create([
+        'name' => 'pending',
+        'metadata' => [],
+    ]);
+
+    $approvedState = $orderWorkflow->states()->create([
+        'name' => 'approved',
+        'metadata' => [],
+    ]);
+
+    $cancelledState = $orderWorkflow->states()->create([
+        'name' => 'cancelled',
+        'metadata' => [],
+    ]);
+
+    $packeddState = $orderWorkflow->states()->create([
+        'name' => 'packed',
+        'metadata' => [],
+    ]);
+
+    $shippedState = $orderWorkflow->states()->create([
+        'name' => 'shipped',
+        'metadata' => [],
+    ]);
+
+    $orderWorkflow->transitions()->create([
+        'name' => 'approve',
+        'to_state_id' => $approvedState->id,
+        'metadata' => [],
+    ]);
+
+    $orderWorkflow->transitions()->create([
+        'name' => 'cancel',
+        'to_state_id' => $cancelledState->id,
+        'metadata' => [],
+    ]);
+
+});