vendor/bornfreee/tactician-domain-events/src/Middleware/ReleaseRecordedEventsMiddleware.php line 46

Open in your IDE?
  1. <?php
  3. namespace BornFree\TacticianDomainEvent\Middleware;
  5. use BornFree\TacticianDomainEvent\EventDispatcher\EventDispatcherInterface;
  6. use BornFree\TacticianDomainEvent\Recorder\ContainsRecordedEvents;
  7. use League\Tactician\Middleware;
  9. class ReleaseRecordedEventsMiddleware implements Middleware
  10. {
  11. /**
  12. * @var ContainsRecordedEvents
  13. */
  14. private $eventRecorder;
  16. /**
  17. * @var EventDispatcherInterface
  18. */
  19. private $eventDispatcher;
  21. /**
  22. * ReleaseRecorderEventsMiddleware constructor.
  23. *
  24. * @param ContainsRecordedEvents $eventRecorder
  25. * @param EventDispatcherInterface $eventDispatcher
  26. */
  27. public function __construct(ContainsRecordedEvents $eventRecorder, EventDispatcherInterface $eventDispatcher)
  28. {
  29. $this->eventRecorder = $eventRecorder;
  30. $this->eventDispatcher = $eventDispatcher;
  31. }
  33. /**
  34. * Dispatches all the recorded events in the EventBus and erases them
  35. *
  36. * @param object $command
  37. * @param callable $next
  38. *
  39. * @return mixed
  40. *
  41. * @throws \Exception
  42. */
  43. public function execute($command, callable $next)
  44. {
  45. try {
  46. $result = $next($command);
  47. } catch (\Exception $exception) {
  48. $this->eventRecorder->eraseEvents();
  50. throw $exception;
  51. }
  53. $recordedEvents = $this->eventRecorder->releaseEvents();
  55. foreach ($recordedEvents as $event) {
  56. $this->eventDispatcher->dispatch($event);
  57. }
  59. return $result;
  60. }
  61. }