|
@@ -12,6 +12,7 @@ use App\Entity\Access\Access;
|
|
|
use App\Service\HelloAsso\HelloAssoService;
|
|
use App\Service\HelloAsso\HelloAssoService;
|
|
|
use App\Service\MercureHub;
|
|
use App\Service\MercureHub;
|
|
|
use http\Client\Response;
|
|
use http\Client\Response;
|
|
|
|
|
+use Psr\Log\LoggerInterface;
|
|
|
use Symfony\Bundle\SecurityBundle\Security;
|
|
use Symfony\Bundle\SecurityBundle\Security;
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -23,6 +24,7 @@ class ConnectionRequestProcessor implements ProcessorInterface
|
|
|
private readonly HelloAssoService $helloAssoService,
|
|
private readonly HelloAssoService $helloAssoService,
|
|
|
private Security $security,
|
|
private Security $security,
|
|
|
private MercureHub $mercureHub,
|
|
private MercureHub $mercureHub,
|
|
|
|
|
+ private LoggerInterface $logger,
|
|
|
) {
|
|
) {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -58,7 +60,11 @@ class ConnectionRequestProcessor implements ProcessorInterface
|
|
|
|
|
|
|
|
$helloAssoProfile = $this->helloAssoService->makeHelloAssoProfile($connectionRequest->getOrganizationId());
|
|
$helloAssoProfile = $this->helloAssoService->makeHelloAssoProfile($connectionRequest->getOrganizationId());
|
|
|
|
|
|
|
|
- $this->mercureHub->publishUpdate($access->getId(), $helloAssoProfile);
|
|
|
|
|
|
|
+ try {
|
|
|
|
|
+ $this->mercureHub->publishUpdate($access->getId(), $helloAssoProfile);
|
|
|
|
|
+ } catch (\Exception $e) {
|
|
|
|
|
+ $this->logger->error('Error while sending mercure update : ' . $e->getMessage());
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
return $connectionRequest;
|
|
return $connectionRequest;
|
|
|
}
|
|
}
|