1	<?php
2
3	namespace App\Application\Handler;
4
5	use App\Enum\NotificationLogStatus;
6	use App\Enum\NotificationStatus;
7	use App\Exception\NotificationNotFoundException;
8	use App\Message\SendNotificationCommand;
9	use App\Service\Data\NotificationLogServiceInterface;
10	use App\Service\Data\NotificationServiceInterface;
11	use App\Service\Notification\Dispatcher\NotificationDispatcherInterface;
12	use Doctrine\ORM\EntityManagerInterface;
13
14	/**
15	* @author Wilhelm Zwertvaegher
16	*/
17	readonly class SendNotificationCommandHandler implements SendNotificationCommandHandlerInterface
18	{
19	public function __construct(
20	private NotificationServiceInterface $notificationService,
21	private NotificationDispatcherInterface $notificationDispatcher,
22	private NotificationLogServiceInterface $notificationLogService,
23	private EntityManagerInterface $entityManager,
24	) {
25	}
26
27	/**
28	* @throws NotificationNotFoundException
29	*/
30	public function __invoke(SendNotificationCommand $command): void
31	{
32	// get notification to be sent
33	$notification = $this->notificationService->getById($command->getNotificationId());
34	if (null === $notification) {
35	throw new NotificationNotFoundException();
36	}
37
38	if (NotificationStatus::PENDING !== $notification->getStatus()) {
39	return;
40	}
41
42	// pass to dispatcher
43	$results = $this->notificationDispatcher->dispatch($notification);
44	// assume the dispatch is fully successful at first
45	$isSuccess = true;
46
47	// save logs for the notification
48	foreach ($results as $result) {
49	// it at least one dispatch result is not successful, then overall success must be false
50	if (NotificationLogStatus::SENT !== $result->getStatus()) {
51	$isSuccess = false;
52	}
53
54	$this->notificationLogService->createFromNotification(
55	$notification,
56	$result
57	);
58	}
59
60	if ($isSuccess) {
61	$this->notificationService->updateStatus($notification, NotificationStatus::HANDLED);
62	}
63
64	$this->entityManager->flush();
65	// clearing the EM may help with memory consumption
66	$this->entityManager->clear();
67	}
68	}

---

Paths

Below are the source code lines that represent each code path as identified by Xdebug. Please note a path is not necessarily coterminous with a line, a line may contain multiple paths and therefore show up more than once. Please also be aware that some paths may include implicit rather than explicit branches, e.g. an if statement always has an else as part of its logical flow even if you didn't write one.

SendNotificationCommandHandler->__construct

19	public function __construct(
20	private NotificationServiceInterface $notificationService,
21	private NotificationDispatcherInterface $notificationDispatcher,
22	private NotificationLogServiceInterface $notificationLogService,
23	private EntityManagerInterface $entityManager,
24	) {
25	}

SendNotificationCommandHandler->__invoke

30	public function __invoke(SendNotificationCommand $command): void
31	{
32	// get notification to be sent
33	$notification = $this->notificationService->getById($command->getNotificationId());
34	if (null === $notification) {
35	throw new NotificationNotFoundException();

30	public function __invoke(SendNotificationCommand $command): void
31	{
32	// get notification to be sent
33	$notification = $this->notificationService->getById($command->getNotificationId());
34	if (null === $notification) {
38	if (NotificationStatus::PENDING !== $notification->getStatus()) {
39	return;

30	public function __invoke(SendNotificationCommand $command): void
31	{
32	// get notification to be sent
33	$notification = $this->notificationService->getById($command->getNotificationId());
34	if (null === $notification) {
38	if (NotificationStatus::PENDING !== $notification->getStatus()) {
43	$results = $this->notificationDispatcher->dispatch($notification);
44	// assume the dispatch is fully successful at first
45	$isSuccess = true;
46
47	// save logs for the notification
48	foreach ($results as $result) {
48	foreach ($results as $result) {
50	if (NotificationLogStatus::SENT !== $result->getStatus()) {
51	$isSuccess = false;
52	}
53
54	$this->notificationLogService->createFromNotification(
48	foreach ($results as $result) {
49	// it at least one dispatch result is not successful, then overall success must be false
50	if (NotificationLogStatus::SENT !== $result->getStatus()) {
51	$isSuccess = false;
52	}
53
54	$this->notificationLogService->createFromNotification(
48	foreach ($results as $result) {
48	foreach ($results as $result) {
49	// it at least one dispatch result is not successful, then overall success must be false
50	if (NotificationLogStatus::SENT !== $result->getStatus()) {
51	$isSuccess = false;
52	}
53
54	$this->notificationLogService->createFromNotification(
55	$notification,
56	$result
57	);
58	}
59
60	if ($isSuccess) {
61	$this->notificationService->updateStatus($notification, NotificationStatus::HANDLED);
62	}
63
64	$this->entityManager->flush();
64	$this->entityManager->flush();
65	// clearing the EM may help with memory consumption
66	$this->entityManager->clear();
67	}

30	public function __invoke(SendNotificationCommand $command): void
31	{
32	// get notification to be sent
33	$notification = $this->notificationService->getById($command->getNotificationId());
34	if (null === $notification) {
38	if (NotificationStatus::PENDING !== $notification->getStatus()) {
43	$results = $this->notificationDispatcher->dispatch($notification);
44	// assume the dispatch is fully successful at first
45	$isSuccess = true;
46
47	// save logs for the notification
48	foreach ($results as $result) {
48	foreach ($results as $result) {
50	if (NotificationLogStatus::SENT !== $result->getStatus()) {
51	$isSuccess = false;
52	}
53
54	$this->notificationLogService->createFromNotification(
48	foreach ($results as $result) {
49	// it at least one dispatch result is not successful, then overall success must be false
50	if (NotificationLogStatus::SENT !== $result->getStatus()) {
51	$isSuccess = false;
52	}
53
54	$this->notificationLogService->createFromNotification(
48	foreach ($results as $result) {
48	foreach ($results as $result) {
49	// it at least one dispatch result is not successful, then overall success must be false
50	if (NotificationLogStatus::SENT !== $result->getStatus()) {
51	$isSuccess = false;
52	}
53
54	$this->notificationLogService->createFromNotification(
55	$notification,
56	$result
57	);
58	}
59
60	if ($isSuccess) {
64	$this->entityManager->flush();
65	// clearing the EM may help with memory consumption
66	$this->entityManager->clear();
67	}

30	public function __invoke(SendNotificationCommand $command): void
31	{
32	// get notification to be sent
33	$notification = $this->notificationService->getById($command->getNotificationId());
34	if (null === $notification) {
38	if (NotificationStatus::PENDING !== $notification->getStatus()) {
43	$results = $this->notificationDispatcher->dispatch($notification);
44	// assume the dispatch is fully successful at first
45	$isSuccess = true;
46
47	// save logs for the notification
48	foreach ($results as $result) {
48	foreach ($results as $result) {
50	if (NotificationLogStatus::SENT !== $result->getStatus()) {
48	foreach ($results as $result) {
49	// it at least one dispatch result is not successful, then overall success must be false
50	if (NotificationLogStatus::SENT !== $result->getStatus()) {
51	$isSuccess = false;
52	}
53
54	$this->notificationLogService->createFromNotification(
48	foreach ($results as $result) {
48	foreach ($results as $result) {
49	// it at least one dispatch result is not successful, then overall success must be false
50	if (NotificationLogStatus::SENT !== $result->getStatus()) {
51	$isSuccess = false;
52	}
53
54	$this->notificationLogService->createFromNotification(
55	$notification,
56	$result
57	);
58	}
59
60	if ($isSuccess) {
61	$this->notificationService->updateStatus($notification, NotificationStatus::HANDLED);
62	}
63
64	$this->entityManager->flush();
64	$this->entityManager->flush();
65	// clearing the EM may help with memory consumption
66	$this->entityManager->clear();
67	}

30	public function __invoke(SendNotificationCommand $command): void
31	{
32	// get notification to be sent
33	$notification = $this->notificationService->getById($command->getNotificationId());
34	if (null === $notification) {
38	if (NotificationStatus::PENDING !== $notification->getStatus()) {
43	$results = $this->notificationDispatcher->dispatch($notification);
44	// assume the dispatch is fully successful at first
45	$isSuccess = true;
46
47	// save logs for the notification
48	foreach ($results as $result) {
48	foreach ($results as $result) {
50	if (NotificationLogStatus::SENT !== $result->getStatus()) {
48	foreach ($results as $result) {
49	// it at least one dispatch result is not successful, then overall success must be false
50	if (NotificationLogStatus::SENT !== $result->getStatus()) {
51	$isSuccess = false;
52	}
53
54	$this->notificationLogService->createFromNotification(
48	foreach ($results as $result) {
48	foreach ($results as $result) {
49	// it at least one dispatch result is not successful, then overall success must be false
50	if (NotificationLogStatus::SENT !== $result->getStatus()) {
51	$isSuccess = false;
52	}
53
54	$this->notificationLogService->createFromNotification(
55	$notification,
56	$result
57	);
58	}
59
60	if ($isSuccess) {
64	$this->entityManager->flush();
65	// clearing the EM may help with memory consumption
66	$this->entityManager->clear();
67	}

30	public function __invoke(SendNotificationCommand $command): void
31	{
32	// get notification to be sent
33	$notification = $this->notificationService->getById($command->getNotificationId());
34	if (null === $notification) {
38	if (NotificationStatus::PENDING !== $notification->getStatus()) {
43	$results = $this->notificationDispatcher->dispatch($notification);
44	// assume the dispatch is fully successful at first
45	$isSuccess = true;
46
47	// save logs for the notification
48	foreach ($results as $result) {
48	foreach ($results as $result) {
48	foreach ($results as $result) {
49	// it at least one dispatch result is not successful, then overall success must be false
50	if (NotificationLogStatus::SENT !== $result->getStatus()) {
51	$isSuccess = false;
52	}
53
54	$this->notificationLogService->createFromNotification(
55	$notification,
56	$result
57	);
58	}
59
60	if ($isSuccess) {
61	$this->notificationService->updateStatus($notification, NotificationStatus::HANDLED);
62	}
63
64	$this->entityManager->flush();
64	$this->entityManager->flush();
65	// clearing the EM may help with memory consumption
66	$this->entityManager->clear();
67	}

30	public function __invoke(SendNotificationCommand $command): void
31	{
32	// get notification to be sent
33	$notification = $this->notificationService->getById($command->getNotificationId());
34	if (null === $notification) {
38	if (NotificationStatus::PENDING !== $notification->getStatus()) {
43	$results = $this->notificationDispatcher->dispatch($notification);
44	// assume the dispatch is fully successful at first
45	$isSuccess = true;
46
47	// save logs for the notification
48	foreach ($results as $result) {
48	foreach ($results as $result) {
48	foreach ($results as $result) {
49	// it at least one dispatch result is not successful, then overall success must be false
50	if (NotificationLogStatus::SENT !== $result->getStatus()) {
51	$isSuccess = false;
52	}
53
54	$this->notificationLogService->createFromNotification(
55	$notification,
56	$result
57	);
58	}
59
60	if ($isSuccess) {
64	$this->entityManager->flush();
65	// clearing the EM may help with memory consumption
66	$this->entityManager->clear();
67	}

30	public function __invoke(SendNotificationCommand $command): void
31	{
32	// get notification to be sent
33	$notification = $this->notificationService->getById($command->getNotificationId());
34	if (null === $notification) {
38	if (NotificationStatus::PENDING !== $notification->getStatus()) {
43	$results = $this->notificationDispatcher->dispatch($notification);
44	// assume the dispatch is fully successful at first
45	$isSuccess = true;
46
47	// save logs for the notification
48	foreach ($results as $result) {
48	foreach ($results as $result) {
49	// it at least one dispatch result is not successful, then overall success must be false
50	if (NotificationLogStatus::SENT !== $result->getStatus()) {
51	$isSuccess = false;
52	}
53
54	$this->notificationLogService->createFromNotification(
55	$notification,
56	$result
57	);
58	}
59
60	if ($isSuccess) {
61	$this->notificationService->updateStatus($notification, NotificationStatus::HANDLED);
62	}
63
64	$this->entityManager->flush();
64	$this->entityManager->flush();
65	// clearing the EM may help with memory consumption
66	$this->entityManager->clear();
67	}

30	public function __invoke(SendNotificationCommand $command): void
31	{
32	// get notification to be sent
33	$notification = $this->notificationService->getById($command->getNotificationId());
34	if (null === $notification) {
38	if (NotificationStatus::PENDING !== $notification->getStatus()) {
43	$results = $this->notificationDispatcher->dispatch($notification);
44	// assume the dispatch is fully successful at first
45	$isSuccess = true;
46
47	// save logs for the notification
48	foreach ($results as $result) {
48	foreach ($results as $result) {
49	// it at least one dispatch result is not successful, then overall success must be false
50	if (NotificationLogStatus::SENT !== $result->getStatus()) {
51	$isSuccess = false;
52	}
53
54	$this->notificationLogService->createFromNotification(
55	$notification,
56	$result
57	);
58	}
59
60	if ($isSuccess) {
64	$this->entityManager->flush();
65	// clearing the EM may help with memory consumption
66	$this->entityManager->clear();
67	}

{main}

3	namespace App\Application\Handler;
4
5	use App\Enum\NotificationLogStatus;
6	use App\Enum\NotificationStatus;
7	use App\Exception\NotificationNotFoundException;
8	use App\Message\SendNotificationCommand;
9	use App\Service\Data\NotificationLogServiceInterface;
10	use App\Service\Data\NotificationServiceInterface;
11	use App\Service\Notification\Dispatcher\NotificationDispatcherInterface;
12	use Doctrine\ORM\EntityManagerInterface;
13
14	/**
15	* @author Wilhelm Zwertvaegher
16	*/
17	readonly class SendNotificationCommandHandler implements SendNotificationCommandHandlerInterface
18	{
19	public function __construct(
20	private NotificationServiceInterface $notificationService,
21	private NotificationDispatcherInterface $notificationDispatcher,
22	private NotificationLogServiceInterface $notificationLogService,
23	private EntityManagerInterface $entityManager,
24	) {
25	}
26
27	/**
28	* @throws NotificationNotFoundException
29	*/
30	public function __invoke(SendNotificationCommand $command): void
31	{
32	// get notification to be sent
33	$notification = $this->notificationService->getById($command->getNotificationId());
34	if (null === $notification) {
35	throw new NotificationNotFoundException();
36	}
37
38	if (NotificationStatus::PENDING !== $notification->getStatus()) {
39	return;
40	}
41
42	// pass to dispatcher
43	$results = $this->notificationDispatcher->dispatch($notification);
44	// assume the dispatch is fully successful at first
45	$isSuccess = true;
46
47	// save logs for the notification
48	foreach ($results as $result) {
49	// it at least one dispatch result is not successful, then overall success must be false
50	if (NotificationLogStatus::SENT !== $result->getStatus()) {
51	$isSuccess = false;
52	}
53
54	$this->notificationLogService->createFromNotification(
55	$notification,
56	$result
57	);
58	}
59
60	if ($isSuccess) {
61	$this->notificationService->updateStatus($notification, NotificationStatus::HANDLED);
62	}
63
64	$this->entityManager->flush();
65	// clearing the EM may help with memory consumption
66	$this->entityManager->clear();
67	}