WebapiExecutor.php

Go to the documentation of this file.

<?php
namespace Magento\FunctionalTestingFramework\DataGenerator\Persist\Curl;

use Magento\FunctionalTestingFramework\Exceptions\TestFrameworkException;
use Magento\FunctionalTestingFramework\Util\Protocol\CurlInterface;
use Magento\FunctionalTestingFramework\Util\Protocol\CurlTransport;

class WebapiExecutor extends AbstractExecutor implements CurlInterface
{
    private $transport;

    private $headers = [
        'Accept: application/json',
        'Content-Type: application/json',
    ];

    private $response;

    const ADMIN_AUTH_URL = '/V1/integration/admin/token';

    private $storeCode;

    public function __construct($storeCode = null)
    {
        if (!isset(parent::$baseUrl)) {
            parent::resolveBaseUrl();
        }

        $this->storeCode = $storeCode;
        $this->transport = new CurlTransport();
        $this->authorize();
    }

    protected function authorize()
    {
        $authUrl = $this->getFormattedUrl(self::ADMIN_AUTH_URL);
        $authCreds = [
            'username' => getenv('MAGENTO_ADMIN_USERNAME'),
            'password' => getenv('MAGENTO_ADMIN_PASSWORD')
        ];

        $this->transport->write($authUrl, json_encode($authCreds), CurlInterface::POST, $this->headers);
        $this->headers = array_merge(
            ['Authorization: Bearer ' . str_replace('"', "", $this->read())],
            $this->headers
        );
    }

    public function write($url, $data = [], $method = CurlInterface::POST, $headers = [])
    {
        $this->transport->write(
            $this->getFormattedUrl($url),
            json_encode($data, JSON_PRETTY_PRINT),
            $method,
            array_unique(array_merge($headers, $this->headers))
        );
    }

    public function read($successRegex = null, $returnRegex = null)
    {
        $this->response = $this->transport->read();
        return $this->response;
    }

    public function addOption($option, $value)
    {
        $this->transport->addOption($option, $value);
    }

    public function close()
    {
        $this->transport->close();
    }

    public function getFormattedUrl($resource)
    {
        $urlResult = parent::$baseUrl . 'rest/';
        if ($this->storeCode != null) {
            $urlResult .= $this->storeCode . "/";
        }
        $urlResult.= trim($resource, "/");
        return $urlResult;
    }
}