Merge pull request #266 from akeneo/dx-104

feat(DX-104) : Adding asynchronous calls in Client

Author: gwendalaubert

.gitignore

@@ -6,3 +6,6 @@ phpspec.yml
 phpunit.xml
 .php_cs.cache
 .php-cs-fixer.cache
+
+### PhpStorm ###
+.idea

composer.lock

@@ -8,7 +8,8 @@
      convertNoticesToExceptions="true"
      convertWarningsToExceptions="true"
      processIsolation="false"
-     stopOnFailure="false">
+     stopOnFailure="false"
+     cacheResult ="false">
 
     <testsuite name="Integration">
         <directory>tests/</directory>

phpunit.xml.dist

@@ -44,6 +44,7 @@
 use Akeneo\Pim\ApiClient\Cache\LRUCache;
 use Akeneo\Pim\ApiClient\Client\AuthenticatedHttpClient;
 use Akeneo\Pim\ApiClient\Client\CachedResourceClient;
+use Akeneo\Pim\ApiClient\Client\ClientInterface;
 use Akeneo\Pim\ApiClient\Client\HttpClient;
 use Akeneo\Pim\ApiClient\Client\Options;
 use Akeneo\Pim\ApiClient\Client\ResourceClient;
@@ -57,7 +58,6 @@
 use Akeneo\Pim\ApiClient\Stream\UpsertResourceListResponseFactory;
 use Http\Discovery\Psr17FactoryDiscovery;
 use Http\Discovery\Psr18ClientDiscovery;
-use Psr\Http\Client\ClientInterface;
 use Psr\Http\Message\RequestFactoryInterface;
 use Psr\Http\Message\StreamFactoryInterface;
 
@@ -295,7 +295,7 @@ protected function setUp(Authentication $authentication): array
         return [$resourceClient, $pageFactory, $cursorFactory, $fileSystem];
     }
 
-    private function getHttpClient(): ClientInterface
+    private function getHttpClient(): ClientInterface|\Psr\Http\Client\ClientInterface
     {
         if (null === $this->httpClient) {
             $this->httpClient = Psr18ClientDiscovery::find();

src/AkeneoPimClientBuilder.php

@@ -10,6 +10,8 @@
 use Akeneo\Pim\ApiClient\Pagination\PageInterface;
 use Akeneo\Pim\ApiClient\Pagination\ResourceCursorFactoryInterface;
 use Akeneo\Pim\ApiClient\Pagination\ResourceCursorInterface;
+use GuzzleHttp\Promise\PromiseInterface;
+use Http\Promise\Promise;
 
 /**
  * @copyright 2022 Akeneo SAS (https://www.akeneo.com)
@@ -60,4 +62,9 @@ public function delete(string $code): int
     {
         return $this->resourceClient->deleteResource(static::APP_CATALOG_URI, [$code]);
     }
+
+    public function upsertAsync(string $code, array $data = []): PromiseInterface|Promise
+    {
+        return $this->resourceClient->upsertAsyncAndReturnPromise(static::APP_CATALOG_URI, [$code], $data);
+    }
 }

src/Api/AppCatalog/AppCatalogApi.php

@@ -7,6 +7,8 @@
 use Akeneo\Pim\ApiClient\Api\Operation\DeletableResourceInterface;
 use Akeneo\Pim\ApiClient\Api\Operation\GettableResourceInterface;
 use Akeneo\Pim\ApiClient\Api\Operation\ListableResourceInterface;
+use GuzzleHttp\Promise\PromiseInterface;
+use Http\Promise\Promise;
 
 /**
  * @copyright 2022 Akeneo SAS (https://www.akeneo.com)
@@ -20,4 +22,5 @@ interface AppCatalogApiInterface extends
     public function create(array $data): array;
 
     public function upsert(string $code, array $data = []): array;
+    public function upsertAsync(string $code, array $data = []): PromiseInterface|Promise;
 }

src/Api/AppCatalog/AppCatalogApiInterface.php

@@ -10,6 +10,9 @@
 use Akeneo\Pim\ApiClient\Pagination\PageInterface;
 use Akeneo\Pim\ApiClient\Pagination\ResourceCursorFactoryInterface;
 use Akeneo\Pim\ApiClient\Pagination\ResourceCursorInterface;
+use GuzzleHttp\Promise\PromiseInterface;
+use Http\Promise\Promise;
+use Psr\Http\Message\StreamInterface;
 
 /**
  * API implementation to manage assets.
@@ -89,11 +92,21 @@ public function upsert(string $code, array $data = []): int
         return $this->resourceClient->upsertResource(static::ASSET_URI, [$code], $data);
     }
 
+    public function upsertAsync(string $code, array $data = []): PromiseInterface|Promise
+    {
+        return $this->resourceClient->upsertAsyncResource(static::ASSET_URI, [$code], $data);
+    }
+
     /**
      * {@inheritdoc}
      */
     public function upsertList($resources): \Traversable
     {
         return $this->resourceClient->upsertStreamResourceList(static::ASSETS_URI, [], $resources);
     }
+
+    public function upsertAsyncList(StreamInterface|array $resources): PromiseInterface|Promise
+    {
+        return $this->resourceClient->upsertAsyncStreamResourceList(self::ASSETS_URI, [], $resources);
+    }
 }

src/Api/AssetApi.php

@@ -10,6 +10,9 @@
 use Akeneo\Pim\ApiClient\Pagination\PageInterface;
 use Akeneo\Pim\ApiClient\Pagination\ResourceCursorFactoryInterface;
 use Akeneo\Pim\ApiClient\Pagination\ResourceCursorInterface;
+use GuzzleHttp\Promise\PromiseInterface;
+use Http\Promise\Promise;
+use Psr\Http\Message\StreamInterface;
 
 /**
  * API implementation to manage asset categories.
@@ -74,6 +77,11 @@ public function upsert(string $code, array $data = []): int
         return $this->resourceClient->upsertResource(static::ASSET_CATEGORY_URI, [$code], $data);
     }
 
+    public function upsertAsync(string $code, array $data = []): PromiseInterface|Promise
+    {
+        return $this->resourceClient->upsertAsyncResource(static::ASSET_CATEGORY_URI, [$code], $data);
+    }
+
     /**
      * {@inheritdoc}
      */
@@ -95,4 +103,9 @@ public function create(string $code, array $data = []): int
 
         return $this->resourceClient->createResource(static::ASSET_CATEGORIES_URI, [], $data);
     }
+
+    public function upsertAsyncList(StreamInterface|array $resources): PromiseInterface|Promise
+    {
+        return $this->resourceClient->upsertAsyncStreamResourceList(static::ASSET_CATEGORIES_URI, [], $resources);
+    }
 }

src/Api/AssetCategoryApi.php

@@ -8,6 +8,8 @@
 use Akeneo\Pim\ApiClient\Pagination\PageFactoryInterface;
 use Akeneo\Pim\ApiClient\Pagination\ResourceCursorFactoryInterface;
 use Akeneo\Pim\ApiClient\Pagination\ResourceCursorInterface;
+use GuzzleHttp\Promise\PromiseInterface;
+use Http\Promise\Promise;
 
 class AssetApi implements AssetApiInterface
 {
@@ -70,4 +72,20 @@ public function delete(string $assetFamilyCode, string $assetCode): int
     {
         return $this->resourceClient->deleteResource(static::ASSET_URI, [$assetFamilyCode, $assetCode]);
     }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function upsertAsync(string $assetFamilyCode, string $assetCode, array $data = []): PromiseInterface|Promise
+    {
+        return $this->resourceClient->upsertAsyncResource(static::ASSET_URI, [$assetFamilyCode, $assetCode], $data);
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function upsertAsyncList(string $assetFamilyCode, array $assets): PromiseInterface|Promise
+    {
+        return $this->resourceClient->upsertAsyncJsonResourceList(static::ASSETS_URI, [$assetFamilyCode], $assets);
+    }
 }

src/Api/AssetManager/AssetApi.php

@@ -6,6 +6,8 @@
 
 use Akeneo\Pim\ApiClient\Exception\HttpException;
 use Akeneo\Pim\ApiClient\Pagination\ResourceCursorInterface;
+use GuzzleHttp\Promise\PromiseInterface;
+use Http\Promise\Promise;
 
 interface AssetApiInterface
 {
@@ -56,6 +58,27 @@ public function upsert(string $assetFamilyCode, string $assetCode, array $data =
      */
     public function upsertList(string $assetFamilyCode, array $assets): array;
 
+    /**
+     * Creates an asset family if it does not exist yet, otherwise updates partially the asset family.
+     *
+     * @throws HttpException
+     *
+     * @return Promise
+     */
+    public function upsertAsync(string $assetFamilyCode, string $assetCode, array $data = []): PromiseInterface|Promise;
+
+    /**
+     * Updates or creates several assets.
+     *
+     * @param string $assetFamilyCode Code of the asset family
+     * @param array  $assets          Array containing the assets to create or update
+     *
+     * @throws HttpException
+     *
+     * @return Promise
+     */
+    public function upsertAsyncList(string $assetFamilyCode, array $assets): PromiseInterface|Promise;
+
     /**
      * Deletes an asset.
      *