filter operations by bulk start_time field

Author: Vasiliev.A

app/code/Magento/AsynchronousOperations/Model/Operation.php

@@ -12,7 +12,7 @@
 /**
  * Class Operation
  */
-class Operation extends DataObject implements DetailedOperationStatusInterface, ExtensibleDataInterface
+class Operation extends DataObject implements DetailedOperationStatusInterface
 {
     /**
      * @inheritDoc

app/code/Magento/AsynchronousOperations/Model/OperationRepository.php

@@ -14,6 +14,7 @@
 use Magento\Framework\Api\SearchCriteria\CollectionProcessorInterface;
 use Magento\AsynchronousOperations\Api\Data\OperationSearchResultsInterfaceFactory as SearchResultFactory;
 use Magento\AsynchronousOperations\Model\ResourceModel\Operation\CollectionFactory;
+use Magento\Framework\Api\ExtensionAttribute\JoinProcessorInterface;
 use Magento\Framework\Exception\InputException;
 use Magento\Framework\Exception\NoSuchEntityException;
 
@@ -37,6 +38,11 @@ class OperationRepository implements \Magento\AsynchronousOperations\Api\Operati
      */
     private $searchResultFactory;
 
+    /**
+     * @var JoinProcessorInterface
+     */
+    private $joinProcessor;
+
     /**
      * @var CollectionProcessorInterface
      */
@@ -51,20 +57,24 @@ class OperationRepository implements \Magento\AsynchronousOperations\Api\Operati
      * Initialize dependencies.
      *
      * @param \Magento\Framework\EntityManager\EntityManager $entityManager
+     * @param \Magento\AsynchronousOperations\Model\ResourceModel\Operation\CollectionFactory $collectionFactory
      * @param \Magento\AsynchronousOperations\Api\Data\OperationSearchResultsInterfaceFactory $searchResultFactory
+     * @param \Magento\Framework\Api\ExtensionAttribute\JoinProcessorInterface $joinProcessor
      * @param \Magento\Framework\Api\SearchCriteria\CollectionProcessorInterface|null $collectionProcessor
      * @param \Psr\Log\LoggerInterface $logger
      */
     public function __construct(
         EntityManager $entityManager,
         CollectionFactory $collectionFactory,
         SearchResultFactory $searchResultFactory,
+        JoinProcessorInterface $joinProcessor,
         CollectionProcessorInterface $collectionProcessor = null,
         \Psr\Log\LoggerInterface $logger
     ) {
         $this->entityManager = $entityManager;
         $this->collectionFactory = $collectionFactory;
         $this->searchResultFactory = $searchResultFactory;
+        $this->joinProcessor = $joinProcessor;
         $this->collectionProcessor = $collectionProcessor ? : ObjectManager::getInstance()
             ->get(\Magento\Framework\Api\SearchCriteria\CollectionProcessorInterface::class);
         $this->logger = $logger;
@@ -75,15 +85,17 @@ public function __construct(
      */
     public function getList(\Magento\Framework\Api\SearchCriteriaInterface $searchCriteria)
     {
+        /** @var \Magento\AsynchronousOperations\Api\Data\OperationSearchResultsInterface $searchResult */
+        $searchResult = $this->searchResultFactory->create();
+
         /** @var \Magento\AsynchronousOperations\Model\ResourceModel\Operation\Collection $collection */
         $collection = $this->collectionFactory->create();
+        $this->joinProcessor->process($collection, \Magento\AsynchronousOperations\Api\Data\OperationInterface::class);
         $this->collectionProcessor->process($searchCriteria, $collection);
-        $collection->load();
-        /** @var \Magento\AsynchronousOperations\Api\Data\OperationSearchResultsInterface $searchResult */
-        $searchResult = $this->searchResultFactory->create();
+
         $searchResult->setSearchCriteria($searchCriteria);
-        $searchResult->setItems($collection->getItems());
         $searchResult->setTotalCount($collection->getSize());
+        $searchResult->setItems($collection->getItems());
 
         return $searchResult;
     }

app/code/Magento/AsynchronousOperations/etc/extension_attributes.xml

@@ -0,0 +1,16 @@
+<?xml version="1.0"?>
+<!--
+/**
+ * Copyright © 2016 Magento. All rights reserved.
+ * See COPYING.txt for license details.
+ */
+-->
+<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework:Api/etc/extension_attributes.xsd">
+    <extension_attributes for="Magento\AsynchronousOperations\Api\Data\OperationInterface">
+        <attribute code="start_time" type="string">
+            <join reference_table="magento_bulk" join_on_field="bulk_uuid" reference_field="uuid">
+                <field column="start_time">start_time</field>
+            </join>
+        </attribute>
+    </extension_attributes>
+</config>