src/Message/AVOMessage.php line 9

Open in your IDE?
  1. <?php
  3. namespace App\Message;
  5. use Carbon\Carbon;
  6. use Pimcore\Model\DataObject\CatalogGridBanner;
  7. use Pimcore\Model\DataObject\CatalogTopBanner;
  9. class AVOMessage{
  10. protected array $enabledModels = [
  11. "Award" => AwardModel::class,
  12. "Advantage" => AdvantageModel::class,
  13. "Feature" => FeatureModel::class,
  14. "Brand" => BrandModel::class,
  15. "BrandCategoryImage" => BrandCategoryImageModel::class,
  16. "Collection" => CollectionModel::class,
  17. "CollectionCategoryImage" => CollectionCategoryImageModel::class,
  18. "Category" => CategoryModel::class,
  19. "Label" => ProductLabelModel::class,
  20. "ProductCard" => ProductCardModel::class,
  21. "ProductVariation" => ProductVariationModel::class,
  22. "ProductProperty" => ProductPropertyModel::class,
  23. "Store" => StoreModel::class,
  24. "ProductStock" => ProductStockModel::class,
  25. "ProductRelease" => ProductReleaseModel::class,
  26. "EuProductRelease" => ProductReleaseModel::class,
  27. "ProductsSet" => ProductsSetModel::class,
  28. "CatalogTopBanner" => CatalogTopBannerModel::class,
  29. "CatalogGridBanner" => CatalogGridBannerModel::class,
  30. ];
  31. public string $action;
  32. public string $model;
  33. public array $data;
  34. public int $timestamp;
  36. protected DataModelInterface $dataModel;
  37. protected Carbon $createdAt;
  39. public function __construct(array $rawEventItem)
  40. {
  41. $this->action = $rawEventItem['action'];
  42. $this->model = $rawEventItem['model'];
  43. $this->data = $rawEventItem['data'];
  44. $this->timestamp = $rawEventItem['timestamp'];
  46. $this->createdAt = Carbon::createFromTimestamp($rawEventItem['timestamp']);
  47. $this->dataModel = $this->getModelByName($rawEventItem['model']);
  48. }
  50. public function getActionName(): string
  51. {
  52. return $this->action;
  53. }
  54. public function getModel(): string
  55. {
  56. return $this->model;
  57. }
  59. public function createdAt(): Carbon
  60. {
  61. return $this->createdAt;
  62. }
  64. public function getDataModel(): DataModelInterface
  65. {
  66. return $this->dataModel;
  67. }
  69. public function defaultExecute(): ?bool
  70. {
  71. return $this->dataModel->{$this->action}();
  72. }
  74. /**
  75. * @param string $modelName
  76. * @return DataModelInterface
  77. * @throws \Exception
  78. */
  79. private function getModelByName(string $modelName): DataModelInterface
  80. {
  81. if(!isset($this->enabledModels[$modelName]))
  82. {
  83. throw new \Exception("Can not find model '{$modelName}' in Event Bus module");
  84. }
  85. return $this->enabledModels[$modelName]::create($this->data, $this);
  86. }
  87. }