TreeHouse\IoBundle\Entity\ImportPart

Complexity

Total Complexity

25

Size/Duplication

Total Lines	308
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	0

Test Coverage

Coverage

41.28%

Importance

Changes

0

23 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getId()	0	4	1
A	setPosition()	0	6	1
A	getPosition()	0	4	1
A	setTransportConfig()	0	6	1
A	getTransportConfig()	0	4	1
A	setProcess()	0	6	1
A	getProcess()	0	4	1
A	setError()	0	6	1
A	getError()	0	4	1
A	setRetries()	0	6	1
A	getRetries()	0	4	1
A	setDatetimeScheduled()	0	6	1
A	getDatetimeScheduled()	0	4	1
A	setDatetimeStarted()	0	6	1
A	getDatetimeStarted()	0	4	1
A	setDatetimeEnded()	0	6	1
A	getDatetimeEnded()	0	4	1
A	setImport()	0	6	1
A	getImport()	0	4	1
A	isStarted()	0	4	1
A	isFinished()	0	4	1
A	isRunning()	0	16	3

<?php

namespace TreeHouse\IoBundle\Entity;

use Doctrine\ORM\Mapping as ORM;

/**
 * @ORM\Table
 * @ORM\Entity(repositoryClass="ImportPartRepository")
 */
class ImportPart
{
    /**
     * @var int
     *
     * @ORM\Id
     * @ORM\Column(type="integer")
     * @ORM\GeneratedValue(strategy="AUTO")
     */
    protected $id;

    /**
     * @var int
     *
     * @ORM\Column(type="integer")
     */
    protected $position;

    /**
     * @var array
     *
     * @ORM\Column(type="json_array")
     */
    protected $transportConfig;

    /**
     * @var int
     *
     * @ORM\Column(type="integer", nullable=true)
     */
    protected $process;

    /**
     * @var string
     *
     * @ORM\Column(type="string", nullable=true)
     */
    protected $error;

    /**
     * @var int
     *
     * @ORM\Column(type="integer")
     */
    protected $retries;

    /**
     * @var \DateTime
     *
     * @ORM\Column(type="datetime", nullable=true)
     */
    protected $datetimeScheduled;

    /**
     * @var \DateTime
     *
     * @ORM\Column(type="datetime", nullable=true)
     */
    protected $datetimeStarted;

    /**
     * @var \DateTime
     *
     * @ORM\Column(type="datetime", nullable=true)
     */
    protected $datetimeEnded;

    /**
     * @var Import
     *
     * @ORM\ManyToOne(targetEntity="Import", inversedBy="parts")
     */
    protected $import;

    /**
     * Constructor.
     */
    public function __construct()
    {
        $this->retries = 1;
    }

    /**
     * @return int
     */
    public function getId()
    {
        return $this->id;
    }

    /**
     * @param int $position
     *
     * @return $this
     */
    public function setPosition($position)
    {
        $this->position = $position;

        return $this;
    }

    /**
     * @return int
     */
    public function getPosition()
    {
        return $this->position;
    }

    /**
     * @param array $transportConfig
     *
     * @return $this
     */
    public function setTransportConfig($transportConfig)
    {
        $this->transportConfig = $transportConfig;

        return $this;
    }

    /**
     * @return array
     */
    public function getTransportConfig()
    {
        return $this->transportConfig;
    }

    /**
     * @param mixed $process
     *
     * @return $this
     */
    public function setProcess($process)
    {
        $this->process = $process;

        return $this;
    }

    /**
     * @return mixed
     */
    public function getProcess()
    {
        return $this->process;
    }

    /**
     * @param string $error
     *
     * @return $this
     */
    public function setError($error)
    {
        $this->error = $error;

        return $this;
    }

    /**
     * @return string
     */
    public function getError()
    {
        return $this->error;
    }

    /**
     * @param int $retries
     *
     * @return $this
     */
    public function setRetries($retries)
    {
        $this->retries = $retries;

        return $this;
    }

    /**
     * @return int
     */
    public function getRetries()
    {
        return $this->retries;
    }

    /**
     * @param \DateTime $datetimeScheduled
     *
     * @return $this
     */
    public function setDatetimeScheduled(\DateTime $datetimeScheduled = null)
    {
        $this->datetimeScheduled = $datetimeScheduled;

        return $this;
    }

    /**
     * @return \DateTime
     */
    public function getDatetimeScheduled()
    {
        return $this->datetimeScheduled;
    }

    /**
     * @param \DateTime $datetimeStarted
     *
     * @return $this
     */
    public function setDatetimeStarted(\DateTime $datetimeStarted = null)
    {
        $this->datetimeStarted = $datetimeStarted;

        return $this;
    }

    /**
     * @return \DateTime
     */
    public function getDatetimeStarted()
    {
        return $this->datetimeStarted;
    }

    /**
     * @param \DateTime $datetimeEnded
     *
     * @return $this
     */
    public function setDatetimeEnded(\DateTime $datetimeEnded = null)
    {
        $this->datetimeEnded = $datetimeEnded;

        return $this;
    }

    /**
     * @return \DateTime
     */
    public function getDatetimeEnded()
    {
        return $this->datetimeEnded;
    }

    /**
     * @param Import $import
     *
     * @return $this
     */
    public function setImport(Import $import = null)
    {
        $this->import = $import;

        return $this;
    }

    /**
     * @return Import
     */
    public function getImport()
    {
        return $this->import;
    }

    /**
     * @return bool
     */
    public function isStarted()
    {
        return !is_null($this->getProcess());
    }

    /**
     * @return bool
     */
    public function isFinished()
    {
        return !is_null($this->getDatetimeEnded());
    }

    /**
     * @throws \InvalidArgumentException When the part does not have a valid pid
     *
     * @return bool
     */
    public function isRunning()
    {
        if (null === $pid = $this->getProcess()) {
            return false;
        }

        if (!$pid) {
            throw new \InvalidArgumentException(
                sprintf('Import part does not have a valid pid: %s', json_encode($pid))
            );
        }

        // kill signal 0: check whether a process is running.
        // see http://www.php.net/manual/en/function.posix-kill.php#82560
        return posix_kill($pid, 0);
    }
}