EntityRESTApiHelper.php

Go to the documentation of this file.

<?php
namespace Magento\FunctionalTestingFramework\Helper;

use GuzzleHttp\Client;

class EntityRESTApiHelper
{
    const INTEGRATION_ADMIN_TOKEN_URI = '/rest/V1/integration/admin/token';

    const APPLICATION_JSON_HEADER = ['Content-Type' => 'application/json'];

    private $guzzle_client;

    public function __construct($host, $port)
    {
        $this->guzzle_client = new Client([
            'base_uri' => "http://{$host}:{$port}",
            'timeout' => 5.0,
        ]);
    }

    public function submitAuthAPIRequest($apiMethod, $requestURI, $jsonBody, $headers)
    {
        $allHeaders = $headers;
        $authTokenVal = $this->getAuthToken();
        $authToken = ['Authorization' => 'Bearer ' . $authTokenVal];
        $allHeaders = array_merge($allHeaders, $authToken);

        return $this->submitAPIRequest($apiMethod, $requestURI, $jsonBody, $allHeaders);
    }

    private function getAuthToken()
    {
        $jsonArray = json_encode(['username' => 'admin', 'password' => 'admin123']);

        $response = $this->submitAPIRequest(
            'POST',
            self::INTEGRATION_ADMIN_TOKEN_URI,
            $jsonArray,
            self::APPLICATION_JSON_HEADER
        );

        if ($response->getStatusCode() != 200) {
            throwException($response->getReasonPhrase() .' Could not get admin token from service, please check logs.');
        }

        $authToken = str_replace('"', "", $response->getBody()->getContents());
        return $authToken;
    }

    private function submitAPIRequest($apiMethod, $requestURI, $jsonBody, $headers)
    {
        $response = $this->guzzle_client->request(
            $apiMethod,
            $requestURI,
            [
                'headers' => $headers,
                'body' => $jsonBody
            ]
        );

        return $response;
    }
}