DevOps - Java代码增量覆盖率工具

1
try (Git git = Git.open(new File(gitRepoPath))) {
2
    Stream<DiffEntry> stream = getDifferentBetweenTwoCommit(git, oldCommit, newCommit);
3
    if (null == stream)
4
        return null;
5
    try (ByteArrayOutputStream out = new ByteArrayOutputStream()) {
6
        DiffFormatter df = new DiffFormatter(out);
7
        // ignores all whitespace
8
        df.setDiffComparator(RawTextComparator.WS_IGNORE_ALL);
9
        df.setRepository(git.getRepository());
10

11
        List<SourceCodeFile> map = stream.map(diffEntry -> {
12
            try {
13
                FileHeader header = df.toFileHeader(diffEntry);
14
                //  analysis new add code block.
15
                List<SourceCodeBlock> list = header.getHunks().stream()
16
                        .flatMap((Function<HunkHeader, Stream<Edit>>) hunk -> hunk.toEditList().stream())
17
                        .filter(edit -> edit.getEndB() - edit.getBeginB() > 0)
18
                        .map(edit -> SourceCodeBlock.of(edit.getBeginB(), edit.getEndB()))
19
                        .collect(Collectors.toList());
20
                if (list.isEmpty())
21
                    return null;
22
                return new SourceCodeFile(diffEntry.getNewPath(), list);
23
            } catch (Exception e) {
24
                throw new RuntimeException(e);
25
            } finally {
26
                out.reset();
27
            }
28
        })
29
                .filter(Objects::nonNull)
30
                .collect(Collectors.toList());
31
        CACHE_MAP.put(cacheKey, map);
32
        return map;
33
    }
34
} catch (Exception e) {
35
    throw new RuntimeException(e);
36
}

1
List<CoverageRelativeResultElement> list = report.getChildrenResults()
2
    .parallelStream()
3
    .filter(cr -> CoverageElement.FILE.equals(cr.getElement()))
4
    .filter(cr -> cr.getPaint() != null)
5
    .map(cr -> scbInfo.stream()
6
            .filter(p -> p.getPath().endsWith(cr.getRelativeSourcePath()))
7
            .limit(1)
8
            .findAny()
9
            .map(scf -> {
10
                int[] lines = scf.getBlocks()
11
                        .stream()
12
                        .flatMapToInt(block -> IntStream.rangeClosed((int) (block.getStartLine() + 1), (int) block.getEndLine())
13
                                .filter(line -> cr.getPaint().isPainted(line))
14
                        ).toArray();
15
                //  absolute coverage
16
                Map<CoverageElement, Ratio> results = new TreeMap<>();
17
                Ratio crHitRatio = analysisLogicHitCoverage(cr.getPaint(), level, cr.getPaint().lines.keys());
18
                results.put(CoverageElement.ABSOLUTE, crHitRatio);
19
                //  newly code coverage
20
                results.put(CoverageElement.RELATIVE, analysisLogicHitCoverage(cr.getPaint(), level, lines));
21
                //  coverage change
22
                CoverageResult pr = cr.getPreviousResult();
23
                if (pr != null) {
24
                    Ratio prHitRatio = analysisLogicHitCoverage(pr.getPaint(), level, pr.getPaint().lines.keys());
25
                    if (prHitRatio.numerator != 0.0F) {
26
                        results.put(CoverageElement.CHANGE, Ratio.create(crHitRatio.getPercentageFloat() - prHitRatio.getPercentageFloat(), 100.0F));
27
                    }
28
                }
29
                return new CoverageRelativeResultElement(cr.getName(), cr.getRelativeSourcePath(), results);
30
            })
31
            .orElse(null)
32
    )
33
    .filter(Objects::nonNull)
34
    .collect(Collectors.toList());