DoctrinePostRepository.php

<?php

/**
 * Simpler version of
 * https://github.com/dddinphp/repository-examples/blob/master/src/Infrastructure/Persistence/Doctrine/DoctrinePostRepository.php#L64
 * 
 * Thanks to using inheritance.
 */

namespace Infrastructure\Persistence\Doctrine;

use Doctrine\ORM\EntityRepository;
use Domain\Model\Post;
use Domain\Model\PostId;
use Domain\Model\CollectionPostRepository as PostRepository;

class DoctrinePostRepository extends EntityRepository implements PostRepository
{
    public function add(Post $aPost)
    {
        $this->_em->persist($aPost);
    }

    public function remove(Post $aPost)
    {
        $this->_em->remove($aPost);
    }

    public function postOfId(PostId $anId)
    {
        return $this->findOneByPostId($anId);
    }

    public function latestPosts(\DateTime $sinceADate)
    {
        return $this->em->createQueryBuilder('p')
            ->where('p.createdAt > :since')
            ->setParameter(':since', $sinceADate)
            ->getQuery()
            ->getResult();
    }

    /**
     * @param DoctrinePostSpecification $specification
     *
     * @return Post[]
     */
    public function query($specification)
    {
        return $specification->buildQuery($this->_em)->getResult();
    }

    public function nextIdentity()
    {
        return new PostId();
    }

    public function size()
    {
        return $this->_em->createQueryBuilder('p')
            ->select('count(p.id)')
            ->getQuery()
            ->getSingleScalarResult();
    }
}