Cog\Laravel\Love\Console\Commands\Recount

Complexity

Total Complexity

17

Size/Duplication

Total Lines	159
Duplicated Lines	0 %

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	findModelTypeInMorphMap()	0	10	2
A	normalizeReactableModelType()	0	6	1
A	collectReactants()	0	10	2
A	handle()	0	33	6
A	warnProcessingStartedOn()	0	13	2
A	reactableModelFromType()	0	14	3
A	getOptions()	0	17	1

<?php

/*
 * This file is part of Laravel Love.
 *
 * (c) Anton Komarev <anton@komarev.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace Cog\Laravel\Love\Console\Commands;

use Cog\Contracts\Love\Reactable\Exceptions\ReactableInvalid;
use Cog\Contracts\Love\Reactable\Models\Reactable as ReactableInterface;
use Cog\Laravel\Love\Reactant\Jobs\RebuildReactionAggregatesJob;
use Cog\Laravel\Love\Reactant\Models\Reactant;
use Cog\Laravel\Love\ReactionType\Models\ReactionType;
use Illuminate\Console\Command;
use Illuminate\Contracts\Bus\Dispatcher as DispatcherInterface;
use Illuminate\Database\Eloquent\Relations\Relation;
use Symfony\Component\Console\Attribute\AsCommand;
use Symfony\Component\Console\Input\InputOption;

#[AsCommand(name: 'love:recount', description: 'Recount reactions of the reactable models')]
final class Recount extends Command
{
    private DispatcherInterface $dispatcher;

    /**
     * Get the console command options.
     *
     * @return array<int, InputOption>
     */
    protected function getOptions(): array
    {
        return [
            new InputOption(
                name: 'model',
                mode: InputOption::VALUE_OPTIONAL,
                description: 'The name of the reactable model',
            ),
            new InputOption(
                name: 'type',
                mode: InputOption::VALUE_OPTIONAL,
                description: 'The name of the reaction type',
            ),
            new InputOption(
                name: 'queue-connection',
                mode: InputOption::VALUE_OPTIONAL,
                description: 'The name of the queue connection',
            ),
        ];
    }

    /**
     * Execute the console command.
     *
     * @throws \Cog\Contracts\Love\Reactable\Exceptions\ReactableInvalid
     */
    public function handle(
        DispatcherInterface $dispatcher,
    ): int {
        $this->dispatcher = $dispatcher;

        if ($reactableType = $this->option('model')) {
            $reactableType = $this->normalizeReactableModelType($reactableType);
        }

        if ($reactionType = $this->option('type')) {
            $reactionType = ReactionType::fromName($reactionType);
        }

        $queueConnectionName = $this->option('queue-connection');
        if ($queueConnectionName === null || $queueConnectionName === '') {
            $queueConnectionName = 'sync';
        }

        $reactants = $this->collectReactants($reactableType);

        $this->warnProcessingStartedOn($queueConnectionName);
        $this->getOutput()->progressStart($reactants->count());
        foreach ($reactants as $reactant) {
            $this->dispatcher->dispatch(
                (new RebuildReactionAggregatesJob($reactant, $reactionType))
                    ->onConnection($queueConnectionName)

It seems like $queueConnectionName can also be of type array; however, parameter $connection of Cog\Laravel\Love\Reactant\Jobs\RebuildReactionAggregatesJob::onConnection() does only seem to accept null|string, maybe add an additional type check?

            );

            $this->getOutput()->progressAdvance();
        }
        $this->getOutput()->progressFinish();

        return self::SUCCESS;
    }

    /**
     * Normalize reactable model type.
     *
     * @throws \Cog\Contracts\Love\Reactable\Exceptions\ReactableInvalid
     */
    private function normalizeReactableModelType(
        string $modelType,
    ): string {
        return $this
            ->reactableModelFromType($modelType)
            ->getMorphClass();

The method getMorphClass() does not exist on Cog\Contracts\Love\Reactable\Models\Reactable. Since it exists in all sub-types, consider adding an abstract or default implementation to Cog\Contracts\Love\Reactable\Models\Reactable.

    }

    /**
     * Instantiate model from type or morph map value.
     *
     * @param string $modelType
     * @return \Cog\Contracts\Love\Reactable\Models\Reactable|\Illuminate\Database\Eloquent\Model
     *
     * @throws \Cog\Contracts\Love\Reactable\Exceptions\ReactableInvalid
     */
    private function reactableModelFromType(
        string $modelType,
    ): ReactableInterface {
        if (!class_exists($modelType)) {
            $modelType = $this->findModelTypeInMorphMap($modelType);
        }

        $model = new $modelType();

        if (!$model instanceof ReactableInterface) {
            throw ReactableInvalid::notImplementInterface($modelType);
        }

        return $model;
    }

    /**
     * Find model type in morph mappings registry.
     *
     * @throws \Cog\Contracts\Love\Reactable\Exceptions\ReactableInvalid
     */
    private function findModelTypeInMorphMap(
        string $modelType,
    ): string {
        $morphMap = Relation::morphMap();

        if (!isset($morphMap[$modelType])) {
            throw ReactableInvalid::classNotExists($modelType);
        }

        return $morphMap[$modelType];
    }

    /**
     * Collect all reactants we want to affect.
     *
     * @param string|null $reactableType
     * @return \Cog\Contracts\Love\Reactant\Models\Reactant[]|\Illuminate\Database\Eloquent\Collection
     */
    private function collectReactants(
        ?string $reactableType = null,
    ): iterable {
        $reactantsQuery = Reactant::query();

        if ($reactableType !== null) {
            $reactantsQuery->where('type', $reactableType);
        }

        return $reactantsQuery->get();
    }

    /**
     * Write warning output that processing has been started.
     */
    private function warnProcessingStartedOn(
        ?string $queueConnectionName,
    ): void {
        if ($queueConnectionName === 'sync') {
            $message = 'Rebuilding reaction aggregates synchronously.';
        } else {
            $message = sprintf(
                'Adding rebuild reaction aggregates to the `%s` queue connection.',
                $queueConnectionName
            );
        }

        $this->warn($message);
    }
}