ASYNC-IMPORT:37 Implement DB operation for save source endpoints

app/code/Magento/ImportService/Api/SourceRepositoryInterface.php

@@ -0,0 +1,46 @@
+<?php
+/**
+ * Copyright © Magento, Inc. All rights reserved.
+ * See COPYING.txt for license details.
+ */
+declare(strict_types=1);
+
+namespace Magento\ImportService\Api;
+
+use Magento\ImportService\Api\Data\SourceInterface;
+
+/**
+ * Interface SourceRepositoryInterface
+ */
+interface SourceRepositoryInterface
+{
+    /**
+     * @param \Magento\ImportService\Api\Data\SourceInterface $source
+     * @return \Magento\ImportService\Api\Data\SourceInterface
+     */
+    public function save(SourceInterface $source);
+
+    /**
+     * @param int $id
+     * @return \Magento\ImportService\Api\Data\SourceInterface
+     */
+    public function getById($id);
+
+    /**
+     * @param \Magento\Framework\Api\SearchCriteriaInterface $criteria
+     * @return \Magento\Framework\Api\SearchResultsInterface
+     */
+    public function getList(\Magento\Framework\Api\SearchCriteriaInterface $criteria);
+
+    /**
+     * @param \Magento\ImportService\Api\Data\SourceInterface $source
+     * @return bool
+     */
+    public function delete(\Magento\ImportService\Api\Data\SourceInterface $source);
+
+    /**
+     * @param int $id
+     * @return bool
+     */
+    public function deleteById($id);
+}

app/code/Magento/ImportService/Model/ResourceModel/Source.php

@@ -0,0 +1,24 @@
+<?php
+/**
+ * Copyright © Magento, Inc. All rights reserved.
+ * See COPYING.txt for license details.
+ */
+declare(strict_types=1);
+
+namespace Magento\ImportService\Model\ResourceModel;
+
+use Magento\Framework\Model\ResourceModel\Db\AbstractDb;
+use Magento\ImportService\Api\Data\SourceInterface;
+
+/**
+ * Class SourceResourceModel
+ */
+class Source extends AbstractDb
+{
+    const TABLE_NAME = 'import_service_source';
+
+    protected function _construct()
+    {
+        $this->_init(self::TABLE_NAME, SourceInterface::ENTITY_ID);
+    }
+}

app/code/Magento/ImportService/Model/ResourceModel/Source/Collection.php

@@ -0,0 +1,23 @@
+<?php
+/**
+ * Copyright © Magento, Inc. All rights reserved.
+ * See COPYING.txt for license details.
+ */
+declare(strict_types=1);
+
+namespace Magento\ImportService\Model\ResourceModel\Source;
+
+use Magento\Framework\Model\ResourceModel\Db\Collection\AbstractCollection;
+use Magento\ImportService\Model\ResourceModel\Source as SourceResourceModel;
+use Magento\ImportService\Model\Source;
+
+/**
+ * Collection of Import Service Sources
+ */
+class Collection extends AbstractCollection
+{
+    protected function _construct()
+    {
+        $this->_init(Source::class, SourceResourceModel::class);
+    }
+}

app/code/Magento/ImportService/Model/Source.php

@@ -9,12 +9,27 @@
 
 use Magento\Framework\Model\AbstractModel;
 use Magento\ImportService\Api\Data\SourceInterface;
+use Magento\ImportService\Model\ResourceModel\Source as SourceResource;
 
 /**
  * Class Source
  */
 class Source extends AbstractModel implements SourceInterface
 {
+    const CACHE_TAG = 'magento_import_service_source';
+
+    protected function _construct()
+    {
+        $this->_init(SourceResource::class);
+    }
+
+    /**
+     * @return array
+     */
+    public function getIdentities()
+    {
+        return [self::CACHE_TAG . '_' . $this->getId()];
+    }
 
     /**
      * @return int

app/code/Magento/ImportService/Model/SourceRepository.php

@@ -0,0 +1,164 @@
+<?php
+/**
+ * Copyright © Magento, Inc. All rights reserved.
+ * See COPYING.txt for license details.
+ */
+declare(strict_types=1);
+
+namespace Magento\ImportService\Model;
+
+use Magento\Framework\Api\SearchCriteriaInterface;
+use Magento\Framework\Api\SearchResultsInterfaceFactory;
+use Magento\Framework\Api\SearchResultsInterface;
+use Magento\Framework\Api\SortOrder;
+use Magento\Framework\Exception\CouldNotDeleteException;
+use Magento\Framework\Exception\CouldNotSaveException;
+use Magento\Framework\Exception\NoSuchEntityException;
+use Magento\Framework\Model\AbstractModel;
+use Magento\ImportService\Api\Data\SourceInterface;
+use Magento\ImportService\Api\SourceRepositoryInterface;
+use Magento\ImportService\Model\ResourceModel\Source as SourceResourceModel;
+use Magento\ImportService\Model\ResourceModel\Source\CollectionFactory as SourceCollectionFactory;
+
+/**
+ * Class SourceRepository
+ */
+class SourceRepository implements SourceRepositoryInterface
+{
+    /**
+     * @var SourceFactory
+     */
+    private $sourceFactory;
+
+    /**
+     * @var SourceResourceModel
+     */
+    private $sourceResourceModel;
+
+    /**
+     * @var SourceCollectionFactory
+     */
+    private $sourceCollectionFactory;
+
+    /**
+     * @var SearchResultsInterfaceFactory
+     */
+    private $searchResultsFactory;
+
+    /**
+     * @param SourceFactory $sourceFactory
+     * @param SourceResourceModel $sourceResourceModel
+     * @param SourceCollectionFactory $sourceCollectionFactory
+     * @param SearchResultsInterfaceFactory $searchResultsFactory
+     */
+    public function __construct(
+        SourceFactory $sourceFactory,
+        SourceResourceModel $sourceResourceModel,
+        SourceCollectionFactory $sourceCollectionFactory,
+        SearchResultsInterfaceFactory $searchResultsFactory
+    ) {
+        $this->sourceFactory        = $sourceFactory;
+        $this->sourceResourceModel  = $sourceResourceModel;
+        $this->sourceCollectionFactory    = $sourceCollectionFactory;
+        $this->searchResultsFactory = $searchResultsFactory;
+    }
+
+    /**
+     * @inheritdoc
+     * @throws CouldNotSaveException
+     */
+    public function save(SourceInterface $source)
+    {
+        try {
+            $this->sourceResourceModel->save($source);
+        } catch (\Exception $e) {
+            throw new CouldNotSaveException(__($e->getMessage()));
+        }
+
+        return $source;
+    }
+
+    /**
+     * @inheritdoc
+     * @throws NoSuchEntityException
+     */
+    public function getById($id)
+    {
+        $source = $this->sourceFactory->create();
+        $this->sourceResourceModel->load($source, $id);
+        if (!$source->getId()) {
+            throw new NoSuchEntityException(__('Source with id "%1" does not exist.', $id));
+        }
+
+        return $source;
+    }
+
+    /**
+     * @inheritdoc
+     * @throws CouldNotDeleteException
+     */
+    public function delete(SourceInterface $source)
+    {
+        try {
+            /** @var AbstractModel|SourceInterface $source */
+            $this->sourceResourceModel->delete($source);
+        } catch (\Exception $exception) {
+            throw new CouldNotDeleteException(__($exception->getMessage()));
+        }
+
+        return true;
+    }
+
+    /**
+     * @inheritdoc
+     * @throws CouldNotDeleteException
+     * @throws NoSuchEntityException
+     */
+    public function deleteById($id)
+    {
+        return $this->delete($this->getById($id));
+    }
+
+    /**
+     * @inheritdoc
+     */
+    public function getList(SearchCriteriaInterface $criteria)
+    {
+        /** @var SearchResultsInterface $searchResults */
+        $searchResults = $this->searchResultsFactory->create();
+        $searchResults->setSearchCriteria($criteria);
+        $sourceCollection = $this->sourceCollectionFactory->create();
+        foreach ($criteria->getFilterGroups() as $filterGroup) {
+            $fields = [];
+            $conditions = [];
+            foreach ($filterGroup->getFilters() as $filter) {
+                $condition = $filter->getConditionType() ? $filter->getConditionType() : 'eq';
+                $fields[] = $filter->getField();
+                $conditions[] = [$condition => $filter->getValue()];
+            }
+            if ($fields) {
+                $sourceCollection->addFieldToFilter($fields, $conditions);
+            }
+        }
+        $searchResults->setTotalCount($sourceCollection->getSize());
+        $sortOrders = $criteria->getSortOrders();
+        if ($sortOrders) {
+            /** @var SortOrder $sortOrder */
+            foreach ($sortOrders as $sortOrder) {
+                $sourceCollection->addOrder(
+                    $sortOrder->getField(),
+                    ($sortOrder->getDirection() == SortOrder::SORT_ASC) ? 'ASC' : 'DESC'
+                );
+            }
+        }
+        $sourceCollection->setCurPage($criteria->getCurrentPage());
+        $sourceCollection->setPageSize($criteria->getPageSize());
+        $sources = [];
+        foreach ($sourceCollection as $sourceModel) {
+            $sources[] = $sourceModel;
+        }
+        $searchResults->setItems($sources);
+
+        return $searchResults;
+    }
+}

app/code/Magento/ImportService/etc/di.xml

@@ -10,7 +10,8 @@
     <preference for="Magento\ImportService\Api\SourceUploadInterface" type="Magento\ImportService\Model\SourceUpload" />
     <preference for="Magento\ImportService\Api\Data\SourceInterface" type="Magento\ImportService\Model\Source" />
     <preference for="Magento\ImportService\Api\Data\SourceUploadResponseInterface" type="Magento\ImportService\Model\SourceUploadResponse" />
-
+    <preference for="Magento\ImportService\Api\SourceRepositoryInterface"
+                type="Magento\ImportService\Model\SourceRepository"/>
     <type name="Magento\ImportService\Model\Import\SourceProcessorPool">
         <arguments>
             <argument name="sourceProcessors" xsi:type="array">
@@ -21,5 +22,4 @@
             </argument>
         </arguments>
     </type>
-
 </config>