TreeHouse\IoBundle\Import\Handler\DoctrineHandler

Complexity

Total Complexity

7

Size/Duplication

Total Lines	81
Duplicated Lines	100 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

76.92%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	5	5	1
A	handle()	25	25	2
A	flush()	4	4	1
A	clear()	4	4	1
A	validate()	8	8	2

<?php

namespace TreeHouse\IoBundle\Import\Handler;

use Symfony\Component\Validator\Validator\ValidatorInterface;
use TreeHouse\IoBundle\Exception\ValidationException;
use TreeHouse\IoBundle\Import\Exception\FailedItemException;
use TreeHouse\IoBundle\Import\Feed\FeedItemBag;
use TreeHouse\IoBundle\Model\SourceInterface;
use TreeHouse\IoBundle\Source\Manager\CachedSourceManager;

class DoctrineHandler implements HandlerInterface

This class seems to be duplicated in your project.

{
    /**
     * @var CachedSourceManager
     */
    protected $sourceManager;

    /**
     * @var ValidatorInterface
     */
    protected $validator;

    /**
     * @param CachedSourceManager $sourceManager
     * @param ValidatorInterface  $validator
     */
    public function __construct(CachedSourceManager $sourceManager, ValidatorInterface $validator)
    {
        $this->sourceManager = $sourceManager;
        $this->validator = $validator;
    }

    /**
     * @inheritdoc
     */
    public function handle(FeedItemBag $item)
    {
        // get source and set the data to it
        $source = $this->sourceManager->findSourceByFeedOrCreate(
            $item->getFeed(),
            $item->getOriginalId(),
            $item->getOriginalUrl()
        );

        // save data
        $source->setData($item->all());
        $source->setOriginalUrl($item->getOriginalUrl());

        try {
            $this->validate($source);
            $this->sourceManager->persist($source);
            $this->sourceManager->flush($source);

            return $source;
        } catch (\Exception $exception) {
            $this->sourceManager->detach($source);

            throw new FailedItemException($source, $exception->getMessage(), $exception->getCode(), $exception);
        }
    }

    /**
     * @inheritdoc
     */
    public function flush()
    {
        $this->sourceManager->flush();
    }

    /**
     * @inheritdoc
     */
    public function clear()
    {
        $this->sourceManager->clear();
    }

    /**
     * @param SourceInterface $source
     *
     * @throws ValidationException
     */
    protected function validate(SourceInterface $source)
    {
        $violations = $this->validator->validate($source);

        if ($violations->count()) {
            throw ValidationException::create($violations);
        }
    }
}