SONAR-22039 Support new timeout properties

1 files changed, 40 insertions, 0 deletions

diff --git a/sonar-scanner-engine/src/test/java/org/sonar/scanner/bootstrap/ScannerWsClientProviderTest.java b/sonar-scanner-engine/src/test/java/org/sonar/scanner/bootstrap/ScannerWsClientProviderTest.java
index 141a3af7670..2e63d4c0139 100644
--- a/sonar-scanner-engine/src/test/java/org/sonar/scanner/bootstrap/ScannerWsClientProviderTest.java
+++ b/sonar-scanner-engine/src/test/java/org/sonar/scanner/bootstrap/ScannerWsClientProviderTest.java
@@ -126,6 +126,46 @@ class ScannerWsClientProviderTest {
   }
 
   @Test
+  void it_should_timeout_on_long_response() {
+    scannerProps.put("sonar.host.url", sonarqubeMock.baseUrl());
+    scannerProps.put("sonar.scanner.responseTimeout", "PT0.2S");
+
+    DefaultScannerWsClient client = underTest.provide(new ScannerProperties(scannerProps), env, GLOBAL_ANALYSIS_MODE, system2, ANALYSIS_WARNINGS);
+
+    sonarqubeMock.stubFor(get("/api/plugins/installed")
+      .willReturn(aResponse().withStatus(200)
+        .withFixedDelay(2000)
+        .withBody("Success")));
+
+    HttpConnector httpConnector = (HttpConnector) client.wsConnector();
+
+    var getRequest = new GetRequest("api/plugins/installed");
+    var thrown = assertThrows(IllegalStateException.class, () -> httpConnector.call(getRequest));
+
+    assertThat(thrown).hasStackTraceContaining("timeout");
+  }
+
+  @Test
+  void it_should_timeout_on_slow_response() {
+    scannerProps.put("sonar.host.url", sonarqubeMock.baseUrl());
+    scannerProps.put("sonar.scanner.socketTimeout", "PT0.2S");
+
+    DefaultScannerWsClient client = underTest.provide(new ScannerProperties(scannerProps), env, GLOBAL_ANALYSIS_MODE, system2, ANALYSIS_WARNINGS);
+
+    sonarqubeMock.stubFor(get("/api/plugins/installed")
+      .willReturn(aResponse().withStatus(200)
+        .withChunkedDribbleDelay(2, 2000)
+        .withBody("Success")));
+
+    HttpConnector httpConnector = (HttpConnector) client.wsConnector();
+
+    var getRequest = new GetRequest("api/plugins/installed");
+    var thrown = assertThrows(IllegalStateException.class, () -> httpConnector.call(getRequest));
+
+    assertThat(thrown).hasStackTraceContaining("timeout");
+  }
+
+  @Test
   void it_should_honor_scanner_proxy_settings() {
     scannerProps.put("sonar.host.url", sonarqubeMock.baseUrl());
     scannerProps.put("sonar.scanner.proxyHost", "localhost");