Use EAV structure instead of flat tables

config/rapidez/attribute-models.php

@@ -0,0 +1,5 @@
+<?php
+
+return [
+    'Magento\Eav\Model\Entity\Attribute\Backend\ArrayBackend' => Rapidez\Core\Models\AttributeModels\ArrayBackend::class,
+];

src/Models/AttributeDateTime.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace Rapidez\Core\Models;
+
+class AttributeDateTime extends EavAttribute
+{
+    protected $casts = ['value' => 'datetime'];
+}

src/Models/AttributeDecimal.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace Rapidez\Core\Models;
+
+class AttributeDecimal extends EavAttribute
+{
+    protected $casts = ['value' => 'float'];
+}

src/Models/AttributeInt.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace Rapidez\Core\Models;
+
+use Rapidez\Core\Models\Traits\HasAttributeOptions;
+
+class AttributeInt extends EavAttribute
+{
+    use HasAttributeOptions;
+}

src/Models/AttributeModels/ArrayBackend.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace Rapidez\Core\Models\AttributeModels;
+
+class ArrayBackend implements AttributeModel
+{
+    public static function value($value, $attribute)
+    {
+        $values = explode(',', $value);
+
+        return collect($values)->map(fn ($value) => $attribute->options[$value]?->value ?? $value);
+    }
+}

src/Models/AttributeModels/AttributeModel.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace Rapidez\Core\Models\AttributeModels;
+
+interface AttributeModel
+{
+    public static function value($value, $attribute);
+}

src/Models/AttributeOption.php

@@ -0,0 +1,23 @@
+<?php
+
+namespace Rapidez\Core\Models;
+
+use Illuminate\Contracts\Database\Eloquent\Builder;
+use Illuminate\Database\Query\JoinClause;
+
+class AttributeOption extends Model
+{
+    protected $table = 'eav_attribute_option';
+
+    protected static function boot(): void
+    {
+        parent::boot();
+
+        static::addGlobalScope('values', function (Builder $builder) {
+            $builder->leftJoin('eav_attribute_option_value', function (JoinClause $join) use ($builder) {
+                $join->on($builder->qualifyColumn('option_id'), '=', 'eav_attribute_option_value.option_id')
+                    ->whereIn('store_id', [0, config('rapidez.store')]);
+            });
+        });
+    }
+}

src/Models/AttributeText.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace Rapidez\Core\Models;
+
+use Rapidez\Core\Models\Traits\HasAttributeOptions;
+
+class AttributeText extends EavAttribute
+{
+    use HasAttributeOptions;
+}

src/Models/AttributeVarchar.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace Rapidez\Core\Models;
+
+use Rapidez\Core\Models\Traits\HasAttributeOptions;
+
+class AttributeVarchar extends EavAttribute
+{
+    use HasAttributeOptions;
+}

src/Models/EavAttribute.php

@@ -0,0 +1,58 @@
+<?php
+
+namespace Rapidez\Core\Models;
+
+use Illuminate\Database\Eloquent\Builder;
+use Illuminate\Database\Eloquent\Casts\Attribute;
+use Illuminate\Support\Facades\Cache;
+use Illuminate\Support\Facades\DB;
+use Rapidez\Core\Models\Scopes\ForCurrentStoreWithoutLimitScope;
+
+class EavAttribute extends Model
+{
+    protected static function boot(): void
+    {
+        parent::boot();
+
+        static::addGlobalScope(new ForCurrentStoreWithoutLimitScope(['attribute_id', 'entity_id']));
+
+        static::addGlobalScope('attribute', function (Builder $builder) {
+            $builder->leftJoin('eav_attribute', $builder->qualifyColumn('attribute_id'), '=', 'eav_attribute.attribute_id');
+        });
+
+        if (isset(static::$hasAttributeOptions)) { // @phpstan-ignore-line
+            static::addGlobalScope('attributeOptions', function (Builder $builder) {
+                $builder->with('attributeOptions'); // @phpstan-ignore-line
+            });
+        }
+    }
+
+    public static function getCached()
+    {
+        return Cache::rememberForever('eav_attributes', function () {
+            return DB::table('eav_attribute')->get()->keyBy('attribute_code');
+        });
+    }
+
+    public function getTable()
+    {
+        // Overwritten to always return table, so that qualifyColumn and such work
+        return $this->table;
+    }
+
+    protected function value(): Attribute
+    {
+        return Attribute::get(function ($value) {
+            if ($this->frontend_input === 'select') {
+                return $this->options[$value]?->value ?? $value;
+            }
+
+            $class = config('rapidez.attribute-models')[$this->backend_model] ?? null;
+            if ($class) {
+                return $class::value($value, $this);
+            }
+
+            return $value;
+        });
+    }
+}

src/Models/ProductEntity.php

@@ -0,0 +1,53 @@
+<?php
+
+namespace Rapidez\Core\Models;
+
+use Illuminate\Contracts\Database\Eloquent\Builder;
+use Illuminate\Database\Eloquent\Relations\BelongsToMany;
+use Rapidez\Core\Models\Scopes\Product\ForCurrentWebsiteScope;
+use Rapidez\Core\Models\Traits\HasCustomAttributes;
+
+class ProductEntity extends Model
+{
+    use HasCustomAttributes;
+
+    protected $table = 'catalog_product_entity';
+    protected $primaryKey = 'entity_id';
+
+    protected $casts = [
+        self::UPDATED_AT => 'datetime',
+        self::CREATED_AT => 'datetime',
+    ];
+
+    protected static function boot(): void
+    {
+        parent::boot();
+
+        static::addGlobalScope(ForCurrentWebsiteScope::class);
+        static::addGlobalScope('customAttributes', fn (Builder $builder) => $builder->withCustomAttributes());
+        static::addGlobalScope('onlyEnabled', fn (Builder $builder) => $builder->whereValue('status', 1));
+    }
+
+    public function gallery(): BelongsToMany
+    {
+        return $this->belongsToMany(
+            config('rapidez.models.product_image'),
+            'catalog_product_entity_media_gallery_value_to_entity',
+            'entity_id',
+            'value_id',
+        );
+    }
+
+    public function getAttribute($key)
+    {
+        if (! $key) {
+            return;
+        }
+
+        if ($value = parent::getAttribute($key)) {
+            return $value;
+        }
+
+        return $this->getCustomAttribute($key)?->value;
+    }
+}

src/Models/ProductStock.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace Rapidez\Core\Models;
+
+use Illuminate\Database\Eloquent\Model;
+
+class ProductStock extends Model
+{
+    protected $table = 'cataloginventory_stock_item';
+}

src/Models/Scopes/ForCurrentStoreWithoutLimitScope.php

@@ -5,13 +5,19 @@
 use Illuminate\Database\Eloquent\Builder;
 use Illuminate\Database\Eloquent\Model;
 use Illuminate\Database\Eloquent\Scope;
+use Illuminate\Support\Facades\DB;
 
 /**
  * Remove results from the default store when store view specific is found.
  */
 class ForCurrentStoreWithoutLimitScope implements Scope
 {
-    public function __construct(public $uniquePerStoreKey, public $storeIdColumn = 'store_id') {}
+    public array $uniquePerStoreKeys;
+
+    public function __construct(string|array $uniquePerStoreKey, public $storeIdColumn = 'store_id')
+    {
+        $this->uniquePerStoreKeys = is_array($uniquePerStoreKey) ? $uniquePerStoreKey : [$uniquePerStoreKey];
+    }
 
     public function apply(Builder $query, Model $model)
     {
@@ -20,18 +26,26 @@ public function apply(Builder $query, Model $model)
                 ->where($query->qualifyColumn($this->storeIdColumn), 0);
         }
 
+        $scope = $this;
+
         return $query
             // Pre-filter results to be default and current store only.
             ->whereIn($query->qualifyColumn($this->storeIdColumn), [0, config('rapidez.store')])
             // Remove values from the default store where values for the current store exist.
             ->where(fn ($query) => $query
                 // Remove values where we already have values in the current store.
-                ->whereNotIn($query->qualifyColumn($this->uniquePerStoreKey), fn ($query) => $query
-                    ->select($model->qualifyColumn($this->uniquePerStoreKey))
-                    ->from($model->getTable())
-                    ->whereColumn($model->qualifyColumn($this->uniquePerStoreKey), $model->qualifyColumn($this->uniquePerStoreKey))
-                    ->where($model->qualifyColumn($this->storeIdColumn), config('rapidez.store'))
-                )
+                ->where(function ($query) use ($scope, $model) {
+                    $query
+                        ->whereNotExists(function ($query) use ($scope, $model) {
+                            $query
+                                ->select(DB::raw(1))
+                                ->from($model->getTable() . ' as comparison')
+                                ->where('comparison.' . $this->storeIdColumn, config('rapidez.store'));
+                            foreach ($scope->uniquePerStoreKeys as $uniquePerStoreKey) {
+                                $query->whereColumn('comparison.' . $uniquePerStoreKey, $model->qualifyColumn($uniquePerStoreKey));
+                            }
+                        });
+                })
                 // Unless the value IS the current store.
                 ->orWhere($query->qualifyColumn($this->storeIdColumn), config('rapidez.store'))
             );

src/Models/Scopes/Product/ForCurrentWebsiteScope.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace Rapidez\Core\Models\Scopes\Product;
+
+use Illuminate\Database\Eloquent\Builder;
+use Illuminate\Database\Eloquent\Model;
+use Illuminate\Database\Eloquent\Scope;
+
+class ForCurrentWebsiteScope implements Scope
+{
+    public function apply(Builder $builder, Model $model)
+    {
+        $builder->leftJoin('catalog_product_website', 'product_id', '=', $model->getQualifiedKeyName());
+        $builder->where('website_id', config('rapidez.website'));
+    }
+}

src/Models/Traits/HasAttributeOptions.php

@@ -0,0 +1,26 @@
+<?php
+
+namespace Rapidez\Core\Models\Traits;
+
+use Illuminate\Database\Eloquent\Casts\Attribute;
+use Illuminate\Database\Eloquent\Relations\HasMany;
+use Rapidez\Core\Models\AttributeOption;
+
+trait HasAttributeOptions
+{
+    protected static $hasAttributeOptions = true;
+
+    protected function options(): Attribute
+    {
+        // Sort by store_id first to always get the higher store id if there are two.
+        return Attribute::get(fn () => $this->attributeOptions
+            ->sortBy('store_id')
+            ->keyBy('option_id')
+        );
+    }
+
+    public function attributeOptions(): HasMany
+    {
+        return $this->hasMany(AttributeOption::class, 'attribute_id', 'attribute_id');
+    }
+}