Jabe\Engine\Impl\ExecutionQueryImpl

Complexity

Total Complexity

45

Size/Duplication

Total Lines	285
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

43 Methods

Rating	Name	Duplication	Size	Complexity
A	processInstanceBusinessKey()	0	5	1
A	getEventSubscriptions()	0	3	1
A	activityId()	0	4	1
A	incidentType()	0	5	1
A	getProcessInstanceId()	0	3	1
A	incidentId()	0	5	1
A	suspended()	0	4	1
A	setEventSubscriptions()	0	3	1
A	executeList()	0	7	1
A	getProcessInstanceIds()	0	3	1
A	incidentMessage()	0	5	1
A	getIncidentType()	0	3	1
A	setSuspensionState()	0	3	1
A	processInstanceId()	0	5	1
A	__construct()	0	3	1
A	orderByProcessDefinitionKey()	0	4	1
A	processVariableValueEquals()	0	4	1
A	processDefinitionId()	0	5	1
A	orderByProcessDefinitionId()	0	4	1
A	messageEventSubscription()	0	3	1
A	eventSubscription()	0	12	3
A	getActivityId()	0	3	1
A	signalEventSubscription()	0	3	1
A	getProcessDefinitionId()	0	3	1
A	active()	0	4	1
A	getIncidentMessage()	0	3	1
A	tenantIdIn()	0	6	1
A	messageEventSubscriptionName()	0	3	1
A	getExecutionId()	0	3	1
A	orderByProcessInstanceId()	0	4	1
A	processDefinitionKey()	0	5	1
A	orderByTenantId()	0	4	1
A	getProcessDefinitionKey()	0	3	1
A	processVariableValueNotEquals()	0	4	1
A	getIncidentMessageLike()	0	3	1
A	incidentMessageLike()	0	5	1
A	signalEventSubscriptionName()	0	3	1
A	getBusinessKey()	0	3	1
A	executionId()	0	5	1
A	withoutTenantId()	0	5	1
A	getIncidentId()	0	3	1
A	getSuspensionState()	0	3	1
A	executeCount()	0	7	1

<?php

namespace Jabe\Engine\Impl;

use Jabe\Engine\Impl\Event\EventType;
use Jabe\Engine\Impl\Interceptor\{
    CommandContext,
    CommandExecutorInterface
};
use Jabe\Engine\Impl\Persistence\Entity\SuspensionState;
use Jabe\Engine\Impl\Util\EnsureUtil;

The type Jabe\Engine\Impl\Util\EnsureUtil was not found. Maybe you did not declare it correctly or list all dependencies?

use Jabe\Engine\Runtime\ExecutionQueryInterface;

class ExecutionQueryImpl extends AbstractVariableQueryImpl implements ExecutionQueryInterface
{
    protected $processDefinitionId;
    protected $processDefinitionKey;
    protected $businessKey;
    protected $activityId;
    protected $executionId;
    protected $processInstanceId;
    protected $eventSubscriptions;
    protected $suspensionState;
    protected $incidentType;
    protected $incidentId;
    protected $incidentMessage;
    protected $incidentMessageLike;

    protected $isTenantIdSet = false;
    protected $tenantIds = [];

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

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

    public function processDefinitionKey(string $processDefinitionKey): ExecutionQueryImpl
    {
        EnsureUtil::ensureNotNull("Process definition key", "processDefinitionKey", $processDefinitionKey);
        $this->processDefinitionKey = $processDefinitionKey;
        return $this;
    }

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

    public function processInstanceBusinessKey(string $businessKey): ExecutionQueryInterface
    {
        EnsureUtil::ensureNotNull("Business key", "businessKey", $businessKey);
        $this->businessKey = $businessKey;
        return $this;
    }

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

    public function activityId(string $activityId): ExecutionQueryImpl
    {
        $this->activityId = $activityId;
        return $this;
    }

    public function signalEventSubscription(string $signalName): ExecutionQueryInterface
    {
        return $this->eventSubscription(EventType::signal(), $signalName);
    }

    public function signalEventSubscriptionName(string $signalName): ExecutionQueryInterface
    {
        return $this->eventSubscription(EventType::signal(), $signalName);
    }

    public function messageEventSubscriptionName(string $messageName): ExecutionQueryInterface
    {
        return $this->eventSubscription(EventType::message(), $messageName);
    }

    public function messageEventSubscription(): ExecutionQueryInterface
    {
        return $this->eventSubscription(EventType::message(), null);

null of type null is incompatible with the type string expected by parameter $eventName of Jabe\Engine\Impl\ExecutionQueryImpl::eventSubscription().

    }

    public function eventSubscription(EventType $eventType, string $eventName): ExecutionQueryInterface
    {
        EnsureUtil::ensureNotNull("event type", "eventType", $eventType);
        if (EventType::message() != $eventType) {
            // event name is optional for message events
            EnsureUtil::ensureNotNull("event name", "eventName", $eventName);
        }
        if (empty($this->eventSubscriptions)) {
            $this->eventSubscriptions = [];
        }
        $this->eventSubscriptions[] = new EventSubscriptionQueryValue($eventName, $eventType->name());
        return $this;
    }

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

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

    public function processVariableValueEquals(string $variableName, $variableValue): ExecutionQueryInterface
    {
        $this->addVariable($variableName, $variableValue, QueryOperator::EQUALS, false);
        return $this;
    }

    public function processVariableValueNotEquals(string $variableName, $variableValue): ExecutionQueryInterface
    {
        $this->addVariable($variableName, $variableValue, QueryOperator::NOT_EQUALS, false);
        return $this;
    }

    public function incidentType(string $incidentType): ExecutionQueryInterface
    {
        EnsureUtil::ensureNotNull("incident type", "incidentType", $incidentType);
        $this->incidentType = $incidentType;
        return $this;
    }

    public function incidentId(string $incidentId): ExecutionQueryInterface
    {
        EnsureUtil::ensureNotNull("incident id", "incidentId", $incidentId);
        $this->incidentId = $incidentId;
        return $this;
    }

    public function incidentMessage(string $incidentMessage): ExecutionQueryInterface
    {
        EnsureUtil::ensureNotNull("incident message", "incidentMessage", $incidentMessage);
        $this->incidentMessage = $incidentMessage;
        return $this;
    }

    public function incidentMessageLike(string $incidentMessageLike): ExecutionQueryInterface
    {
        EnsureUtil::ensureNotNull("incident messageLike", "incidentMessageLike", $incidentMessageLike);
        $this->incidentMessageLike = $incidentMessageLike;
        return $this;
    }

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

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

    //ordering ////////////////////////////////////////////////////

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

    public function orderByProcessDefinitionId(): ExecutionQueryImpl
    {
        $this->orderBy(new QueryOrderingProperty(QueryOrderingProperty::RELATION_PROCESS_DEFINITION, ExecutionQueryProperty::processDefinitionId()));

The type Jabe\Engine\Impl\QueryOrderingProperty was not found. Maybe you did not declare it correctly or list all dependencies?

        return $this;
    }

    public function orderByProcessDefinitionKey(): ExecutionQueryImpl
    {
        $this->orderBy(new QueryOrderingProperty(QueryOrderingProperty::RELATION_PROCESS_DEFINITION, ExecutionQueryProperty::processDefinitionKey()));
        return $this;
    }

    public function orderByTenantId(): ExecutionQueryInterface
    {
        $this->orderBy(ExecutionQueryProperty::tenantId());

The method Jabe\Engine\Impl\ExecutionQueryProperty::tenantId() is not static, but was called statically.

        return $this;
    }

    //results ////////////////////////////////////////////////////
    public function executeCount(CommandContext $commandContext): int
    {
        $this->checkQueryOk();
        $this->ensureVariablesInitialized();
        return $commandContext
        ->getExecutionManager()
        ->findExecutionCountByQueryCriteria($this);
    }

    public function executeList(CommandContext $commandContext, Page $page): array

The type Jabe\Engine\Impl\Page was not found. Maybe you did not declare it correctly or list all dependencies?

    {
        $this->checkQueryOk();
        $this->ensureVariablesInitialized();
        return $commandContext
        ->getExecutionManager()
        ->findExecutionsByQueryCriteria($this, $page);
    }

    //getters ////////////////////////////////////////////////////

    public function getProcessDefinitionKey(): string
    {
        return $this->processDefinitionKey;
    }

    public function getProcessDefinitionId(): string
    {
        return $this->processDefinitionId;
    }

    public function getActivityId(): string
    {
        return $this->activityId;
    }

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

    public function getProcessInstanceIds(): array
    {
        return [];
    }

    public function getBusinessKey(): string
    {
        return $this->businessKey;
    }

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

    public function getSuspensionState(): SuspensionState
    {
        return $this->suspensionState;
    }

    public function setSuspensionState(SuspensionState $suspensionState): void
    {
        $this->suspensionState = $suspensionState;
    }

    public function getEventSubscriptions(): array
    {
        return $this->eventSubscriptions;
    }

    public function setEventSubscriptions(array $eventSubscriptions): void
    {
        $this->eventSubscriptions = $eventSubscriptions;
    }

    public function getIncidentId(): string
    {
        return $this->incidentId;
    }

    public function getIncidentType(): string
    {
        return $this->incidentType;
    }

    public function getIncidentMessage(): string
    {
        return $this->incidentMessage;
    }

    public function getIncidentMessageLike(): string
    {
        return $this->incidentMessageLike;
    }
}