src/InsuranceCompany/Uniqa/SOAP/Subscriber/ErrorHandlingSubscriber.php line 36

Open in your IDE?
  1. <?php
  4. namespace App\InsuranceCompany\Uniqa\SOAP\Subscriber;
  6. use App\InsuranceCompany\Common\Type\ResultProviderInterface;
  7. use App\InsuranceCompany\Uniqa\Exception\Exception;
  8. use App\InsuranceCompany\Uniqa\SOAP\Generated\Type\GetPolicyDueInstallmentResult;
  9. use App\InsuranceCompany\Uniqa\SOAP\Generated\Type\Info;
  10. use App\InsuranceCompany\Uniqa\SOAP\Interfaces\ResultInterface;
  11. use Phpro\SoapClient\Event\ResponseEvent;
  12. use Psr\Log\LoggerInterface;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use UnexpectedValueException;
  16. /**
  17.  * Class ErrorHandlingSubscriber
  18.  */
  19. class ErrorHandlingSubscriber implements EventSubscriberInterface
  20. {
  21.     /**
  22.      * Constructor
  23.      *
  24.      * @param LoggerInterface $logger
  25.      */
  26.     public function __construct(
  27.         private readonly LoggerInterface $logger,
  28.     )
  29.     {
  30.     }
  32.     /**
  33.      * @param ResponseEvent $event
  34.      * @throws Exception
  35.      */
  36.     public function onClientResponse(ResponseEvent $event)
  37.     {
  38.         $response = $event->getResponse();
  40.         if (!($response instanceof ResultProviderInterface)) {
  41.             throw new UnexpectedValueException('Response type is not a result provider');
  42.         }
  44.         $result = $response->getResult();
  46.         if (!($result instanceof ResultInterface)) {
  47.             throw new UnexpectedValueException('Result type is not a result');
  48.         }
  50.         $this->logger->info('Correlation ID: ' . $result->getCorrelationID());
  51.         $status = $result->getStatus();
  52.         $statusCode = $status->getStatusType();
  54.         if ($statusCode === 0) {
  55.             return;
  56.         }
  58.         $info = $status->getInfo()->getArray();
  60.         // Even if there are no unpaid installments, client name is returned and used in
  61.         // installment payment request
  62.         if ($result instanceof GetPolicyDueInstallmentResult) {
  63.             $noUnpaidInstallmentsInfo = array_filter($info, static fn(Info $info) =>
  64.                 $info->getType() === 'ERROR' && $info->getCode() === 'PSM-401'
  65.             );
  67.             if (count($noUnpaidInstallmentsInfo) > 0) {
  68.                 return;
  69.             }
  70.         }
  72.         throw Exception::fromInfoAndStatus($info, $statusCode);
  73.     }
  75.     /**
  76.      * {@inheritdoc}
  77.      * @noinspection PhpArrayShapeAttributeCanBeAddedInspection
  78.      */
  79.     public static function getSubscribedEvents(): array
  80.     {
  81.         return [
  82.             ResponseEvent::class => 'onClientResponse',
  83.         ];
  84.     }
  85. }