Test fetch function with ResponseSimulator

Author: g105b

src/RequestResolver.php

@@ -149,6 +149,10 @@ public function tick():void {
 					$this->responseList[$i]->endDeferredResponse();
 					$this->responseList[$i] = null;
 				}
+				if($this->deferredList[$i]) {
+					$this->deferredList[$i]->resolve($this->responseList[$i]);
+					$this->deferredList[$i] = null;
+				}
 			}
 		}
 

test/unit/Helper/ResponseSimulator.php

@@ -0,0 +1,94 @@
+<?php
+namespace Gt\Fetch\Test\Helper;
+
+class ResponseSimulator {
+	const RANDOM_BODY_WORDS = ["pursuit","forest","gravel","timber","wonder","eject","slogan","monkey","construct","earthquake","respect","publish","forward","circle","summer","define","highlight","refuse","salon","theater","lily","earwax","variant","account","resource"];
+	static protected $headerCallback;
+	static protected $bodyCallback;
+	static protected $headerBuffer;
+	static protected $bodyBuffer;
+	static protected $started = false;
+
+	static public function setHeaderCallback(callable $callback) {
+		self::$headerCallback = $callback;
+	}
+
+	static public function setBodyCallback(callable $callback) {
+		self::$bodyCallback = $callback;
+	}
+
+	static public function start() {
+		self::$started = true;
+		self::$headerBuffer = self::generateRandomHeaders();
+		self::$bodyBuffer = self::generateRandomBody();
+	}
+
+	static protected function generateRandomHeaders():array {
+		$headers = [];
+
+		$headers []= "HTTP/0.0 999 OK";
+		$headers []= "Date: " . date("D, d M Y H:i:s T");
+		$headers []= "Repository: PhpGt/Fetch";
+
+		$length = rand(1, 10);
+		for($i = 0; $i < $length; $i++) {
+			$randIndex = array_rand(self::RANDOM_BODY_WORDS);
+			$key = self::RANDOM_BODY_WORDS[$randIndex];
+			$value = uniqid();
+			$headers []= "$key: $value";
+		}
+
+		foreach($headers as $i => $h) {
+			$headers[$i] .= "\r\n";
+		}
+
+		$headers []= "\r\n";
+
+		return $headers;
+	}
+
+	static protected function generateRandomBody():string {
+		$body = "";
+		$length = rand(10, 100);
+		for($i = 0; $i < $length; $i++) {
+			$randIndex = array_rand(self::RANDOM_BODY_WORDS);
+			$body .= self::RANDOM_BODY_WORDS[$randIndex];
+			$body .= " ";
+		}
+
+		return $body;
+	}
+
+	static public function hasStarted():bool {
+		return self::$started;
+	}
+
+	static public function sendChunk($ch):int {
+		if(!empty(self::$headerBuffer)) {
+			$data = array_shift(self::$headerBuffer);
+
+			call_user_func(
+				self::$headerCallback,
+				$ch,
+				$data
+			);
+
+			return 1;
+		}
+		elseif(!empty(self::$bodyBuffer)) {
+			$data = self::$bodyBuffer;
+			self::$bodyBuffer = "";
+
+			call_user_func(
+				self::$bodyCallback,
+				$ch,
+				$data
+			);
+
+			return 1;
+		}
+		else {
+			return 0;
+		}
+	}
+}

test/unit/Helper/TestCurl.php

@@ -0,0 +1,29 @@
+<?php
+namespace Gt\Fetch\Test\Helper;
+
+use Gt\Curl\Curl;
+
+class TestCurl extends Curl {
+	protected $id;
+
+	public function __construct(string $url = null) {
+		$this->id = uniqid("dummy-curl-");
+		parent::__construct($url);
+	}
+
+	public function setOpt(int $option, $value):bool {
+		if($option === CURLOPT_HEADERFUNCTION) {
+			ResponseSimulator::setHeaderCallback($value);
+		}
+
+		if($option === CURLOPT_WRITEFUNCTION) {
+			ResponseSimulator::setBodyCallback($value);
+		}
+
+		return true;
+	}
+
+	public function getHandle() {
+		return $this;
+	}
+}

test/unit/Helper/TestCurlMulti.php

@@ -0,0 +1,22 @@
+<?php
+namespace Gt\Fetch\Test\Helper;
+
+use Gt\Curl\CurlInterface;
+use Gt\Curl\CurlMulti;
+
+class TestCurlMulti extends CurlMulti {
+	protected $ch;
+
+	public function add(CurlInterface $curl):void {
+		$this->ch = $curl;
+	}
+
+	public function exec(int &$stillRunning):int {
+		if(!ResponseSimulator::hasStarted()) {
+			ResponseSimulator::start();
+		}
+
+		$stillRunning += ResponseSimulator::sendChunk($this->ch);
+		return CURLM_OK;
+	}
+}

test/unit/HttpTest.php

@@ -1,9 +1,34 @@
 <?php
 namespace Gt\Fetch;
 
-use Gt\Fetch\Test\Helper\Helper;
+use Gt\Curl\Curl;
+use Gt\Curl\CurlInterface;
+use Gt\Curl\CurlMulti;
+use Gt\Curl\CurlMultiInterface;
+use Gt\Fetch\Test\Helper\TestCurl;
+use Gt\Fetch\Test\Helper\TestCurlMulti;
+use Gt\Http\Request;
+use Gt\Http\Uri;
 use PHPUnit\Framework\TestCase;
+use Psr\Http\Message\RequestInterface;
+use Psr\Http\Message\ResponseInterface;
 
 class HttpTest extends TestCase {
+	public function testFetch() {
+		$fakeStatus = null;
 
+		$http = new Http(
+			[],
+			0.01,
+			TestCurl::class,
+			TestCurlMulti::class
+		);
+		$http->fetch("test://should-return")
+		->then(function(BodyResponse $response)use(&$fakeStatus) {
+			$fakeStatus = $response->status;
+		});
+
+		$http->wait();
+		self::assertEquals(999, $fakeStatus);
+	}
 }