Process::wait() - Code Metrics - gyselroth/mongodb-php-task-scheduler - Measure and Improve Code Quality continuously with Scrutinizer

Process::wait() B
last analyzed 2019-10-30 09:53 UTC

↳ Parent: Process

Complexity

Conditions	6
Paths	5

Size

Total Lines	37
Code Lines	20

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	14
CRAP Score	7.7305

Importance

Changes

Metric	Value
eloc	20
dl	0
loc	37
ccs	14
cts	22
cp	0.6364
rs	8.9777
c	0
b	0
f	0
cc	6
nc	5
nop	0
crap	7.7305

<?php

declare(strict_types=1);

/**
 * TaskScheduler
 *
 * @author      Raffael Sahli <[email protected]>
 * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
 * @license     MIT https://opensource.org/licenses/MIT
 */

namespace TaskScheduler;

use MongoDB\BSON\ObjectId;

class Process
{
    /**
     * Job.
     *
     * @var array
     */
    protected $job;

    /**
     * Scheduler.
     *
     * @var Scheduler
     */
    protected $scheduler;

    /**
     * Events queue.
     *
     * @var MessageQueue
     */
    protected $events;

    /**
     * Initialize process.
     */
    public function __construct(array $job, Scheduler $scheduler, MessageQueue $events)
    {
        $this->job = $job;
        $this->scheduler = $scheduler;
        $this->events = $events;
    }

    /**
     * To array.
     */
    public function toArray(): array
    {
        return $this->job;
    }

    /**
     * Get job options.
     */
    public function getOptions(): array
    {
        return $this->job['options'];
    }

    /**
     * Get class.
     */
    public function getClass(): string
    {
        return $this->job['class'];
    }

    /**
     * Get job data.
     */
    public function getData()
    {
        return $this->job['data'];
    }

    /**
     * Get ID.
     */
    public function getId(): ObjectId
    {
        return $this->job['_id'];
    }

    /**
     * Restart job.
     */
    public function getWorker(): ObjectId
    {
        return $this->job['worker'];
    }

    /**
     * Wait for job beeing executed.
     */
    public function wait(): Process
    {
        $cursor = $this->events->getCursor([
            'job' => $this->getId(),
            'status' => ['$gte' => JobInterface::STATUS_DONE],
        ]);

        while (true) {
            if (null === $cursor->current()) {
                if ($cursor->getInnerIterator()->isDead()) {
                if ($cursor->getInnerIterator()->/** @scrutinizer ignore-call */ isDead()) {
                    $this->events->create();

                    return $this->wait();
                }

                $this->events->next($cursor, function () {
                    $this->wait();
                });

                continue;
            }

            $event = $cursor->current();
            $this->events->next($cursor, function () {
                $this->wait();
            });

            $this->job['status'] = $event['status'];

            if (JobInterface::STATUS_FAILED === $this->job['status'] && isset($event['exception'])) {
                throw new $event['exception']['class'](
                    $event['exception']['message'],
                    $event['exception']['code']
                );
            }

            return $this;
        }
interface ReturnsInt {
    public function returnsIntHinted(): int;
}

class MyClass implements ReturnsInt {
    public function returnsIntHinted(): int
    {
        if (foo()) {
            return 123;
        }
        // here: null is implicitly returned
    }
}
    }

    /**
     * Get status.
     */
    public function getStatus(): int
    {
        return $this->job['status'];
    }
}


gyselroth / mongodb-php-task-scheduler

Process::wait() B last analyzed 2019-10-30 09:53 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

Process::wait() B
last analyzed 2019-10-30 09:53 UTC