chore: generated code for commit e974ffc. [skip ci]

Co-authored-by: Pierre Millot <[email protected]>
Co-authored-by: Thomas Raffray <[email protected]>

Author: 3 people

clients/algoliasearch-client-swift/Sources/Core/Networking/HTTP/AlgoliaError.swift

@@ -25,7 +25,12 @@ public enum AlgoliaError: Error, LocalizedError {
         case let .httpError(error):
             "HTTP error: \(error)"
         case let .noReachableHosts(errors, exposeIntermediateErrors):
-            "All hosts are unreachable. " + (exposeIntermediateErrors ? "Intermediate errors:\n- \(errors.map(\.localizedDescription).joined(separator: "\n- "))" : "You can use 'exposeIntermediateErrors: true' in the config to investigate.")
+            "All hosts are unreachable. " +
+                (
+                    exposeIntermediateErrors ?
+                        "Intermediate errors:\n- \(errors.map(\.localizedDescription).joined(separator: "\n- "))" :
+                        "You can use 'exposeIntermediateErrors: true' in the config to investigate."
+                )
         case .missingData:
             "Missing response data"
         case .decodingFailure:

clients/algoliasearch-client-swift/Sources/Core/Networking/RetryStrategy/AlgoliaRetryStrategy.swift

@@ -40,7 +40,7 @@ class AlgoliaRetryStrategy: RetryStrategy {
             if !self.hosts.contains(where: { $0.supports(callType) && $0.isUp }) {
                 self.hosts.resetAll(for: callType)
             }
-            
+
             var hostIterator = self.hosts
                 .sorted { $0.lastUpdated.compare($1.lastUpdated) == .orderedAscending }
                 .filter { $0.supports(callType) && $0.isUp }

clients/algoliasearch-client-swift/Sources/Core/Networking/Transporter.swift

@@ -142,6 +142,9 @@ open class Transporter {
             }
         }
 
-        throw AlgoliaError.noReachableHosts(intermediateErrors: intermediateErrors, exposeIntermediateErrors: self.exposeIntermediateErrors)
+        throw AlgoliaError.noReachableHosts(
+            intermediateErrors: intermediateErrors,
+            exposeIntermediateErrors: self.exposeIntermediateErrors
+        )
     }
 }

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

@@ -93,8 +93,38 @@ public async Task ApiTest2()
     );
   }
 
-  [Fact(DisplayName = "test the compression strategy")]
+  [Fact(DisplayName = "tests the retry strategy error")]
   public async Task ApiTest3()
+  {
+    SearchConfig _config = new SearchConfig("test-app-id", "test-api-key")
+    {
+      CustomHosts = new List<StatefulHost>
+      {
+        new()
+        {
+          Scheme = HttpScheme.Http,
+          Url = "localhost",
+          Port = 6676,
+          Up = true,
+          LastUse = DateTime.UtcNow,
+          Accept = CallType.Read | CallType.Write,
+        }
+      }
+    };
+    var client = new SearchClient(_config);
+
+    _ex = await Assert.ThrowsAnyAsync<Exception>(async () =>
+    {
+      var res = await client.CustomGetAsync("1/test/hang/csharp");
+    });
+    Assert.Equal(
+      "RetryStrategy failed to connect to Algolia. Reason: The operation has timed out.".ToLowerInvariant(),
+      _ex.Message.ToLowerInvariant()
+    );
+  }
+
+  [Fact(DisplayName = "test the compression strategy")]
+  public async Task ApiTest4()
   {
     SearchConfig _config = new SearchConfig("test-app-id", "test-api-key")
     {

tests/output/dart/test/client/insights_test.dart

@@ -124,7 +124,7 @@ void main() {
 
   test('throws when incorrect region is given', () async {
     final requester = RequestInterceptor();
-    expectError(
+    await expectError(
       '`region` must be one of the following: de, us',
       () async {
         final client = InsightsClient(

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

@@ -62,6 +62,28 @@ void main() {
     }
   });
 
+  test('tests the retry strategy error', () async {
+    final requester = RequestInterceptor();
+    final client = SearchClient(
+        appId: "test-app-id",
+        apiKey: "test-api-key",
+        options: ClientOptions(hosts: [
+          Host.create(url: 'localhost:6676', scheme: 'http'),
+        ]));
+    await expectError(
+      'UnreachableHostsException{errors: [AlgoliaTimeoutException{error: DioException [receive timeout]: The request took longer than 0:00:05.000000 to receive data. It was aborted. To get rid of this exception, try raising the RequestOptions.receiveTimeout above the duration of 0:00:05.000000 or improve the response time of the server.}]}',
+      () async {
+        try {
+          final res = await client.customGet(
+            path: "1/test/hang/dart",
+          );
+        } on InterceptionException catch (_) {
+          // Ignore InterceptionException
+        }
+      },
+    );
+  });
+
   test('calls api with correct user agent', () async {
     final requester = RequestInterceptor();
     final client = SearchClient(
@@ -121,7 +143,7 @@ void main() {
 
   test('client throws with invalid parameters', () async {
     final requester = RequestInterceptor();
-    expectError(
+    await expectError(
       '`appId` is missing.',
       () async {
         final client = SearchClient(
@@ -130,7 +152,7 @@ void main() {
             options: ClientOptions(requester: requester));
       },
     );
-    expectError(
+    await expectError(
       '`appId` is missing.',
       () async {
         final client = SearchClient(
@@ -139,7 +161,7 @@ void main() {
             options: ClientOptions(requester: requester));
       },
     );
-    expectError(
+    await expectError(
       '`apiKey` is missing.',
       () async {
         final client = SearchClient(
@@ -157,7 +179,7 @@ void main() {
       apiKey: 'apiKey',
       options: ClientOptions(requester: requester),
     );
-    expectError(
+    await expectError(
       'Parameter `apiKey` is required when calling `addApiKey`.',
       () async {
         try {
@@ -178,7 +200,7 @@ void main() {
       apiKey: 'apiKey',
       options: ClientOptions(requester: requester),
     );
-    expectError(
+    await expectError(
       'Parameter `indexName` is required when calling `addOrUpdateObject`.',
       () async {
         try {
@@ -192,7 +214,7 @@ void main() {
         }
       },
     );
-    expectError(
+    await expectError(
       'Parameter `objectID` is required when calling `addOrUpdateObject`.',
       () async {
         try {
@@ -206,7 +228,7 @@ void main() {
         }
       },
     );
-    expectError(
+    await expectError(
       'Parameter `body` is required when calling `addOrUpdateObject`.',
       () async {
         try {