Actualys\Bundle\DrupalCommerceConnectorBundle\Writer\DeltaProductWriter

Complexity

Total Complexity

4

Size/Duplication

Total Lines	58
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	write()	0	10	2
A	setStepExecution()	0	7	1

<?php

namespace Actualys\Bundle\DrupalCommerceConnectorBundle\Writer;

use Akeneo\Bundle\BatchBundle\Entity\JobInstance;
use Pim\Bundle\CatalogBundle\Manager\ChannelManager;
use Pim\Bundle\DeltaExportBundle\Manager\ProductExportManager;
use Akeneo\Bundle\BatchBundle\Entity\StepExecution;
use Symfony\Component\EventDispatcher\EventDispatcher;
use Guzzle\Http\Exception\ClientErrorResponseException;

class DeltaProductWriter extends ProductWriter
{
    /**
     * @var ProductExportManager
     */
    protected $productExportManager;

    /**
     * @var JobInstance
     */
    protected $jobInstance;

    /**
     * @var EventDispatcher
     */
    protected $eventDispatcher;

    /**
     * Constructor
     *
     * @param EventDispatcher      $eventDispatcher
     * @param ChannelManager       $channelManager
     * @param ProductExportManager $productExportManager
     */
    public function __construct(
      EventDispatcher $eventDispatcher,
      ChannelManager $channelManager,

The parameter $channelManager is not used and could be removed.

      ProductExportManager $productExportManager
    ) {
        $this->eventDispatcher = $eventDispatcher;
        $this->productExportManager = $productExportManager;
    }

    /**
     * @param array $items
     */
    public function write(array $items)
    {
        parent::write($items);
        foreach ($items as $item) {
            $this->productExportManager->updateProductExport(
              $item['sku'],
              $this->jobInstance
            );
        }
    }

    /**
     * {@inheritdoc}
     */
    public function setStepExecution(StepExecution $stepExecution)
    {
        parent::setStepExecution($stepExecution);

        $this->jobInstance = $stepExecution->getJobExecution()->getJobInstance(
        );
    }
}