class GuzzleConnectionDebug in Elasticsearch Connector 7

Hierarchy

• class \Elasticsearch\Connections\GuzzleConnectionDebug extends \Elasticsearch\Connections\AbstractConnection implements \Elasticsearch\Connections\ConnectionInterface

File

modules/elasticsearch_connector_devel/includes/GuzzleConnectionDebugging.inc, line 25

Namespace

Elasticsearch\Connections

class GuzzleConnectionDebug extends AbstractConnection implements ConnectionInterface {
  public static $debugOutput;

  /** @var  Client */
  private $guzzle;
  private $connectionOpts = array();

  /**
   * @param string                   $host             Host string
   * @param int                      $port             Host port
   * @param array                    $connectionParams Array of connection parameters
   * @param \Psr\Log\LoggerInterface $log              logger object
   * @param \Psr\Log\LoggerInterface $trace            logger object (for curl traces)
   *
   * @throws \Elasticsearch\Common\Exceptions\InvalidArgumentException
   * @return \Elasticsearch\Connections\GuzzleConnection
   */
  public function __construct($hostDetails, $connectionParams, LoggerInterface $log, LoggerInterface $trace) {
    if (isset($connectionParams['guzzleClient']) !== true) {
      $guzzleOptions = array();
      $guzzleOptions['curl.options']['body_as_string'] = true;
      if (isset($connectionParams['auth']) === true) {
        $guzzleOptions['request.options']['auth'] = $connectionParams['auth'];
      }
      if (!isset($connectionParams['guzzleOptions'])) {
        $connectionParams['guzzleOptions'] = array();
      }
      $connectionParams = array_merge($connectionParams, $connectionParams['guzzleOptions']);
      $this->guzzle = new \Guzzle\Http\Client(null, $guzzleOptions);
    }
    if (isset($hostDetails['port']) !== true) {
      $hostDetails['port'] = 9200;
    }
    if (isset($connectionParams)) {
      $this->connectionOpts = $connectionParams;
    }
    return parent::__construct($hostDetails, $connectionParams, $log, $trace);
  }

  /**
   * Returns the transport schema
   *
   * @return string
   */
  public function getTransportSchema() {
    return $this->transportSchema;
  }

  /**
   * @return array
   */
  public function getLastRequestInfo() {
    return $this->lastRequest;
  }

  /**
   * Perform an HTTP request on the cluster
   *
   * @param string      $method HTTP method to use for request
   * @param string      $uri    HTTP URI to use for request
   * @param null|string $params Optional URI parameters
   * @param null|string $body   Optional request body
   * @param array       $options
   *
   * @return array
   */
  public function performRequest($method, $uri, $params = null, $body = null, $options = array()) {
    $uri = $this
      ->getURI($uri, $params);
    $options += $this->connectionOpts;
    $request = $this
      ->buildGuzzleRequest($method, $uri, $body, $options);
    self::$debugOutput[] = array(
      'request' => array(
        'method' => $method,
        'uri' => $uri,
        'params' => $params,
        'body' => $body,
        'options' => $options,
      ),
    );
    $time = time();
    $response = $this
      ->sendRequest($request, $body);
    self::$debugOutput[] = array(
      'response' => array(
        'status' => $response
          ->getStatusCode(),
        'text' => $response
          ->getBody(true),
        'info' => $response
          ->getInfo(),
      ),
    );
    return array(
      'status' => $response
        ->getStatusCode(),
      'text' => $response
        ->getBody(true),
      'info' => $response
        ->getInfo(),
    );
  }

  /**
   * @param string $uri
   * @param array $params
   *
   * @return string
   */
  private function getURI($uri, $params) {
    $uri = $this->host . $uri;
    if (isset($params) === true) {
      $uri .= '?' . http_build_query($params);
    }
    return $uri;
  }

  /**
   * @param string $method
   * @param string $uri
   * @param string $body
   * @param array $options
   *
   * @return Request
   */
  private function buildGuzzleRequest($method, $uri, $body, $options = array()) {
    if ($method === 'GET' && isset($body) === true) {
      $method = 'POST';
    }
    if (isset($body) === true) {
      $request = $this->guzzle
        ->{$method}($uri, array(), $body, $options);
    }
    else {
      $request = $this->guzzle
        ->{$method}($uri, array(), $options);
    }
    return $request;
  }

  /**
   * @param Request $request
   *
   * @param string  $body
   *
   * @throws \Elasticsearch\Common\Exceptions\TransportException
   * @return \Guzzle\Http\Message\Response
   */
  private function sendRequest(Request $request, $body) {
    try {
      $request
        ->send();
    } catch (ServerErrorResponseException $exception) {
      $this
        ->process5xxError($request, $exception, $body);
    } catch (ClientErrorResponseException $exception) {
      $this
        ->process4xxError($request, $exception, $body);
    } catch (CurlException $exception) {
      $this
        ->processCurlError($exception);
    } catch (\Exception $exception) {
      $error = 'Unexpected error: ' . $exception
        ->getMessage();
      $this->log
        ->critical($error);
      throw new TransportException($error);
    }
    $this
      ->processSuccessfulRequest($request, $body);
    return $request
      ->getResponse();
  }

  /**
   * @param Request                      $request
   * @param ServerErrorResponseException $exception
   * @param string                       $body
   *
   * @throws \Elasticsearch\Common\Exceptions\RoutingMissingException
   * @throws \Elasticsearch\Common\Exceptions\NoShardAvailableException
   * @throws \Guzzle\Http\Exception\ServerErrorResponseException
   * @throws \Elasticsearch\Common\Exceptions\NoDocumentsToGetException
   */
  private function process5xxError(Request $request, ServerErrorResponseException $exception, $body) {
    $this
      ->logErrorDueToFailure($request, $exception, $body);
    $statusCode = $request
      ->getResponse()
      ->getStatusCode();
    $exceptionText = $exception
      ->getMessage();
    $responseBody = $request
      ->getResponse()
      ->getBody(true);
    $exceptionText = "{$statusCode} Server Exception: {$exceptionText}\n{$responseBody}";
    $this->log
      ->error($exceptionText);
    if ($statusCode === 500 && strpos($responseBody, "RoutingMissingException") !== false) {
      throw new RoutingMissingException($exceptionText, $statusCode, $exception);
    }
    elseif ($statusCode === 500 && preg_match('/ActionRequestValidationException.+ no documents to get/', $responseBody) === 1) {
      throw new NoDocumentsToGetException($exceptionText, $statusCode, $exception);
    }
    elseif ($statusCode === 500 && strpos($responseBody, 'NoShardAvailableActionException') !== false) {
      throw new NoShardAvailableException($exceptionText, $statusCode, $exception);
    }
    else {
      throw new \Elasticsearch\Common\Exceptions\ServerErrorResponseException($exceptionText, $statusCode, $exception);
    }
  }
  private function process4xxError(Request $request, ClientErrorResponseException $exception, $body) {
    $this
      ->logErrorDueToFailure($request, $exception, $body);
    $statusCode = $request
      ->getResponse()
      ->getStatusCode();
    $exceptionText = $exception
      ->getMessage();
    $responseBody = $request
      ->getResponse()
      ->getBody(true);
    $exceptionText = "{$statusCode} Server Exception: {$exceptionText}\n{$responseBody}";
    if ($statusCode === 400 && strpos($responseBody, "AlreadyExpiredException") !== false) {
      throw new AlreadyExpiredException($exceptionText, $statusCode, $exception);
    }
    elseif ($statusCode === 403) {
      throw new Forbidden403Exception($exceptionText, $statusCode, $exception);
    }
    elseif ($statusCode === 404) {
      throw new Missing404Exception($exceptionText, $statusCode, $exception);
    }
    elseif ($statusCode === 409) {
      throw new Conflict409Exception($exceptionText, $statusCode, $exception);
    }
    elseif ($statusCode === 400 && strpos($responseBody, 'script_lang not supported') !== false) {
      throw new ScriptLangNotSupportedException($exceptionText . $statusCode);
    }
  }

  /**
   * @param Request    $request
   * @param \Exception $exception
   * @param string     $body
   */
  private function logErrorDueToFailure(Request $request, \Exception $exception, $body) {
    $response = $request
      ->getResponse();
    $headers = $request
      ->getHeaders()
      ->getAll();
    $this
      ->logRequestFail($request
      ->getMethod(), $request
      ->getUrl(), $response
      ->getInfo('total_time'), $headers, $response
      ->getStatusCode(), $body, $exception
      ->getMessage());
  }

  /**
   * @param CurlException $exception\
   */
  private function processCurlError(CurlException $exception) {
    $error = 'Curl error: ' . $exception
      ->getMessage();
    $this->log
      ->error($error);
    $this
      ->throwCurlException($exception
      ->getErrorNo(), $exception
      ->getError());
  }

  /**
   * @param Request $request
   * @param string  $body
   */
  private function processSuccessfulRequest(Request $request, $body) {
    $response = $request
      ->getResponse();
    $headers = $request
      ->getHeaders()
      ->getAll();
    $this
      ->logRequestSuccess($request
      ->getMethod(), $request
      ->getUrl(), $body, $headers, $response
      ->getStatusCode(), $response
      ->getBody(true), $response
      ->getInfo('total_time'));
  }

}

Members

Name	Modifiers	Type	Description	Overrides
GuzzleConnectionDebug::$connectionOpts	private	property
GuzzleConnectionDebug::$debugOutput	public static	property
GuzzleConnectionDebug::$guzzle	private	property	@var Client
GuzzleConnectionDebug::buildGuzzleRequest	private	function
GuzzleConnectionDebug::getLastRequestInfo	public	function
GuzzleConnectionDebug::getTransportSchema	public	function	Returns the transport schema
GuzzleConnectionDebug::getURI	private	function
GuzzleConnectionDebug::logErrorDueToFailure	private	function
GuzzleConnectionDebug::performRequest	public	function	Perform an HTTP request on the cluster
GuzzleConnectionDebug::process4xxError	private	function
GuzzleConnectionDebug::process5xxError	private	function
GuzzleConnectionDebug::processCurlError	private	function
GuzzleConnectionDebug::processSuccessfulRequest	private	function
GuzzleConnectionDebug::sendRequest	private	function
GuzzleConnectionDebug::__construct	public	function