10668219380

Committed 02 Sep 2024 01:35PM UTC coverage: 90.767% (+0.02%) from 90.75%

Build # 10668219380

Build Type

push

github

Committed by

h4kuna

Commit Message

feat(command): rename phpstan -> stan

Run Details

521 of 574 relevant lines covered (90.77%)

0.91 hits per line

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

96.55

/src/Utils/FileRequestBlockingService.php

<?php declare(strict_types=1);

namespace h4kuna\Fio\Utils;

use Closure;
use h4kuna\Dir\Dir;
use h4kuna\Fio\Contracts\RequestBlockingServiceContract;
use h4kuna\Fio\Exceptions\InvalidState;
use Nette\SafeStream\Wrapper;
use Psr\Http\Message\ResponseInterface;

final class FileRequestBlockingService implements RequestBlockingServiceContract
{
        /** @var array<string, string> */
        private static array $tokens = [];

        /**
         * @param int $waitTime - seconds
         */
        public function __construct(
                private Dir $tempDir,
                private int $waitTime = 31,
        ) {
        }


        public function synchronize(string $token, Closure $callback): ?ResponseInterface
        {
                $tempFile = $this->loadFileName($token);
                $file = self::createFileResource($tempFile);
                $sleep = $this->waitTime - (time() - ((int) fgets($file, 30)));
                if ($sleep > 0) {
                        sleep($sleep);
                }

                try {
                        $response = $callback();
                } finally {
                        fseek($file, 0);
                        ftruncate($file, 0);
                        fputs($file, (string) time());
                        fclose($file);
                }

                return $response;
        }

        /**
         * @return resource
         */
        private static function createFileResource(string $filePath)
        {
                if (is_file($filePath) === false) {
                        touch($filePath);
                }
                $file = fopen(self::safeProtocol($filePath), 'r+');
                if ($file === false) {
                        throw new InvalidState('Open file is failed ' . $filePath);
                }

                return $file;
        }


        private function loadFileName(string $token): string
        {
                $key = substr($token, 10, -10);
                if (!isset(self::$tokens[$key])) {
                        self::$tokens[$key] = $this->tempDir->filename(md5($key));
                }

                return self::$tokens[$key];
        }


        private static function safeProtocol(string $filename): string
        {
                return Wrapper::Protocol . "://$filename";
        }
}

1	<?php declare(strict_types=1);
2
3	namespace h4kuna\Fio\Utils;
4
5	use Closure;
6	use h4kuna\Dir\Dir;
7	use h4kuna\Fio\Contracts\RequestBlockingServiceContract;
8	use h4kuna\Fio\Exceptions\InvalidState;
9	use Nette\SafeStream\Wrapper;
10	use Psr\Http\Message\ResponseInterface;
11
12	final class FileRequestBlockingService implements RequestBlockingServiceContract
13	{
14	/** @var array<string, string> */
15	private static array $tokens = [];
16
17	/**
18	* @param int $waitTime - seconds
19	*/
20	public function __construct(	1✔
21	private Dir $tempDir,
22	private int $waitTime = 31,
23	) {
24	}	1✔
25
26
27	public function synchronize(string $token, Closure $callback): ?ResponseInterface	1✔
28	{
29	$tempFile = $this->loadFileName($token);	1✔
30	$file = self::createFileResource($tempFile);	1✔
31	$sleep = $this->waitTime - (time() - ((int) fgets($file, 30)));	1✔
32	if ($sleep > 0) {	1✔
33	sleep($sleep);	1✔
34	}
35
36	try {
37	$response = $callback();	1✔
38	} finally {	1✔
39	fseek($file, 0);	1✔
40	ftruncate($file, 0);	1✔
41	fputs($file, (string) time());	1✔
42	fclose($file);	1✔
43	}
44
45	return $response;	1✔
46	}
47
48	/**
49	* @return resource
50	*/
51	private static function createFileResource(string $filePath)	1✔
52	{
53	if (is_file($filePath) === false) {	1✔
54	touch($filePath);	1✔
55	}
56	$file = fopen(self::safeProtocol($filePath), 'r+');	1✔
57	if ($file === false) {	1✔
58	throw new InvalidState('Open file is failed ' . $filePath);	×
59	}
60
61	return $file;	1✔
62	}
63
64
65	private function loadFileName(string $token): string	1✔
66	{
67	$key = substr($token, 10, -10);	1✔
68	if (!isset(self::$tokens[$key])) {	1✔
69	self::$tokens[$key] = $this->tempDir->filename(md5($key));	1✔
70	}
71
72	return self::$tokens[$key];	1✔
73	}
74
75
76	private static function safeProtocol(string $filename): string	1✔
77	{
78	return Wrapper::Protocol . "://$filename";	1✔
79	}
80	}

h4kuna / fio / 10668219380

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