ExternalTaskQueryImpl::processInstanceIdIn() - Code Metrics - Inspection of "feat: port filter implementations" - bingo-soft/jabe - Measure and Improve Code Quality continuously with Scrutinizer

Test Failed

Push — main ( 5af89f...c76fcf )

by Bingo

created 2022-05-20 13:04 UTC

ExternalTaskQueryImpl::processInstanceIdIn() A

↳ Parent: ExternalTaskQueryImpl

Complexity

Conditions	1
Paths	1

Size

Total Lines	5
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
eloc	3
c	1
b	0
f	0
dl	0
loc	5
rs	10
cc	1
nc	1
nop	1

<?php

namespace Jabe\Engine\Impl;

use Jabe\Engine\ExternalTask\ExternalTaskQueryInterface;
use Jabe\Engine\Impl\Interceptor\{
    CommandContext,
    CommandExecutorInterface
};
use Jabe\Engine\Impl\Persistence\Entity\SuspensionState;
use Jabe\Engine\Impl\Util\{
    ClockUtil,
    CompareUtil,
filter:
    dependency_paths: ["lib/*"]
    EnsureUtil,
filter:
    dependency_paths: ["lib/*"]
    ImmutablePair
filter:
    dependency_paths: ["lib/*"]
};

class ExternalTaskQueryImpl extends AbstractQuery implements ExternalTaskQueryInterface
{
    protected $externalTaskId;
    protected $externalTaskIds = [];
    protected $workerId;
    protected $lockExpirationBefore;
    protected $lockExpirationAfter;
    protected $topicName;
    protected $locked;
    protected $notLocked;
    protected $executionId;
    protected $processInstanceId;
    protected $processInstanceIdIn = [];
    protected $processDefinitionId;
    protected $activityId;
    protected $activityIdIn = [];
    protected $suspensionState;
    protected $priorityHigherThanOrEquals;
    protected $priorityLowerThanOrEquals;
    protected $retriesLeft;
    protected $tenantIds = [];

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

    public function externalTaskId(string $externalTaskId): ExternalTaskQueryInterface
    {
        EnsureUtil::ensureNotNull("externalTaskId", "externalTaskId", $externalTaskId);
        $this->externalTaskId = $externalTaskId;
        return $this;
    }

    public function externalTaskIdIn(array $externalTaskIds): ExternalTaskQueryInterface
    {
        EnsureUtil::ensureNotEmpty("Set of external task ids", "externalTaskIds", $externalTaskIds);
        $this->externalTaskIds = $externalTaskIds;
        return $this;
    }

    public function workerId(string $workerId): ExternalTaskQueryInterface
    {
        EnsureUtil::ensureNotNull("workerId", "workerId", $workerId);
        $this->workerId = $workerId;
        return $this;
    }

    public function lockExpirationBefore(string $lockExpirationDate): ExternalTaskQueryInterface
    {
        EnsureUtil::ensureNotNull("lockExpirationBefore", "lockExpirationDate", $lockExpirationDate);
        $this->lockExpirationBefore = $lockExpirationDate;
        return $this;
    }

    public function lockExpirationAfter(string $lockExpirationDate): ExternalTaskQueryInterface
    {
        EnsureUtil::ensureNotNull("lockExpirationAfter", "lockExpirationDate", $lockExpirationDate);
        $this->lockExpirationAfter = $lockExpirationDate;
        return $this;
    }

    public function topicName(string $topicName): ExternalTaskQueryInterface
    {
        EnsureUtil::ensureNotNull("topicName", "topicName", $topicName);
        $this->topicName = $topicName;
        return $this;
    }

    public function locked(): ExternalTaskQueryInterface
    {
        $this->locked = true;
        return $this;
    }

    public function notLocked(): ExternalTaskQueryInterface
    {
        $this->notLocked = true;
        return $this;
    }

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

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

    public function processInstanceIdIn(array $processInstanceIdIn): ExternalTaskQueryInterface
    {
        EnsureUtil::ensureNotNull("processInstanceIdIn", "processInstanceIdIn", $processInstanceIdIn);
        $this->processInstanceIdIn = $processInstanceIdIn;
        return $this;
    }

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

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

    public function activityIdIn(array $activityIdIn): ExternalTaskQueryInterface
    {
        EnsureUtil::ensureNotNull("activityIdIn", "activityIdIn", $activityIdIn);
        $this->activityIdIn = $activityIdIn;
        return $this;
    }

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

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

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

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

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

    public function noRetriesLeft(): ExternalTaskQueryInterface
    {
        $this->retriesLeft = false;
        return $this;
    }

    protected function hasExcludingConditions(): bool
    {
        return parent::hasExcludingConditions()
            || CompareUtil::areNotInAscendingOrder($this->priorityHigherThanOrEquals, $this->priorityLowerThanOrEquals);
    }

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

    public function orderById(): ExternalTaskQueryInterface
    {
        return $this->orderBy(ExternalTaskQueryProperty::id());
    }

    public function orderByLockExpirationTime(): ExternalTaskQueryInterface
    {
        return $this->orderBy(ExternalTaskQueryProperty::lockExpirationTime());
    }

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

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

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

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

    public function orderByPriority(): ExternalTaskQueryInterface
    {
        return $this->orderBy(ExternalTaskQueryProperty::priority());
    }

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

    public function executeList(CommandContext $commandContext, Page $page): array
filter:
    dependency_paths: ["lib/*"]
    {
        $this->checkQueryOk();
        return $commandContext
            ->getExternalTaskManager()
            ->findExternalTasksByQueryCriteria($this);
    }

    public function executeIdsList(CommandContext $commandContext): array
    {
        $this->checkQueryOk();
        return $commandContext
            ->getExternalTaskManager()
            ->findExternalTaskIdsByQueryCriteria($this);
    }

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

    public function getExternalTaskId(): string
    {
        return $this->externalTaskId;
    }

    public function getWorkerId(): string
    {
        return $this->workerId;
    }

    public function getLockExpirationBefore(): string
    {
        return $this->lockExpirationBefore;
    }

    public function getLockExpirationAfter(): string
    {
        return $this->lockExpirationAfter;
    }

    public function getTopicName(): string
    {
        return $this->topicName;
    }

    public function getLocked(): bool
    {
        return $this->locked;
    }

    public function getNotLocked(): bool
    {
        return $this->notLocked;
    }

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

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

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

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

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

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

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


1			<?php
2
3			namespace Jabe\Engine\Impl;
4
5			use Jabe\Engine\ExternalTask\ExternalTaskQueryInterface;
6			use Jabe\Engine\Impl\Interceptor\{
7			CommandContext,
8			CommandExecutorInterface
9			};
10			use Jabe\Engine\Impl\Persistence\Entity\SuspensionState;
11			use Jabe\Engine\Impl\Util\{
12			ClockUtil,
13			CompareUtil,
			0 ignored issues – show Bug introduced 2022-05-20 13:10 UTC by Report Bug Copy Issue Report The type `Jabe\Engine\Impl\Util\CompareUtil` was not found. Maybe you did not declare it correctly or list all dependencies? The issue could also be caused by a filter entry in the build configuration. If the path has been excluded in your configuration, e.g. `excluded_paths: ["lib/"]`, you can move it to the dependency path list as follows: filter: dependency_paths: ["lib/"] For further information see https://scrutinizer-ci.com/docs/tools/php/php-scrutinizer/#list-dependency-paths Loading history...
14			EnsureUtil,
			0 ignored issues – show Bug introduced 2022-05-20 13:10 UTC by Report Bug Copy Issue Report The type `Jabe\Engine\Impl\Util\EnsureUtil` was not found. Maybe you did not declare it correctly or list all dependencies? The issue could also be caused by a filter entry in the build configuration. If the path has been excluded in your configuration, e.g. `excluded_paths: ["lib/"]`, you can move it to the dependency path list as follows: filter: dependency_paths: ["lib/"] For further information see https://scrutinizer-ci.com/docs/tools/php/php-scrutinizer/#list-dependency-paths Loading history...
15			ImmutablePair
			0 ignored issues – show Bug introduced 2022-05-20 13:10 UTC by Report Bug Copy Issue Report The type `Jabe\Engine\Impl\Util\ImmutablePair` was not found. Maybe you did not declare it correctly or list all dependencies? The issue could also be caused by a filter entry in the build configuration. If the path has been excluded in your configuration, e.g. `excluded_paths: ["lib/"]`, you can move it to the dependency path list as follows: filter: dependency_paths: ["lib/"] For further information see https://scrutinizer-ci.com/docs/tools/php/php-scrutinizer/#list-dependency-paths Loading history...
16			};
17
18			class ExternalTaskQueryImpl extends AbstractQuery implements ExternalTaskQueryInterface
19			{
20			protected $externalTaskId;
21			protected $externalTaskIds = [];
22			protected $workerId;
23			protected $lockExpirationBefore;
24			protected $lockExpirationAfter;
25			protected $topicName;
26			protected $locked;
27			protected $notLocked;
28			protected $executionId;
29			protected $processInstanceId;
30			protected $processInstanceIdIn = [];
31			protected $processDefinitionId;
32			protected $activityId;
33			protected $activityIdIn = [];
34			protected $suspensionState;
35			protected $priorityHigherThanOrEquals;
36			protected $priorityLowerThanOrEquals;
37			protected $retriesLeft;
38			protected $tenantIds = [];
39
40			public function __construct(CommandExecutorInterface $commandExecutor)
41			{
42			parent::__construct($commandExecutor);
43			}
44
45			public function externalTaskId(string $externalTaskId): ExternalTaskQueryInterface
46			{
47			EnsureUtil::ensureNotNull("externalTaskId", "externalTaskId", $externalTaskId);
48			$this->externalTaskId = $externalTaskId;
49			return $this;
50			}
51
52			public function externalTaskIdIn(array $externalTaskIds): ExternalTaskQueryInterface
53			{
54			EnsureUtil::ensureNotEmpty("Set of external task ids", "externalTaskIds", $externalTaskIds);
55			$this->externalTaskIds = $externalTaskIds;
56			return $this;
57			}
58
59			public function workerId(string $workerId): ExternalTaskQueryInterface
60			{
61			EnsureUtil::ensureNotNull("workerId", "workerId", $workerId);
62			$this->workerId = $workerId;
63			return $this;
64			}
65
66			public function lockExpirationBefore(string $lockExpirationDate): ExternalTaskQueryInterface
67			{
68			EnsureUtil::ensureNotNull("lockExpirationBefore", "lockExpirationDate", $lockExpirationDate);
69			$this->lockExpirationBefore = $lockExpirationDate;
70			return $this;
71			}
72
73			public function lockExpirationAfter(string $lockExpirationDate): ExternalTaskQueryInterface
74			{
75			EnsureUtil::ensureNotNull("lockExpirationAfter", "lockExpirationDate", $lockExpirationDate);
76			$this->lockExpirationAfter = $lockExpirationDate;
77			return $this;
78			}
79
80			public function topicName(string $topicName): ExternalTaskQueryInterface
81			{
82			EnsureUtil::ensureNotNull("topicName", "topicName", $topicName);
83			$this->topicName = $topicName;
84			return $this;
85			}
86
87			public function locked(): ExternalTaskQueryInterface
88			{
89			$this->locked = true;
90			return $this;
91			}
92
93			public function notLocked(): ExternalTaskQueryInterface
94			{
95			$this->notLocked = true;
96			return $this;
97			}
98
99			public function executionId(string $executionId): ExternalTaskQueryInterface
100			{
101			EnsureUtil::ensureNotNull("executionId", "executionId", $executionId);
102			$this->executionId = $executionId;
103			return $this;
104			}
105
106			public function processInstanceId(string $processInstanceId): ExternalTaskQueryInterface
107			{
108			EnsureUtil::ensureNotNull("processInstanceId", "processInstanceId", $processInstanceId);
109			$this->processInstanceId = $processInstanceId;
110			return $this;
111			}
112
113			public function processInstanceIdIn(array $processInstanceIdIn): ExternalTaskQueryInterface
114			{
115			EnsureUtil::ensureNotNull("processInstanceIdIn", "processInstanceIdIn", $processInstanceIdIn);
116			$this->processInstanceIdIn = $processInstanceIdIn;
117			return $this;
118			}
119
120			public function processDefinitionId(string $processDefinitionId): ExternalTaskQueryInterface
121			{
122			EnsureUtil::ensureNotNull("processDefinitionId", "processDefinitionId", $processDefinitionId);
123			$this->processDefinitionId = $processDefinitionId;
124			return $this;
125			}
126
127			public function activityId(string $activityId): ExternalTaskQueryInterface
128			{
129			EnsureUtil::ensureNotNull("activityId", "activityId", $activityId);
130			$this->activityId = $activityId;
131			return $this;
132			}
133
134			public function activityIdIn(array $activityIdIn): ExternalTaskQueryInterface
135			{
136			EnsureUtil::ensureNotNull("activityIdIn", "activityIdIn", $activityIdIn);
137			$this->activityIdIn = $activityIdIn;
138			return $this;
139			}
140
141			public function priorityHigherThanOrEquals(int $priority): ExternalTaskQueryInterface
142			{
143			$this->priorityHigherThanOrEquals = $priority;
144			return $this;
145			}
146
147			public function priorityLowerThanOrEquals(int $priority): ExternalTaskQueryInterface
148			{
149			$this->priorityLowerThanOrEquals = $priority;
150			return $this;
151			}
152
153			public function suspended(): ExternalTaskQueryInterface
154			{
155			$this->suspensionState = SuspensionState::suspended();
156			return $this;
157			}
158
159			public function active(): ExternalTaskQueryInterface
160			{
161			$this->suspensionState = SuspensionState::active();
162			return $this;
163			}
164
165			public function withRetriesLeft(): ExternalTaskQueryInterface
166			{
167			$this->retriesLeft = true;
168			return $this;
169			}
170
171			public function noRetriesLeft(): ExternalTaskQueryInterface
172			{
173			$this->retriesLeft = false;
174			return $this;
175			}
176
177			protected function hasExcludingConditions(): bool
178			{
179			return parent::hasExcludingConditions()
180			\|\| CompareUtil::areNotInAscendingOrder($this->priorityHigherThanOrEquals, $this->priorityLowerThanOrEquals);
181			}
182
183			public function tenantIdIn(array $tenantIds): ExternalTaskQueryInterface
184			{
185			EnsureUtil::ensureNotNull("tenantIds", "tenantIds", $tenantIds);
186			$this->tenantIds = $tenantIds;
187			return $this;
188			}
189
190			public function orderById(): ExternalTaskQueryInterface
191			{
192			return $this->orderBy(ExternalTaskQueryProperty::id());
193			}
194
195			public function orderByLockExpirationTime(): ExternalTaskQueryInterface
196			{
197			return $this->orderBy(ExternalTaskQueryProperty::lockExpirationTime());
198			}
199
200			public function orderByProcessInstanceId(): ExternalTaskQueryInterface
201			{
202			return $this->orderBy(ExternalTaskQueryProperty::processInstanceId());
203			}
204
205			public function orderByProcessDefinitionId(): ExternalTaskQueryInterface
206			{
207			return $this->orderBy(ExternalTaskQueryProperty::processDefinitionId());
208			}
209
210			public function orderByProcessDefinitionKey(): ExternalTaskQueryInterface
211			{
212			return $this->orderBy(ExternalTaskQueryProperty::processDefinitionKey());
213			}
214
215			public function orderByTenantId(): ExternalTaskQueryInterface
216			{
217			return $this->orderBy(ExternalTaskQueryProperty::tenantId());
218			}
219
220			public function orderByPriority(): ExternalTaskQueryInterface
221			{
222			return $this->orderBy(ExternalTaskQueryProperty::priority());
223			}
224
225			public function executeCount(CommandContext $commandContext): int
226			{
227			$this->checkQueryOk();
228			return $commandContext
229			->getExternalTaskManager()
230			->findExternalTaskCountByQueryCriteria($this);
231			}
232
233			public function executeList(CommandContext $commandContext, Page $page): array
			0 ignored issues – show Bug introduced 2022-05-20 13:10 UTC by Report Bug Copy Issue Report The type `Jabe\Engine\Impl\Page` was not found. Maybe you did not declare it correctly or list all dependencies? The issue could also be caused by a filter entry in the build configuration. If the path has been excluded in your configuration, e.g. `excluded_paths: ["lib/"]`, you can move it to the dependency path list as follows: filter: dependency_paths: ["lib/"] For further information see https://scrutinizer-ci.com/docs/tools/php/php-scrutinizer/#list-dependency-paths Loading history...
234			{
235			$this->checkQueryOk();
236			return $commandContext
237			->getExternalTaskManager()
238			->findExternalTasksByQueryCriteria($this);
239			}
240
241			public function executeIdsList(CommandContext $commandContext): array
242			{
243			$this->checkQueryOk();
244			return $commandContext
245			->getExternalTaskManager()
246			->findExternalTaskIdsByQueryCriteria($this);
247			}
248
249			public function executeDeploymentIdMappingsList(CommandContext $commandContext): array
250			{
251			$this->checkQueryOk();
252			return $commandContext
253			->getExternalTaskManager()
254			->findDeploymentIdMappingsByQueryCriteria($this);
255			}
256
257			public function getExternalTaskId(): string
258			{
259			return $this->externalTaskId;
260			}
261
262			public function getWorkerId(): string
263			{
264			return $this->workerId;
265			}
266
267			public function getLockExpirationBefore(): string
268			{
269			return $this->lockExpirationBefore;
270			}
271
272			public function getLockExpirationAfter(): string
273			{
274			return $this->lockExpirationAfter;
275			}
276
277			public function getTopicName(): string
278			{
279			return $this->topicName;
280			}
281
282			public function getLocked(): bool
283			{
284			return $this->locked;
285			}
286
287			public function getNotLocked(): bool
288			{
289			return $this->notLocked;
290			}
291
292			public function getExecutionId(): string
293			{
294			return $this->executionId;
295			}
296
297			public function getProcessInstanceId(): string
298			{
299			return $this->processInstanceId;
300			}
301
302			public function getProcessDefinitionId(): string
303			{
304			return $this->processDefinitionId;
305			}
306
307			public function getActivityId(): string
308			{
309			return $this->activityId;
310			}
311
312			public function getSuspensionState(): SuspensionState
313			{
314			return $this->suspensionState;
315			}
316
317			public function getRetriesLeft(): bool
318			{
319			return $this->retriesLeft;
320			}
321
322			public function getNow(): string
323			{
324			return ClockUtil::getCurrentTime()->format('c');
325			}
326			}
327

bingo-soft / jabe

Push — main ( 5af89f...c76fcf )

ExternalTaskQueryImpl::processInstanceIdIn() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like