21017989272

Committed 15 Jan 2026 02:53AM UTC coverage: 44.43%. First build

Build # 21017989272

Build Type

Pull #6436

github

Committed by

web-flow

Commit Message

Merge 6ef45535a into db0316516

Pull Request Pull Request #6436: feat: async parallel signing

Run Details

415 of 962 new or added lines in 46 files covered. (43.14%)

7036 of 15836 relevant lines covered (44.43%)

4.94 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

4.76

/lib/Service/WorkerHealthService.php

<?php

declare(strict_types=1);
/**
 * SPDX-FileCopyrightText: 2026 LibreCode coop and contributors
 * SPDX-License-Identifier: AGPL-3.0-or-later
 */

namespace OCA\Libresign\Service;

use OCA\Libresign\Service\Worker\StartThrottlePolicy;
use OCA\Libresign\Service\Worker\WorkerConfiguration;
use OCA\Libresign\Service\Worker\WorkerCounter;
use OCA\Libresign\Service\Worker\WorkerStarter;
use Psr\Log\LoggerInterface;

class WorkerHealthService {
        public function __construct(
                private WorkerConfiguration $config,
                private WorkerCounter $counter,
                private StartThrottlePolicy $throttle,
                private WorkerStarter $starter,
                private LoggerInterface $logger,
        ) {
        }

        public function isAsyncLocalEnabled(): bool {
                return $this->config->isAsyncLocalEnabled();
        }

        public function ensureWorkerRunning(): bool {
                try {
                        if (!$this->config->isAsyncLocalEnabled()) {
                                return false;
                        }

                        $workersNeeded = $this->calculateWorkersNeeded();
                        if ($workersNeeded === 0) {
                                return true;
                        }

                        if ($this->throttle->isThrottled()) {
                                return true;
                        }

                        $this->throttle->recordAttempt();
                        $this->starter->startWorkers($workersNeeded);
                        return true;
                } catch (\Throwable $e) {
                        $this->logger->error('Failed to ensure worker is running: {error}', [
                                'error' => $e->getMessage(),
                                'exception' => $e,
                        ]);
                        return false;
                }
        }

        private function calculateWorkersNeeded(): int {
                $desired = $this->config->getDesiredWorkerCount();
                $running = $this->counter->countRunning();
                return max(0, $desired - $running);
        }
}

1	<?php
2
3	declare(strict_types=1);
4	/**
5	* SPDX-FileCopyrightText: 2026 LibreCode coop and contributors
6	* SPDX-License-Identifier: AGPL-3.0-or-later
7	*/
8
9	namespace OCA\Libresign\Service;
10
11	use OCA\Libresign\Service\Worker\StartThrottlePolicy;
12	use OCA\Libresign\Service\Worker\WorkerConfiguration;
13	use OCA\Libresign\Service\Worker\WorkerCounter;
14	use OCA\Libresign\Service\Worker\WorkerStarter;
15	use Psr\Log\LoggerInterface;
16
17	class WorkerHealthService {
18	public function __construct(
19	private WorkerConfiguration $config,
20	private WorkerCounter $counter,
21	private StartThrottlePolicy $throttle,
22	private WorkerStarter $starter,
23	private LoggerInterface $logger,
24	) {
25	}	6✔
26
27	public function isAsyncLocalEnabled(): bool {
NEW 28	return $this->config->isAsyncLocalEnabled();	×
29	}
30
31	public function ensureWorkerRunning(): bool {
32	try {
NEW 33	if (!$this->config->isAsyncLocalEnabled()) {	×
NEW 34	return false;	×
35	}
36
NEW 37	$workersNeeded = $this->calculateWorkersNeeded();	×
NEW 38	if ($workersNeeded === 0) {	×
NEW 39	return true;	×
40	}
41
NEW 42	if ($this->throttle->isThrottled()) {	×
NEW 43	return true;	×
44	}
45
NEW 46	$this->throttle->recordAttempt();	×
NEW 47	$this->starter->startWorkers($workersNeeded);	×
NEW 48	return true;	×
NEW 49	} catch (\Throwable $e) {	×
NEW 50	$this->logger->error('Failed to ensure worker is running: {error}', [	×
NEW 51	'error' => $e->getMessage(),	×
NEW 52	'exception' => $e,	×
NEW 53	]);	×
NEW 54	return false;	×
55	}
56	}
57
58	private function calculateWorkersNeeded(): int {
NEW 59	$desired = $this->config->getDesiredWorkerCount();	×
NEW 60	$running = $this->counter->countRunning();	×
NEW 61	return max(0, $desired - $running);	×
62	}
63	}

LibreSign / libresign / 21017989272

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous