Maketok\DataMigration\Workflow\Result

Complexity

Total Complexity

36

Size/Duplication

Total Lines	214
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

100%

Importance

Changes

0

19 Methods

Rating	Name	Duplication	Size	Complexity
A	getTotalRowsProcessed()	0	8	2
A	getAllErrors()	0	8	2
A	getAllExceptions()	0	8	2
A	getParticipants()	0	4	1
A	getActionProcessed()	0	5	2
A	getActionErrors()	0	5	2
A	getActionExceptions()	0	5	2
A	addActionError()	0	10	3
A	addActionException()	0	10	3
A	incrementActionProcessed()	0	10	3
A	getStartTime()	0	4	1
A	getEndTime()	0	4	1
A	getActionStartTime()	0	5	2
A	getActionEndTime()	0	5	2
A	setStartTime()	0	4	1
A	setEndTime()	0	4	1
A	setActionStartTime()	0	8	2
A	setActionEndTime()	0	8	2
A	getTotalRowsThrough()	0	8	2

<?php

namespace Maketok\DataMigration\Workflow;

class Result implements ResultInterface
{
    /**
     * @var array
     */
    protected $participants;
    /**
     * @var \DateTime
     */
    protected $startTime;
    /**
     * @var \DateTime
     */
    protected $endTime;

    /**
     * {@inheritdoc}
     */
    public function getTotalRowsProcessed()
    {
        $rows = 0;
        foreach ($this->participants as $key => $data) {
            $rows += $this->getActionProcessed($key);
        }
        return $rows;
    }

    /**
     * {@inheritdoc}
     */
    public function getAllErrors()
    {
        $errors = [];
        foreach ($this->participants as $key => $data) {
            $errors = array_merge($errors, $this->getActionErrors($key));
        }
        return $errors;
    }

    /**
     * {@inheritdoc}
     */
    public function getAllExceptions()
    {
        $exceptions = [];
        foreach ($this->participants as $key => $data) {
            $exceptions = array_merge($exceptions, $this->getActionExceptions($key));
        }
        return $exceptions;
    }

    /**
     * {@inheritdoc}
     */
    public function getParticipants()
    {
        return $this->participants;
    }

    /**
     * {@inheritdoc}
     */
    public function getActionProcessed($code)
    {
        return isset($this->participants[$code]['rows_processed']) ?
            $this->participants[$code]['rows_processed'] : 0;
    }

    /**
     * {@inheritdoc}
     */
    public function getActionErrors($code)
    {
        return isset($this->participants[$code]['errors']) ?
            $this->participants[$code]['errors'] : [];
    }

    /**
     * {@inheritdoc}
     */
    public function getActionExceptions($code)
    {
        return isset($this->participants[$code]['exceptions']) ?
            $this->participants[$code]['exceptions'] : [];
    }

    /**
     * {@inheritdoc}
     */
    public function addActionError($code, $message)
    {
        if (isset($this->participants[$code]['errors'])) {
            $this->participants[$code]['errors'][] = $message;
        } elseif (isset($this->participants[$code])) {
            $this->participants[$code]['errors'] = [$message];
        } else {
            $this->participants[$code] = ['errors' => [$message]];
        }
    }

    /**
     * {@inheritdoc}
     */
    public function addActionException($code, \Exception $ex)

Avoid variables with short names like $ex. Configured minimum length is 3.

    {
        if (isset($this->participants[$code]['exceptions'])) {
            $this->participants[$code]['exceptions'][] = $ex;
        } elseif (isset($this->participants[$code])) {
            $this->participants[$code]['exceptions'] = [$ex];
        } else {
            $this->participants[$code] = ['exceptions' => [$ex]];
        }
    }

    /**
     * {@inheritdoc}
     */
    public function incrementActionProcessed($code, $value = 1)
    {
        if (isset($this->participants[$code]['rows_processed'])) {
            $this->participants[$code]['rows_processed'] += $value;
        } elseif (isset($this->participants[$code])) {
            $this->participants[$code]['rows_processed'] = $value;
        } else {
            $this->participants[$code] = ['rows_processed' => $value];
        }
    }

    /**
     * {@inheritdoc}
     */
    public function getStartTime()
    {
        return $this->startTime;
    }

    /**
     * {@inheritdoc}
     */
    public function getEndTime()
    {
        return $this->endTime;
    }

    /**
     * {@inheritdoc}
     */
    public function getActionStartTime($code)
    {
        return isset($this->participants[$code]['start_time']) ?
            $this->participants[$code]['start_time'] : null;
    }

    /**
     * {@inheritdoc}
     */
    public function getActionEndTime($code)
    {
        return isset($this->participants[$code]['end_time']) ?
            $this->participants[$code]['end_time'] : null;
    }

    /**
     * {@inheritdoc}
     */
    public function setStartTime(\DateTime $time)
    {
        $this->startTime = $time;
    }

    /**
     * {@inheritdoc}
     */
    public function setEndTime(\DateTime $time)
    {
        $this->endTime = $time;
    }

    /**
     * {@inheritdoc}
     */
    public function setActionStartTime($code, \DateTime $time)
    {
        if (isset($this->participants[$code])) {
            $this->participants[$code]['start_time'] = $time;
        } else {
            $this->participants[$code] = ['start_time' => $time];
        }
    }

    /**
     * {@inheritdoc}
     */
    public function setActionEndTime($code, \DateTime $time)
    {
        if (isset($this->participants[$code])) {
            $this->participants[$code]['end_time'] = $time;
        } else {
            $this->participants[$code] = ['end_time' => $time];
        }
    }

    /**
     * {@inheritdoc}
     */
    public function getTotalRowsThrough()
    {
        $rows = [];
        foreach ($this->participants as $key => $data) {
            $rows[] = $this->getActionProcessed($key);
        }
        return min($rows);
    }
}