HTTPlug compatibility (#3)

* Begin Httplug compatibility - getState

* Complete work for HTTPlug compatibility
Closes #2

* Fix trait property errors

Author: Greg Bowler

composer.json

@@ -4,7 +4,8 @@
 	"license": "MIT",
 
 	"require": {
-		"php": ">=7.4"
+		"php": ">=7.4",
+		"php-http/httplug": "^2.2.0"
 	},
 	"require-dev": {
 		"phpunit/phpunit": "9.*",

composer.lock

@@ -2,12 +2,15 @@
 namespace Gt\Promise;
 
 use Throwable;
+use Http\Promise\Promise as HttpPromiseInterface;
 
 class FulfilledPromise implements PromiseInterface {
 	use Resolvable;
+	use Waitable;
 
 	/** @var mixed */
 	private $value;
+	private string $state;
 
 	/** @param ?mixed $promiseOrValue */
 	public function __construct($promiseOrValue = null) {
@@ -71,4 +74,8 @@ function($value)
 			}
 		);
 	}
+
+	public function getState():string {
+		return HttpPromiseInterface::FULFILLED;
+	}
 }

src/FulfilledPromise.php

@@ -2,14 +2,17 @@
 namespace Gt\Promise;
 
 use Throwable;
+use Http\Promise\Promise as HttpPromiseInterface;
 
-class Promise implements PromiseInterface {
+class Promise implements PromiseInterface, HttpPromiseInterface {
 	use Resolvable;
+	use Waitable;
 
 	/** @var mixed */
 	private $result;
 	/** @var callable[] */
 	private array $handlers;
+	private string $state;
 
 	/**
 	 * @param callable $executor A function to be executed by the
@@ -22,6 +25,7 @@ class Promise implements PromiseInterface {
 	public function __construct(callable $executor) {
 		$this->handlers = [];
 		$this->call($executor);
+		$this->state = HttpPromiseInterface::PENDING;
 	}
 
 	public function then(
@@ -73,6 +77,10 @@ function(PromiseInterface $promise) use ($onFulfilled, $onRejected) {
 		);
 	}
 
+	public function getState():string {
+		return $this->state;
+	}
+
 	private function resolver(
 		callable $onFulfilled = null,
 		callable $onRejected = null
@@ -94,6 +102,7 @@ private function reject(Throwable $reason):void {
 			return;
 		}
 
+		$this->state = HttpPromiseInterface::REJECTED;
 		$this->settle(new RejectedPromise($reason));
 	}
 

src/Promise.php

@@ -48,4 +48,17 @@ public function catch(
 	public function finally(
 		callable $onFulfilledOrRejected
 	):PromiseInterface;
+
+	/**
+	 * TODO: Documentation.
+	 */
+	public function complete(
+		callable $onFulfilled = null,
+		callable $onRejected = null
+	):void;
+
+	public function getState():string;
+
+	/** @return mixed */
+	public function wait(bool $unwrap = true);
 }

src/PromiseInterface.php

@@ -2,11 +2,14 @@
 namespace Gt\Promise;
 
 use Throwable;
+use Http\Promise\Promise as HttpPromiseInterface;
 
 class RejectedPromise implements PromiseInterface {
 	use Resolvable;
+	use Waitable;
 
 	private Throwable $reason;
+	private string $state;
 
 	public function __construct(Throwable $reason) {
 		$this->reason = $reason;
@@ -72,4 +75,8 @@ function(Throwable $reason)
 			}
 		);
 	}
+
+	public function getState():string {
+		return HttpPromiseInterface::REJECTED;
+	}
 }

src/RejectedPromise.php

@@ -1,12 +1,16 @@
 <?php
 namespace Gt\Promise;
 
+use Http\Promise\Promise as HttpPromiseInterface;
+
 trait Resolvable {
 	private function resolve($promiseOrValue = null):PromiseInterface {
 		if ($promiseOrValue instanceof PromiseInterface) {
 			return $promiseOrValue;
 		}
 
+		$this->state = HttpPromiseInterface::FULFILLED;
+
 		return new FulfilledPromise($promiseOrValue);
 	}
 }