AsyncHttpClient\Core\AsyncHttpClientDefault

Complexity

Total Complexity

6

Size/Duplication

Total Lines	89
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	addService()	0	4	1
A	send()	0	17	2
A	createRequest()	0	7	1
A	defineHandlers()	0	19	1

<?php
/**
 * Created by PhpStorm.
 * User: christian
 * Date: 12/24/16
 * Time: 8:12 PM
 */

namespace AsyncHttpClient\Core;


use AsyncHttpClient\Logger\AsyncHttpLogger;
use AsyncHttpClient\Service\AsyncHttpService;
use React\EventLoop\LoopInterface;
use React\HttpClient\Client as ReactClient;
use React\HttpClient\Request;
use React\HttpClient\Response;

class AsyncHttpClientDefault implements AsyncHttpClient
{

    /**
     * @var AsyncHttpService[]
     */
    private $services = [];

    /**
     * @var ReactClient
     */
    private $client;

    /**
     * @var LoopInterface
     */
    private $loop;

    /**
     * @var AsyncHttpLogger
     */
    private $logger;

    /**
     * AsyncServiceExecutor constructor.
     *
     * @param ReactClient     $client
     * @param LoopInterface   $loop
     * @param AsyncHttpLogger $logger
     */
    public function __construct(ReactClient $client, LoopInterface $loop, AsyncHttpLogger $logger)
    {
        $this->client = $client;
        $this->loop   = $loop;
        $this->logger = $logger;
    }


    public function addService(AsyncHttpService $service)
    {
        $this->services[] = $service;
    }

    public function send()
    {
        $startTime = microtime(true);

        while (count($this->services) > 0) {
            $service = array_shift($this->services);
            $request = $this->createRequest($service);

            $this->defineHandlers($request, $service);

            $request->end();
        }

        $this->loop->run();

        $this->logger->logTotal($startTime);
    }

    private function createRequest(AsyncHttpService $service)
    {
        $request = $this->client->request($service->getMethod(), $service->getUrl(), $service->getHeaders());
        $request->write($service->getContent());
        
        return $request;
    }

    private function defineHandlers(Request $request, AsyncHttpService $service)
    {
        $start = microtime(true);

        $request->on('response', function (Response $response) use ($start, $service) {

            $response->on('data', function ($data, Response $response) use ($start, $service) {

                $service->execute($data, $response);

                $this->logger->log($service->getMethod(), $service->getUrl(), $data, $start);
            }
            );

            // TODO: Implements error case
            // $response->on('error', ...);

73% of this comment could be valid code. Did you maybe forget this after debugging?

        }
        );
    }
}