fix(go): retry strategy (#5159) (generated) [skip ci]

Co-authored-by: Clément Vannicatte <[email protected]>
Co-authored-by: Antoine GILLES <[email protected]>

Author: 3 people

tests/output/csharp/src/generated/client/Search.test.cs

@@ -115,7 +115,7 @@ public async Task ApiTest3()
     );
   }
 
-  [Fact(DisplayName = "tests the retry strategy error")]
+  [Fact(DisplayName = "tests the retry strategy on timeout")]
   public async Task ApiTest4()
   {
     SearchConfig _config = new SearchConfig("test-app-id", "test-api-key")
@@ -148,8 +148,64 @@ public async Task ApiTest4()
     );
   }
 
-  [Fact(DisplayName = "test the compression strategy")]
+  [Fact(DisplayName = "tests the retry strategy on 5xx")]
   public async Task ApiTest5()
+  {
+    SearchConfig _config = new SearchConfig("test-app-id", "test-api-key")
+    {
+      CustomHosts = new List<StatefulHost>
+      {
+        new()
+        {
+          Scheme = HttpScheme.Http,
+          Url =
+            Environment.GetEnvironmentVariable("CI") == "true"
+              ? "localhost"
+              : "host.docker.internal",
+          Port = 6671,
+          Up = true,
+          LastUse = DateTime.UtcNow,
+          Accept = CallType.Read | CallType.Write,
+        },
+        new()
+        {
+          Scheme = HttpScheme.Http,
+          Url =
+            Environment.GetEnvironmentVariable("CI") == "true"
+              ? "localhost"
+              : "host.docker.internal",
+          Port = 6672,
+          Up = true,
+          LastUse = DateTime.UtcNow,
+          Accept = CallType.Read | CallType.Write,
+        },
+        new()
+        {
+          Scheme = HttpScheme.Http,
+          Url =
+            Environment.GetEnvironmentVariable("CI") == "true"
+              ? "localhost"
+              : "host.docker.internal",
+          Port = 6673,
+          Up = true,
+          LastUse = DateTime.UtcNow,
+          Accept = CallType.Read | CallType.Write,
+        },
+      },
+    };
+    var client = new SearchClient(_config);
+
+    var res = await client.CustomPostAsync("1/test/error/csharp");
+
+    JsonAssert.EqualOverrideDefault(
+      "{\"status\":\"ok\"}",
+      JsonSerializer.Serialize(res, JsonConfig.Options),
+      new JsonDiffConfig(false)
+    );
+  }
+
+  [Fact(DisplayName = "test the compression strategy")]
+  public async Task ApiTest6()
   {
     SearchConfig _config = new SearchConfig("test-app-id", "test-api-key")
     {
@@ -186,7 +242,7 @@ public async Task ApiTest5()
   }
 
   [Fact(DisplayName = "calls api with default read timeouts")]
-  public async Task ApiTest6()
+  public async Task ApiTest7()
   {
     var client = new SearchClient(new SearchConfig("appId", "apiKey"), _echo);
     await client.CustomGetAsync("1/test");
@@ -197,7 +253,7 @@ public async Task ApiTest6()
   }
 
   [Fact(DisplayName = "calls api with default write timeouts")]
-  public async Task ApiTest7()
+  public async Task ApiTest8()
   {
     var client = new SearchClient(new SearchConfig("appId", "apiKey"), _echo);
     await client.CustomPostAsync("1/test");
@@ -208,7 +264,7 @@ public async Task ApiTest7()
   }
 
   [Fact(DisplayName = "can handle unknown response fields")]
-  public async Task ApiTest8()
+  public async Task ApiTest9()
   {
     SearchConfig _config = new SearchConfig("test-app-id", "test-api-key")
     {
@@ -240,7 +296,7 @@ public async Task ApiTest8()
   }
 
   [Fact(DisplayName = "can handle unknown response fields inside a nested oneOf")]
-  public async Task ApiTest9()
+  public async Task ApiTest10()
   {
     SearchConfig _config = new SearchConfig("test-app-id", "test-api-key")
     {

tests/output/dart/test/client/search_test.dart

@@ -90,7 +90,7 @@ void main() {
     }
   });
 
-  test('tests the retry strategy error', () async {
+  test('tests the retry strategy on timeout', () async {
     final requester = RequestInterceptor();
     final client = SearchClient(
         appId: "test-app-id",
@@ -115,6 +115,36 @@ void main() {
     );
   });
 
+  test('tests the retry strategy on 5xx', () async {
+    final requester = RequestInterceptor();
+    final client = SearchClient(
+        appId: "test-app-id",
+        apiKey: "test-api-key",
+        options: ClientOptions(hosts: [
+          Host.create(
+              url:
+                  '${Platform.environment['CI'] == 'true' ? 'localhost' : 'host.docker.internal'}:6671',
+              scheme: 'http'),
+          Host.create(
+              url:
+                  '${Platform.environment['CI'] == 'true' ? 'localhost' : 'host.docker.internal'}:6672',
+              scheme: 'http'),
+          Host.create(
+              url:
+                  '${Platform.environment['CI'] == 'true' ? 'localhost' : 'host.docker.internal'}:6673',
+              scheme: 'http'),
+        ]));
+    requester.setOnRequest((request) {});
+    try {
+      final res = await client.customPost(
+        path: "1/test/error/dart",
+      );
+      expectBody(res, """{"status":"ok"}""");
+    } on InterceptionException catch (_) {
+      // Ignore InterceptionException
+    }
+  });
+
   test('calls api with default read timeouts', () async {
     final requester = RequestInterceptor();
     final client = SearchClient(

tests/output/go/tests/client/search_test.go

@@ -119,7 +119,7 @@ void apiTest3() {
   }
 
   @Test
-  @DisplayName("tests the retry strategy error")
+  @DisplayName("tests the retry strategy on timeout")
   void apiTest4() {
     SearchClient client = new SearchClient(
       "test-app-id",
@@ -149,8 +149,44 @@ void apiTest4() {
   }
 
   @Test
-  @DisplayName("test the compression strategy")
+  @DisplayName("tests the retry strategy on 5xx")
   void apiTest5() {
+    SearchClient client = new SearchClient(
+      "test-app-id",
+      "test-api-key",
+      withCustomHosts(
+        Arrays.asList(
+          new Host(
+            "true".equals(System.getenv("CI")) ? "localhost" : "host.docker.internal",
+            EnumSet.of(CallType.READ, CallType.WRITE),
+            "http",
+            6671
+          ),
+          new Host(
+            "true".equals(System.getenv("CI")) ? "localhost" : "host.docker.internal",
+            EnumSet.of(CallType.READ, CallType.WRITE),
+            "http",
+            6672
+          ),
+          new Host(
+            "true".equals(System.getenv("CI")) ? "localhost" : "host.docker.internal",
+            EnumSet.of(CallType.READ, CallType.WRITE),
+            "http",
+            6673
+          )
+        ),
+        false
+      )
+    );
+
+    Object res = client.customPost("1/test/error/java");
+
+    assertDoesNotThrow(() -> JSONAssert.assertEquals("{\"status\":\"ok\"}", json.writeValueAsString(res), JSONCompareMode.STRICT));
+  }
+
+  @Test
+  @DisplayName("test the compression strategy")
+  void apiTest6() {
     SearchClient client = new SearchClient(
       "test-app-id",
       "test-api-key",
@@ -190,7 +226,7 @@ void apiTest5() {
 
   @Test
   @DisplayName("calls api with default read timeouts")
-  void apiTest6() {
+  void apiTest7() {
     SearchClient client = createClient();
 
     client.customGet("1/test");
@@ -201,7 +237,7 @@ void apiTest6() {
 
   @Test
   @DisplayName("calls api with default write timeouts")
-  void apiTest7() {
+  void apiTest8() {
     SearchClient client = createClient();
 
     client.customPost("1/test");
@@ -212,7 +248,7 @@ void apiTest7() {
 
   @Test
   @DisplayName("can handle unknown response fields")
-  void apiTest8() {
+  void apiTest9() {
     SearchClient client = new SearchClient(
       "test-app-id",
       "test-api-key",
@@ -242,7 +278,7 @@ void apiTest8() {
 
   @Test
   @DisplayName("can handle unknown response fields inside a nested oneOf")
-  void apiTest9() {
+  void apiTest10() {
     SearchClient client = new SearchClient(
       "test-app-id",
       "test-api-key",

tests/output/java/src/test/java/com/algolia/client/Search.test.java

@@ -97,7 +97,7 @@ describe('api', () => {
     expect(result).toEqual({ message: 'ok test server response' });
   }, 25000);
 
-  test('tests the retry strategy error', async () => {
+  test('tests the retry strategy on timeout', async () => {
     const client = algoliasearch('test-app-id', 'test-api-key', {
       hosts: [
         {
@@ -120,6 +120,35 @@ describe('api', () => {
     }
   }, 25000);
 
+  test('tests the retry strategy on 5xx', async () => {
+    const client = algoliasearch('test-app-id', 'test-api-key', {
+      hosts: [
+        {
+          url: 'localhost',
+          port: 6671,
+          accept: 'readWrite',
+          protocol: 'http',
+        },
+        {
+          url: 'localhost',
+          port: 6672,
+          accept: 'readWrite',
+          protocol: 'http',
+        },
+        {
+          url: 'localhost',
+          port: 6673,
+          accept: 'readWrite',
+          protocol: 'http',
+        },
+      ],
+    });
+
+    const result = await client.customPost({ path: '1/test/error/javascript' });
+
+    expect(result).toEqual({ status: 'ok' });
+  }, 25000);
+
   test('calls api with default read timeouts', async () => {
     const client = createClient();