Beanie\Job\Job

Complexity

Total Complexity

13

Size/Duplication

Total Lines	148
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes	6
Bugs	0	Features	0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	getState()	0	4	1
A	getId()	0	4	1
A	getData()	0	4	1
A	kick()	0	5	1
A	release()	0	9	2
A	touch()	0	5	1
A	bury()	0	6	1
A	delete()	0	6	1
A	stats()	0	4	1
A	executeCommand()	0	6	1
A	jsonSerialize()	0	8	1

<?php


namespace Beanie\Job;


use Beanie\Beanie;
use Beanie\Command\CommandFactory;
use Beanie\Command\CommandInterface;
use Beanie\Command\Response;
use Beanie\Server\Server;

class Job implements \JsonSerializable
{
    const STATE_UNKNOWN = null;
    const STATE_RELEASED = 'RELEASED';
    const STATE_RESERVED = 'RESERVED';
    const STATE_BURIED = 'BURIED';
    const STATE_DELETED = 'DELETED';

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

    /** @var mixed */
    protected $data;

    /** @var Server */
    protected $server;

    /** @var null|string */
    protected $state;

    /** @var CommandFactory */
    protected $commandFactory;

    /**
     * @param int $id
     * @param mixed $data
     * @param Server $server
     * @param null|string $state
     */
    public function __construct($id, $data, Server $server, $state = self::STATE_UNKNOWN)
    {
        $this->id = (int) $id;
        $this->data = $data;
        $this->server = $server;
        $this->state = $state;
        $this->commandFactory = CommandFactory::instance();
    }

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

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

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

    /**
     * @return $this
     */
    public function kick()
    {
        $this->executeCommand(CommandInterface::COMMAND_KICK_JOB);
        return $this;
    }

    /**
     * @param int $priority
     * @param int $delay
     * @return $this
     */
    public function release($priority = Beanie::DEFAULT_PRIORITY, $delay = Beanie::DEFAULT_DELAY)
    {
        $response = $this->executeCommand(CommandInterface::COMMAND_RELEASE, [$priority, $delay]);
        $this->state = $response->getName() === Response::RESPONSE_RELEASED
            ? self::STATE_RELEASED
            : self::STATE_BURIED;

        return $this;
    }

    /**
     * @return $this
     */
    public function touch()
    {
        $this->executeCommand(CommandInterface::COMMAND_TOUCH);
        return $this;
    }

    /**
     * @param int $priority
     * @return $this
     */
    public function bury($priority = Beanie::DEFAULT_PRIORITY)
    {
        $this->executeCommand(CommandInterface::COMMAND_BURY, [$priority]);
        $this->state = self::STATE_BURIED;
        return $this;
    }

    /**
     * @return $this
     */
    public function delete()
    {
        $this->executeCommand(CommandInterface::COMMAND_DELETE);
        $this->state = self::STATE_DELETED;
        return $this;
    }

    /**
     * @return array
     */
    public function stats()
    {
        return $this->executeCommand(CommandInterface::COMMAND_STATS_JOB)->getData();
    }

    /**
     * @param string $command
     * @param array $arguments
     * @return Response
     */
    private function executeCommand($command, $arguments = [])
    {
        return $this->server
            ->dispatchCommand($this->commandFactory->create($command, array_merge([$this->id], $arguments)))
            ->invoke();
    }

    /**
     * @return array
     */
    public function jsonSerialize()
    {
        return [
            'id' => $this->id,
            'server' => (string)$this->server,
            'state' => $this->state
        ];
    }
}