Saxulum\ModelImporter\Importer

Complexity

Total Complexity

11

Size/Duplication

Total Lines	125
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	9

Importance

Changes	12
Bugs	0	Features	7

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	2
B	import()	0	24	3
A	importModels()	0	20	3
A	importModel()	0	20	2
A	modelInfo()	0	7	1

<?php

namespace Saxulum\ModelImporter;

use Psr\Log\LoggerInterface;
use Psr\Log\NullLogger;
use Saxulum\ModelImporter\Progress\NullProgress;
use Saxulum\ModelImporter\Progress\ProgressInterface;

class Importer
{
    /**
     * @var ReaderInterface
     */
    protected $reader;

    /**
     * @var WriterInterface
     */
    protected $writer;

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

    /**
     * @param ReaderInterface $reader
     * @param WriterInterface $writer
     * @param LoggerInterface $logger
     */
    public function __construct(ReaderInterface $reader, WriterInterface $writer, LoggerInterface $logger = null)
    {
        $this->reader = $reader;
        $this->writer = $writer;
        $this->logger = null !== $logger ? $logger : new NullLogger();
    }

    /**
     * @param int                    $limit
     * @param ProgressInterface|null $progress
     *
     * @return \DateTime
     */
    public function import($limit = 100, ProgressInterface $progress = null)
    {
        if (null === $progress) {
            $progress = new NullProgress();
        }

        $importDate = new \DateTime();

        $this->logger->info('Import started at {importDate}', ['importDate' => $importDate]);

        $offset = 0;

        while ([] !== $readerModels = $this->reader->getReaderModels($offset, $limit)) {
            $this->logger->info('Read, offset: {offset}, limit: {limit}', ['offset' => $offset, 'limit' => $limit]);
            $this->importModels($readerModels, $importDate, $progress);
            $this->reader->clearReaderModels();
            $offset += $limit;
        }

        $this->writer->removeWriterModels($importDate);
        $this->logger->info('Removed all outdates');

        return $importDate;
    }

    /**
     * @param ReaderModelInterface[]|array $readerModels
     * @param \DateTime                    $importDate
     * @param ProgressInterface            $progress
     */
    protected function importModels(array $readerModels, \DateTime $importDate, ProgressInterface $progress)
    {
        $writerModels = [];
        foreach ($readerModels as $readerModel) {
            try {
                $writerModels[] = $this->importModel($readerModel, $importDate);
            } catch (NotImportableException $e) {
                $this->logger->warning(
                    $e->getMessage(),
                    ['identifier' => $readerModel->getImportIdentifier()]
                );
            }
            $progress->advance();
        }

        $this->writer->flushWriterModels($writerModels);
        $this->writer->clearWriterModels();

        $this->logger->info('Flushed models');
    }

    /**
     * @param ReaderModelInterface $readerModel
     * @param \DateTime            $importDate
     *
     * @return WriterModelInterface
     */
    protected function importModel(ReaderModelInterface $readerModel, \DateTime $importDate)
    {
        $writerModel = $this->writer->findWriterModel($readerModel);
        if (null === $writerModel) {
            $writerModel = $this->writer->createWriterModel($readerModel);
            $this->modelInfo($readerModel, 'created');
        } else {
            $this->writer->updateWriterModel($writerModel, $readerModel);
            $this->modelInfo($readerModel, 'updated');
        }

        $writerModel->setImportIdentifier($readerModel->getImportIdentifier());
        $writerModel->setLastImportDate($importDate);

        $this->writer->persistWriterModel($writerModel);

        $this->modelInfo($readerModel, 'persisted');

        return $writerModel;
    }

    /**
     * @param ReaderModelInterface $readerModel
     * @param string               $action
     */
    protected function modelInfo(ReaderModelInterface $readerModel, $action)
    {
        $this->logger->info(
            ucfirst($action).' model with identifier {identifier}',
            ['identifier' => $readerModel->getImportIdentifier()]
        );
    }
}