Add event subscriber for Guard Event

Author: kpscyber

src/LaravelWorkflowProcessServiceProvider.php

@@ -2,7 +2,9 @@
 
 namespace Soap\LaravelWorkflowProcess;
 
+use Illuminate\Support\Facades\Event;
 use Soap\LaravelWorkflowProcess\Commands\LaravelWorkflowProcessCommand;
+use Soap\LaravelWorkflowProcess\Listeners\WorkflowGuardSubscriber;
 use Spatie\LaravelPackageTools\Package;
 use Spatie\LaravelPackageTools\PackageServiceProvider;
 
@@ -19,7 +21,11 @@ public function configurePackage(Package $package): void
             ->name('laravel-workflow-process')
             ->hasConfigFile()
             ->hasViews()
-            ->hasMigration('create_laravel_workflow_process_table')
             ->hasCommand(LaravelWorkflowProcessCommand::class);
     }
+
+    public function packageBooted()
+    {
+        Event::subscribe(WorkflowGuardSubscriber::class);
+    }
 }

src/Listeners/WorkflowGuardSubscriber.php

@@ -0,0 +1,42 @@
+<?php
+
+namespace Soap\LaravelWorkflowProcess\Listeners;
+
+use Symfony\Component\ExpressionLanguage\ExpressionLanguage;
+use ZeroDaHero\LaravelWorkflow\Events\GuardEvent;
+
+class WorkflowGuardSubscriber
+{
+    /**
+     * Handle the event.
+     */
+    public function handleOnGuard(GuardEvent $event): void
+    {
+        // This is a call by using event proxy to Symfony GuardEvent
+        $subject = $event->getSubject();
+        $transition = $event->getTransition();
+        $workflow = $event->getWorkflow();
+        $metaData = $workflow->getMetadataStore()->getTransitionMetadata($transition);
+        if (isset($metaData['guard'])) {
+            $guard = $metaData['guard'];
+            $expressionLanguage = new ExpressionLanguage;
+            $result = $expressionLanguage->evaluate($guard, [
+                'authenticated' => auth()->check(),
+                'subject' => $subject,
+                'user' => auth()->user(),
+            ]);
+            if (! $result) {
+                $event->setBlocked(true, 'Guard blocked');
+            }
+        }
+
+    }
+
+    public function subscribe($events): void
+    {
+        $events->listen(
+            'workflow.guard',
+            [WorkflowGuardSubscriber::class, 'handleOnGuard']
+        );
+    }
+}

workbench/app/Models/Post.php

@@ -0,0 +1,11 @@
+<?php
+
+namespace Workbench\App\Models;
+
+use Illuminate\Database\Eloquent\Factories\HasFactory;
+use Illuminate\Database\Eloquent\Model;
+
+class Post extends Model
+{
+    use HasFactory;
+}

workbench/app/Models/User.php

@@ -6,11 +6,10 @@
 use Illuminate\Database\Eloquent\Factories\HasFactory;
 use Illuminate\Foundation\Auth\User as Authenticatable;
 use Illuminate\Notifications\Notifiable;
-use Laravel\Sanctum\HasApiTokens;
 
 class User extends Authenticatable
 {
-    use HasApiTokens, HasFactory, Notifiable;
+    use HasFactory, Notifiable;
 
     /**
      * The attributes that are mass assignable.

workbench/config/workflow.php

@@ -0,0 +1,33 @@
+<?php
+
+namespace Workbench\Database\Factories;
+
+use Illuminate\Database\Eloquent\Factories\Factory;
+use Workbench\App\Models\Post;
+
+/**
+ * @template TModel of \Workbench\App\Models\Post
+ *
+ * @extends \Illuminate\Database\Eloquent\Factories\Factory<TModel>
+ */
+class PostFactory extends Factory
+{
+    /**
+     * The name of the factory's corresponding model.
+     *
+     * @var class-string<TModel>
+     */
+    protected $model = Post::class;
+
+    /**
+     * Define the model's default state.
+     *
+     * @return array<string, mixed>
+     */
+    public function definition(): array
+    {
+        return [
+            //
+        ];
+    }
+}

workbench/config/workflow_registry.php

@@ -0,0 +1,31 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    /**
+     * Run the migrations.
+     */
+    public function up(): void
+    {
+        Schema::create('posts', function (Blueprint $table) {
+            $table->id();
+            $table->string('title');
+            $table->text('content');
+            $table->string('state')->default('draft');
+            $table->unsignedBigInteger('user_id');
+            $table->timestamps();
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     */
+    public function down(): void
+    {
+        Schema::dropIfExists('posts');
+    }
+};