Worker::at() - Code Metrics - mmucklo/DtcQueueBundle - Measure and Improve Code Quality continuously with Scrutinizer

Worker::at() C
last analyzed 2024-05-15 00:16 UTC

↳ Parent: Worker

Complexity

Conditions	12
Paths	39

Size

Total Lines	56
Code Lines	40

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	29
CRAP Score	13.912

Importance

Changes	2
Bugs	1	Features	0

Metric	Value
cc	12
eloc	40
c	2
b	1
f	0
nc	39
nop	3
dl	0
loc	56
ccs	29
cts	38
cp	0.7632
crap	13.912
rs	6.9666

How to fix Long Method Complexity

<?php

namespace Dtc\QueueBundle\Model;

use Dtc\QueueBundle\Manager\JobManagerInterface;
use Dtc\QueueBundle\Util\Util;

abstract class Worker
{
    public const RESULT_SUCCESS = 0;
    public const RESULT_FAILURE = 1;

    /** @var JobManagerInterface */
    private $jobManager;
    private $currentJob;

    public function setCurrentJob(BaseJob $job)
    {
        $this->currentJob = $job;
    }

    public function getCurrentJob()
    {
        return $this->currentJob;
    }

    public function setJobManager(JobManagerInterface $jobManager)
    {
        $this->jobManager = $jobManager;
    }

    /**
     * @return
     */
    public function getJobManager()
    {
        return $this->jobManager;
    }

    /**
     * @param int|null $time
     * @param bool     $batch
     * @param int|null $priority
     *
     * @throws \Exception
     * @throws \InvalidArgumentException
     */
    public function at($time = null, $batch = false, $priority = null)
    {
        $timeU = $time;
        if (null === $time) {
            $timeU = Util::getMicrotimeStr();
            $dateTime = \DateTime::createFromFormat(
                'U.u',
                $timeU
            );
            if (!$dateTime) {

                throw new \Exception("Could not create DateTime object from $timeU");
            }
            $dateTime->setTimezone(new \DateTimeZone(date_default_timezone_get()));
        } else {
            $localeInfo = localeconv();
            $decimalPoint = isset($localeInfo['decimal_point']) ? $localeInfo['decimal_point'] : '.';
            $hasDecimalPoint = false !== strpos(strval($time), $decimalPoint);
            $hasEnDecimalPoint = '.' === $decimalPoint ? $hasDecimalPoint : strpos(strval($time), '.');
            if (!$hasEnDecimalPoint) {
                if ($hasDecimalPoint) {
                    $dateTime = \DateTime::createFromFormat(
                        'U'.$decimalPoint.'u',
                        strval($timeU)
                    );
                    if (!$dateTime) {

                        throw new \InvalidArgumentException("Could not create DateTime object from $timeU");
                    }
                    $dateTime->setTimezone(new \DateTimeZone(date_default_timezone_get()));
                } else {
                    $dateTime = \DateTime::createFromFormat(
                        'U',
                        strval($timeU)
                    );
                    if (!$dateTime) {

                        throw new \InvalidArgumentException("Could not create DateTime object from $timeU");
                    }
                    $dateTime->setTimezone(new \DateTimeZone(date_default_timezone_get()));
                }
            } else {
                $dateTime = \DateTime::createFromFormat(
                    'U.u',
                    strval($timeU)
                );
                if (!$dateTime) {

                    throw new \InvalidArgumentException("Could not create DateTime object from $timeU");
                }
                $dateTime->setTimezone(new \DateTimeZone(date_default_timezone_get()));
            }
        }

        if (!($dateTime instanceof \DateTime)) {

            throw new \InvalidArgumentException("Invalid time: $time".($timeU != $time ? " - (micro: $timeU)" : ''));
        }
        $jobClass = $this->jobManager->getJobClass();

        return new $jobClass($this, $batch, $priority, $dateTime);
    }

    /**
     * @param int      $delay    Amount of time to delay
     * @param int|null $priority
     */
    public function later($delay = 0, $priority = null)
    {
        return $this->batchOrLaterDelay($delay, false, $priority);
    }

    public function batchOrLaterDelay($delay = 0, $batch = false, $priority = null)
    {
        $timing = Util::getMicrotimeStr();
        $parts = explode('.', $timing);
        $parts[0] = strval(intval($parts[0]) + intval($delay));
        $localeInfo = localeconv();
        $decimalPoint = isset($localeInfo['decimal_point']) ? $localeInfo['decimal_point'] : '.';

        $job = $this->at(implode($decimalPoint, $parts), $batch, $priority);
        $job = $this->at(/** @scrutinizer ignore-type */ implode($decimalPoint, $parts), $batch, $priority);
        $job->setDelay($delay);

        return $job;
    }

    /**
     * @param int      $delay    Amount of time to delay
     * @param int|null $priority
     */
    public function batchLater($delay = 0, $priority = null)
    {
        return $this->batchOrLaterDelay($delay, true, $priority);
    }

    /**
     * @param int|null $time
     * @param int|null $priority
     */
    public function batchAt($time = null, $priority = null)
    {
        return $this->at($time, true, $priority);
    }

    abstract public function getName();
}


mmucklo / DtcQueueBundle

Worker::at() C last analyzed 2024-05-15 00:16 UTC

Complexity

Size

Duplication

Code Coverage

Importance

How to fix Long Method Complexity

Long Method

Duplication Side-by-Side

Filter issues like

Worker::at() C
last analyzed 2024-05-15 00:16 UTC