Some TagRepository Stuff

Author: Ulf Tietze

Api/CacheTagRepositoryInterface.php

@@ -9,4 +9,6 @@ interface CacheTagRepositoryInterface
     public function getById(int $id):? CacheTagInterface;
 
     public function getByTag(string $tag):? CacheTagInterface;
+
+    public function save(CacheTagInterface $cacheTag): void;
 }

Model/CacheTagRepository.php

@@ -5,6 +5,7 @@
 use Firegento\CacheWarmup\Api\CacheTagRepositoryInterface;
 use Firegento\CacheWarmup\Api\Data\CacheTagInterface;
 use Firegento\CacheWarmup\Api\Data\CacheTagInterfaceFactory;
+use Firegento\CacheWarmup\Model\Route\Query\SaveTag;
 use Firegento\CacheWarmup\Model\Tag\Query\GetById;
 use Firegento\CacheWarmup\Model\Tag\Query\GetByTag;
 
@@ -19,13 +20,19 @@ class CacheTagRepository implements CacheTagRepositoryInterface
      * @var GetByTag
      */
     protected $getByTag;
+    /**
+     * @var SaveTag
+     */
+    protected $saveCommand;
 
     public function __construct(
         GetById  $getById,
-        GetByTag $getByTag
+        GetByTag $getByTag,
+        SaveTag  $saveCommand
     ) {
         $this->getById  = $getById;
         $this->getByTag = $getByTag;
+        $this->saveCommand = $saveCommand;
     }
 
     public function getById(int $id):? CacheTagInterface
@@ -37,4 +44,9 @@ public function getByTag(string $cacheTag):? CacheTagInterface
     {
         return $this->getByTag->execute($cacheTag);
     }
+
+    public function save(CacheTagInterface $cacheTag): void
+    {
+        $this->saveCommand->execute($cacheTag);
+    }
 }

Service/Tag/GetExistingOrNewTagModel.php

@@ -0,0 +1,40 @@
+<?php declare(strict_types=1);
+
+namespace Firegento\CacheWarmup\Service\Tag;
+
+
+use Firegento\CacheWarmup\Api\CacheTagRepositoryInterface;
+use Firegento\CacheWarmup\Api\Data\CacheTagInterface;
+
+class GetExistingOrNewTagModel
+{
+    /**
+     * @var CacheTagRepositoryInterface
+     */
+    protected $cacheTagRepository;
+    /**
+     * @var NewTagModelProvider
+     */
+    protected $newTagModelProvider;
+
+    public function __construct(
+        CacheTagRepositoryInterface $cacheTagRepository,
+        NewTagModelProvider $newTagModelProvider
+    ) {
+        $this->cacheTagRepository  = $cacheTagRepository;
+        $this->newTagModelProvider = $newTagModelProvider;
+    }
+
+    public function getByTag(string $cacheTag): CacheTagInterface
+    {
+        $cacheTag = $this->cacheTagRepository->getByTag($cacheTag);
+
+        if (!$cacheTag) {
+            $cacheTag = $this->newTagModelProvider->createForTag($cacheTag);
+            $this->cacheTagRepository->save($cacheTag);
+            $cacheTag = $this->cacheTagRepository->getByTag($cacheTag);
+        }
+
+        return $cacheTag;
+    }
+}

Service/Tag/NewTagModelProvider.php

@@ -0,0 +1,29 @@
+<?php declare(strict_types=1);
+
+namespace Firegento\CacheWarmup\Service\Tag;
+
+
+use Firegento\CacheWarmup\Api\Data\CacheTagInterface;
+use Firegento\CacheWarmup\Api\Data\CacheTagInterfaceFactory;
+
+class NewTagModelProvider
+{
+    /**
+     * @var CacheTagInterfaceFactory
+     */
+    protected $cacheTagInterfaceFactory;
+
+    public function __construct(CacheTagInterfaceFactory $cacheTagInterfaceFactory)
+    {
+        $this->cacheTagInterfaceFactory = $cacheTagInterfaceFactory;
+    }
+
+    public function createForTag(string $cacheTag): CacheTagInterface
+    {
+        /** @var CacheTagInterface $tagModel */
+        $tagModel = $this->cacheTagInterfaceFactory->create();
+        $tagModel->setCacheTag($cacheTag);
+
+        return $tagModel;
+    }
+}