-
Notifications
You must be signed in to change notification settings - Fork 10
/
NotificationTaskRunner.php
52 lines (43 loc) · 1.36 KB
/
NotificationTaskRunner.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
<?php
declare(strict_types=1);
namespace SchedulerBundle\Runner;
use SchedulerBundle\Worker\WorkerInterface;
use Symfony\Component\Notifier\NotifierInterface;
use SchedulerBundle\Task\NotificationTask;
use SchedulerBundle\Task\Output;
use SchedulerBundle\Task\TaskInterface;
use Throwable;
/**
* @author Guillaume Loulier <contact@guillaumeloulier.fr>
*/
final class NotificationTaskRunner implements RunnerInterface
{
public function __construct(private ?NotifierInterface $notifier = null)
{
}
/**
* {@inheritdoc}
*/
public function run(TaskInterface $task, WorkerInterface $worker): Output
{
if (!$task instanceof NotificationTask) {
return new Output($task, null, Output::ERROR);
}
try {
if (!$this->notifier instanceof NotifierInterface) {
return new Output($task, 'The task cannot be handled as the notifier is not defined', Output::ERROR);
}
$this->notifier->send($task->getNotification(), ...$task->getRecipients());
return new Output($task, null);
} catch (Throwable $throwable) {
return new Output($task, $throwable->getMessage(), Output::ERROR);
}
}
/**
* {@inheritdoc}
*/
public function support(TaskInterface $task): bool
{
return $task instanceof NotificationTask;
}
}