src/InsuranceCompany/Bulstrad/SOAP/Subscriber/ErrorHandlingSubscriber.php line 22

Open in your IDE?
  1. <?php
  4. namespace App\InsuranceCompany\Bulstrad\SOAP\Subscriber;
  6. use App\InsuranceCompany\Bulstrad\Exception\Exception;
  7. use App\InsuranceCompany\Bulstrad\SOAP\Interfaces\ResponseInterface;
  8. use App\InsuranceCompany\Bulstrad\SOAP\Interfaces\StatusMessageTypeInterface;
  9. use Phpro\SoapClient\Event\ResponseEvent;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use UnexpectedValueException;
  13. /**
  14.  * Class ErrorHandlingSubscriber
  15.  */
  16. class ErrorHandlingSubscriber implements EventSubscriberInterface
  17. {
  18.     /**
  19.      * @param ResponseEvent $event
  20.      * @throws Exception
  21.      */
  22.     public function onClientResponse(ResponseEvent $event)
  23.     {
  24.         $response = $event->getResponse();
  26.         if (!($response instanceof ResponseInterface)) {
  27.             throw new UnexpectedValueException('Response type is not a ResponseInterface');
  28.         }
  30.         $status = $response->getStatus();
  31.         $result = $status->getResult();
  33.         if ($result === 0) {
  34.             return;
  35.         }
  37.         /**
  38.          * @var StatusMessageTypeInterface[] $messages
  39.          */
  40.         $messages = $status->getMessages()->getMessage();
  42.         $errorMessage = implode('; ', array_map(function(StatusMessageTypeInterface $message) {
  43.             return $message->getCode() . ': ' . $message->getDescription();
  44.         }, $messages));
  46.         $exception = new Exception(
  47.             message: $errorMessage,
  48.             code: $result,
  49.             messages: $messages,
  50.         );
  52.         $internalServerError = $exception->getMessageByCode('OSB-380001');
  54.         if ($internalServerError?->getDescription() === 'Internal Server Error') {
  55.             $exception = new Exception(
  56.                 message: 'Проблем при комуникацията със застрахователна компания Булстрад',
  57.                 code: $result,
  58.                 messages: $messages,
  59.             );
  60.         }
  62.         $loginError = $exception->getMessageByCode('SOA_ERROR');
  64.         if (str_contains($loginError?->getDescription() ?? '', 'WEB.COMMON.LOGIN.NO_SUCH_USER')) {
  65.             $exception = new Exception(
  66.                 message: 'В момента няма достъп до застрахователна компания Булстрад',
  67.                 code: $result,
  68.                 messages: $messages,
  69.             );
  70.         }
  72.         throw $exception;
  73.     }
  75.     /**
  76.      * {@inheritdoc}
  77.      * @noinspection PhpArrayShapeAttributeCanBeAddedInspection
  78.      */
  79.     public static function getSubscribedEvents(): array
  80.     {
  81.         return [
  82.             ResponseEvent::class => 'onClientResponse',
  83.         ];
  84.     }
  85. }