9935584685

Committed 15 Jul 2024 07:44AM UTC coverage: 47.259% (-18.3%) from 65.524%

Build Type

push

github

Committed by darkdarin

Commit Message

fix: tests

Run Details

4 of 4 new or added lines in 2 files covered. (100.0%)

431 existing lines in 40 files now uncovered.

612 of 1295 relevant lines covered (47.26%)

2.53 hits per line

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

0.0

/src/Core/Support/DaemonWorker.php

<?php

namespace Tochka\Promises\Core\Support;

use Carbon\Carbon;

trait DaemonWorker
{
    private int $sleepTime;
    private Carbon $lastIteration;

    /**
     * @param callable $callback
     * @param null|callable(): bool $shouldQuitCallback
     * @param null|callable(): bool $shouldPausedCallback
     * @return void
     */
    public function daemon(callable $callback, ?callable $shouldQuitCallback = null, ?callable $shouldPausedCallback = null): void
    {
        if ($shouldQuitCallback === null) {
            $shouldQuitCallback = fn(): bool => false;
        }
        if ($shouldPausedCallback === null) {
            $shouldPausedCallback = fn(): bool => false;
        }

        while (true) {
            if ($shouldQuitCallback()) {
                return;
            }

            if ($shouldPausedCallback() || $this->sleepAfterLastIteration()) {
                $this->sleep(1);

                continue;
            }

            $callback();

            $this->lastIteration = Carbon::now();
        }
    }

    private function sleep(int|float $seconds): void
    {
        if (is_float($seconds)) {
            $seconds = (int) $seconds * 1000000;
            if ($seconds < 0) {
                return;
            }

            usleep($seconds);
        } else {
            if ($seconds < 0) {
                return;
            }

            sleep($seconds);
        }
    }

    private function sleepAfterLastIteration(): bool
    {
        return $this->lastIteration > Carbon::now()->subSeconds($this->sleepTime);
    }
}

1	<?php
2
3	namespace Tochka\Promises\Core\Support;
4
5	use Carbon\Carbon;
6
7	trait DaemonWorker
8	{
9	private int $sleepTime;
10	private Carbon $lastIteration;
11
12	/**
13	* @param callable $callback
14	* @param null\|callable(): bool $shouldQuitCallback
15	* @param null\|callable(): bool $shouldPausedCallback
16	* @return void
17	*/
18	public function daemon(callable $callback, ?callable $shouldQuitCallback = null, ?callable $shouldPausedCallback = null): void
19	{
20	if ($shouldQuitCallback === null) {	×
21	$shouldQuitCallback = fn(): bool => false;	×
22	}
UNCOV 23	if ($shouldPausedCallback === null) {	×
UNCOV 24	$shouldPausedCallback = fn(): bool => false;	×
25	}
26
UNCOV 27	while (true) {	×
28	if ($shouldQuitCallback()) {	×
UNCOV 29	return;	×
30	}
31
UNCOV 32	if ($shouldPausedCallback() \|\| $this->sleepAfterLastIteration()) {	×
33	$this->sleep(1);	×
34
UNCOV 35	continue;	×
36	}
37
UNCOV 38	$callback();	×
39
40	$this->lastIteration = Carbon::now();	×
41	}
42	}
43
44	private function sleep(int\|float $seconds): void
45	{
UNCOV 46	if (is_float($seconds)) {	×
UNCOV 47	$seconds = (int) $seconds * 1000000;	×
48	if ($seconds < 0) {	×
UNCOV 49	return;	×
50	}
51
UNCOV 52	usleep($seconds);	×
53	} else {
UNCOV 54	if ($seconds < 0) {	×
UNCOV 55	return;	×
56	}
57
UNCOV 58	sleep($seconds);	×
59	}
60	}
61
62	private function sleepAfterLastIteration(): bool
63	{
UNCOV 64	return $this->lastIteration > Carbon::now()->subSeconds($this->sleepTime);	×
65	}
66	}

tochka-developers / queue-promises / 9935584685

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