new Microsoft\Kiota\Http\Promise interface extending Http\Promise\Promise

Author: hubipe

packages/abstractions/src/Authentication/AccessTokenProvider.php

@@ -8,7 +8,8 @@
 
 namespace Microsoft\Kiota\Abstractions\Authentication;
 
-use Http\Promise\Promise;
+use Microsoft\Kiota\Http\Promise;
+use Microsoft\Kiota\Http\RejectedPromise;
 
 /**
  * Interface AccessTokenProvider

packages/abstractions/src/Authentication/AnonymousAuthenticationProvider.php

@@ -2,8 +2,8 @@
 
 namespace Microsoft\Kiota\Abstractions\Authentication;
 
-use Http\Promise\FulfilledPromise;
-use Http\Promise\Promise;
+use Microsoft\Kiota\Http\FulfilledPromise;
+use Microsoft\Kiota\Http\Promise;
 use Microsoft\Kiota\Abstractions\RequestInformation;
 
 class AnonymousAuthenticationProvider implements AuthenticationProvider {

packages/abstractions/src/Authentication/AuthenticationProvider.php

@@ -1,7 +1,7 @@
 <?php
 namespace Microsoft\Kiota\Abstractions\Authentication;
 
-use Http\Promise\Promise;
+use Microsoft\Kiota\Http\Promise;
 use Microsoft\Kiota\Abstractions\RequestInformation;
 
 /**

packages/abstractions/src/Authentication/BaseBearerTokenAuthenticationProvider.php

@@ -2,8 +2,8 @@
 
 namespace Microsoft\Kiota\Abstractions\Authentication;
 
-use Http\Promise\FulfilledPromise;
-use Http\Promise\Promise;
+use Microsoft\Kiota\Http\FulfilledPromise;
+use Microsoft\Kiota\Http\Promise;
 use Microsoft\Kiota\Abstractions\RequestInformation;
 
 /**

packages/abstractions/src/NativeResponseHandler.php

@@ -2,9 +2,9 @@
 
 namespace Microsoft\Kiota\Abstractions;
 
-use Http\Promise\FulfilledPromise;
+use Microsoft\Kiota\Http\FulfilledPromise;
 use Psr\Http\Message\ResponseInterface;
-use Http\Promise\Promise;
+use Microsoft\Kiota\Http\Promise;
 
 /**
  * Default response handler that returns the PSR-7 Response

packages/abstractions/src/RequestAdapter.php

@@ -1,7 +1,7 @@
 <?php
 namespace Microsoft\Kiota\Abstractions;
 
-use Http\Promise\Promise;
+use Microsoft\Kiota\Http\Promise;
 use Microsoft\Kiota\Abstractions\Serialization\ParseNodeFactory;
 use Microsoft\Kiota\Abstractions\Serialization\SerializationWriterFactory;
 use Microsoft\Kiota\Abstractions\Store\BackingStoreFactory;

packages/abstractions/src/ResponseHandler.php

@@ -1,7 +1,7 @@
 <?php
 namespace Microsoft\Kiota\Abstractions;
 
-use Http\Promise\Promise;
+use Microsoft\Kiota\Http\Promise;
 use Psr\Http\Message\ResponseInterface;
 use Microsoft\Kiota\Abstractions\Serialization\Parsable;
 

packages/abstractions/tests/Authentication/BaseBearerTokenAuthenticationProviderTest.php

@@ -2,7 +2,7 @@
 
 namespace Microsoft\Kiota\Abstractions\Tests\Authentication;
 
-use Http\Promise\FulfilledPromise;
+use Microsoft\Kiota\Http\FulfilledPromise;
 use Microsoft\Kiota\Abstractions\Authentication\AccessTokenProvider;
 use Microsoft\Kiota\Abstractions\Authentication\BaseBearerTokenAuthenticationProvider;
 use Microsoft\Kiota\Abstractions\RequestInformation;

packages/abstractions/tests/TestFiles/TestRequestAdapter.php

@@ -2,8 +2,8 @@
 
 namespace Microsoft\Kiota\Abstractions\Tests\TestFiles;
 
-use Http\Promise\FulfilledPromise;
-use Http\Promise\Promise;
+use Microsoft\Kiota\Http\FulfilledPromise;
+use Microsoft\Kiota\Http\Promise;
 use Microsoft\Kiota\Abstractions\RequestAdapter;
 use Microsoft\Kiota\Abstractions\RequestInformation;
 use Microsoft\Kiota\Abstractions\Serialization\ParseNodeFactory;

packages/authentication/phpleague/src/Oauth/CAEConfigurationTrait.php

@@ -8,7 +8,7 @@
 
 namespace Microsoft\Kiota\Authentication\Oauth;
 
-use Http\Promise\Promise;
+use Microsoft\Kiota\Http\Promise;
 
 trait CAEConfigurationTrait
 {

packages/authentication/phpleague/src/Oauth/TokenRequestContext.php

@@ -9,7 +9,7 @@
 namespace Microsoft\Kiota\Authentication\Oauth;
 
 use League\OAuth2\Client\Token\AccessToken;
-use Http\Promise\Promise;
+use Microsoft\Kiota\Http\Promise;
 
 /**
  * Interface TokenRequestContext

packages/authentication/phpleague/src/PhpLeagueAccessTokenProvider.php

@@ -10,9 +10,9 @@
 
 
 use Exception;
-use Http\Promise\FulfilledPromise;
-use Http\Promise\Promise;
-use Http\Promise\RejectedPromise;
+use Microsoft\Kiota\Http\FulfilledPromise;
+use Microsoft\Kiota\Http\Promise;
+use Microsoft\Kiota\Http\RejectedPromise;
 use InvalidArgumentException;
 use League\OAuth2\Client\Provider\AbstractProvider;
 use League\OAuth2\Client\Provider\Exception\IdentityProviderException;

packages/authentication/phpleague/tests/PhpLeagueAccessTokenProviderTest.php

@@ -7,7 +7,7 @@
 use GuzzleHttp\Handler\MockHandler;
 use GuzzleHttp\Psr7\Request;
 use GuzzleHttp\Psr7\Response;
-use Http\Promise\FulfilledPromise;
+use Microsoft\Kiota\Http\FulfilledPromise;
 use InvalidArgumentException;
 use League\OAuth2\Client\Token\AccessToken;
 use Microsoft\Kiota\Authentication\Cache\InMemoryAccessTokenCache;

packages/http/guzzle/src/GuzzleRequestAdapter.php

@@ -14,7 +14,7 @@
 use Exception;
 use GuzzleHttp\ClientInterface;
 use GuzzleHttp\Psr7\Request;
-use Http\Promise\Promise;
+use Microsoft\Kiota\Http\Promise;
 use InvalidArgumentException;
 use Microsoft\Kiota\Abstractions\ApiClientBuilder;
 use Microsoft\Kiota\Abstractions\ApiException;

packages/http/guzzle/tests/GuzzleRequestAdapterTest.php

@@ -7,8 +7,8 @@
 use GuzzleHttp\Psr7\Request;
 use GuzzleHttp\Psr7\Response;
 use GuzzleHttp\Psr7\Utils;
-use Http\Promise\FulfilledPromise;
-use Http\Promise\Promise;
+use Microsoft\Kiota\Http\FulfilledPromise;
+use Microsoft\Kiota\Http\Promise;
 use Microsoft\Kiota\Abstractions\ApiException;
 use Microsoft\Kiota\Abstractions\Authentication\AuthenticationProvider;
 use Microsoft\Kiota\Abstractions\Enum;

packages/http/promise/src/FulfilledPromise.php

@@ -0,0 +1,56 @@
+<?php
+declare(strict_types=1);
+
+namespace Microsoft\Kiota\Http;
+
+/**
+ * A promise already fulfilled.
+ *
+ * @author Joel Wurtz <[email protected]>
+ *
+ * @template-covariant T
+ *
+ * @implements Promise<T>
+ */
+final class FulfilledPromise implements Promise
+{
+	/**
+	 * @var T
+	 */
+	private $result;
+
+	/**
+	 * @param T $result
+	 */
+	public function __construct($result)
+	{
+		$this->result = $result;
+	}
+
+	public function then(?callable $onFulfilled = null, ?callable $onRejected = null)
+	{
+		if (null === $onFulfilled) {
+			return $this;
+		}
+
+		try {
+			return new self($onFulfilled($this->result));
+		} catch (\Exception $e) {
+			return new RejectedPromise($e);
+		}
+	}
+
+	public function getState()
+	{
+		return Promise::FULFILLED;
+	}
+
+	public function wait($unwrap = true)
+	{
+		if ($unwrap) {
+			return $this->result;
+		}
+
+		return;
+	}
+}

packages/http/promise/src/Promise.php

@@ -0,0 +1,54 @@
+<?php
+declare(strict_types=1);
+
+namespace Microsoft\Kiota\Http;
+
+/**
+ * Promise represents a value that may not be available yet, but will be resolved at some point in future.
+ * It acts like a proxy to the actual value.
+ *
+ * This interface is an extension of the promises/a+ specification.
+ *
+ * @see https://promisesaplus.com/
+ *
+ * @author Joel Wurtz <[email protected]>
+ * @author Márk Sági-Kazár <[email protected]>
+ *
+ * @template-covariant T
+ */
+interface Promise extends \Http\Promise\Promise
+{
+
+	/**
+	 * Adds behavior for when the promise is resolved or rejected (response will be available, or error happens).
+	 *
+	 * If you do not care about one of the cases, you can set the corresponding callable to null
+	 * The callback will be called when the value arrived and never more than once.
+	 *
+	 * @param callable(T): V|null          $onFulfilled called when a response will be available
+	 * @param callable(\Throwable): V|null $onRejected  called when an exception occurs
+	 *
+	 * @return Promise<V> a new resolved promise with value of the executed callback (onFulfilled / onRejected)
+	 *
+	 * @template V
+	 */
+	public function then(?callable $onFulfilled = null, ?callable $onRejected = null);
+
+	/**
+	 * Wait for the promise to be fulfilled or rejected.
+	 *
+	 * When this method returns, the request has been resolved and if callables have been
+	 * specified, the appropriate one has terminated.
+	 *
+	 * When $unwrap is true (the default), the response is returned, or the exception thrown
+	 * on failure. Otherwise, nothing is returned or thrown.
+	 *
+	 * @param bool $unwrap Whether to return resolved value / throw reason or not
+	 *
+	 * @return ($unwrap is true ? T : null) Resolved value, null if $unwrap is set to false
+	 *
+	 * @throws \Exception the rejection reason if $unwrap is set to true and the request failed
+	 */
+	public function wait($unwrap = true);
+
+}

packages/http/promise/src/RejectedPromise.php

@@ -0,0 +1,56 @@
+<?php
+declare(strict_types=1);
+
+namespace Microsoft\Kiota\Http;
+
+/**
+ * A rejected promise.
+ *
+ * @author Joel Wurtz <[email protected]>
+ *
+ * @template-covariant T
+ *
+ * @implements Promise<T>
+ */
+final class RejectedPromise implements Promise
+{
+	/**
+	 * @var \Exception
+	 */
+	private $exception;
+
+	public function __construct(\Exception $exception)
+	{
+		$this->exception = $exception;
+	}
+
+	/**
+	 * {@inheritdoc}
+	 */
+	public function then(?callable $onFulfilled = null, ?callable $onRejected = null)
+	{
+		if (null === $onRejected) {
+			return $this;
+		}
+
+		try {
+			return new FulfilledPromise($onRejected($this->exception));
+		} catch (\Exception $e) {
+			return new self($e);
+		}
+	}
+
+	public function getState()
+	{
+		return Promise::REJECTED;
+	}
+
+	public function wait($unwrap = true)
+	{
+		if ($unwrap) {
+			throw $this->exception;
+		}
+
+		return NULL;
+	}
+}

phpstan.neon

@@ -6,6 +6,7 @@ parameters:
         - packages/abstractions/src
         - packages/authentication/phpleague/src
         - packages/http/guzzle/src
+        - packages/http/promise/src
         - packages/bundle/src
         - packages/serialization/json/src
         - packages/serialization/form/src