Jabe\Engine\Impl\JobQueryImpl

Complexity

Total Complexity

71

Size/Duplication

Total Lines	464
Duplicated Lines	0 %

Importance

Changes

0

58 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	duedateLowerThan()	0	5	1
A	unserialize()	0	32	1
A	withException()	0	4	1
A	orderByJobRetries()	0	3	1
A	getExceptionMessage()	0	3	1
A	serialize()	0	32	1
A	priorityLowerThanOrEquals()	0	4	1
A	noRetriesLeft()	0	4	1
A	executeCount()	0	6	1
A	executeDeploymentIdMappingsList()	0	6	1
A	executeList()	0	6	1
A	includeJobsWithoutTenantId()	0	4	1
A	getProcessInstanceId()	0	3	1
A	executable()	0	4	1
A	processDefinitionId()	0	5	1
A	tenantIdIn()	0	6	1
A	duedateHigherThan()	0	5	1
A	suspended()	0	4	1
A	orderByProcessDefinitionKey()	0	3	1
A	isWithException()	0	3	1
A	processInstanceIds()	0	5	1
A	jobIds()	0	5	1
A	getRetriesLeft()	0	3	1
A	getIds()	0	3	1
A	orderByJobDuedate()	0	3	1
A	orderByExecutionId()	0	3	1
A	withRetriesLeft()	0	4	1
A	orderByTenantId()	0	3	1
B	hasExcludingDueDateParameters()	0	20	9
A	createdBefore()	0	5	1
A	priorityHigherThanOrEquals()	0	4	1
A	duedateHigherThen()	0	3	1
A	failedActivityId()	0	5	1
A	duedateLowerThen()	0	3	1
A	getNow()	0	3	1
A	timers()	0	7	2
A	hasExcludingConditions()	0	6	4
A	executionId()	0	5	1
A	active()	0	4	1
A	activityId()	0	5	1
A	orderByJobId()	0	3	1
A	processInstanceId()	0	5	1
A	processDefinitionKey()	0	5	1
A	getExecutable()	0	3	1
A	getProcessInstanceIds()	0	3	1
A	orderByJobPriority()	0	3	1
A	withoutTenantId()	0	5	1
A	duedateHigherThenOrEquals()	0	5	1
A	exceptionMessage()	0	5	1
A	orderByProcessDefinitionId()	0	3	1
A	createdAfter()	0	5	1
A	jobDefinitionId()	0	5	1
A	duedateLowerThenOrEquals()	0	5	1
A	orderByProcessInstanceId()	0	3	1
A	jobId()	0	5	1
A	messages()	0	7	2
A	getExecutionId()	0	3	1

<?php

namespace Jabe\Engine\Impl;

use Jabe\Engine\ProcessEngineException;
use Jabe\Engine\Impl\Interceptor\{
    CommandContext,
    CommandExecutorInterface
};
use Jabe\Engine\Impl\Persistence\Entity\SuspensionState;
use Jabe\Engine\Impl\Util\{
    ClockUtil,
    CompareUtil,
    EnsureUtil,
    ImmutablePair
};
use Jabe\Engine\Runtime\{
    JobInterface,
    JobQueryInterface
};

class JobQueryImpl extends AbstractQuery implements JobQueryInterface, \Serializable
{
    protected $activityId;
    protected $id;
    protected $ids = [];
    protected $jobDefinitionId;
    protected $processInstanceId;
    protected $processInstanceIds = [];
    protected $executionId;
    protected $processDefinitionId;
    protected $processDefinitionKey;
    protected $retriesLeft;
    protected $executable;
    protected $onlyTimers;
    protected $onlyMessages;
    protected $duedateHigherThan;
    protected $duedateLowerThan;
    protected $duedateHigherThanOrEqual;
    protected $duedateLowerThanOrEqual;
    protected $createdBefore;
    protected $createdAfter;
    protected $priorityHigherThanOrEqual;
    protected $priorityLowerThanOrEqual;
    protected $withException;
    protected $exceptionMessage;
    protected $failedActivityId;
    protected $noRetriesLeft;
    protected $suspensionState;
    protected $isTenantIdSet = false;
    protected $tenantIds = [];
    protected $includeJobsWithoutTenantId = false;

    public function __construct(CommandExecutorInterface $commandExecutor)
    {
        parent::__construct($commandExecutor);
    }

    public function serialize()
    {
        return json_encode([
            'id' => $this->id,
            'activityId' => $this->activityId,
            'ids' => $this->ids,
            'jobDefinitionId' => $this->jobDefinitionId,
            'processInstanceId' => $this->processInstanceId,
            'processInstanceIds' => $this->processInstanceIds,
            'executionId' => $this->executionId,
            'processDefinitionId' => $this->processDefinitionId,
            'processDefinitionKey' => $this->processDefinitionKey,
            'retriesLeft' => $this->retriesLeft,
            'executable' => $this->executable,
            'onlyTimers' => $this->onlyTimers,
            'onlyMessages' => $this->onlyMessages,
            'duedateHigherThan' => $this->duedateHigherThan,
            'duedateLowerThan' => $this->duedateLowerThan,
            'duedateHigherThanOrEqual' => $this->duedateHigherThanOrEqual,
            'duedateLowerThanOrEqual' => $this->duedateLowerThanOrEqual,
            'createdBefore' => $this->createdBefore,
            'createdAfter' => $this->createdAfter,
            'priorityHigherThanOrEqual' => $this->priorityHigherThanOrEqual,
            'priorityLowerThanOrEqual' => $this->priorityLowerThanOrEqual,
            'withException' => $this->withException,
            'exceptionMessage' => $this->exceptionMessage,
            'failedActivityId' => $this->failedActivityId,
            'noRetriesLeft' => $this->noRetriesLeft,
            'suspensionState' => serialize($this->suspensionState),
            'isTenantIdSet' => $this->isTenantIdSet,
            'tenantIds' => $this->tenantIds,
            'includeJobsWithoutTenantId' => $this->includeJobsWithoutTenantId
        ]);
    }

    public function unserialize($data)
    {
        $json = json_decode($data);
        $this->id = $json->id;
        $this->activityId = $json->activityId;
        $this->ids = $json->ids;
        $this->jobDefinitionId = $json->jobDefinitionId;
        $this->processInstanceId = $json->processInstanceId;
        $this->processInstanceIds = $json->processInstanceIds;
        $this->executionId = $json->executionId;
        $this->processDefinitionId = $json->processDefinitionId;
        $this->processDefinitionKey = $json->processDefinitionKey;
        $this->retriesLeft = $json->retriesLeft;
        $this->executable = $json->executable;
        $this->onlyTimers = $json->onlyTimers;
        $this->onlyMessages = $json->onlyMessages;
        $this->duedateHigherThan = $json->duedateHigherThan;
        $this->duedateLowerThan = $json->duedateLowerThan;
        $this->duedateHigherThanOrEqual = $json->duedateHigherThanOrEqual;
        $this->duedateLowerThanOrEqual = $json->duedateLowerThanOrEqual;
        $this->createdBefore = $json->createdBefore;
        $this->createdAfter = $json->createdAfter;
        $this->priorityHigherThanOrEqual = $json->priorityHigherThanOrEqual;
        $this->priorityLowerThanOrEqual = $json->priorityLowerThanOrEqual;
        $this->withException = $json->withException;
        $this->exceptionMessage = $json->exceptionMessage;
        $this->failedActivityId = $json->failedActivityId;
        $this->noRetriesLeft = $json->noRetriesLeft;
        $this->suspensionState = unserialize($json->suspensionState);
        $this->isTenantIdSet = $json->isTenantIdSet;
        $this->tenantIds = $json->tenantIds;
        $this->includeJobsWithoutTenantId = $json->includeJobsWithoutTenantId;
    }

    public function jobId(string $jobId): JobQueryInterface
    {
        EnsureUtil::ensureNotNull("Provided job id", "jobId", $jobId);
        $this->id = $jobId;
        return $this;
    }

    public function jobIds(array $ids): JobQueryInterface
    {
        EnsureUtil::ensureNotEmpty("Set of job ids", "ids", $ids);
        $this->ids = $ids;
        return $this;
    }

    public function jobDefinitionId(string $jobDefinitionId): JobQueryInterface
    {
        EnsureUtil::ensureNotNull("Provided job definition id", "jobDefinitionId", $jobDefinitionId);
        $this->jobDefinitionId = $jobDefinitionId;
        return $this;
    }

    public function processInstanceId(string $processInstanceId): JobQueryImpl
    {
        EnsureUtil::ensureNotNull("Provided process instance id", "processInstanceId", $processInstanceId);
        $this->processInstanceId = $processInstanceId;
        return $this;
    }

    public function processInstanceIds(array $processInstanceIds): JobQueryInterface
    {
        EnsureUtil::ensureNotEmpty("Set of process instance ids", "processInstanceIds", $processInstanceIds);
        $this->processInstanceIds = $processInstanceIds;
        return $this;
    }

    public function executionId(string $executionId): JobQueryImpl
    {
        EnsureUtil::ensureNotNull("Provided execution id", "executionId", $executionId);
        $this->executionId = $executionId;
        return $this;
    }

    public function processDefinitionId(string $processDefinitionId): JobQueryInterface
    {
        EnsureUtil::ensureNotNull("Provided process definition id", "processDefinitionId", $processDefinitionId);
        $this->processDefinitionId = $processDefinitionId;
        return $this;
    }

    public function processDefinitionKey(string $processDefinitionKey): JobQueryInterface
    {
        EnsureUtil::ensureNotNull("Provided process instance key", "processDefinitionKey", $processDefinitionKey);
        $this->processDefinitionKey = $processDefinitionKey;
        return $this;
    }

    public function activityId(string $activityId): JobQueryInterface
    {
        EnsureUtil::ensureNotNull("Provided activity id", "activityId", $activityId);
        $this->activityId = $activityId;
        return $this;
    }

    public function withRetriesLeft(): JobQueryInterface
    {
        $this->retriesLeft = true;
        return $this;
    }

    public function executable(): JobQueryInterface
    {
        $this->executable = true;
        return $this;
    }

    public function timers(): JobQueryInterface
    {
        if ($this->onlyMessages) {
            throw new ProcessEngineException("Cannot combine onlyTimers() with onlyMessages() in the same query");
        }
        $this->onlyTimers = true;
        return $this;
    }

    public function messages(): JobQueryInterface
    {
        if ($this->onlyTimers) {
            throw new ProcessEngineException("Cannot combine onlyTimers() with onlyMessages() in the same query");
        }
        $this->onlyMessages = true;
        return $this;
    }

    public function duedateHigherThan(string $date): JobQueryInterface
    {
        EnsureUtil::ensureNotNull("Provided date", "date", $date);
        $this->duedateHigherThan = $date;
        return $this;
    }

    public function duedateLowerThan(string $date): JobQueryInterface
    {
        EnsureUtil::ensureNotNull("Provided date", "date", $date);
        $this->duedateLowerThan = $date;
        return $this;
    }

    public function duedateHigherThen(string $date): JobQueryInterface
    {
        return $this->duedateHigherThan($date);
    }

    public function duedateHigherThenOrEquals(string $date): JobQueryInterface
    {
        EnsureUtil::ensureNotNull("Provided date", "date", $date);
        $this->duedateHigherThanOrEqual = $date;
        return $this;
    }

    public function duedateLowerThen(string $date): JobQueryInterface
    {
        return $this->duedateLowerThan($date);
    }

    public function duedateLowerThenOrEquals(string $date): JobQueryInterface
    {
        EnsureUtil::ensureNotNull("Provided date", "date", $date);
        $this->duedateLowerThanOrEqual = $date;
        return $this;
    }

    public function createdBefore(string $date): JobQueryInterface
    {
        EnsureUtil::ensureNotNull("Provided date", "date", $date);
        $this->createdBefore = $date;
        return $this;
    }

    public function createdAfter(string $date): JobQueryInterface
    {
        EnsureUtil::ensureNotNull("Provided date", "date", $date);
        $this->createdAfter = $date;
        return $this;
    }

    public function priorityHigherThanOrEquals(int $priority): JobQueryInterface
    {
        $this->priorityHigherThanOrEqual = $priority;
        return $this;
    }

    public function priorityLowerThanOrEquals(int $priority): JobQueryInterface
    {
        $this->priorityLowerThanOrEqual = $priority;
        return $this;
    }

    public function withException(): JobQueryInterface
    {
        $this->withException = true;
        return $this;
    }

    public function exceptionMessage(string $exceptionMessage): JobQueryInterface
    {
        EnsureUtil::ensureNotNull("Provided exception message", "exceptionMessage", $exceptionMessage);
        $this->exceptionMessage = $exceptionMessage;
        return $this;
    }

    public function failedActivityId(string $activityId): JobQueryInterface
    {
        EnsureUtil::ensureNotNull("Provided activity id", "activityId", $activityId);
        $this->failedActivityId = $activityId;
        return $this;
    }

    public function noRetriesLeft(): JobQueryInterface
    {
        $this->noRetriesLeft = true;
        return $this;
    }

    public function active(): JobQueryInterface
    {
        $this->suspensionState = SuspensionState::active();
        return $this;
    }

    public function suspended(): JobQueryInterface
    {
        $this->suspensionState = SuspensionState::suspended();
        return $this;
    }

    protected function hasExcludingConditions(): bool
    {
        return parent::hasExcludingConditions()
            || CompareUtil::areNotInAscendingOrder($this->priorityHigherThanOrEqual, $this->priorityLowerThanOrEqual)
            || $this-> hasExcludingDueDateParameters()
            || CompareUtil::areNotInAscendingOrder($this->createdAfter, $this->createdBefore);
    }

    private function hasExcludingDueDateParameters(): bool
    {
        $dueDates = [];
        if ($this->duedateHigherThan != null && $this->duedateHigherThanOrEqual != null) {
            $dueDates[] = CompareUtil::min($this->duedateHigherThan, $this->duedateHigherThanOrEqual);
            $dueDates[] = CompareUtil::max($this->duedateHigherThan, $this->duedateHigherThanOrEqual);
        } elseif ($this->duedateHigherThan != null) {
            $dueDates[] = $duedateHigherThan;

The variable $duedateHigherThan seems to be never defined.

        } elseif ($this->duedateHigherThanOrEqual != null) {
            $dueDates[] = $this->duedateHigherThanOrEqual;
        }
        if ($this->duedateLowerThan != null && $this->duedateLowerThanOrEqual != null) {
            $dueDates[] = CompareUtil::min($this->duedateLowerThan, $this->duedateLowerThanOrEqual);
            $dueDates[] = CompareUtil::max($this->duedateLowerThan, $this->duedateLowerThanOrEqual);
        } elseif ($this->duedateLowerThan != null) {
            $dueDates[] = $this->duedateLowerThan;
        } elseif ($this->duedateLowerThanOrEqual != null) {
            $dueDates[] = $this->duedateLowerThanOrEqual;
        }
        return CompareUtil::areNotInAscendingOrder($dueDates);
    }

    public function tenantIdIn(array $tenantIds): JobQueryInterface
    {
        EnsureUtil::ensureNotNull("tenantIds", "tenantIds", $tenantIds);
        $this->tenantIds = $tenantIds;
        $this->isTenantIdSet = true;
        return $this;
    }

    public function withoutTenantId(): JobQueryInterface
    {
        $this->isTenantIdSet = true;
        $this->tenantIds = null;
        return $this;
    }

    public function includeJobsWithoutTenantId(): JobQueryInterface
    {
        $this->includeJobsWithoutTenantId = true;
        return $this;
    }

    public function orderByJobDuedate(): JobQueryInterface
    {
        return $this->orderBy(JobQueryProperty::duedate());
    }

    public function orderByExecutionId(): JobQueryInterface
    {
        return $this->orderBy(JobQueryProperty::executionId());
    }

    public function orderByJobId(): JobQueryInterface
    {
        return $this->orderBy(JobQueryProperty::jobId());
    }

    public function orderByProcessInstanceId(): JobQueryInterface
    {
        return $this->orderBy(JobQueryProperty::processInstanceId());
    }

    public function orderByProcessDefinitionId(): JobQueryInterface
    {
        return $this->orderBy(JobQueryProperty::processDefinitionId());
    }

    public function orderByProcessDefinitionKey(): JobQueryInterface
    {
        return $this->orderBy(JobQueryProperty::processDefinitionKey());
    }

    public function orderByJobRetries(): JobQueryInterface
    {
        return $this->orderBy(JobQueryProperty::retries());
    }

    public function orderByJobPriority(): JobQueryInterface
    {
        return $this->orderBy(JobQueryProperty::priority());
    }

    public function orderByTenantId(): JobQueryInterface
    {
        return $this->orderBy(JobQueryProperty::tenantId());
    }

    public function executeCount(CommandContext $commandContext): int
    {
        $this->checkQueryOk();
        return $commandContext
            ->getJobManager()
            ->findJobCountByQueryCriteria($this);
    }

    public function executeList(CommandContext $commandContext, Page $page): array
    {
        $this->checkQueryOk();
        return $commandContext
            ->getJobManager()
            ->findJobsByQueryCriteria($this, $page);
    }

    public function executeDeploymentIdMappingsList(CommandContext $commandContext): array
    {
        $this->checkQueryOk();
        return $commandContext
            ->getJobManager()
            ->findDeploymentIdMappingsByQueryCriteria($this);
    }

    public function getIds(): array
    {
        return $this->ids;
    }

    public function getProcessInstanceId(): string
    {
        return $this->processInstanceId;
    }

    public function getProcessInstanceIds(): array
    {
        return $this->processInstanceIds;
    }

    public function getExecutionId(): string
    {
        return $this->executionId;
    }

    public function getRetriesLeft(): bool
    {
        return $this->retriesLeft;
    }

    public function getExecutable(): bool
    {
        return $this->executable;
    }

    public function getNow(): string
    {
        return ClockUtil::getCurrentTime()->format('c');
    }

    public function isWithException(): bool
    {
        return $this->withException;
    }

    public function getExceptionMessage(): string
    {
        return $this->exceptionMessage;
    }
}