Saxulum\ModelImporter\Importer

Complexity

Total Complexity

9

Size/Duplication

Total Lines	102
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes	7
Bugs	0	Features	2

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	2
A	import()	0	19	2
A	importModels()	0	9	2
A	importModel()	0	17	2
A	modelInfo()	0	7	1

<?php

namespace Saxulum\ModelImporter;

use Psr\Log\LoggerInterface;
use Psr\Log\NullLogger;

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
     *
     * @return \DateTime
     */
    public function import($limit = 100)
    {
        $importDate = new \DateTime();

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

        $offset = 0;

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

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

        return $importDate;
    }

    /**
     * @param ReaderModelInterface[]|array $readerModels
     * @param \DateTime                    $importDate
     */
    protected function importModels(array $readerModels, \DateTime $importDate)
    {
        foreach ($readerModels as $readerModel) {
            $this->importModel($readerModel, $importDate);
        }

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

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

        $writerModel->setReaderIdentifier($readerModel->getIdentifier());
        $writerModel->setLastImportDate($importDate);

        $this->writer->persist($writerModel);
        $this->modelInfo($readerModel, 'persisted');
    }

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