hgraca / explicit-architecture-php

use Acme\App\Core\SharedKernel\Component\Blog\Domain\Post\Comment\CommentId;

use Acme\App\Core\SharedKernel\Component\User\Domain\User\UserId;

final class FindAuthorIdByCommentIdQuery implements FindAuthorIdByCommentIdQueryInterface

{

    /**

     * @var DqlQueryBuilderInterface

     */

    private $dqlQueryBuilder;

    /**

     * @var QueryServiceRouterInterface

     */

    private $queryService;

    public function __construct(

        DqlQueryBuilderInterface $dqlQueryBuilder,

        QueryServiceRouterInterface $queryService

    ) {

        $this->dqlQueryBuilder = $dqlQueryBuilder;

        $this->queryService = $queryService;

    }

    public function execute(CommentId $commentId): UserId

    {

        $dqlQuery = $this->dqlQueryBuilder->create(Comment::class)

            ->select('Comment.authorId')

            ->where('Comment.id = :commentId')

            ->setParameter('commentId', $commentId)

            ->build();

        return $this->queryService->query($dqlQuery)->getSingleResult()['authorId'];

    }

}

use Acme\App\Core\Port\Persistence\QueryServiceRouterInterface;

use Acme\App\Core\SharedKernel\Component\User\Domain\User\UserId;

final class FindAuthorIdByPostIdQuery implements FindAuthorIdByPostIdQueryInterface

{

    /**

     * @var DqlQueryBuilderInterface

     */

    private $dqlQueryBuilder;

    /**

     * @var QueryServiceRouterInterface

     */

    private $queryService;

    public function __construct(

        DqlQueryBuilderInterface $dqlQueryBuilder,

        QueryServiceRouterInterface $queryService

    ) {

        $this->dqlQueryBuilder = $dqlQueryBuilder;

        $this->queryService = $queryService;

    }

    public function execute(PostId $postId): UserId

    {

        $dqlQuery = $this->dqlQueryBuilder->create(Post::class)

            ->select('Post.authorId')

            ->where('Post.id = :postId')

            ->setParameter('postId', $postId)

            ->build();

        return $this->queryService->query($dqlQuery)->getSingleResult()['authorId'];

    }

}