@@ -17,14 +17,14 @@ |
||
17 | 17 | public function __construct( |
18 | 18 | private readonly MailerConfig $config, |
19 | 19 | private readonly QueueInterface $queue |
20 | - ) { |
|
20 | + ){ |
|
21 | 21 | } |
22 | 22 | |
23 | 23 | public function send(MessageInterface ...$message): void |
24 | 24 | { |
25 | 25 | $options = Options::onQueue($this->config->getQueue()); |
26 | 26 | |
27 | - foreach ($message as $msg) { |
|
27 | + foreach ($message as $msg){ |
|
28 | 28 | $this->queue->push( |
29 | 29 | self::JOB_NAME, |
30 | 30 | MessageSerializer::pack($msg), |
@@ -24,7 +24,8 @@ |
||
24 | 24 | { |
25 | 25 | $options = Options::onQueue($this->config->getQueue()); |
26 | 26 | |
27 | - foreach ($message as $msg) { |
|
27 | + foreach ($message as $msg) |
|
28 | + { |
|
28 | 29 | $this->queue->push( |
29 | 30 | self::JOB_NAME, |
30 | 31 | MessageSerializer::pack($msg), |
@@ -10,6 +10,6 @@ |
||
10 | 10 | { |
11 | 11 | public function __construct( |
12 | 12 | public readonly Email $message |
13 | - ) { |
|
13 | + ){ |
|
14 | 14 | } |
15 | 15 | } |
@@ -11,6 +11,6 @@ |
||
11 | 11 | public function __construct( |
12 | 12 | public readonly Email $message, |
13 | 13 | public readonly \Throwable $exception |
14 | - ) { |
|
14 | + ){ |
|
15 | 15 | } |
16 | 16 | } |
@@ -32,11 +32,13 @@ discard block |
||
32 | 32 | */ |
33 | 33 | public function handle(string $name, string $id, string|array $payload): void |
34 | 34 | { |
35 | - if (\is_string($payload)) { |
|
35 | + if (\is_string($payload)) |
|
36 | + { |
|
36 | 37 | $payload = \json_decode($payload, true, 512, JSON_THROW_ON_ERROR); |
37 | 38 | } |
38 | 39 | |
39 | - if (!\is_array($payload)) { |
|
40 | + if (!\is_array($payload)) |
|
41 | + { |
|
40 | 42 | throw new InvalidArgumentException('Mail job payload should be an array.'); |
41 | 43 | } |
42 | 44 | |
@@ -44,13 +46,17 @@ discard block |
||
44 | 46 | |
45 | 47 | $email = $this->renderer->render($message); |
46 | 48 | |
47 | - if ($email->getFrom() === []) { |
|
49 | + if ($email->getFrom() === []) |
|
50 | + { |
|
48 | 51 | $email->from(Address::create($this->config->getFromAddress())); |
49 | 52 | } |
50 | 53 | |
51 | - try { |
|
54 | + try |
|
55 | + { |
|
52 | 56 | $this->mailer->send($email); |
53 | - } catch (TransportExceptionInterface $e) { |
|
57 | + } |
|
58 | + catch (TransportExceptionInterface $e) |
|
59 | + { |
|
54 | 60 | $this->dispatcher?->dispatch(new MessageNotSent($email, $e)); |
55 | 61 | |
56 | 62 | throw $e; |
@@ -21,20 +21,20 @@ discard block |
||
21 | 21 | private readonly SymfonyMailer $mailer, |
22 | 22 | private readonly RendererInterface $renderer, |
23 | 23 | private readonly ?EventDispatcherInterface $dispatcher = null |
24 | - ) { |
|
24 | + ){ |
|
25 | 25 | } |
26 | 26 | |
27 | 27 | /** |
28 | 28 | * @throws TransportExceptionInterface |
29 | 29 | * @throws InvalidArgumentException |
30 | 30 | */ |
31 | - public function handle(string $name, string $id, string|array $payload): void |
|
31 | + public function handle(string $name, string $id, string | array $payload): void |
|
32 | 32 | { |
33 | - if (\is_string($payload)) { |
|
33 | + if (\is_string($payload)){ |
|
34 | 34 | $payload = \json_decode($payload, true, 512, JSON_THROW_ON_ERROR); |
35 | 35 | } |
36 | 36 | |
37 | - if (!\is_array($payload)) { |
|
37 | + if (!\is_array($payload)){ |
|
38 | 38 | throw new InvalidArgumentException('Mail job payload should be an array.'); |
39 | 39 | } |
40 | 40 | |
@@ -42,13 +42,13 @@ discard block |
||
42 | 42 | |
43 | 43 | $email = $this->renderer->render($message); |
44 | 44 | |
45 | - if ($email->getFrom() === []) { |
|
45 | + if ($email->getFrom() === []){ |
|
46 | 46 | $email->from(Address::create($this->config->getFromAddress())); |
47 | 47 | } |
48 | 48 | |
49 | - try { |
|
49 | + try{ |
|
50 | 50 | $this->mailer->send($email); |
51 | - } catch (TransportExceptionInterface $e) { |
|
51 | + }catch (TransportExceptionInterface $e){ |
|
52 | 52 | $this->dispatcher?->dispatch(new MessageNotSent($email, $e)); |
53 | 53 | |
54 | 54 | throw $e; |
@@ -25,6 +25,6 @@ |
||
25 | 25 | |
26 | 26 | public function init(ViewsBootloader $views): void |
27 | 27 | { |
28 | - $views->addDirectory('sendit', __DIR__ . '/../../views'); |
|
28 | + $views->addDirectory('sendit', __DIR__.'/../../views'); |
|
29 | 29 | } |
30 | 30 | } |
@@ -14,7 +14,7 @@ |
||
14 | 14 | { |
15 | 15 | public function __construct( |
16 | 16 | private readonly LoggerInterface $logger |
17 | - ) { |
|
17 | + ){ |
|
18 | 18 | } |
19 | 19 | |
20 | 20 | public function onMessageSent(MessageSent $event): void |
@@ -15,7 +15,7 @@ |
||
15 | 15 | { |
16 | 16 | public function __construct( |
17 | 17 | private readonly \Throwable $e |
18 | - ) { |
|
18 | + ){ |
|
19 | 19 | } |
20 | 20 | |
21 | 21 | /** |
@@ -17,7 +17,7 @@ |
||
17 | 17 | public function __construct( |
18 | 18 | private readonly UriInterface $uri, |
19 | 19 | private readonly int $status = 401 |
20 | - ) { |
|
20 | + ){ |
|
21 | 21 | } |
22 | 22 | |
23 | 23 | protected function denyAccess(Request $request, RequestHandlerInterface $handler): Response |
@@ -28,7 +28,7 @@ |
||
28 | 28 | TokenStorageInterface $tokenStorage, |
29 | 29 | TransportRegistry $transportRegistry, |
30 | 30 | ?EventDispatcherInterface $eventDispatcher = null |
31 | - ) { |
|
31 | + ){ |
|
32 | 32 | $this->authMiddleware = new AuthMiddleware( |
33 | 33 | $scope, |
34 | 34 | $actorProvider, |