97 lines
3.4 KiB
PHP
Executable File
97 lines
3.4 KiB
PHP
Executable File
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
namespace Mautic\MessengerBundle\MessageHandler;
|
|
|
|
use Mautic\LeadBundle\Entity\LeadRepository;
|
|
use Mautic\MessengerBundle\Exceptions\InvalidPayloadException;
|
|
use Mautic\MessengerBundle\Message\PageHitNotification;
|
|
use Mautic\PageBundle\Entity\Hit;
|
|
use Mautic\PageBundle\Entity\HitRepository;
|
|
use Mautic\PageBundle\Entity\PageRepository;
|
|
use Mautic\PageBundle\Entity\RedirectRepository;
|
|
use Mautic\PageBundle\Model\PageModel;
|
|
use Psr\Log\LoggerInterface;
|
|
use Symfony\Component\Messenger\Attribute\AsMessageHandler;
|
|
use Symfony\Component\Messenger\Handler\Acknowledger;
|
|
|
|
#[AsMessageHandler]
|
|
class PageHitNotificationHandler
|
|
{
|
|
public function __construct(
|
|
private PageRepository $pageRepository,
|
|
private HitRepository $hitRepository,
|
|
private LeadRepository $leadRepository,
|
|
private LoggerInterface $logger,
|
|
private RedirectRepository $redirectRepository,
|
|
private PageModel $pageModel,
|
|
) {
|
|
}
|
|
|
|
/**
|
|
* @throws InvalidPayloadException
|
|
*/
|
|
public function __invoke(PageHitNotification $message, ?Acknowledger $ack = null): void
|
|
{
|
|
$parsed = $this->parseMessage($message);
|
|
$this->pageModel->processPageHit(...$parsed);
|
|
$this->logger->info('processed page hit #'.$message->getHitId());
|
|
}
|
|
|
|
/**
|
|
* @return array<string, mixed>
|
|
*
|
|
* @throws InvalidPayloadException
|
|
*/
|
|
private function parseMessage(PageHitNotification $message): array
|
|
{
|
|
$hit = $message->getHitId() > 0 ? $this->hitRepository->find($message->getHitId()) : null;
|
|
|
|
$pageObject = null;
|
|
if (null !== $message->getPageId()) {
|
|
try {
|
|
$pageObject = $message->isRedirect()
|
|
? $this->redirectRepository->find($message->getPageId())
|
|
: $this->pageRepository->find($message->getPageId());
|
|
} catch (\Exception $exception) {
|
|
$this->logger->error(
|
|
sprintf('Invalid page/redirect, exception. #%s', $message->getPageId()),
|
|
['message' => $message]
|
|
);
|
|
throw $exception;
|
|
}
|
|
|
|
if (null === $pageObject) {
|
|
$this->logger->error(
|
|
sprintf('Invalid page/redirect, id not found. #%s', $message->getPageId())
|
|
);
|
|
throw new InvalidPayloadException('Missing required information', ['message' => $message]);
|
|
}
|
|
}
|
|
|
|
if (!$hit instanceof Hit && $message->getHitId() > 0) {
|
|
$this->logger->warning('Invalid hit id #'.$message->getHitId(), ['message' => $message]);
|
|
|
|
throw new InvalidPayloadException('Invalid hit id #'.$message->getHitId(), (array) $message);
|
|
}
|
|
|
|
// Lead IS mandatory field
|
|
if (null === $lead = $this->leadRepository->find($message->getLeadId())) {
|
|
$this->logger->error('Invalid lead id #'.$message->getLeadId(), ['message' => $message]);
|
|
|
|
throw new InvalidPayloadException('Invalid lead id', (array) $message);
|
|
}
|
|
|
|
return [
|
|
'hit' => $hit,
|
|
'page' => $pageObject,
|
|
'request' => $message->getRequest(),
|
|
'lead' => $lead,
|
|
'trackingNewlyGenerated' => $message->isNew(),
|
|
'activeRequest' => false,
|
|
'hitDate' => $message->getEventTime(),
|
|
];
|
|
}
|
|
}
|