vendor/ruflin/elastica/src/Exception/Bulk/Response/ActionException.php line 9

Open in your IDE?
  1. <?php
  3. namespace Elastica\Exception\Bulk\Response;
  5. use Elastica\Bulk\Action;
  6. use Elastica\Bulk\Response as BulkResponse;
  7. use Elastica\Exception\BulkException;
  9. class ActionException extends BulkException
  10. {
  11.     /**
  12.      * @var BulkResponse
  13.      */
  14.     protected $_response;
  16.     public function __construct(BulkResponse $response)
  17.     {
  18.         $this->_response = $response;
  20.         parent::__construct($this->getErrorMessage($response));
  21.     }
  23.     public function getAction(): Action
  24.     {
  25.         return $this->getResponse()->getAction();
  26.     }
  28.     public function getResponse(): BulkResponse
  29.     {
  30.         return $this->_response;
  31.     }
  33.     public function getErrorMessage(BulkResponse $response): string
  34.     {
  35.         $error = $response->getError();
  36.         $opType = $response->getOpType();
  37.         $data = $response->getData();
  39.         $path = '';
  40.         if (isset($data['_index'])) {
  41.             $path .= '/'.$data['_index'];
  42.         }
  44.         if (isset($data['_type'])) {
  45.             $path .= '/'.$data['_type'];
  46.         }
  48.         if (isset($data['_id'])) {
  49.             $path .= '/'.$data['_id'];
  50.         }
  52.         return "{$opType}: {$path} caused {$error}";
  53.     }
  54. }