feat: la scala

Author: shortcuts

clients/algoliasearch-client-scala/src/main/scala/algoliasearch/ApiClient.scala

@@ -19,6 +19,12 @@ import scala.util.Try
   *   the name of the client
   * @param defaultHosts
   *   the default hosts
+  * @param defaultReadTimeout
+  *   the default read timeout
+  * @param defaultConnectTimeout
+  *   the default connect timeout
+  * @param defaultWriteTimeout
+  *   the default write timeout
   * @param formats
   *   the JSON formats
   * @param options
@@ -53,13 +59,21 @@ abstract class ApiClient(
       apiKey: String,
       clientName: String,
       options: ClientOptions,
-      defaultHosts: Seq[Host]
+      defaultHosts: Seq[Host],
+      defaultReadTimeout: Duration,
+      defaultConnectTimeout: Duration,
+      defaultWriteTimeout: Duration
   ): Requester = {
     val algoliaAgent = AlgoliaAgent(BuildInfo.version)
       .addSegment(AgentSegment(clientName, Some(BuildInfo.version)))
       .addSegments(options.agentSegments)
 
     val hosts = if (options.hosts.isEmpty) defaultHosts else options.hosts
+
+    option.readTimeout = Option(options.readTimeout).getOrElse(defaultReadTimeout)
+    option.writeTimeout = Option(options.writeTimeout).getOrElse(defaultWriteTimeout)
+    option.connectTimeout = Option(options.connectTimeout).getOrElse(defaultConnectTimeout)
+
     val statefulHosts = hosts.map(host => StatefulHost(host)).toList
 
     val builder = HttpRequester

clients/algoliasearch-client-scala/src/main/scala/algoliasearch/config/ClientOptions.scala

@@ -34,9 +34,9 @@ import scala.concurrent.duration.Duration
 case class ClientOptions(
     agentSegments: Seq[AgentSegment] = Seq.empty,
     hosts: Seq[Host] = Seq.empty,
-    connectTimeout: Duration = Duration(2, TimeUnit.SECONDS),
-    writeTimeout: Duration = Duration(30, TimeUnit.SECONDS),
-    readTimeout: Duration = Duration(5, TimeUnit.SECONDS),
+    connectTimeout: Option[Duration] = Duration(2, TimeUnit.SECONDS),
+    writeTimeout: Option[Duration] = Duration(30, TimeUnit.SECONDS),
+    readTimeout: Option[Duration] = Duration(5, TimeUnit.SECONDS),
     defaultHeaders: Map[String, String] = Map.empty,
     compressionType: CompressionType = CompressionType.None,
     logging: Option[Logging] = None,

generators/src/main/java/com/algolia/codegen/AlgoliaScalaGenerator.java

@@ -7,6 +7,7 @@
 import io.swagger.v3.oas.models.Operation;
 import io.swagger.v3.oas.models.servers.Server;
 import java.io.File;
+import java.time.temporal.ChronoUnit;
 import java.util.List;
 import java.util.Map;
 import java.util.logging.Logger;
@@ -99,6 +100,7 @@ private String typeToName(String content) {
   public void processOpenAPI(OpenAPI openAPI) {
     super.processOpenAPI(openAPI);
     Helpers.generateServers(super.fromServers(openAPI.getServers()), additionalProperties);
+    Timeouts.enrichBundle(openAPI, additionalProperties, ChronoUnit.SECONDS);
   }
 
   @Override

templates/scala/api.mustache

@@ -43,6 +43,18 @@ object {{classname}} {
     clientOptions = clientOptions
   )
 
+  private def readTimeout(): Duration = {
+    Duration({{#x-timeouts.server.read}}{{{.}}}{{/x-timeouts.server.read}}, TimeUnit.SECONDS)
+  }
+
+  private def connectTimeout(): Duration = {
+    Duration({{#x-timeouts.server.connect}}{{{.}}}{{/x-timeouts.server.connect}}, TimeUnit.SECONDS)
+  }
+
+  private def writeTimeout(): Duration = {
+    Duration({{#x-timeouts.server.write}}{{{.}}}{{/x-timeouts.server.write}}, TimeUnit.SECONDS)
+  }
+
   {{#hasRegionalHost}}
   private def hosts(region: {{#fallbackToAliasHost}}Option[String] = None{{/fallbackToAliasHost}}{{^fallbackToAliasHost}}String{{/fallbackToAliasHost}}): Seq[Host] = {
     val allowedRegions = Seq({{#allowedRegions}}"{{.}}"{{^-last}},{{/-last}}{{/allowedRegions}})
@@ -96,6 +108,9 @@ class {{classname}}(
       apiKey = apiKey,
       clientName = "{{{baseName}}}",
       defaultHosts = hosts({{#hostWithAppID}}appId{{/hostWithAppID}}{{#hasRegionalHost}}region{{/hasRegionalHost}}),
+      defaultReadTimeout = readTimeout(),
+      defaultWriteTimeout = writeTimeout(),
+      defaultConnectTimeout = connectTimeout(),
       formats = JsonSupport.format,
       options = clientOptions
     ) {