SWP\Bundle\CoreBundle\Command\ProcessPackagesCommand

Complexity

Total Complexity

7

Size/Duplication

Total Lines	102
Duplicated Lines	5.88 %

Coupling/Cohesion

Components	2
Dependencies	14

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	17	1
A	configure()	0	21	1
B	execute()	6	45	5

<?php

declare(strict_types=1);

/*
 * This file is part of the Superdesk Web Publisher Core Bundle.
 *
 * Copyright 2019 Sourcefabric z.ú. and contributors.
 *
 * For the full copyright and license information, please see the
 * AUTHORS and LICENSE files distributed with this source code.
 *
 * @copyright 2019 Sourcefabric z.ú
 * @license http://www.superdesk.org/license
 */

namespace SWP\Bundle\CoreBundle\Command;

use Knp\Component\Pager\Pagination\SlidingPagination;
use Knp\Component\Pager\PaginatorInterface;
use OldSound\RabbitMqBundle\RabbitMq\ProducerInterface;
use SWP\Bundle\CoreBundle\Repository\PackageRepositoryInterface;
use SWP\Bundle\MultiTenancyBundle\MultiTenancyEvents;
use SWP\Component\Bridge\Model\PackageInterface;
use SWP\Component\Common\Criteria\Criteria;
use SWP\Component\MultiTenancy\Context\TenantContextInterface;
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\EventDispatcher\EventDispatcherInterface;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\RequestStack;

class ProcessPackagesCommand extends Command
{
    protected static $defaultName = 'swp:package:process';

    private $eventDispatcher;

    private $tenantContext;

    private $packageRepository;

    private $paginator;

    private $requestStack;

    private $contentPushProducer;

    public function __construct(
        EventDispatcherInterface $eventDispatcher,
        TenantContextInterface $tenantContext,
        PackageRepositoryInterface $packageRepository,
        PaginatorInterface $paginator,
        RequestStack $requestStack,
        ProducerInterface $contentPushProducer
    ) {
        parent::__construct();

        $this->eventDispatcher = $eventDispatcher;
        $this->tenantContext = $tenantContext;
        $this->packageRepository = $packageRepository;
        $this->paginator = $paginator;
        $this->requestStack = $requestStack;
        $this->contentPushProducer = $contentPushProducer;
    }

    protected function configure(): void
    {
        $this
            ->setName(self::$defaultName)
            ->setDescription('Finds packages by term and process them.')
            ->addOption('limit', null, InputArgument::OPTIONAL, 'Pagination limit', 10)
            ->addOption('page', null, InputArgument::OPTIONAL, 'Pagination page', 1)
            ->addOption('order', null, InputArgument::OPTIONAL, 'Packages order. Example: updatedAt=desc', 'updatedAt=desc')
            ->addOption('authors', null, InputArgument::OPTIONAL, 'Filter by authors. Example: "author1,author2"', null)
            ->addOption('statuses', null, InputArgument::OPTIONAL, 'Filter by package statuses. Example: "new,published,unpublished"', null)
            ->addOption('dry-run', null, InputArgument::OPTIONAL, 'Do not execute anything, just show what was found', false)
            ->setHelp(<<<'EOT'
The <info>swp:package:packages</info> finds packages by given term and process them.

  <info>php %command.full_name%</info>

  <info>term</info> argument is the value of the string by which to find the packages.

EOT
            );
    }

    protected function execute(InputInterface $input, OutputInterface $output): void
    {
        $this->eventDispatcher->dispatch(MultiTenancyEvents::TENANTABLE_DISABLE);
        $currentTenant = $this->tenantContext->getTenant();
        $this->requestStack->push(new Request());

        $order = [];
        parse_str($input->getOption('order'), $order);

        $filters = [
            'organization' => $currentTenant->getOrganization()->getId(),
        ];
        if (null !== $input->getOption('authors')) {

This code seems to be duplicated across your project.

            $filters['authors'] = \explode(',', $input->getOption('authors'));
        }
        if (null !== $input->getOption('statuses')) {

This code seems to be duplicated across your project.

            $filters['statuses'] = \explode(',', $input->getOption('statuses'));
        }

        $criteria = new Criteria($filters);

        /** @var SlidingPagination $pagination */
        $pagination = $this->paginator->paginate(
            $this->packageRepository->getQueryByCriteria($criteria, $order, 'p'),

It seems like $order can also be of type null; however, SWP\Component\Storage\Repository\RepositoryInterface::getQueryByCriteria() does only seem to accept array, maybe add an additional type check?

            $input->getOption('page'),
            $input->getOption('limit')
        );

        $output->writeln(sprintf('Packages found: %s', $pagination->getTotalItemCount()));

        /** @var PackageInterface $package */
        foreach ($pagination->getItems() as $package) {
            $output->writeln(sprintf('Processing package with guid: %s', $package->getGuid()));
            if (true === (bool) $input->getOption('dry-run')) {
                continue;
            }

            //send package to content push
            $payload = \serialize([
                'package' => $package,
                'tenant' => $currentTenant,
            ]);
            $this->contentPushProducer->publish($payload);
        }
    }
}