OroCRM\Bundle\MagentoBundle\ImportExport\Writer\NewsletterSubscriberInitialWriter

Complexity

Total Complexity

5

Size/Duplication

Total Lines	27
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes	1
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
B	write()	0	21	5

<?php

namespace OroCRM\Bundle\MagentoBundle\ImportExport\Writer;

use OroCRM\Bundle\MagentoBundle\Entity\MagentoSoapTransport;
use OroCRM\Bundle\MagentoBundle\Entity\NewsletterSubscriber;

class NewsletterSubscriberInitialWriter extends ProxyEntityWriter
{
    /**
     * @param NewsletterSubscriber[] $items
     */
    public function write(array $items)
    {
        parent::write($items);

        $count = count($items);
        if (!$count) {
            return;
        }
        // Save minimum originId received by initial sync for further filtering in case of failure
        $lastSubscriber = $items[$count - 1];
        $transport = $lastSubscriber->getChannel()->getTransport();
        if ($transport instanceof MagentoSoapTransport) {
            /** @var MagentoSoapTransport $transport */
            $transport = $this->databaseHelper->getEntityReference($transport);
            $syncedToId = $transport->getNewsletterSubscriberSyncedToId();
            if (!$syncedToId || $syncedToId > $lastSubscriber->getOriginId()) {
                $transport->setNewsletterSubscriberSyncedToId($lastSubscriber->getOriginId());
                $this->writer->write([$transport]);
            }
        }
    }
}