MultiHttp\MultiRequest

Complexity

Total Complexity

15

Size/Duplication

Total Lines	94
Duplicated Lines	9.57 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	create()	0	8	2
A	prepare()	0	4	1
A	add()	9	10	1
A	addOptions()	0	11	3
A	import()	0	9	2
B	execute()	0	27	5

<?php

namespace MultiHttp;

use MultiHttp\Exception\InvalidArgumentException;

/**
 *
 * @author  qiangjian@staff.sina.com.cn sunsky303@gmail.com
 * Date: 2017/6/9
 * Time: 15:09
 * @version $Id: $
 * @since 1.0
 * @copyright Sina Corp.
 */
class MultiRequest
{
    protected static $requestPool;
    protected static $multiHandler;
    private static $instance;

    protected function __construct()
    {
    }

    public static function create(): MultiRequest
    {
        if (!(self::$instance instanceof self)) {
            self::$instance = new self;
        }
        self::prepare();
        return self::$instance;
    }

    protected static function prepare(): void
    {
        self::$multiHandler = curl_multi_init();
    }

    public function add($method, $uri, $payload, array $options = array())

This method seems to be duplicated in your project.

    {
        $options = array(
                'method' => $method,
                'url' => $uri,
                'data' => $payload,
            ) + $options;
        $this->addOptions(array($options));
        return $this;
    }

    /**
     * @param array $URLOptions
     * example: array(array('url'=>'http://localhost:9999/','timeout'=>1, 'method'=>'POST', 'data'=>'aa=bb&c=d'))
     * @return $this
     */
    public function addOptions(array $URLOptions)
    {
        foreach ($URLOptions as $options) {
            $request = Request::create()->addOptions($options)->applyOptions();
            if (isset($options['callback'])) {
                $request->onEnd($options['callback']);
            }
            $this->import($request);
        }
        return $this;
    }

    public function import(Request $request)
    {
        if (!is_resource($request->curlHandle)) {
            throw new InvalidArgumentException('Request curl handle is not initialized');
        }
        curl_multi_add_handle(self::$multiHandler, $request->curlHandle);
        self::$requestPool[] = $request;
        return $this;
    }

    /**
     * @return array(Response)

The doc-type array(Response) could not be parsed: Expected "|" or "end of type", but got "(" at position 5. (view supported doc-types)

     */
    public function execute()
    {
        $sleepTime = 1000;//microsecond, prevent  CPU 100%
        do {
            curl_multi_exec(self::$multiHandler, $active);
            // bug in PHP 5.3.18+ where curl_multi_select can return -1
            // https://bugs.php.net/bug.php?id=63411
            if (curl_multi_select(self::$multiHandler) == -1) {
                usleep($sleepTime);
            }
            usleep($sleepTime);
        } while ($active);
        $return = array();
        foreach (self::$requestPool as $request) {
            $response = $request->makeResponse(true);
            $func = $response->request->endCallback();
            if (isset($func)) {
                $func($response);
            }
            $return[] = $response;
            curl_multi_remove_handle(self::$multiHandler, $request->curlHandle);
            curl_close($request->curlHandle);
        }
        curl_multi_close(self::$multiHandler);
        self::$requestPool = null;
        return $return;
    }

}