mpyw\Cowitter\Traits\RequestorTrait

Complexity

Total Complexity

20

Size/Duplication

Total Lines	93
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes	4
Bugs	2	Features	0

15 Methods

Rating	Name	Duplication	Size	Complexity
	getInternalCurl()	0	1	?
A	getAsync()	0	4	1
A	postAsync()	0	4	1
A	postMultipartAsync()	0	4	1
A	get()	0	4	1
A	post()	0	4	1
A	postMultipart()	0	4	1
A	streaming()	0	12	4
A	streamingAsync()	0	15	4
A	getOutAsync()	0	4	1
A	postOutAsync()	0	4	1
A	postMultipartOutAsync()	0	4	1
A	getOut()	0	4	1
A	postOut()	0	4	1
A	postMultipartOut()	0	4	1

<?php

namespace mpyw\Cowitter\Traits;

use mpyw\Co\CURLException;
use mpyw\Cowitter\Components\StreamHandler;
use mpyw\Cowitter\Helpers\ResponseYielder;

trait RequestorTrait
{
    abstract protected function getInternalCurl();

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

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

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

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

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

    public function postMultipart($endpoint, array $params = [], $return_response_object = false)
    {
        return ResponseYielder::syncExecDecoded($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)
    {
        return ResponseYielder::asyncExecDecoded($this->getInternalCurl()->getOut($endpoint, $params), $return_response_object);
    }

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

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

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

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

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