implement cache vary data repository

Author: David Verholen

Api/CacheVaryDataRepositoryInterface.php

@@ -0,0 +1,17 @@
+<?php
+declare(strict_types=1);
+
+namespace Firegento\CacheWarmup\Api;
+
+interface CacheVaryDataRepositoryInterface
+{
+    /**
+     * @param array $varyData
+     */
+    public function save(array $varyData): void;
+
+    /**
+     * @return array[]
+     */
+    public function getAll(): array;
+}

Model/CacheVaryDataRepository.php

@@ -0,0 +1,42 @@
+<?php
+declare(strict_types=1);
+
+namespace Firegento\CacheWarmup\Model;
+
+use Firegento\CacheWarmup\Api\CacheVaryDataRepositoryInterface;
+use Firegento\CacheWarmup\Model\VaryData\Query\GetAllVaryData;
+use Firegento\CacheWarmup\Model\VaryData\Query\SaveVaryData;
+
+class CacheVaryDataRepository implements CacheVaryDataRepositoryInterface
+{
+    /**
+     * @var SaveVaryData
+     */
+    private $saveVaryData;
+    /**
+     * @var GetAllVaryData
+     */
+    private $getAllVaryData;
+
+    public function __construct(SaveVaryData $saveVaryData, GetAllVaryData $getAllVaryData)
+    {
+        $this->saveVaryData = $saveVaryData;
+        $this->getAllVaryData = $getAllVaryData;
+    }
+
+    /**
+     * @param array $varyData
+     */
+    public function save(array $varyData): void
+    {
+        $this->saveVaryData->execute($varyData);
+    }
+
+    /**
+     * @return array[]
+     */
+    public function getAll(): array
+    {
+        return $this->getAllVaryData->execute();
+    }
+}

Model/Tag/Query/SaveTag.php

@@ -26,4 +26,4 @@ public function execute(CacheTagInterface $cacheTag): void
             ['cache_tag' => $cacheTag->getCacheTag()]
         );
     }
-}
+}

Model/VaryData/Query/GetAllVaryData.php

@@ -0,0 +1,43 @@
+<?php
+declare(strict_types=1);
+/**
+ * GetAllVaryData
+ *
+ * @copyright Copyright © 2019 brandung GmbH & Co. KG. All rights reserved.
+ * @author    david.verholen@brandung.de
+ */
+
+namespace Firegento\CacheWarmup\Model\VaryData\Query;
+
+use Magento\Framework\App\ResourceConnection;
+use Magento\Framework\Serialize\SerializerInterface;
+
+class GetAllVaryData
+{
+    /**
+     * @var ResourceConnection
+     */
+    protected $resourceConnection;
+    /**
+     * @var SerializerInterface
+     */
+    private $serializer;
+
+    public function __construct(ResourceConnection $resourceConnection, SerializerInterface $serializer)
+    {
+        $this->resourceConnection = $resourceConnection;
+        $this->serializer = $serializer;
+    }
+
+    /**
+     * @return array[]
+     */
+    public function execute(): array
+    {
+        $connection = $this->resourceConnection->getConnection();
+        return $connection->select()
+            ->from('cache_vary_data')
+            ->query()
+            ->fetchAll();
+    }
+}

Model/VaryData/Query/SaveVaryData.php

@@ -0,0 +1,35 @@
+<?php
+declare(strict_types=1);
+
+namespace Firegento\CacheWarmup\Model\VaryData\Query;
+
+use Magento\Framework\App\ResourceConnection;
+use Magento\Framework\Serialize\SerializerInterface;
+
+class SaveVaryData
+{
+    /**
+     * @var ResourceConnection
+     */
+    protected $resourceConnection;
+    /**
+     * @var SerializerInterface
+     */
+    private $serializer;
+
+    public function __construct(ResourceConnection $resourceConnection, SerializerInterface $serializer)
+    {
+        $this->resourceConnection = $resourceConnection;
+        $this->serializer = $serializer;
+    }
+
+    public function execute(array $varyData): void
+    {
+        $connection = $this->resourceConnection->getConnection();
+        $connection->insertOnDuplicate(
+            'cache_vary_data',
+            ['vary_data' => $this->serializer->serialize($varyData)],
+            ['vary_data']
+        );
+    }
+}