Mathielen\DataImport\Writer\ObjectWriter

Complexity

Total Complexity

12

Size/Duplication

Total Lines	83
Duplicated Lines	14.46 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

86.21%

Importance

Changes	3
Bugs	1	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	prepare()	0	4	1
A	write()	0	4	1
A	finish()	0	4	1
A	writeItem()	0	10	1
A	convert()	0	11	2
A	__construct()	0	8	2
A	setObjectFactory()	12	12	4

<?php
namespace Mathielen\DataImport\Writer;

use Ddeboer\DataImport\Writer\WriterInterface;
use Mathielen\DataImport\Writer\ObjectWriter\ObjectFactoryInterface;
use Mathielen\DataImport\Writer\ObjectWriter\DefaultObjectFactory;

/**
 * Writes data to a given SplObjectStorage
 */
class ObjectWriter implements WriterInterface
{

    /**
     * @var ObjectFactoryInterface
     */
    private $objectFactory;

    /**
     * @var \SplObjectStorage
     */
    private $objectStorage;

    public function __construct(\SplObjectStorage $objectStorage, $classOrObjectFactory=null)
    {
        $this->objectStorage = $objectStorage;

        if (!empty($classOrObjectFactory)) {
            $this->setObjectFactory($classOrObjectFactory);
        }
    }

    public function setObjectFactory($classOrObjectFactory)

This method seems to be duplicated in your project.

    {
        if (is_object($classOrObjectFactory) && $classOrObjectFactory instanceof ObjectFactoryInterface) {
            $objectFactory = $classOrObjectFactory;
        } elseif (is_string($classOrObjectFactory)) {
            $objectFactory = new DefaultObjectFactory($classOrObjectFactory);
        } else {
            throw new \InvalidArgumentException("classOrObjectFactory must not be empty");
        }

        $this->objectFactory = $objectFactory;
    }

    /**
     * {@inheritDoc}
     */
    public function prepare()
    {
        return $this;
    }

    /**
     * (non-PHPdoc)
     * @see \Ddeboer\DataImport\Writer\WriterInterface::writeItem()
     */
    public function writeItem(array $item)
    {
        //convert
        $objectOrItem = $this->convert($item);

        //write
        $this->write($objectOrItem);

        return $this;
    }

    private function convert(array $item)
    {
        //dont convert if no object factory
        if (!$this->objectFactory) {
            return $item;
        }

        $object = $this->objectFactory->factor($item);

        return $object;
    }

    protected function write($object)
    {
        $this->objectStorage->attach($object);
    }

    /**
     * {@inheritDoc}
     */
    public function finish()
    {
        return $this;
    }
}