magento-engcom/bulk-api#4 Support for Async operations in WebAPI

- Fixed integration tests

Author: vrann

app/code/Magento/SwaggerWebapi/Model/SchemaType/Rest.php

@@ -22,7 +22,7 @@ class Rest implements SchemaTypeInterface
      *
      * @param string $code
      */
-    public function __construct(string $code)
+    public function __construct(string $code = 'rest')
     {
         $this->code = $code;
     }

app/code/Magento/SwaggerWebapiAsync/Model/SchemaType/Async.php

@@ -22,7 +22,7 @@ class Async implements SchemaTypeInterface
      *
      * @param string $code
      */
-    public function __construct(string $code)
+    public function __construct(string $code = 'async')
     {
         $this->code = $code;
     }

dev/tests/integration/framework/Magento/TestFramework/MessageQueue/PublisherConsumerController.php

@@ -78,6 +78,7 @@ public function initialize()
             if (!$this->getConsumerProcessIds($consumer)) {
                 exec("{$this->getConsumerStartCommand($consumer, true)} > /dev/null &");
             }
+            sleep(5);
         }
 
         if (file_exists($this->logFilePath)) {
@@ -160,7 +161,7 @@ public function waitForAsynchronousResult(callable $condition, $params)
         do {
             sleep(1);
             $assertion = call_user_func_array($condition, $params);
-        } while (!$assertion && ($i++ < 180));
+        } while (!$assertion && ($i++ < 20));
 
         if (!$assertion) {
             throw new PreconditionFailedException("No asynchronous messages were processed.");

dev/tests/integration/testsuite/Magento/AsynchronousOperations/Model/MassScheduleTest.php

@@ -96,9 +96,6 @@ protected function setUp()
     }
 
     /**
-     * @magentoAppArea adminhtml
-     * @magentoDbIsolation enabled
-     * @magentoAppIsolation enabled
      * @dataProvider productDataProvider
      * @param ProductInterface[] $products
      */
@@ -129,6 +126,8 @@ public function sendBulk($products)
                 $this->skus[] = $data['product']->getSku();
             }
         }
+        $this->clearProducts();
+
         $result = $this->massSchedule->publishMass('async.V1.products.POST', $products);
 
         //assert bulk accepted with no errors
@@ -188,9 +187,6 @@ public function assertProductExists($productsSkus, $count)
     }
 
     /**
-     * @magentoAppArea adminhtml
-     * @magentoDbIsolation enabled
-     * @magentoAppIsolation enabled
      * @dataProvider productExceptionDataProvider
      * @param ProductInterface[] $products
      */
@@ -272,7 +268,11 @@ public function productDataProvider()
             ],
             'multiple_products' => [
                 [
-                    ['product' => $this->getProduct()],
+                    ['product' => $this->getProduct()
+                        ->setName('Simple Product 3')
+                        ->setSku('unique-simple-product3')
+                        ->setMetaTitle('meta title 3')
+                    ],
                     ['product' => $this->getProduct()
                         ->setName('Simple Product 2')
                         ->setSku('unique-simple-product2')