src/InsuranceCompany/Bulins/SOAP/Subscriber/ErrorHandlingSubscriber.php line 26

Open in your IDE?
  1. <?php
  4. namespace App\InsuranceCompany\Bulins\SOAP\Subscriber;
  6. use App\InsuranceCompany\Bulins\Exception\Exception;
  7. use App\InsuranceCompany\Bulins\SOAP\Generated\Type\ErrorDescription;
  8. use App\InsuranceCompany\Bulins\SOAP\Generated\Type\Result;
  9. use App\InsuranceCompany\Common\Exception\NullValueException;
  10. use App\InsuranceCompany\Common\Type\CustomResultInterface;
  11. use App\InsuranceCompany\Common\Type\ResultProviderInterface;
  12. use Phpro\SoapClient\Event\ResponseEvent;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use UnexpectedValueException;
  16. /**
  17.  * Class ErrorHandlingSubscriber
  18.  */
  19. class ErrorHandlingSubscriber implements EventSubscriberInterface
  20. {
  21.     /**
  22.      * @param ResponseEvent $event
  23.      * @throws Exception
  24.      * @throws NullValueException
  25.      */
  26.     public function onClientResponse(ResponseEvent $event)
  27.     {
  28.         $response = $event->getResponse();
  30.         if (!($response instanceof ResultProviderInterface)) {
  31.             throw new UnexpectedValueException('Response type is not a result provider');
  32.         }
  34.         $result = $response->getResult();
  36.         if ($result === null) {
  37.             throw new NullValueException();
  38.         }
  40.         if (!($result instanceof Result)) {
  41.             if ($result instanceof CustomResultInterface) {
  42.                 return;
  43.             }
  45.             throw new UnexpectedValueException('Result is not a subclass of Result');
  46.         }
  48.         $status = $result->getStatus();
  50.         switch ($status) {
  51.             case 'Error':
  52.                 $errors = [];
  54.                 foreach ($result->getErrors() as $errorDesc) {
  55.                     /**
  56.                      * @var ErrorDescription $errorDesc
  57.                      */
  58.                     $name = $errorDesc->getPropertyName();
  60.                     if (strlen($name) > 0) {
  61.                         $errors[] = $name . ': ' . $errorDesc->getMessage();
  62.                     } else {
  63.                         $errors[] = $errorDesc->getMessage();
  64.                     }
  65.                 }
  67.                 throw new Exception(
  68.                     message: implode(PHP_EOL, $errors),
  69.                     errors: $result->getErrors(),
  70.                 );
  71.             case 'Success':
  72.                 // nothing to do
  73.                 break;
  74.             case 'None':
  75.                 throw new UnexpectedValueException('Service returned status None');
  76.             default:
  77.                 throw new UnexpectedValueException('Undefined status: ' . $status);
  78.         }
  79.     }
  81.     /**
  82.      * {@inheritdoc}
  83.      * @noinspection PhpArrayShapeAttributeCanBeAddedInspection
  84.      */
  85.     public static function getSubscribedEvents(): array
  86.     {
  87.         return [
  88.             ResponseEvent::class => 'onClientResponse',
  89.         ];
  90.     }
  91. }