TreeHouse\IoBundle\Bridge\WorkerBundle\Executor\ImportPartExecutor

Complexity

Total Complexity

13

Size/Duplication

Total Lines	144
Duplicated Lines	8.33 %

Coupling/Cohesion

Components	2
Dependencies	13

Test Coverage

Coverage

0%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	getName()	0	4	1
A	getObjectPayload()	0	4	1
A	supportsObject()	0	4	1
A	configurePayload()	12	12	2
B	execute()	0	40	4
A	findImportPart()	0	4	1
A	validate()	0	13	2

<?php

namespace TreeHouse\IoBundle\Bridge\WorkerBundle\Executor;

use Doctrine\Common\Persistence\ManagerRegistry;
use Psr\Log\LoggerInterface;
use Symfony\Component\OptionsResolver\Exception\InvalidArgumentException;
use Symfony\Component\OptionsResolver\Options;
use Symfony\Component\OptionsResolver\OptionsResolver;
use TreeHouse\IoBundle\Entity\ImportPart;
use TreeHouse\IoBundle\Import\Feed\TransportFactory;
use TreeHouse\IoBundle\Import\ImportFactory;
use TreeHouse\WorkerBundle\Executor\AbstractExecutor;
use TreeHouse\WorkerBundle\Executor\ObjectPayloadInterface;

/**
 * Performs import of a single ImportPart.
 */
class ImportPartExecutor extends AbstractExecutor implements ObjectPayloadInterface
{
    const NAME = 'import.part';

    /**
     * @var ManagerRegistry
     */
    protected $doctrine;

    /**
     * @var ImportFactory
     */
    protected $importFactory;

    /**
     * @var LoggerInterface
     */
    protected $logger;

    /**
     * @param ManagerRegistry $doctrine
     * @param ImportFactory   $importFactory
     * @param LoggerInterface $logger
     */
    public function __construct(ManagerRegistry $doctrine, ImportFactory $importFactory, LoggerInterface $logger)
    {
        $this->doctrine = $doctrine;
        $this->importFactory = $importFactory;
        $this->logger = $logger;
    }

    /**
     * @return string
     */
    public function getName()
    {
        return self::NAME;
    }

    /**
     * @inheritdoc
     */
    public function getObjectPayload($object)
    {
        return [$object->getId()];
    }

    /**
     * @inheritdoc
     */
    public function supportsObject($object)
    {
        return $object instanceof ImportPart;
    }

    /**
     * @inheritdoc
     */
    public function configurePayload(OptionsResolver $resolver)

This method seems to be duplicated in your project.

    {
        $resolver->setRequired(0);
        $resolver->setAllowedTypes(0, 'numeric');
        $resolver->setNormalizer(0, function (Options $options, $value) {
            if (null === $part = $this->findImportPart($value)) {
                throw new InvalidArgumentException(sprintf('Import part with id "%d" does not exist', $value));
            }

            return $part;
        });
    }

    /**
     * @inheritdoc
     */
    public function execute(array $payload)
    {
        /** @var ImportPart $part */
        list($part) = $payload;

        $import = $part->getImport();
        $feed = $import->getFeed();

        $this->logger->info(
            sprintf(
                'Importing part <comment>%d</comment> of %s-feed for import "%d" for origin "%s"',
                $part->getPosition(),
                $feed->getType(),
                $import->getId(),
                $feed->getOrigin()->getTitle()
            )
        );

        if ($import->isFinished()) {
            $this->logger->info(sprintf('Import %d has already finished', $import->getId()));

            return false;
        }

        if ($part->isFinished()) {
            $this->logger->info(sprintf('Part %d has already finished', $part->getId()));

            return false;
        }

        if (!$this->validate($part)) {
            return false;
        }

        $job = $this->importFactory->createImportJob($part);
        $job->setLogger($this->logger);
        $job->run();

        return true;
    }

    /**
     * @param int $partId
     *
     * @return ImportPart
     */
    protected function findImportPart($partId)
    {
        return $this->doctrine->getRepository('TreeHouseIoBundle:ImportPart')->find($partId);
    }

    /**
     * @param ImportPart $part
     *
     * @return bool
     */
    protected function validate(ImportPart $part)
    {
        // validate that we have a valid transport config
        try {
            TransportFactory::createTransportFromConfig($part->getTransportConfig());
        } catch (\RuntimeException $e) {
            $part->setError($e->getMessage());

            return false;
        }

        return true;
    }
}