sourceItemRepository = $sourceItemRepository; $this->searchCriteriaBuilder = $searchCriteriaBuilder; } /** * Returns source item from specific source by given SKU. Return null if source item is not found * * @param string $sourceCode * @param string $sku * @return SourceItemInterface * @throws NoSuchEntityException */ public function execute(string $sourceCode, string $sku): SourceItemInterface { $searchCriteria = $this->searchCriteriaBuilder ->addFilter(SourceItemInterface::SOURCE_CODE, $sourceCode) ->addFilter(SourceItemInterface::SKU, $sku) ->create(); $sourceItemsResult = $this->sourceItemRepository->getList($searchCriteria); if ($sourceItemsResult->getTotalCount() === 0) { throw new NoSuchEntityException( __('Source item not found by source code: %1 and sku: %2.', $sourceCode, $sku) ); } return current($sourceItemsResult->getItems()); } }