IndexStructure.php 1.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061
  1. <?php
  2. /**
  3. * Copyright © Magento, Inc. All rights reserved.
  4. * See COPYING.txt for license details.
  5. */
  6. namespace Magento\Elasticsearch\Model\Indexer;
  7. use Magento\Framework\Indexer\IndexStructureInterface;
  8. use Magento\Elasticsearch\Model\Adapter\Elasticsearch as ElasticsearchAdapter;
  9. use Magento\Framework\App\ScopeResolverInterface;
  10. class IndexStructure implements IndexStructureInterface
  11. {
  12. /**
  13. * @var ElasticsearchAdapter
  14. */
  15. private $adapter;
  16. /**
  17. * @var ScopeResolverInterface
  18. */
  19. private $scopeResolver;
  20. /**
  21. * @param ElasticsearchAdapter $adapter
  22. * @param ScopeResolverInterface $scopeResolver
  23. */
  24. public function __construct(
  25. ElasticsearchAdapter $adapter,
  26. ScopeResolverInterface $scopeResolver
  27. ) {
  28. $this->adapter = $adapter;
  29. $this->scopeResolver = $scopeResolver;
  30. }
  31. /**
  32. * {@inheritdoc}
  33. */
  34. public function delete(
  35. $indexerId,
  36. array $dimensions = []
  37. ) {
  38. $dimension = current($dimensions);
  39. $scopeId = $this->scopeResolver->getScope($dimension->getValue())->getId();
  40. $this->adapter->cleanIndex($scopeId, $indexerId);
  41. }
  42. /**
  43. * {@inheritdoc}
  44. *
  45. */
  46. public function create(
  47. $indexerId,
  48. array $fields,
  49. array $dimensions = []
  50. ) {
  51. $dimension = current($dimensions);
  52. $scopeId = $this->scopeResolver->getScope($dimension->getValue())->getId();
  53. $this->adapter->checkIndex($scopeId, $indexerId, false);
  54. }
  55. }