RestClient.php

Go to the documentation of this file.

<?php
namespace Magento\TestFramework\TestCase\Webapi\Adapter\Rest;

use Magento\TestFramework\TestCase\HttpClient\CurlClient;
use Magento\TestFramework\Helper\JsonSerializer;
use Magento\TestFramework\Helper\Bootstrap;

class RestClient
{
    const EMPTY_REQUEST_BODY = 'Empty body';

    private $restBasePath = '/rest/';

    private $curlClient;

    private $jsonSerializer;

    public function __construct(
        \Magento\TestFramework\TestCase\HttpClient\CurlClient $curlClient = null,
        \Magento\TestFramework\Helper\JsonSerializer $jsonSerializer = null
    ) {
        $objectManager = Bootstrap::getObjectManager();
        $this->curlClient = $curlClient ? : $objectManager->get(CurlClient::class);
        $this->jsonSerializer = $jsonSerializer ? : $objectManager->get(JsonSerializer::class);
    }

    public function get($resourcePath, $data = [], $headers = [])
    {
        $url = $this->constructResourceUrl($resourcePath);
        if (!empty($data)) {
            $url .= '?' . http_build_query($data);
        }

        $responseBody = $this->curlClient->get($url, $data, $headers);
        return $this->jsonSerializer->jsonDecode($responseBody);
    }

    public function post($resourcePath, $data, $headers = [])
    {
        $url = $this->constructResourceUrl($resourcePath);
        if (in_array("Content-Type: application/json", $headers)) {
            // json encode data
            if ($data != self::EMPTY_REQUEST_BODY) {
                $data = $this->jsonSerializer->jsonEncode($data);
            } else {
                $data = '';
            }
        }
        $responseBody = $this->curlClient->post($url, $data, $headers);
        return $this->jsonSerializer->jsonDecode($responseBody);
    }

    public function put($resourcePath, $data, $headers = [])
    {
        $url = $this->constructResourceUrl($resourcePath);
        if (in_array("Content-Type: application/json", $headers)) {
            // json encode data
            if ($data != self::EMPTY_REQUEST_BODY) {
                $data = $this->jsonSerializer->jsonEncode($data);
            } else {
                $data = '';
            }
        }
        $responseBody = $this->curlClient->put($url, $data, $headers);
        return $this->jsonSerializer->jsonDecode($responseBody);
    }

    public function delete($resourcePath, $headers = [])
    {
        $url = $this->constructResourceUrl($resourcePath);
        $responseBody = $this->curlClient->delete($url, $headers);
        return $this->jsonSerializer->jsonDecode($responseBody);
    }

    public function constructResourceUrl($resourcePath)
    {
        return rtrim(TESTS_BASE_URL, '/') . $this->restBasePath . ltrim($resourcePath, '/');
    }
}