Knp\FriendlyContexts\Context\ApiContext

Complexity

Total Complexity

40

Size/Duplication

Total Lines	272
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Importance

Changes	5
Bugs	0	Features	0

17 Methods

Rating	Name	Duplication	Size	Complexity
A	getResponse()	0	4	1
A	getHeaders()	0	16	4
A	iPrepareRequest()	0	15	2
A	iSpecifiedTheFollowingHttpAuthentication()	0	8	1
A	iSpecifiedTheFollowingOauthCredentials()	0	8	1
A	iSpecifiedHeaders()	0	4	1
A	iSpecifiedQueries()	0	4	1
B	iSpecifiedTheBody()	0	12	5
A	iSpecifiedData()	0	10	2
A	iSpecifiedFiles()	0	12	3
A	iSpecifiedCookies()	0	4	1
A	iSpecifiedOptions()	0	4	1
A	iSendTheRequest()	0	8	2
B	iShouldReceiveResponse()	0	43	5
A	theResponseShouldContainsHeaders()	0	12	2
C	theResponsShouldContainsJson()	0	35	7
A	theResponseShouldContains()	0	4	1

<?php

namespace Knp\FriendlyContexts\Context;

use Behat\Gherkin\Node\TableNode;
use Behat\Gherkin\Node\PyStringNode;
use Guzzle\Common\ToArrayInterface;
use Guzzle\Http\Exception\BadResponseException;
use Knp\FriendlyContexts\Http\Security\HttpExtension;

class ApiContext extends RawPageContext
{
    protected $response;

    public function getResponse()
    {
        return $this->response;
    }

    protected function getHeaders()
    {
        if (null !== $this->response) {
            throw new \InvalidArgumentException('First, you need to send a request.');
        }

        $headers = $this->response->getHeaders();

        if ($headers instanceof ToArrayInterface) {
            return $headers->toArray();
        } elseif (is_array($headers)) {
            return $headers;
        }

        throw new \RuntimeException('Unable to retrieve response headers.');
    }

    /**
     * @Given /^I prepare a (?<method>[A-Za-z]+) request on "(?<page>[^"].*)?"$/
     * @Given /^I prepare a (?<method>[A-Za-z]+) request on the (.*) (?<hasPage>page|resource)$/
     * @Given /^I prepare a (?<method>[A-Za-z]+) request on the (.*) (?<hasPage>page|resource) with:?$/
     */
    public function iPrepareRequest($method, $page, $hasPage = false, TableNode $table = null)
    {
        $hasPage = (bool)$hasPage;
        $method  = strtoupper($method);

        $this->getRequestBuilder()->setMethod($method);

        if ($hasPage) {
            $path = $this->getPagePath($page, $table);
        } else {
            $path = $page;
        }

        $this->getRequestBuilder()->setUri($path);
    }

    /**
     * @Given /^I specified the following request http (?<scheme>[a-z]+) credentials:?$/
     */
    public function iSpecifiedTheFollowingHttpAuthentication(TableNode $credentialsTable, $scheme)
    {
        $this
            ->getRequestBuilder()
            ->setCredentials($credentialsTable->getRowsHash())
            ->addSecurityExtension(new HttpExtension($scheme))
        ;
    }

    /**
     * @Given /^I specified the following request oauth credentials:?$/
     */
    public function iSpecifiedTheFollowingOauthCredentials(TableNode $credentialsTable)
    {
        $this
            ->getRequestBuilder()
            ->setCredentials($credentialsTable->getRowsHash())
            ->addSecurityExtension(new OauthExtension)
        ;
    }

    /**
     * @Given /^I specified the following request headers:?$/
     */
    public function iSpecifiedHeaders(TableNode $table)
    {
        $this->getRequestBuilder()->setHeaders($table->getRowsHash());
    }

    /**
     * @Given /^I specified the following request queries:?$/
     */
    public function iSpecifiedQueries(TableNode $table)
    {
        $this->getRequestBuilder()->setQueries($table->getRowsHash());
    }

    /**
     * @Given /^I specified the following request body:?$/
     */
    public function iSpecifiedTheBody($data)
    {
        if (is_object($data) and $data instanceof TableNode) {

Using logical operators such as and instead of && is generally not recommended.

            $data = $data->getRowsHash();
        }

        if (is_object($data) and $data instanceof PyStringNode) {

Using logical operators such as and instead of && is generally not recommended.

            $data = (string)$data;
        }

        $this->getRequestBuilder()->setBody($data);
    }

    /**
     * @Given /^I specified the following request data:?$/
     */
    public function iSpecifiedData(TableNode $dataTable)
    {
        $requestBuilder = $this->getRequestBuilder();

        if ('POST' === $requestBuilder->getMethod()) {
            $requestBuilder->setPostBody($dataTable->getRowsHash());
        } else {
            $requestBuilder->setBody($dataTable->getRowsHash());
        }
    }

    /**
     * @Given /^I specified the following request files:?$/
     */
    public function iSpecifiedFiles(TableNode $fileTable)
    {
        $requestBuilder = $this->getRequestBuilder();

        if ('POST' !== $requestBuilder->getMethod()) {
            throw new \RuntimeException('You can\'t send files with a non POST method');
        }

        foreach ($fileTable->getRowsHash() as $name => $path) {
            $requestBuilder->addFile($name, $path);
        }
    }

    /**
     * @Given /^I specified the following request cookies:?$/
     */
    public function iSpecifiedCookies(TableNode $cookiesTable)
    {
        $this->getRequestBuilder()->setCookies($cookiesTable->getRowsHash());
    }

    /**
     * @Given /^I specified the following request options:?$/
     */
    public function iSpecifiedOptions(TableNode $optionsTable)
    {
        $this->getRequestBuilder()->setOptions($optionsTable->getRowsHash());
    }

    /**
     * @When /^I send the request$/
     */
    public function iSendTheRequest()
    {
        try {
            $this->response = $this->getRequestBuilder()->build()->send();
        } catch (BadResponseException $e) {
            $this->response = $e->getResponse();
        }
    }

    /**
     * @Then /^I should receive a (?<httpCode>[0-9]+) response$/
     * @Then /^I should receive a (?<httpCode>[0-9]+) (?<shortType>[a-zA-Z]+) response$/
     */
    public function iShouldReceiveResponse($httpCode, $shortType = null)
    {
        $httpCode = (int)$httpCode;

        if (null === $this->response) {
            throw new \RuntimeException('You must send a request before testing a response.');
        }

        $this->getAsserter()->assertEquals(
            $httpCode,
            $this->response->getStatusCode(),
            sprintf(
                'Expecting response code to be "%d" but "%d" given',
                $httpCode,
                $this->response->getStatusCode()
            )
        );

        if (null !== $shortType) {
            $contentTypes = $this->getHttpContentTypeGuesser()->guess($shortType);

            foreach ($contentTypes as $contentType) {
                try {
                    $formatedContentType = explode(';', $this->response->getContentType());
                    $formatedContentType = $formatedContentType[0];

                    $this
                        ->getAsserter()
                        ->assertEquals($contentType, $formatedContentType)
                     ;
                    return;
                } catch (\Exception $e) {
                    continue;
                }
            }

            throw new \Exception(sprintf(
                'The response Content-Type ("%s") is not a(n) "%s" response type',
                $formatedContentType,
                $shortType
            ));
        }
    }

    /**
     * @Then /^the response should contains? the following headers:?$/
     */
    public function theResponseShouldContainsHeaders(TableNode $headerTable)
    {
        if (null === $this->response) {
            throw new \RuntimeException('You must send a request before testing a response.');
        }

        $expectedHeaders = $headerTable->getRowsHash();
        $this->getAsserter()->assertArrayContains(
            $expectedHeaders,
            $this->getHeaders()
        );
    }

    /**
     * @Then /^the response should contains? the following json:?$/
     */
    public function theResponsShouldContainsJson($jsonData)
    {
        if (!is_object($jsonData)) {
            throw new \InvalidArgumentException('Invalid json data');
        }

        $json = false;

        if ($jsonData instanceof PyStringNode) {
            $json = json_decode($jsonData->getRaw(), true);
        } elseif ($jsonData instanceof TableNode) {
            $json = $jsonData->getRowsHash();
        } elseif ($jsonData instanceof \stdClass || true === is_array($jsonData)) {
            $json = $jsonData;
        }

        if (false === $json) {
            throw new \InvalidArgumentException(sprintf(
                'Invalid json data class ("%s")',
                get_class($jsonData)
            ));
        }

        $expected = json_encode($json);
        $real     = json_encode($this->response->json());

        $this->getAsserter()->assertEquals(
            $expected,
            $real,
            sprintf("The given json\r\n\r\n%s\r\nis not equal to the expected\r\n\r\n%s",
                $real,
                $expected
            )
        );
    }

    /**
     * @Then /^the response should contains?:?$/
     */
    public function theResponseShouldContains(PyStringNode $bodyNode)
    {
        $this->getAsserter()->assertEquals($bodyNode->getRaw(), $this->response->getBody(true));
    }
}