forked from phpstan/phpstan-src
-
Notifications
You must be signed in to change notification settings - Fork 1
/
AnalyserRunner.php
102 lines (91 loc) · 2.44 KB
/
AnalyserRunner.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
<?php declare(strict_types = 1);
namespace PHPStan\Command;
use Closure;
use PHPStan\Analyser\Analyser;
use PHPStan\Analyser\AnalyserResult;
use PHPStan\Parallel\ParallelAnalyser;
use PHPStan\Parallel\Scheduler;
use PHPStan\Process\CpuCoreCounter;
use Symfony\Component\Console\Input\InputInterface;
use function array_filter;
use function array_values;
use function count;
use function function_exists;
use function is_file;
class AnalyserRunner
{
public function __construct(
private Scheduler $scheduler,
private Analyser $analyser,
private ParallelAnalyser $parallelAnalyser,
private CpuCoreCounter $cpuCoreCounter,
)
{
}
/**
* @param string[] $files
* @param string[] $allAnalysedFiles
* @param Closure(string $file): void|null $preFileCallback
* @param Closure(int ): void|null $postFileCallback
*/
public function runAnalyser(
array $files,
array $allAnalysedFiles,
?Closure $preFileCallback,
?Closure $postFileCallback,
bool $debug,
bool $allowParallel,
?string $projectConfigFile,
?string $tmpFile,
?string $insteadOfFile,
InputInterface $input,
): AnalyserResult
{
$filesCount = count($files);
if ($filesCount === 0) {
return new AnalyserResult([], [], [], [], false);
}
$schedule = $this->scheduler->scheduleWork($this->cpuCoreCounter->getNumberOfCpuCores(), $files);
$mainScript = null;
if (isset($_SERVER['argv'][0]) && is_file($_SERVER['argv'][0])) {
$mainScript = $_SERVER['argv'][0];
}
if (
!$debug
&& $allowParallel
&& function_exists('proc_open')
&& $mainScript !== null
&& $schedule->getNumberOfProcesses() > 0
) {
return $this->parallelAnalyser->analyse($schedule, $mainScript, $postFileCallback, $projectConfigFile, $tmpFile, $insteadOfFile, $input);
}
return $this->analyser->analyse(
$this->switchTmpFile($files, $insteadOfFile, $tmpFile),
$preFileCallback,
$postFileCallback,
$debug,
$this->switchTmpFile($allAnalysedFiles, $insteadOfFile, $tmpFile),
);
}
/**
* @param string[] $analysedFiles
* @return string[]
*/
private function switchTmpFile(
array $analysedFiles,
?string $insteadOfFile,
?string $tmpFile,
): array
{
$analysedFiles = array_values(array_filter($analysedFiles, static function (string $file) use ($insteadOfFile): bool {
if ($insteadOfFile === null) {
return true;
}
return $file !== $insteadOfFile;
}));
if ($tmpFile !== null) {
$analysedFiles[] = $tmpFile;
}
return $analysedFiles;
}
}