vendor/shopware/core/Framework/DataAbstractionLayer/Write/WriteException.php line 9

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\DataAbstractionLayer\Write;
  5. use Shopware\Core\Framework\Api\EventListener\ErrorResponseFactory;
  6. use Shopware\Core\Framework\ShopwareHttpException;
  7. use Symfony\Component\HttpFoundation\Response;
  9. class WriteException extends ShopwareHttpException
  10. {
  11.     private const MESSAGE = "There are {{ errorCount }} error(s) while writing data.\n\n{{ messagesString }}";
  13.     /**
  14.      * @var \Throwable[]
  15.      */
  16.     private $exceptions = [];
  18.     public function __construct()
  19.     {
  20.         parent::__construct(self::MESSAGE, ['errorCount' => 0]);
  21.     }
  23.     public function add(\Throwable $exception): WriteException
  24.     {
  25.         $this->exceptions[] = $exception;
  26.         $this->updateMessage();
  28.         return $this;
  29.     }
  31.     public function getExceptions(): array
  32.     {
  33.         return $this->exceptions;
  34.     }
  36.     /**
  37.      * @throws WriteException
  38.      */
  39.     public function tryToThrow(): void
  40.     {
  41.         if (\count($this->exceptions)) {
  42.             throw $this;
  43.         }
  44.     }
  46.     public function getErrorCode(): string
  47.     {
  48.         return 'FRAMEWORK__WRITE_ERROR';
  49.     }
  51.     public function getStatusCode(): int
  52.     {
  53.         return Response::HTTP_BAD_REQUEST;
  54.     }
  56.     public function getErrors(bool $withTrace = false): \Generator
  57.     {
  58.         foreach ($this->getExceptions() as $innerException) {
  59.             if ($innerException instanceof ShopwareHttpException) {
  60.                 yield from $innerException->getErrors($withTrace);
  62.                 continue;
  63.             }
  65.             $errorFactory = new ErrorResponseFactory();
  66.             yield from $errorFactory->getErrorsFromException($innerException, $withTrace);
  67.         }
  68.     }
  70.     private function updateMessage(): void
  71.     {
  72.         $messages = [];
  74.         foreach ($this->getErrors() as $index => $error) {
  75.             $pointer = $error['source']['pointer'] ?? '/';
  76.             $messages[] = sprintf('%d. [%s] %s', $index + 1, $pointer, $error['detail']);
  77.         }
  79.         $messagesString = implode(\PHP_EOL, $messages);
  81.         $this->parameters = [
  82.             'errorCount' => \count($this->exceptions),
  83.             'messages' => $messages,
  84.             'messagesString' => $messagesString,
  85.         ];
  87.         $this->message = $this->parse(self::MESSAGE, $this->parameters);
  88.     }
  89. }