App\Blog\Post\PostRepository

Complexity

Total Complexity

6

Size/Duplication

Total Lines	58
Duplicated Lines	0 %

Test Coverage

Coverage

35.7%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	findAllPreloaded()	0	5	1
A	__construct()	0	4	1
A	findByTag()	0	7	1
A	prepareDataReader()	0	3	1
A	save()	0	5	1
A	fullPostPage()	0	12	1

<?php

declare(strict_types=1);

namespace App\Blog\Post;

use App\Blog\Entity\Post;
use Cycle\ORM\ORMInterface;
use Cycle\ORM\Select;
use Cycle\ORM\Transaction;
use Throwable;
use Yiisoft\Data\Reader\DataReaderInterface;
use Yiisoft\Data\Reader\Sort;
use Yiisoft\Yii\Cycle\DataReader\SelectDataReader;

final class PostRepository extends Select\Repository
{
    private ORMInterface $orm;

    public function __construct(Select $select, ORMInterface $orm)
    {
        $this->orm = $orm;
        parent::__construct($select);
    }

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

    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): ?Post
    {
        $query = $this
            ->select()
            ->where(['slug' => $slug])
            ->load('user', ['method' => Select::SINGLE_QUERY])
            ->load(['tags'])
            // force loading in single query with comments
            ->load('comments.user', ['method' => Select::SINGLE_QUERY])
            ->load('comments', ['method' => Select::OUTER_QUERY]);
        /** @var Post|null $post */
        return $query->fetchOne();
    }

    /**
     * @param Post $post
     *
     * @throws Throwable
     */
    public function save(Post $post): void
    {
        $transaction = new Transaction($this->orm);
        $transaction->persist($post);
        $transaction->run();
    }

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