App\Blog\Post\PostRepository

Complexity

Total Complexity

5

Size/Duplication

Total Lines	55
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	findAllPreloaded()	0	5	1
A	findByTag()	0	7	1
A	fullPostPage()	0	24	2
A	prepareDataReader()	0	3	1

<?php

namespace App\Blog\Post;

use App\Blog\Comment\Scope\PublicScope;
use App\Blog\Entity\Post;
use Cycle\ORM\Select;
use Yiisoft\Data\Reader\DataReaderInterface;
use Yiisoft\Data\Reader\Sort;
use Yiisoft\Yii\Cycle\DataReader\SelectDataReader;

final class PostRepository extends Select\Repository
{
    /**
     * Get posts without filter with preloaded Users and Tags
     * @return SelectDataReader
     */
    public function findAllPreloaded(): DataReaderInterface
    {
        $query = $this->select()
                ->load(['user', 'tags']);
        return $this->prepareDataReader($query);
    }

    /**
     * @param int|string $tagId
     * @return SelectDataReader
     */
    public function findByTag($tagId): DataReaderInterface
    {
        $query = $this
            ->select()
            ->where(['tags.id' => $tagId])
            ->load('user', ['method' => Select::SINGLE_QUERY]);
        return $this->prepareDataReader($query);
    }

    public function fullPostPage(string $slug, ?string $userId = null): ?Post
    {
        $query = $this
            ->select()
            ->where(['slug' => $slug])
            ->load('user', [
                'method' => Select::SINGLE_QUERY,
            ])
            ->load('tags', [
                'method' => Select::OUTER_QUERY,
            ])
            // force loading in single query with comments
            ->load('comments.user', ['method' => Select::SINGLE_QUERY])
            ->load('comments', [
                'method' => Select::OUTER_QUERY,
                // not works (default Constraint would not be replaced):
                'load' => new PublicScope($userId === null ? null : ['user_id' => $userId]),
            ]);
        /** @var null|Post $post */
        $post = $query->fetchOne();
        // /** @var Select\Repository $commentRepo */
        // $commentRepo = $this->orm->getRepository(Comment::class);
        // $commentRepo->select()->load('user')->where('post_id', $post->getId())->fetchAll();
        return $post;
    }

    private function prepareDataReader($query): SelectDataReader
    {
        return (new SelectDataReader($query))->withSort((new Sort([]))->withOrder(['published_at' => 'desc']));
    }
}