1	<?php
2
3	namespace App\Notification\Infrastructure\Adapter;
4
5	use App\Notification\Domain\Model\Notification;
6	use App\Notification\Domain\Model\NotificationDispatchResult;
7	use App\Notification\Domain\Port\Driven\NotificationDispatcher;
8	use App\Notification\Domain\Port\Driven\NotificationLogRepository;
9	use App\Notification\Infrastructure\Sender\NotificationSender;
10	use Symfony\Component\DependencyInjection\Attribute\AutowireIterator;
11
12	/**
13	* @author Wilhelm Zwertvaegher
14	*/
15	class NotificationDispatcherAdapter implements NotificationDispatcher
16	{
17	/**
18	* @var array<NotificationSender>
19	*/
20	private array $senders;
21
22	/**
23	* @param iterable<NotificationSender> $senders
24	*/
25	public function __construct(
26	#[AutowireIterator('app.notification_sender')]
27	iterable $senders,
28	private readonly NotificationLogRepository $notificationLogRepository
29	) {
30	$this->senders = is_array($senders) ? $senders : iterator_to_array($senders);
31	}
32
33	public function addSender(NotificationSender $notificationSender): void
34	{
35	if (!array_any($this->senders, fn($sender) => $sender->getName() === $notificationSender->getName())) {
36	$this->senders[] = $notificationSender;
37	}
38	}
39
40	/**
41	* @param Notification $notification
42	* @return array<NotificationDispatchResult>
43	*/
44	public function dispatch(Notification $notification): array
45	{
46	$results = [];
47
48	foreach ($this->senders as $sender) {
49	if ($sender->supports($notification) &&
50	// avoid resending a notification which already succeeded
51	// this may be useful in case a notification previously partially failed, which could result in a global retry
52	!$this->notificationLogRepository->hasSuccess($notification->getMessageId(), $sender->getName())
53	) {
54	$senderResult = $sender->send($notification);
55	$results[] = new NotificationDispatchResult($sender->getName(), $senderResult->getStatus(), $senderResult->getMessage());
56	}
57	}
58
59	return $results;
60	}
61	}

---

Branches

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

NotificationDispatcherAdapter->__construct

25	public function __construct(
26	#[AutowireIterator('app.notification_sender')]
27	iterable $senders,
28	private readonly NotificationLogRepository $notificationLogRepository
29	) {
30	$this->senders = is_array($senders) ? $senders : iterator_to_array($senders);

30	$this->senders = is_array($senders) ? $senders : iterator_to_array($senders);

30	$this->senders = is_array($senders) ? $senders : iterator_to_array($senders);

30	$this->senders = is_array($senders) ? $senders : iterator_to_array($senders);
31	}

NotificationDispatcherAdapter->addSender

33	public function addSender(NotificationSender $notificationSender): void
34	{
35	if (!array_any($this->senders, fn($sender) => $sender->getName() === $notificationSender->getName())) {

36	$this->senders[] = $notificationSender;
37	}
38	}

38

}

NotificationDispatcherAdapter->dispatch

44	public function dispatch(Notification $notification): array
45	{
46	$results = [];
47
48	foreach ($this->senders as $sender) {

48	foreach ($this->senders as $sender) {

49	if ($sender->supports($notification) &&

52	!$this->notificationLogRepository->hasSuccess($notification->getMessageId(), $sender->getName())

52	!$this->notificationLogRepository->hasSuccess($notification->getMessageId(), $sender->getName())

48	foreach ($this->senders as $sender) {
49	if ($sender->supports($notification) &&
50	// avoid resending a notification which already succeeded
51	// this may be useful in case a notification previously partially failed, which could result in a global retry
52	!$this->notificationLogRepository->hasSuccess($notification->getMessageId(), $sender->getName())
53	) {
54	$senderResult = $sender->send($notification);

48	foreach ($this->senders as $sender) {

48	foreach ($this->senders as $sender) {
49	if ($sender->supports($notification) &&
50	// avoid resending a notification which already succeeded
51	// this may be useful in case a notification previously partially failed, which could result in a global retry
52	!$this->notificationLogRepository->hasSuccess($notification->getMessageId(), $sender->getName())
53	) {
54	$senderResult = $sender->send($notification);
55	$results[] = new NotificationDispatchResult($sender->getName(), $senderResult->getStatus(), $senderResult->getMessage());
56	}
57	}
58
59	return $results;
60	}

{closure:/home/runner/work/my-lego-collection/my-lego-collection/back/src/Notification/Infrastructure/Adapter/NotificationDispatcherAdapter.php:35-35}

35	if (!array_any($this->senders, fn($sender) => $sender->getName() === $notificationSender->getName())) {

{main}

3	namespace App\Notification\Infrastructure\Adapter;
4
5	use App\Notification\Domain\Model\Notification;
6	use App\Notification\Domain\Model\NotificationDispatchResult;
7	use App\Notification\Domain\Port\Driven\NotificationDispatcher;
8	use App\Notification\Domain\Port\Driven\NotificationLogRepository;
9	use App\Notification\Infrastructure\Sender\NotificationSender;
10	use Symfony\Component\DependencyInjection\Attribute\AutowireIterator;
11
12	/**
13	* @author Wilhelm Zwertvaegher
14	*/
15	class NotificationDispatcherAdapter implements NotificationDispatcher
16	{
17	/**
18	* @var array<NotificationSender>
19	*/
20	private array $senders;
21
22	/**
23	* @param iterable<NotificationSender> $senders
24	*/
25	public function __construct(
26	#[AutowireIterator('app.notification_sender')]
27	iterable $senders,
28	private readonly NotificationLogRepository $notificationLogRepository
29	) {
30	$this->senders = is_array($senders) ? $senders : iterator_to_array($senders);
31	}
32
33	public function addSender(NotificationSender $notificationSender): void
34	{
35	if (!array_any($this->senders, fn($sender) => $sender->getName() === $notificationSender->getName())) {
36	$this->senders[] = $notificationSender;
37	}
38	}
39
40	/**
41	* @param Notification $notification
42	* @return array<NotificationDispatchResult>
43	*/
44	public function dispatch(Notification $notification): array
45	{
46	$results = [];
47
48	foreach ($this->senders as $sender) {
49	if ($sender->supports($notification) &&
50	// avoid resending a notification which already succeeded
51	// this may be useful in case a notification previously partially failed, which could result in a global retry
52	!$this->notificationLogRepository->hasSuccess($notification->getMessageId(), $sender->getName())
53	) {
54	$senderResult = $sender->send($notification);
55	$results[] = new NotificationDispatchResult($sender->getName(), $senderResult->getStatus(), $senderResult->getMessage());
56	}
57	}
58
59	return $results;
60	}