Extraload\Pipeline\DefaultPipeline

Complexity

Total Complexity

6

Size/Duplication

Total Lines	51
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	1
A	process()	0	22	3
A	dispatch()	0	8	2

<?php

namespace Extraload\Pipeline;

use Extraload\Extractor\ExtractorInterface;
use Extraload\Transformer\TransformerInterface;
use Extraload\Loader\LoaderInterface;
use Extraload\Events;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;
use Symfony\Component\EventDispatcher\GenericEvent;

class DefaultPipeline implements PipelineInterface
{
    private $extractor;
    private $transformer;
    private $loader;
    private $eventDispatcher;

    public function __construct(
        ExtractorInterface $extractor,
        TransformerInterface $transformer,
        LoaderInterface $loader,
        EventDispatcherInterface $eventDispatcher = null
    ) {
        $this->extractor = $extractor;
        $this->transformer = $transformer;
        $this->loader = $loader;
        $this->eventDispatcher = $eventDispatcher;
    }

    public function process()
    {
        $this->dispatch(Events::PRE_PROCESS);

        while (null !== $extracted = $this->extractor->extract()) {
            $this->dispatch(Events::EXTRACT, $extracted);

            $transformed = $this->transformer->transform($extracted);
            $this->dispatch(Events::TRANSFORM, $transformed);

            if (null === $transformed) {
                continue;
            }

            $this->loader->load($transformed);
            $this->dispatch(Events::LOAD, $transformed);
        }

        $this->loader->flush();

        $this->dispatch(Events::POST_PROCESS);
    }

    private function dispatch($name, $subject = null)
    {
        if (null === $this->eventDispatcher) {
            return;
        }

        $this->eventDispatcher->dispatch($name, new GenericEvent($subject));
    }
}