| 1 | <?php |
||
| 14 | class CoverageMerger |
||
| 15 | { |
||
| 16 | /** @var CoverageFetcher */ |
||
| 17 | private $coverageFetcher; |
||
| 18 | |||
| 19 | /** @var CodeCoverage */ |
||
| 20 | private $coverageData; |
||
| 21 | |||
| 22 | /** |
||
| 23 | * CoverageMerger constructor. |
||
| 24 | * @param CoverageFetcher $coverageFetcher |
||
| 25 | */ |
||
| 26 | 10 | public function __construct(CoverageFetcher $coverageFetcher) |
|
| 27 | { |
||
| 28 | 10 | $this->coverageFetcher = $coverageFetcher; |
|
| 29 | } |
||
| 30 | |||
| 31 | /** |
||
| 32 | * @param ProcessEvent $processEvent |
||
| 33 | */ |
||
| 34 | 2 | public function onProcessParsingCompleted(ProcessEvent $processEvent) |
|
| 35 | { |
||
| 36 | 2 | $process = $processEvent->getProcess(); |
|
| 37 | 2 | if ($process->isToBeRetried()) { |
|
| 38 | return; |
||
| 39 | } |
||
| 40 | |||
| 41 | 2 | $this->merge($process); |
|
| 42 | } |
||
| 43 | |||
| 44 | 2 | private function merge(AbstractParaunitProcess $process) |
|
| 45 | { |
||
| 46 | 2 | $newCoverageData = $this->coverageFetcher->fetch($process); |
|
| 47 | |||
| 48 | 2 | if ($this->coverageData instanceof CodeCoverage) { |
|
| 49 | 1 | $this->coverageData->merge($newCoverageData); |
|
| 50 | } else { |
||
| 51 | 2 | $this->coverageData = $newCoverageData; |
|
| 52 | } |
||
| 53 | } |
||
| 54 | |||
| 55 | 2 | public function getCoverageData(): CodeCoverage |
|
| 59 | } |
||
| 60 |