mpyw\Cowitter\Traits\RequestorTrait

Complexity

Total Complexity

25

Size/Duplication

Total Lines	132
Duplicated Lines	0 %

Test Coverage

Coverage

79.17%

Importance

Changes

0

19 Methods

Rating	Name	Duplication	Size	Complexity
A	post()	0	3	1
A	getAsync()	0	3	1
A	get()	0	3	1
A	deleteAsync()	0	3	1
A	postAsync()	0	3	1
A	postMultipartAsync()	0	3	1
A	putAsync()	0	3	1
A	delete()	0	3	1
A	postOut()	0	3	1
A	getOut()	0	3	1
A	postMultipart()	0	3	1
A	postJson()	0	3	1
A	streamingAsync()	0	13	4
A	postMultipartOut()	0	3	1
A	postOutAsync()	0	3	1
A	getOutAsync()	0	3	1
A	put()	0	3	1
A	streaming()	0	10	4
A	postMultipartOutAsync()	0	3	1

<?php

namespace mpyw\Cowitter\Traits;

use mpyw\Co\CoInterface;
use mpyw\Co\CURLException;
use mpyw\Cowitter\Components\StreamHandler;
use mpyw\Cowitter\Helpers\CurlExecutor;

trait RequestorTrait
{
    abstract protected function getInternalCurl();

    public function getAsync($endpoint, array $params = [], $return_response_object = false)
    {
        yield CoInterface::RETURN_WITH => (yield CurlExecutor::execDecodedAsync($this->getInternalCurl()->get($endpoint, $params), $return_response_object));
        // @codeCoverageIgnoreStart
    }
    // @codeCoverageIgnoreEnd

    public function postAsync($endpoint, array $params = [], $return_response_object = false)
    {
        yield CoInterface::RETURN_WITH => (yield CurlExecutor::execDecodedAsync($this->getInternalCurl()->post($endpoint, $params), $return_response_object));
        // @codeCoverageIgnoreStart
    }
    // @codeCoverageIgnoreEnd

    public function deleteAsync($endpoint, array $params = [], $return_response_object = false)
    {
        yield CoInterface::RETURN_WITH => (yield CurlExecutor::execDecodedAsync($this->getInternalCurl()->delete($endpoint, $params), $return_response_object));
        // @codeCoverageIgnoreStart
    }
    // @codeCoverageIgnoreEnd

    public function putAsync($endpoint, array $params = [], $return_response_object = false)
    {
        yield CoInterface::RETURN_WITH => (yield CurlExecutor::execDecodedAsync($this->getInternalCurl()->put($endpoint, $params), $return_response_object));
        // @codeCoverageIgnoreStart
    }
    // @codeCoverageIgnoreEnd

    public function postMultipartAsync($endpoint, array $params = [], $return_response_object = false)
    {
        yield CoInterface::RETURN_WITH => (yield CurlExecutor::execDecodedAsync($this->getInternalCurl()->postMultipart($endpoint, $params), $return_response_object));
        // @codeCoverageIgnoreStart
    }
    // @codeCoverageIgnoreEnd

    public function get($endpoint, array $params = [], $return_response_object = false)
    {
        return CurlExecutor::execDecoded($this->getInternalCurl()->get($endpoint, $params), $return_response_object);
    }

    public function post($endpoint, array $params = [], $return_response_object = false)
    {
        return CurlExecutor::execDecoded($this->getInternalCurl()->post($endpoint, $params), $return_response_object);
    }

    public function postJson($endpoint, array $params = [], $return_response_object = false)
    {
        return CurlExecutor::execDecoded($this->getInternalCurl()->postJson($endpoint, $params), $return_response_object);
    }

    public function delete($endpoint, array $params = [], $return_response_object = false)
    {
        return CurlExecutor::execDecoded($this->getInternalCurl()->delete($endpoint, $params), $return_response_object);
    }

    public function put($endpoint, array $params = [], $return_response_object = false)
    {
        return CurlExecutor::execDecoded($this->getInternalCurl()->put($endpoint, $params), $return_response_object);
    }

    public function postMultipart($endpoint, array $params = [], $return_response_object = false)
    {
        return CurlExecutor::execDecoded($this->getInternalCurl()->postMultipart($endpoint, $params), $return_response_object);
    }

    public function streamingAsync($endpoint, callable $event_handler, array $params = [], callable $header_response_handler = null)
    {
        $handler = new StreamHandler($header_response_handler, $event_handler);
        $ch = $this->getInternalCurl()->streaming($endpoint, $params, $handler);
        try {
            yield $ch;
        } catch (CURLException $e) {
            if (!$handler->isHaltedByUser()) {
                throw $e;
            }
        }
        if (!$handler->isHaltedByUser()) {
            throw new \UnexpectedValueException('Streaming stopped unexpectedly.');
        }
    }

    public function streaming($endpoint, callable $event_handler, array $params = [], callable $header_response_handler = null)
    {
        $handler = new StreamHandler($header_response_handler, $event_handler);
        $ch = $this->getInternalCurl()->streaming($endpoint, $params, $handler);
        $result = curl_exec($ch);
        if (!$handler->isHaltedByUser() && $result === false) {
            throw new CURLException(curl_error($ch), curl_errno($ch), $ch);
        }
        if (!$handler->isHaltedByUser()) {
            throw new \UnexpectedValueException('Streaming stopped unexpectedly.');
        }
    }

    public function getOutAsync($endpoint, array $params = [], $return_response_object = false)
    {
        yield CoInterface::RETURN_WITH => (yield CurlExecutor::execDecodedAsync($this->getInternalCurl()->getOut($endpoint, $params), $return_response_object));
        // @codeCoverageIgnoreStart
    }
    // @codeCoverageIgnoreEnd

    public function postOutAsync($endpoint, array $params = [], $return_response_object = false)
    {
        yield CoInterface::RETURN_WITH => (yield CurlExecutor::execDecodedAsync($this->getInternalCurl()->postOut($endpoint, $params), $return_response_object));
        // @codeCoverageIgnoreStart
    }
    // @codeCoverageIgnoreEnd

    public function postMultipartOutAsync($endpoint, array $params = [], $return_response_object = false)
    {
        yield CoInterface::RETURN_WITH => (yield CurlExecutor::execDecodedAsync($this->getInternalCurl()->postMultipartOut($endpoint, $params), $return_response_object));
        // @codeCoverageIgnoreStart
    }
    // @codeCoverageIgnoreEnd

    public function getOut($endpoint, array $params = [], $return_response_object = false)
    {
        return CurlExecutor::execDecoded($this->getInternalCurl()->getOut($endpoint, $params), $return_response_object);
    }

    public function postOut($endpoint, array $params = [], $return_response_object = false)
    {
        return CurlExecutor::execDecoded($this->getInternalCurl()->postOut($endpoint, $params), $return_response_object);
    }

    public function postMultipartOut($endpoint, array $params = [], $return_response_object = false)
    {
        return CurlExecutor::execDecoded($this->getInternalCurl()->postMultipartOut($endpoint, $params), $return_response_object);
    }
}