wip

examples/Counter/src/Events/DecrementCount.php

@@ -0,0 +1,24 @@
+<?php
+
+namespace Thunk\Verbs\Examples\Counter\Events;
+
+use Thunk\Verbs\Event;
+use Thunk\Verbs\Examples\Counter\Events\ResetCount;
+use Thunk\Verbs\Examples\Counter\States\CountState;
+use Thunk\Verbs\Attributes\Autodiscovery\AppliesToSingletonState;
+
+#[AppliesToSingletonState(CountState::class)]
+class DecrementCount extends Event
+{
+    public function apply(CountState $state)
+    {
+        $state->count--;
+    }
+
+    public function handle()
+    {
+        if ($this->state(CountState::class)->count < 0) {
+            ResetCount::fire();
+        }
+    }
+}

examples/Counter/src/Events/ResetCount.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace Thunk\Verbs\Examples\Counter\Events;
+
+use Thunk\Verbs\Event;
+use Thunk\Verbs\Examples\Counter\States\CountState;
+use Thunk\Verbs\Attributes\Autodiscovery\AppliesToSingletonState;
+
+#[AppliesToSingletonState(CountState::class)]
+class ResetCount extends Event
+{
+    public function apply(CountState $state)
+    {
+        $state->count = 0;
+    }
+}

examples/Counter/tests/FireOnReplayTest.php

@@ -0,0 +1,19 @@
+<?php
+
+use Thunk\Verbs\Facades\Verbs;
+use Thunk\Verbs\Examples\Counter\Events\DecrementCount;
+
+it('does not fire nested events while replaying', function () {
+    $state = DecrementCount::fire()->state();
+
+    Verbs::commit();
+
+    // The DecrementCount handle() fires
+    // ResetCount since count < 0
+    expect($state->count)->toBe(0);
+
+    Verbs::replay();
+
+    // This time only DecrementCount fires
+    expect($state->fresh()->count)->toBe(-1);
+});

src/Lifecycle/Broker.php

@@ -18,7 +18,7 @@ public function __construct(
     ) {
     }
 
-    public function fire(Event $event): ?Event
+    public function fire(Event $event): Event|null
     {
         if ($this->is_replaying) {
             return null;

src/Support/PendingEvent.php

@@ -96,7 +96,7 @@ public function hydrate(array $data): static
         return $this;
     }
 
-    public function fire(...$args): Event
+    public function fire(...$args): Event|null
     {
         if (! empty($args) || is_string($this->event)) {
             $this->hydrate(static::normalizeArgs($args));