Mpclarkson\ResqueBundle\Worker

Complexity

Total Complexity

11

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	1
Bugs	0	Features	0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getId()	0	4	1
A	stop()	0	6	1
A	getQueues()	0	6	1
A	getProcessedCount()	0	4	1
A	getFailedCount()	0	4	1
A	getCurrentJobStart()	0	10	2
A	getCurrentJob()	0	12	2
A	getWorker()	0	4	1

<?php

namespace Mpclarkson\ResqueBundle;

class Worker
{
    /**
     * @var \Resque_Worker
     */
    protected $worker;

    public function __construct(\Resque_Worker $worker)
    {
        $this->worker = $worker;
    }

    public function getId()
    {
        return (string) $this->worker;
    }

    public function stop()
    {
        $parts = \explode(':', $this->getId());

        \posix_kill($parts[1], 3);
    }

    public function getQueues()
    {
        return \array_map(function($queue) {
            return new Queue($queue);
        }, $this->worker->queues());
    }

    public function getProcessedCount()
    {
        return $this->worker->getStat('processed');
    }

    public function getFailedCount()
    {
        return $this->worker->getStat('failed');
    }

    public function getCurrentJobStart()
    {
        $job = $this->worker->job();

        if (!$job) {
            return null;
        }

        return new \DateTime($job['run_at']);
    }

    public function getCurrentJob()
    {
        $job = $this->worker->job();

        if (!$job) {
            return null;
        }

        $job = new \Resque_Job($job['queue'], $job['payload']);

        return $job->getInstance();
    }

    public function getWorker()
    {
        return $this->worker;
    }
}