Sonata\NotificationBundle\Model\Message

Complexity

Total Complexity

31

Size/Duplication

Total Lines	288
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	0

Importance

Changes

0

27 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	__clone()	0	9	1
A	setBody()	0	4	1
A	getBody()	0	4	1
A	getValue()	0	17	4
A	setCompletedAt()	0	4	1
A	getCompletedAt()	0	4	1
A	setCreatedAt()	0	4	1
A	getCreatedAt()	0	4	1
A	setGroup()	0	4	1
A	getGroup()	0	4	1
A	setType()	0	4	1
A	getType()	0	4	1
A	setState()	0	4	1
A	getState()	0	4	1
A	setRestartCount()	0	4	1
A	getRestartCount()	0	4	1
A	setUpdatedAt()	0	4	1
A	getUpdatedAt()	0	4	1
A	getStateList()	0	10	1
A	setStartedAt()	0	4	1
A	getStartedAt()	0	4	1
A	getStateName()	0	6	2
A	isRunning()	0	4	1
A	isCancelled()	0	4	1
A	isError()	0	4	1
A	isOpen()	0	4	1

<?php

declare(strict_types=1);

/*
 * This file is part of the Sonata Project package.
 *
 * (c) Thomas Rabaix <thomas.rabaix@sonata-project.org>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Sonata\NotificationBundle\Model;

class Message implements MessageInterface
{
    /**
     * @var string
     */
    protected $type;

    /**
     * @var array
     */
    protected $body;

    /**
     * @var int
     */
    protected $state;

    /**
     * @var int
     */
    protected $restartCount = 0;

    /**
     * @var string
     */
    protected $group;

    /**
     * @var \DateTime
     */
    protected $createdAt;

    /**
     * @var \DateTime
     */
    protected $updatedAt;

    /**
     * @var \DateTime
     */
    protected $startedAt;

    /**
     * @var \DateTime
     */
    protected $completedAt;

    public function __construct()
    {
        $this->createdAt = new \DateTime();
        $this->updatedAt = new \DateTime();
        $this->state = self::STATE_OPEN;
    }

    /**
     * {@inheritdoc}
     */
    public function __clone()
    {
        $this->state = self::STATE_OPEN;
        $this->startedAt = null;
        $this->completedAt = null;

        $this->createdAt = new \DateTime();
        $this->updatedAt = new \DateTime();
    }

    /**
     * {@inheritdoc}
     */
    public function setBody(array $body): void
    {
        $this->body = $body;
    }

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

    /**
     * {@inheritdoc}
     */
    public function getValue($names, $default = null)
    {
        if (!\is_array($names)) {
            $names = [$names];
        }

        $body = $this->getBody();
        foreach ($names as $name) {
            if (!isset($body[$name])) {
                return $default;
            }

            $body = $body[$name];
        }

        return $body;
    }

    /**
     * {@inheritdoc}
     */
    public function setCompletedAt(?\DateTime $completedAt = null): void
    {
        $this->completedAt = $completedAt;
    }

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

    /**
     * {@inheritdoc}
     */
    public function setCreatedAt(?\DateTime $createdAt = null): void
    {
        $this->createdAt = $createdAt;
    }

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

    /**
     * {@inheritdoc}
     */
    public function setGroup($group): void
    {
        $this->group = $group;
    }

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

    /**
     * {@inheritdoc}
     */
    public function setType($type): void
    {
        $this->type = $type;
    }

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

    /**
     * {@inheritdoc}
     */
    public function setState($state): void
    {
        $this->state = $state;
    }

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

    /**
     * {@inheritdoc}
     */
    public function setRestartCount($restartCount): void
    {
        $this->restartCount = $restartCount;
    }

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

    /**
     * {@inheritdoc}
     */
    public function setUpdatedAt(?\DateTime $updatedAt = null): void
    {
        $this->updatedAt = $updatedAt;
    }

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

    /**
     * @return string[]
     */
    public static function getStateList()
    {
        return [
            self::STATE_OPEN => 'open',
            self::STATE_IN_PROGRESS => 'in_progress',
            self::STATE_DONE => 'done',
            self::STATE_ERROR => 'error',
            self::STATE_CANCELLED => 'cancelled',
        ];
    }

    /**
     * {@inheritdoc}
     */
    public function setStartedAt(?\DateTime $startedAt = null): void
    {
        $this->startedAt = $startedAt;
    }

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

    /**
     * {@inheritdoc}
     */
    public function getStateName()
    {
        $list = self::getStateList();

        return isset($list[$this->getState()]) ? $list[$this->getState()] : '';
    }

    /**
     * {@inheritdoc}
     */
    public function isRunning()
    {
        return self::STATE_IN_PROGRESS === $this->state;
    }

    /**
     * {@inheritdoc}
     */
    public function isCancelled()
    {
        return self::STATE_CANCELLED === $this->state;
    }

    /**
     * {@inheritdoc}
     */
    public function isError()
    {
        return self::STATE_ERROR === $this->state;
    }

    /**
     * {@inheritdoc}
     */
    public function isOpen()
    {
        return self::STATE_OPEN === $this->state;
    }
}