App\Command\Fixture\AddCommand

Complexity

Total Complexity

21

Size/Duplication

Total Lines	131
Duplicated Lines	0 %

Importance

Changes	2
Bugs	1	Features	1

7 Methods

Rating	Name	Duplication	Size	Complexity
A	saveEntities()	0	7	2
A	configure()	0	6	1
A	__construct()	0	4	1
A	execute()	0	24	4
A	addUsers()	0	6	2
A	addTags()	0	19	4
B	addPosts()	0	38	7

<?php

namespace App\Command\Fixture;

use App\Blog\Entity\Comment;
use App\Blog\Entity\Post;
use App\Blog\Entity\Tag;
use App\Entity\User;
use App\Blog\Tag\TagRepository;
use Cycle\ORM\Transaction;
use Faker\Factory;
use Faker\Generator;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Style\SymfonyStyle;
use Yiisoft\Yii\Console\ExitCode;
use Yiisoft\Yii\Cycle\Command\CycleDependencyPromise;

The type Yiisoft\Yii\Cycle\Command\CycleDependencyPromise was not found. Maybe you did not declare it correctly or list all dependencies?

class AddCommand extends Command
{
    protected static $defaultName = 'fixture/add';

    private CycleDependencyPromise $promise;
    private Generator $faker;
    /** @var User[] */
    private array $users = [];
    /** @var Tag[] */
    private array $tags = [];

    private const DEFAULT_COUNT = 10;

    public function __construct(CycleDependencyPromise $promise)
    {
        $this->promise = $promise;
        parent::__construct();
    }

    public function configure(): void
    {
        $this
            ->setDescription('Add fixtures')
            ->setHelp('This command adds random content')
            ->addArgument('count', InputArgument::OPTIONAL, 'Count', self::DEFAULT_COUNT);
    }

    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        $io = new SymfonyStyle($input, $output);

        $count = (int)$input->getArgument('count');
        // get faker
        if (!class_exists(Factory::class)) {
            $io->error('Faker should be installed. Run `composer install --dev`');
            return ExitCode::UNSPECIFIED_ERROR;
        }
        $this->faker = Factory::create();

        try {
            $this->addUsers($count);
            $this->addTags($count);
            $this->addPosts($count);

            $this->saveEntities();
        } catch (\Throwable $t) {
            $io->error($t->getMessage());
            return $t->getCode() ?: ExitCode::UNSPECIFIED_ERROR;
        }
        $io->success('Done');
        return ExitCode::OK;
    }

    private function saveEntities(): void
    {
        $transaction = new Transaction($this->promise->getORM());
        foreach ($this->users as $user) {
            $transaction->persist($user);
        }
        $transaction->run();
    }

    private function addUsers(int $count): void
    {
        for ($i = 0; $i <= $count; ++$i) {
            $login = $this->faker->firstName . rand(0, 9999);
            $user = new User($login, $login);
            $this->users[] = $user;
        }
    }

    private function addTags(int $count): void
    {
        /** @var TagRepository $tagRepository */
        $tagRepository = $this->promise->getORM()->getRepository(Tag::class);
        $this->tags = [];
        $tagWords = [];
        for ($i = 0, $fails = 0; $i <= $count; ++$i) {
            $word = $this->faker->word();
            if (in_array($word, $tagWords, true)) {
                --$i;
                ++$fails;
                if ($fails >= $count) {
                    break;
                }
                continue;
            }
            $tagWords[] = $word;
            $tag = $tagRepository->getOrCreate($word);
            $this->tags[] = $tag;
        }
    }

    private function addPosts(int $count): void
    {
        if (count($this->users) === 0) {
            throw new \Exception('No users');
        }
        for ($i = 0; $i <= $count; ++$i) {
            /** @var User $postUser */
            $postUser = $this->users[array_rand($this->users)];
            $post = new Post($this->faker->text(64), $this->faker->realText(rand(1000, 4000)));
            $post->setUser($postUser);
            $postUser->addPost($post);
            $public = rand(0, 2) > 0;
            $post->setPublic($public);
            if ($public) {
                $post->setPublishedAt(new \DateTimeImmutable(date('r', rand(time(), strtotime('-2 years')))));
            }
            // link tags
            $postTags = (array)array_rand($this->tags, rand(1, count($this->tags)));
            foreach ($postTags as $tagId) {
                $tag = $this->tags[$tagId];
                $post->addTag($tag);
                // todo: uncomment when issue is resolved https://github.com/cycle/orm/issues/70
                // $tag->addPost($post);
            }
            // add comments
            $commentsCount = rand(0, $count);
            for ($j = 0; $j <= $commentsCount; ++$j) {
                $comment = new Comment($this->faker->realText(rand(100, 500)));
                $commentPublic = rand(0, 3) > 0;
                $comment->setPublic($commentPublic);
                if ($commentPublic) {
                    $comment->setPublishedAt(new \DateTimeImmutable(date('r', rand(time(), strtotime('-1 years')))));
                }
                $commentUser = $this->users[array_rand($this->users)];
                $comment->setUser($commentUser);
                $commentUser->addComment($comment);
                $post->addComment($comment);
                $comment->setPost($post);
            }
        }
    }
}