3 * Copyright (C) 2009-2024 SonarSource SA
4 * mailto:info AT sonarsource DOT com
6 * This program is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU Lesser General Public
8 * License as published by the Free Software Foundation; either
9 * version 3 of the License, or (at your option) any later version.
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 * Lesser General Public License for more details.
16 * You should have received a copy of the GNU Lesser General Public License
17 * along with this program; if not, write to the Free Software Foundation,
18 * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
20 package org.sonar.ce.task.projectanalysis.batch;
22 import com.google.common.collect.ImmutableList;
24 import java.io.IOException;
25 import org.apache.commons.io.FileUtils;
26 import org.junit.Before;
27 import org.junit.Rule;
28 import org.junit.Test;
29 import org.sonar.api.impl.utils.JUnitTempFolder;
30 import org.sonar.core.util.CloseableIterator;
31 import org.sonar.scanner.protocol.output.FileStructure;
32 import org.sonar.scanner.protocol.output.ScannerReport;
33 import org.sonar.scanner.protocol.output.ScannerReportWriter;
35 import static com.google.common.collect.ImmutableList.of;
36 import static org.assertj.core.api.Assertions.assertThat;
37 import static org.assertj.core.api.Assertions.assertThatThrownBy;
39 public class BatchReportReaderImplTest {
40 private static final int COMPONENT_REF = 1;
41 private static final ScannerReport.Changesets CHANGESETS = ScannerReport.Changesets.newBuilder().setComponentRef(COMPONENT_REF).build();
42 private static final ScannerReport.Measure MEASURE = ScannerReport.Measure.newBuilder().build();
43 private static final ScannerReport.Component COMPONENT = ScannerReport.Component.newBuilder().setRef(COMPONENT_REF).build();
44 private static final ScannerReport.Issue ISSUE = ScannerReport.Issue.newBuilder().build();
45 private static final ScannerReport.Duplication DUPLICATION = ScannerReport.Duplication.newBuilder().build();
46 private static final ScannerReport.CpdTextBlock DUPLICATION_BLOCK = ScannerReport.CpdTextBlock.newBuilder().build();
47 private static final ScannerReport.Symbol SYMBOL = ScannerReport.Symbol.newBuilder().build();
48 private static final ScannerReport.SyntaxHighlightingRule SYNTAX_HIGHLIGHTING_1 = ScannerReport.SyntaxHighlightingRule.newBuilder().build();
49 private static final ScannerReport.SyntaxHighlightingRule SYNTAX_HIGHLIGHTING_2 = ScannerReport.SyntaxHighlightingRule.newBuilder().build();
50 private static final ScannerReport.LineCoverage COVERAGE_1 = ScannerReport.LineCoverage.newBuilder().build();
51 private static final ScannerReport.LineCoverage COVERAGE_2 = ScannerReport.LineCoverage.newBuilder().build();
54 public JUnitTempFolder tempFolder = new JUnitTempFolder();
56 private ScannerReportWriter writer;
57 private BatchReportReaderImpl underTest;
61 BatchReportDirectoryHolder holder = new ImmutableBatchReportDirectoryHolder(tempFolder.newDir());
62 underTest = new BatchReportReaderImpl(holder);
63 FileStructure fileStructure = new FileStructure(holder.getDirectory());
64 writer = new ScannerReportWriter(fileStructure);
68 public void readMetadata_throws_ISE_if_no_metadata() {
69 assertThatThrownBy(() -> underTest.readMetadata())
70 .isInstanceOf(IllegalStateException.class);
74 public void readMetadata_result_is_cached() {
75 ScannerReport.Metadata metadata = ScannerReport.Metadata.newBuilder().build();
77 writer.writeMetadata(metadata);
79 ScannerReport.Metadata res = underTest.readMetadata();
80 assertThat(res).isEqualTo(metadata);
81 assertThat(underTest.readMetadata()).isSameAs(res);
85 public void readScannerLogs() throws IOException {
86 File scannerLogFile = writer.getFileStructure().analysisLog();
87 FileUtils.write(scannerLogFile, "log1\nlog2");
89 CloseableIterator<String> logs = underTest.readScannerLogs();
90 assertThat(logs).toIterable().containsExactly("log1", "log2");
94 public void readScannerLogs_no_logs() {
95 CloseableIterator<String> logs = underTest.readScannerLogs();
96 assertThat(logs.hasNext()).isFalse();
100 public void readComponentMeasures_returns_empty_list_if_there_is_no_measure() {
101 assertThat(underTest.readComponentMeasures(COMPONENT_REF)).isExhausted();
105 public void verify_readComponentMeasures_returns_measures() {
106 writer.appendComponentMeasure(COMPONENT_REF, MEASURE);
108 try (CloseableIterator<ScannerReport.Measure> measures = underTest.readComponentMeasures(COMPONENT_REF)) {
109 assertThat(measures.next()).isEqualTo(MEASURE);
110 assertThat(measures.hasNext()).isFalse();
115 public void readComponentMeasures_is_not_cached() {
116 writer.appendComponentMeasure(COMPONENT_REF, MEASURE);
118 assertThat(underTest.readComponentMeasures(COMPONENT_REF)).isNotSameAs(underTest.readComponentMeasures(COMPONENT_REF));
122 public void readChangesets_returns_null_if_no_changeset() {
123 assertThat(underTest.readChangesets(COMPONENT_REF)).isNull();
127 public void verify_readChangesets_returns_changesets() {
128 writer.writeComponentChangesets(CHANGESETS);
130 ScannerReport.Changesets res = underTest.readChangesets(COMPONENT_REF);
131 assertThat(res).isEqualTo(CHANGESETS);
135 public void readChangesets_is_not_cached() {
136 writer.writeComponentChangesets(CHANGESETS);
138 assertThat(underTest.readChangesets(COMPONENT_REF)).isNotSameAs(underTest.readChangesets(COMPONENT_REF));
142 public void readComponent_throws_ISE_if_file_does_not_exist() {
143 assertThatThrownBy(() -> underTest.readComponent(COMPONENT_REF))
144 .isInstanceOf(IllegalStateException.class);
148 public void verify_readComponent_returns_Component() {
149 writer.writeComponent(COMPONENT);
151 assertThat(underTest.readComponent(COMPONENT_REF)).isEqualTo(COMPONENT);
155 public void readComponent_is_not_cached() {
156 writer.writeComponent(COMPONENT);
158 assertThat(underTest.readComponent(COMPONENT_REF)).isNotSameAs(underTest.readComponent(COMPONENT_REF));
162 public void readComponentIssues_returns_empty_list_if_file_does_not_exist() {
163 assertThat(underTest.readComponentIssues(COMPONENT_REF)).isExhausted();
167 public void verify_readComponentIssues_returns_Issues() {
168 writer.writeComponentIssues(COMPONENT_REF, of(ISSUE));
170 try (CloseableIterator<ScannerReport.Issue> res = underTest.readComponentIssues(COMPONENT_REF)) {
171 assertThat(res.next()).isEqualTo(ISSUE);
172 assertThat(res.hasNext()).isFalse();
177 public void readComponentIssues_it_not_cached() {
178 writer.writeComponentIssues(COMPONENT_REF, of(ISSUE));
180 assertThat(underTest.readComponentIssues(COMPONENT_REF)).isNotSameAs(underTest.readComponentIssues(COMPONENT_REF));
184 public void readComponentDuplications_returns_empty_list_if_file_does_not_exist() {
185 assertThat(underTest.readComponentDuplications(COMPONENT_REF)).isExhausted();
189 public void verify_readComponentDuplications_returns_Issues() {
190 writer.writeComponentDuplications(COMPONENT_REF, of(DUPLICATION));
192 try (CloseableIterator<ScannerReport.Duplication> res = underTest.readComponentDuplications(COMPONENT_REF)) {
193 assertThat(res.next()).isEqualTo(DUPLICATION);
194 assertThat(res.hasNext()).isFalse();
199 public void readComponentDuplications_it_not_cached() {
200 writer.writeComponentDuplications(COMPONENT_REF, of(DUPLICATION));
202 assertThat(underTest.readComponentDuplications(COMPONENT_REF)).isNotSameAs(underTest.readComponentDuplications(COMPONENT_REF));
206 public void readComponentDuplicationBlocks_returns_empty_list_if_file_does_not_exist() {
207 assertThat(underTest.readCpdTextBlocks(COMPONENT_REF)).isExhausted();
211 public void verify_readComponentDuplicationBlocks_returns_Issues() {
212 writer.writeCpdTextBlocks(COMPONENT_REF, of(DUPLICATION_BLOCK));
214 try (CloseableIterator<ScannerReport.CpdTextBlock> res = underTest.readCpdTextBlocks(COMPONENT_REF)) {
215 assertThat(res.next()).isEqualTo(DUPLICATION_BLOCK);
216 assertThat(res.hasNext()).isFalse();
221 public void readComponentDuplicationBlocks_is_not_cached() {
222 writer.writeCpdTextBlocks(COMPONENT_REF, of(DUPLICATION_BLOCK));
224 assertThat(underTest.readCpdTextBlocks(COMPONENT_REF)).isNotSameAs(underTest.readCpdTextBlocks(COMPONENT_REF));
228 public void readComponentSymbols_returns_empty_list_if_file_does_not_exist() {
229 assertThat(underTest.readComponentSymbols(COMPONENT_REF)).isExhausted();
233 public void verify_readComponentSymbols_returns_Issues() {
234 writer.writeComponentSymbols(COMPONENT_REF, of(SYMBOL));
236 try (CloseableIterator<ScannerReport.Symbol> res = underTest.readComponentSymbols(COMPONENT_REF)) {
237 assertThat(res.next()).isEqualTo(SYMBOL);
238 assertThat(res.hasNext()).isFalse();
243 public void readComponentSymbols_it_not_cached() {
244 writer.writeComponentSymbols(COMPONENT_REF, of(SYMBOL));
246 assertThat(underTest.readComponentSymbols(COMPONENT_REF)).isNotSameAs(underTest.readComponentSymbols(COMPONENT_REF));
250 public void readComponentSyntaxHighlighting_returns_empty_CloseableIterator_when_file_does_not_exist() {
251 assertThat(underTest.readComponentSyntaxHighlighting(COMPONENT_REF)).isExhausted();
255 public void verify_readComponentSyntaxHighlighting() {
256 writer.writeComponentSyntaxHighlighting(COMPONENT_REF, of(SYNTAX_HIGHLIGHTING_1, SYNTAX_HIGHLIGHTING_2));
258 CloseableIterator<ScannerReport.SyntaxHighlightingRule> res = underTest.readComponentSyntaxHighlighting(COMPONENT_REF);
259 assertThat(res).toIterable().containsExactly(SYNTAX_HIGHLIGHTING_1, SYNTAX_HIGHLIGHTING_2);
264 public void readComponentCoverage_returns_empty_CloseableIterator_when_file_does_not_exist() {
265 assertThat(underTest.readComponentCoverage(COMPONENT_REF)).isExhausted();
269 public void verify_readComponentCoverage() {
270 writer.writeComponentCoverage(COMPONENT_REF, of(COVERAGE_1, COVERAGE_2));
272 CloseableIterator<ScannerReport.LineCoverage> res = underTest.readComponentCoverage(COMPONENT_REF);
273 assertThat(res).toIterable().containsExactly(COVERAGE_1, COVERAGE_2);
278 public void readFileSource_returns_absent_optional_when_file_does_not_exist() {
279 assertThat(underTest.readFileSource(COMPONENT_REF)).isEmpty();
283 public void verify_readFileSource() throws IOException {
284 File file = writer.getSourceFile(COMPONENT_REF);
285 FileUtils.writeLines(file, of("1", "2", "3"));
287 CloseableIterator<String> res = underTest.readFileSource(COMPONENT_REF).get();
288 assertThat(res).toIterable().containsExactly("1", "2", "3");
293 public void verify_readAnalysisWarnings() {
294 ScannerReport.AnalysisWarning warning1 = ScannerReport.AnalysisWarning.newBuilder().setText("warning 1").build();
295 ScannerReport.AnalysisWarning warning2 = ScannerReport.AnalysisWarning.newBuilder().setText("warning 2").build();
296 ImmutableList<ScannerReport.AnalysisWarning> warnings = of(warning1, warning2);
297 writer.writeAnalysisWarnings(warnings);
299 CloseableIterator<ScannerReport.AnalysisWarning> res = underTest.readAnalysisWarnings();
300 assertThat(res).toIterable().containsExactlyElementsOf(warnings);