Completed
Pull Request — master (#94)
by Alessandro
04:33
created

CoverageMerger::getCoverageData()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 4
Code Lines 2

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 2
CRAP Score 1

Importance

Changes 0
Metric Value
dl 0
loc 4
ccs 2
cts 2
cp 1
rs 10
c 0
b 0
f 0
cc 1
eloc 2
nc 1
nop 0
crap 1
1
<?php
2
declare(strict_types=1);
3
4
namespace Paraunit\Coverage;
5
6
use Paraunit\Lifecycle\ProcessEvent;
7
use Paraunit\Process\AbstractParaunitProcess;
8
use Paraunit\Proxy\Coverage\CodeCoverage;
9
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
10
11
/**
12
 * Class CoverageMerger
13
 * @package Paraunit\Coverage
14
 */
15
class CoverageMerger implements EventSubscriberInterface
16
{
17
    /** @var  CoverageFetcher */
18
    private $coverageFetcher;
19
20
    /** @var  CodeCoverage */
21
    private $coverageData;
22
23
    /**
24
     * CoverageMerger constructor.
25
     * @param CoverageFetcher $coverageFetcher
26
     */
27 11
    public function __construct(CoverageFetcher $coverageFetcher)
28
    {
29 11
        $this->coverageFetcher = $coverageFetcher;
30
    }
31
32 9
    public static function getSubscribedEvents(): array
33
    {
34
        return [
35 9
            ProcessEvent::PROCESS_PARSING_COMPLETED => 'onProcessParsingCompleted',
36
        ];
37
    }
38
39
    /**
40
     * @param ProcessEvent $processEvent
41
     */
42 3
    public function onProcessParsingCompleted(ProcessEvent $processEvent)
43
    {
44 3
        $process = $processEvent->getProcess();
45 3
        if ($process->isToBeRetried()) {
46
            return;
47
        }
48
49 3
        $this->merge($process);
50
    }
51
52 3
    private function merge(AbstractParaunitProcess $process)
53
    {
54 3
        $newCoverageData = $this->coverageFetcher->fetch($process);
55
56 3
        if ($this->coverageData instanceof CodeCoverage) {
57 1
            $this->coverageData->merge($newCoverageData);
58
        } else {
59 3
            $this->coverageData = $newCoverageData;
60
        }
61
    }
62
63 3
    public function getCoverageData(): CodeCoverage
64
    {
65 3
        return $this->coverageData;
66
    }
67
}
68