mpyw\Cowitter\Helpers\ResponseYielder

Complexity

Total Complexity

15

Size/Duplication

Total Lines	57
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

69.05%

Importance

Changes	2
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
B	syncExec()	0	18	5
A	asyncExec()	0	15	4
A	syncExecDecoded()	0	9	3
A	asyncExecDecoded()	0	9	3

<?php

namespace mpyw\Cowitter\Helpers;

use mpyw\Co\CURLException;
use mpyw\Co\CoInterface;
use mpyw\Cowitter\Response;
use mpyw\Cowitter\Helpers\ResponseBodyDecoder;

class ResponseYielder
{
    public static function syncExec($ch)
    {
        if (false === $buffer = curl_exec($ch)) {
            throw new CURLException(curl_error($ch), curl_errno($ch), $ch);
        }
        $response = new Response($buffer, $ch);
        if ($response->getStatusCode() >= 300 &&
            $response->getStatusCode() < 400 &&
            '' !== $url = $response->getHeaderLine('Location')) {
            curl_setopt_array($ch, [
                CURLOPT_URL => $url,
                CURLOPT_HTTPGET => true,
                CURLOPT_REFERER => curl_getinfo($ch, CURLINFO_EFFECTIVE_URL),
            ]);
            return static::syncExec($ch);
        }
        return $response;
    }

    public static function asyncExec($ch)
    {
        $response = new Response((yield $ch), $ch);
        if ($response->getStatusCode() >= 300 &&
            $response->getStatusCode() < 400 &&
            '' !== $url = $response->getHeaderLine('Location')) {
            curl_setopt_array($ch, [
                CURLOPT_URL => $url,
                CURLOPT_HTTPGET => true,
                CURLOPT_REFERER => curl_getinfo($ch, CURLINFO_EFFECTIVE_URL),
            ]);
            yield CoInterface::RETURN_WITH => static::syncExec($ch);
        }
        yield CoInterface::RETURN_WITH => $response;
    }

    public static function syncExecDecoded($ch, $return_response_object = false)
    {
        $response = static::syncExec($ch);
        $response = ResponseBodyDecoder::getDecodedResponse($response, $ch);
        if (!$return_response_object) {
            $response = $response->hasContent() ? $response->getContent() : null;
        }
        return $response;
    }

    public static function asyncExecDecoded($ch, $return_response_object = false)
    {
        $response = (yield static::asyncExec($ch));
        $response = ResponseBodyDecoder::getDecodedResponse($response, $ch);
        if (!$return_response_object) {
            $response = $response->hasContent() ? $response->getContent() : null;
        }
        yield CoInterface::RETURN_WITH => $response;
    }
}