Lines
100.00%
31 / 31
Methods
100.00%
6 / 6
Classes
100.00%
1 / 1
| Name | Lines | Methods | CRAP | ||||
|---|---|---|---|---|---|---|---|
| __construct | 100.00% | 2 / 2 | 100.00% | 1 / 1 | 1 | ||
| getEntity | 100.00% | 1 / 1 | 100.00% | 1 / 1 | 1 | ||
| getScopeList | 100.00% | 1 / 1 | 100.00% | 1 / 1 | 1 | ||
| getProcessList | 100.00% | 12 / 12 | 100.00% | 1 / 1 | 2 | ||
| getNextProcess | 100.00% | 14 / 14 | 100.00% | 1 / 1 | 3 | ||
| isClusterEnabled | 100.00% | 1 / 1 | 100.00% | 1 / 1 | 2 | ||
| 15 | class ClusterHelper | |
| 16 | { | |
| 17 | protected static $cluster = null; | |
| 18 | ||
| 19 | protected static $workstation = null; | |
| 20 | ||
| 21 | public function __construct(Workstation $workstation) | |
| 22 | { | |
| 23 | static::$workstation = $workstation; | |
| 24 | static::$cluster = \App::$http->readGetResult('/scope/' . $workstation->scope['id'] . '/cluster/')->getEntity(); | |
| 25 | } | |
| 26 | ||
| 27 | public static function getEntity() | |
| 28 | { | |
| 29 | return static::$cluster; | |
| 30 | } | |
| 31 | ||
| 32 | public static function getScopeList() | |
| 33 | { | |
| 34 | return static::$workstation->getScopeList(static::$cluster); | |
| 35 | } | |
| 36 | ||
| 37 | /** @psalm-api */ | |
| 38 | public static function getProcessList($selectedDate) | |
| 39 | { | |
| 40 | if (static::isClusterEnabled()) { | |
| 41 | $processList = \App::$http | |
| 42 | ->readGetResult( | |
| 43 | '/cluster/' . static::$cluster->id . '/process/' . $selectedDate . '/', | |
| 44 | ['gql' => GraphDefaults::getProcess()] | |
| 45 | ); | |
| 46 | } else { | |
| 47 | $processList = \App::$http | |
| 48 | ->readGetResult( | |
| 49 | '/scope/' . static::$workstation->scope['id'] . '/process/' . $selectedDate . '/', | |
| 50 | ['gql' => GraphDefaults::getProcess()] | |
| 51 | ); | |
| 52 | } | |
| 53 | return $processList->getCollection() ?? new ProcessList(); | |
| 54 | } | |
| 55 | ||
| 56 | public static function getNextProcess(array $excludedIds) | |
| 57 | { | |
| 58 | $exclude = is_array($excludedIds) ? ExcludeIds::toQuery($excludedIds) : (string) $excludedIds; | |
| 59 | if (static::isClusterEnabled()) { | |
| 60 | $nextProcess = \App::$http->readGetResult( | |
| 61 | '/cluster/' . static::$cluster['id'] . '/queue/next/', | |
| 62 | [ | |
| 63 | 'exclude' => $exclude, | |
| 64 | 'allowClusterWideCall' => \App::$allowClusterWideCall | |
| 65 | ] | |
| 66 | )->getEntity(); | |
| 67 | } else { | |
| 68 | $nextProcess = \App::$http->readGetResult( | |
| 69 | '/scope/' . static::$workstation->scope['id'] . '/queue/next/', | |
| 70 | ['exclude' => $exclude] | |
| 71 | )->getEntity(); | |
| 72 | } | |
| 73 | ||
| 74 | return $nextProcess; | |
| 75 | } | |
| 76 | ||
| 77 | public static function isClusterEnabled(): bool | |
| 78 | { | |
| 79 | return (static::$workstation->queue['clusterEnabled'] && static::$cluster); | |
| 80 | } | |
| 81 | } |