#1 Rework Tasks & Transfomers using AdapterRegistry

Author: njoubert-cleverage

config/services/registry.yaml

@@ -0,0 +1,4 @@
+services:
+    cleverage_cache_process.registry.adapter:
+        class: CleverAge\CacheProcessBundle\Registry\AdapterRegistry
+        public: false

config/services/task.yaml

@@ -0,0 +1,20 @@
+services:
+    cleverage_cache_process.task.get:
+        class: CleverAge\CacheProcessBundle\Task\GetTask
+        public: false
+        shared: false
+        arguments:
+            - '@cleverage_cache_process.registry.adapter'
+    CleverAge\CacheProcessBundle\Task\GetTask:
+        alias: cleverage_cache_process.task.get
+        public: true
+
+    cleverage_cache_process.task.set:
+        class: CleverAge\CacheProcessBundle\Task\SetTask
+        public: false
+        shared: false
+        arguments:
+            - '@cleverage_cache_process.registry.adapter'
+    CleverAge\CacheProcessBundle\Task\SetTask:
+        alias: cleverage_cache_process.task.set
+        public: true

config/services/task.yml

@@ -0,0 +1,66 @@
+<?php
+
+declare(strict_types=1);
+
+namespace CleverAge\CacheProcessBundle\Adapter;
+
+use Psr\Cache\CacheItemInterface;
+use Symfony\Component\Cache\CacheItem;
+
+class Adapter implements AdapterInterface
+{
+    public function __construct(
+        private readonly \Symfony\Component\Cache\Adapter\AdapterInterface $adapter,
+        private readonly string $code,
+    ) {}
+
+    public function getCode(): string
+    {
+        return $this->code;
+    }
+
+    public function getItem(mixed $key): CacheItem
+    {
+        return $this->adapter->getItem($key);
+    }
+
+    public function getItems(array $keys = []): iterable
+    {
+        return $this->adapter->getItems($keys);
+    }
+
+    public function clear(string $prefix = ''): bool
+    {
+        return $this->adapter->clear($prefix);
+    }
+
+    public function hasItem(string $key): bool
+    {
+        return $this->adapter->hasItem($key);
+    }
+
+    public function deleteItem(string $key): bool
+    {
+        return $this->adapter->deleteItem($key);
+    }
+
+    public function deleteItems(array $keys): bool
+    {
+        return $this->adapter->deleteItems($keys);
+    }
+
+    public function save(CacheItemInterface $item): bool
+    {
+        return $this->adapter->save($item);
+    }
+
+    public function saveDeferred(CacheItemInterface $item): bool
+    {
+        return $this->adapter->saveDeferred($item);
+    }
+
+    public function commit(): bool
+    {
+        return $this->adapter->commit();
+    }
+}

config/services/transformer.yml

@@ -0,0 +1,13 @@
+<?php
+
+declare(strict_types=1);
+
+namespace CleverAge\CacheProcessBundle\Adapter;
+
+interface AdapterInterface extends \Symfony\Component\Cache\Adapter\AdapterInterface
+{
+    /**
+     * Return the code of the adapter used in adapter registry.
+     */
+    public function getCode(): string;
+}

src/Adapter/Adapter.php

@@ -8,12 +8,28 @@
  * file that was distributed with this source code.
  */
 
-namespace CleverAge\CacheProcessBundle\src;
+namespace CleverAge\CacheProcessBundle;
 
+use CleverAge\ProcessBundle\DependencyInjection\Compiler\RegistryCompilerPass;
+use Symfony\Component\DependencyInjection\ContainerBuilder;
 use Symfony\Component\HttpKernel\Bundle\Bundle;
 
 class CleverAgeCacheProcessBundle extends Bundle
 {
+    /**
+     * Adding compiler passes to inject services into registry.
+     */
+    public function build(ContainerBuilder $container): void
+    {
+        $container->addCompilerPass(
+            new RegistryCompilerPass(
+                'cleverage_cache_process.registry.adapter',
+                'cleverage.cache.adapter',
+                'addAdapter'
+            )
+        );
+    }
+
     public function getPath(): string
     {
         return \dirname(__DIR__);

src/Adapter/AdapterInterface.php

@@ -0,0 +1,10 @@
+<?php
+
+declare(strict_types=1);
+
+namespace CleverAge\CacheProcessBundle\Exception;
+
+/**
+ * Exception thrown when trying to fetch a missing Cache Adapter.
+ */
+class MissingAdapterException extends \Exception {}

src/CleverAgeCacheProcessBundle.php

@@ -0,0 +1,37 @@
+<?php
+
+declare(strict_types=1);
+
+namespace CleverAge\CacheProcessBundle\Registry;
+
+use CleverAge\CacheProcessBundle\Adapter\AdapterInterface;
+use CleverAge\CacheProcessBundle\Exception\MissingAdapterException;
+
+/**
+ * Holds all tagged cache adapters services.
+ */
+class AdapterRegistry
+{
+    /** @var AdapterInterface[] */
+    private array $adapters = [];
+
+    public function addAdapter(AdapterInterface $adapter): void
+    {
+        if (\array_key_exists($adapter->getCode(), $this->adapters)) {
+            throw new \UnexpectedValueException("Adapter {$adapter->getCode()} is already defined");
+        }
+        $this->adapters[$adapter->getCode()] = $adapter;
+    }
+
+    /**
+     * @throws MissingAdapterException
+     */
+    public function getAdapter(string $code): AdapterInterface
+    {
+        if (!\array_key_exists($code, $this->adapters)) {
+            throw new MissingAdapterException("Adapter {$code} is missing");
+        }
+
+        return $this->adapters[$code];
+    }
+}