Caching

CachedSkuRepository.php

<?php

class CachedSkuRepository implements SkuRepositoryInterface
{
    private $repository;

    private $cache;

    public function __construct(
        SkuRepositoryInterface $repository,
        CacheItemPoolInterface $cache
    ) {
        $this->repository = $repository;
        $this->cache      = $cache;
    }

    public function find($id)
    {
        $item = $this->cache->getItem((string)$id);
        if (!$item->isHit()) {
            $sku = $this->repository->find($id);
            $item->set($sku);
            $this->cache->save($item);
        }
        return $item->get();
    }
  
    public function persist($entity)
    {
      // persist
      $this->repository->persist($entity);
      
      // delete cache if exist
      $key = (string)$entity->getId();
      if( $this->cache->hasItem($key)) {
        $this->cache->deleteItem($key);
      }
    }
}

DoctrineSkuRepository.php

<?php

class DoctrineSkuRepository implements SkuRepositoryInterface
{
    private $em;

    public function __construct(EntityManager $em)
    {
        $this->em = $em;
    }

    public function find($id)
    {
      return $this->em->getRepository(SkuRepository::class)->find($id);
    }
    
    public function persist($entity)
    {
        $this->em->persist($entity);
    }
}

SkuRepositoryInterface.php

<?php

interface SkuRepositoryInterface
{
  public function persist(Sku $entity);
  
  public function find($id);
}