/
ReviewPersistProcessor.php
70 lines (61 loc) · 2.12 KB
/
ReviewPersistProcessor.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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
<?php
declare(strict_types=1);
namespace App\State\Processor;
use ApiPlatform\Doctrine\Common\State\PersistProcessor;
use ApiPlatform\Metadata\Operation;
use ApiPlatform\Metadata\Post;
use ApiPlatform\State\ProcessorInterface;
use App\Entity\Review;
use Psr\Clock\ClockInterface;
use Symfony\Bundle\SecurityBundle\Security;
use Symfony\Component\DependencyInjection\Attribute\Autowire;
/**
* @implements ProcessorInterface<Review, Review>
*/
final readonly class ReviewPersistProcessor implements ProcessorInterface
{
/**
* @param PersistProcessor $persistProcessor
* @param MercureProcessor $mercureProcessor
*/
public function __construct(
#[Autowire(service: PersistProcessor::class)]
private ProcessorInterface $persistProcessor,
#[Autowire(service: MercureProcessor::class)]
private ProcessorInterface $mercureProcessor,
private Security $security,
private ClockInterface $clock
) {
}
/**
* @param Review $data
*/
public function process(mixed $data, Operation $operation, array $uriVariables = [], array $context = []): Review
{
// standard PUT
if (isset($context['previous_data'])) {
$data->user = $context['previous_data']->user;
$data->publishedAt = $context['previous_data']->publishedAt;
}
// prevent overriding user, for instance from admin
if ($operation instanceof Post) {
/** @phpstan-ignore-next-line */
$data->user = $this->security->getUser();
$data->publishedAt = $this->clock->now();
}
// save entity
$data = $this->persistProcessor->process($data, $operation, $uriVariables, $context);
// publish on Mercure
foreach (['/admin/reviews/{id}{._format}', '/books/{bookId}/reviews/{id}{._format}'] as $uriTemplate) {
$this->mercureProcessor->process(
$data,
$operation,
$uriVariables,
$context + [
'item_uri_template' => $uriTemplate,
]
);
}
return $data;
}
}