Allow specifying Curl implementation

Author: g105b

src/Http.php

@@ -1,6 +1,8 @@
 <?php
 namespace Gt\Fetch;
 
+use Gt\Curl\Curl;
+use Gt\Curl\CurlMulti;
 use Gt\Http\Uri;
 use Http\Promise\Promise as HttpPromise;
 use Http\Client\HttpClient;
@@ -33,13 +35,19 @@ class Http implements HttpClient, HttpAsyncClient {
 
 	public function __construct(
 		array $options = [],
-		float $interval = 0.01
+		float $interval = 0.01,
+		string $curlClass = Curl::class,
+		string $curlMultiClass = CurlMulti::class
 	) {
 		$this->options = $options + $this->options;
 		$this->interval = $interval;
 
 		$this->loop = LoopFactory::create();
-		$this->requestResolver = new RequestResolver($this->loop);
+		$this->requestResolver = new RequestResolver(
+			$this->loop,
+			$curlClass,
+			$curlMultiClass
+		);
 		$this->timer = $this->loop->addPeriodicTimer(
 			$this->interval,
 			[$this->requestResolver, "tick"]
@@ -114,12 +122,15 @@ public function getOptions():array {
 	}
 
 	/**
-	 * @param string|UriInterface $uri
+	 * @param string|UriInterface $input
 	 * @return string
 	 */
-	public function ensureUriInterface($uri):UriInterface {
-		if(is_string($uri)) {
-			$uri = new Uri($uri);
+	public function ensureUriInterface($input):UriInterface {
+		if($input instanceof RequestInterface) {
+			$uri = $input->getUri();
+		}
+		else {
+			$uri = new Uri($input);
 		}
 
 		return $uri;

src/RequestResolver.php

@@ -26,20 +26,31 @@ class RequestResolver {
 	/** @var string[] */
 	protected $headerList;
 
-	public function __construct(LoopInterface $loop) {
+	protected $curlClass;
+	protected $curlMultiClass;
+
+	public function __construct(
+		LoopInterface $loop,
+		string $curlClass,
+		string $curlMultiClass
+	) {
 		$this->loop = $loop;
 		$this->curlList = [];
 		$this->curlMultiList = [];
 		$this->deferredList = [];
 		$this->headerList = [];
+
+		$this->curlClass = $curlClass;
+		$this->curlMultiClass = $curlMultiClass;
 	}
 
 	public function add(
 		UriInterface $uri,
 		array $init,
 		Deferred $deferred
 	):void {
-		$curl = new Curl($uri);
+		/** @var CurlInterface $curl */
+		$curl = new $this->curlClass($uri);
 
 		if(!empty($init["curlopt"])) {
 			$curl->setOptArray($init["curlopt"]);
@@ -50,7 +61,8 @@ public function add(
 		$curl->setOpt(CURLOPT_HEADERFUNCTION, [$this, "writeHeader"]);
 		$curl->setOpt(CURLOPT_WRITEFUNCTION, [$this, "writeBody"]);
 
-		$curlMulti = new CurlMulti();
+		/** @var CurlMultiInterface $curlMulti */
+		$curlMulti = new $this->curlMultiClass();
 		$curlMulti->add($curl);
 
 		$this->curlList []= $curl;