RestResponse.php in Salesforce Suite 5.0.x

Namespace

Drupal\salesforce\Rest

File

src/Rest/RestResponse.php

<?php

namespace Drupal\salesforce\Rest;

use Drupal\Component\Serialization\Json;
use Drupal\Core\StringTranslation\StringTranslationTrait;
use GuzzleHttp\Psr7\Response;
use Psr\Http\Message\ResponseInterface;

/**
 * Class RestResponse.
 *
 * @package Drupal\salesforce\Rest
 */
class RestResponse extends Response {
  use StringTranslationTrait;

  /**
   * The original Response used to build this object.
   *
   * @var \GuzzleHttp\Psr7\Response
   * @see __get()
   */
  protected $response;

  /**
   * The json-decoded response body.
   *
   * @var mixed
   * @see __get()
   */
  protected $data;

  /**
   * RestResponse constructor.
   *
   * @param \Psr\Http\Message\ResponseInterface $response
   *   A response.
   */
  public function __construct(ResponseInterface $response) {
    $this->response = $response;
    parent::__construct($response
      ->getStatusCode(), $response
      ->getHeaders(), $response
      ->getBody(), $response
      ->getProtocolVersion(), $response
      ->getReasonPhrase());
    $this
      ->handleJsonResponse();
  }

  /**
   * Magic getter method to return the given property.
   *
   * @param string $key
   *   The property name.
   *
   * @return mixed
   *   The property value.
   *
   * @throws \Exception
   *   If $key property does not exist.
   */
  public function __get($key) {
    if (!property_exists($this, $key)) {
      throw new \Exception("Undefined property {$key}");
    }
    return $this->{$key};
  }

  /**
   * Helper function to eliminate repetitive json parsing.
   *
   * @return $this
   *
   * @throws \Drupal\salesforce\Rest\RestException
   */
  private function handleJsonResponse() {
    $this->data = '';
    $response_body = $this
      ->getBody()
      ->getContents();
    if (empty($response_body)) {
      return NULL;
    }

    // Allow any exceptions here to bubble up:
    try {
      $data = Json::decode($response_body);
    } catch (\Exception $e) {
      throw new RestException($this, $e
        ->getMessage(), $e
        ->getCode(), $e);
    }
    if (empty($data) || !is_array($data)) {
      throw new RestException($this, $this
        ->t('Invalid response'));
    }
    if (!empty($data['error'])) {
      throw new RestException($this, $data['error']);
    }
    if (!empty($data[0]) && count($data) == 1) {
      $data = $data[0];
    }
    if (!empty($data['error'])) {
      throw new RestException($this, $data['error']);
    }
    if (!empty($data['errorCode'])) {
      throw new RestException($this, $data['errorCode']);
    }
    $this->data = $data;
    return $this;
  }

}

Classes

Name	Description
RestResponse	Class RestResponse.