Maketok\DataMigration\QueueWorkflow

Complexity

Total Complexity

4

Size/Duplication

Total Lines	48
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	add()	0	4	1
A	execute()	0	10	2

<?php

namespace Maketok\DataMigration;

use Maketok\DataMigration\Action\ActionInterface;
use Maketok\DataMigration\Action\ConfigInterface;
use Maketok\DataMigration\Workflow\ResultInterface;

class QueueWorkflow implements WorkflowInterface
{
    /**
     * @var \SplQueue
     */
    protected $queue;
    /**
     * @var ResultInterface
     */
    protected $result;
    /**
     * @var ConfigInterface
     */
    protected $config;

    /**
     * @param ConfigInterface $config
     * @param ResultInterface $result
     */
    public function __construct(ConfigInterface $config, ResultInterface $result)
    {
        $this->config = $config;
        $this->result = $result;
        $this->queue = new \SplQueue();
    }

    /**
     * {@inheritdoc}
     */
    public function add(ActionInterface $action)
    {
        $this->queue->enqueue($action);
    }

    /**
     * {@inheritdoc}
     */
    public function execute()
    {
        $this->result->setStartTime(new \DateTime());
        while (!$this->queue->isEmpty()) {
            /** @var ActionInterface $action */
            $action = $this->queue->dequeue();
            $action->process($this->result);
        }
        $this->result->setEndTime(new \DateTime());
    }
}