test(Inventory): test product search for availability by multiple channels

Author: Jens Schulze

tests/integration/Inventory/InventoryUpdateRequestTest.php

@@ -9,6 +9,8 @@
 use Commercetools\Core\Model\CustomField\CustomFieldObject;
 use Commercetools\Core\Model\Inventory\InventoryDraft;
 use Commercetools\Core\Model\Message\InventoryEntryDeletedMessage;
+use Commercetools\Core\Model\Product\ProductProjection;
+use Commercetools\Core\Model\Product\Search\Filter;
 use Commercetools\Core\Model\Type\TypeReference;
 use Commercetools\Core\Request\CustomField\Command\SetCustomFieldAction;
 use Commercetools\Core\Request\CustomField\Command\SetCustomTypeAction;
@@ -22,6 +24,7 @@
 use Commercetools\Core\Request\Inventory\InventoryDeleteRequest;
 use Commercetools\Core\Request\Inventory\InventoryUpdateRequest;
 use Commercetools\Core\Request\Messages\MessageQueryRequest;
+use Commercetools\Core\Request\Products\ProductProjectionSearchRequest;
 
 class InventoryUpdateRequestTest extends ApiTestCase
 {
@@ -180,6 +183,45 @@ public function testSetSupplyChannel()
         $this->deleteRequest->setVersion($result->getVersion());
     }
 
+    public function testQueryChannels()
+    {
+        $channel = $this->getChannel();
+        $draft = $this->getDraft('sku');
+        $draft = $draft->setQuantityOnStock(1);
+        $draft->setSupplyChannel($channel->getReference());
+        $this->createInventory($draft);
+
+        $product = $this->getProduct();
+
+        $retries = 0;
+        do {
+            $retries++;
+            sleep(1);
+            $request = ProductProjectionSearchRequest::of()
+                ->addFilterQuery(Filter::ofName('id')->setValue($product->getId()))
+                ->limit(1);
+            $response = $request->executeWithClient($this->getClient());
+            $result = $request->mapResponse($response);
+        } while ($result->count() > 0 && $retries <= 9);
+
+        $request = ProductProjectionSearchRequest::of()
+            ->addFilterQuery(
+                Filter::ofName('variants.availability.isOnStockInChannels')->setValue([$channel->getId()])
+            )
+            ->limit(1);
+        $response = $request->executeWithClient($this->getClient());
+        $result = $request->mapResponse($response);
+
+        $this->assertSame(
+            $product->getId(),
+            $result->current()->getId()
+        );
+        $this->assertSame(
+            $channel->getId(),
+            $result->current()->getMasterVariant()->getAvailability()->getChannels()->key()
+        );
+    }
+
     /**
      * @large
      */