[Scala] Properly handle csv collectionFormat

modules/swagger-codegen/src/main/resources/scala/apiInvoker.mustache

@@ -52,6 +52,9 @@ class ApiInvoker(val mapper: ObjectMapper = ScalaJsonUtil.getJsonMapper,
   def escape(value: String): String = {
     URLEncoder.encode(value, "utf-8").replaceAll("\\+", "%20")
   }
+  def escape(values: List[String]): String = {
+     values.map(escape).mkString(",")
+  }
 
   def escape(value: Long): String = value.toString
   def escape(value: Double): String = value.toString

samples/client/petstore-security-test/scala/.swagger-codegen/VERSION

@@ -0,0 +1 @@
+2.3.0-SNAPSHOT

samples/client/petstore-security-test/scala/build.gradle

@@ -104,6 +104,12 @@ ext {
     jackson_version = "2.4.2"
     junit_version = "4.8.1"
     scala_test_version = "2.2.4"
+    swagger_async_httpclient_version = "0.3.5"
+}
+
+repositories {
+    mavenLocal()
+    mavenCentral()
 }
 
 dependencies {
@@ -117,4 +123,5 @@ dependencies {
     testCompile "junit:junit:$junit_version"
     compile "joda-time:joda-time:$jodatime_version"
     compile "org.joda:joda-convert:$joda_version"
+    compile "com.wordnik.swagger:swagger-async-httpclient_2.10:$swagger_async_httpclient_version"
 }

samples/client/petstore-security-test/scala/build.sbt

@@ -1,33 +1,34 @@
-lazy val root = (project in file(".")).
-    settings(
-        version       := "1.0.0",
-        name          := "swagger-scala-client",
-        organization  := "io.swagger",
-        scalaVersion  := "2.11.8",
-
-        libraryDependencies ++= Seq(
-            "com.fasterxml.jackson.module" %% "jackson-module-scala" % "2.4.2",
-            "com.sun.jersey" % "jersey-core" % "1.19",
-            "com.sun.jersey" % "jersey-client" % "1.19",
-            "com.sun.jersey.contribs" % "jersey-multipart" % "1.19",
-            "org.jfarcand" % "jersey-ahc-client" % "1.0.5",
-            "io.swagger" % "swagger-core" % "1.5.8",
-            "joda-time" % "joda-time" % "2.2",
-            "org.joda" % "joda-convert" % "1.2",
-            "org.scalatest" %% "scalatest" % "2.2.4" % "test",
-            "junit" % "junit" % "4.8.1" % "test"
-        ),
-
-        resolvers ++= Seq(
-            Resolver.jcenterRepo,
-            Resolver.mavenLocal
-        ),
-
-        scalacOptions := Seq(
-          "-unchecked",
-          "-deprecation",
-          "-feature"
-        ),
-
-        publishArtifact in (Compile, packageDoc) := false
-    )
+version       := "1.0.0"
+
+name          := "swagger-scala-client"
+
+organization  := "io.swagger"
+
+scalaVersion  := "2.11.8"
+
+libraryDependencies ++= Seq(
+  "com.fasterxml.jackson.module" %% "jackson-module-scala" % "2.4.2",
+  "com.sun.jersey" % "jersey-core" % "1.19",
+  "com.sun.jersey" % "jersey-client" % "1.19",
+  "com.sun.jersey.contribs" % "jersey-multipart" % "1.19",
+  "org.jfarcand" % "jersey-ahc-client" % "1.0.5",
+  "io.swagger" % "swagger-core" % "1.5.8",
+  "joda-time" % "joda-time" % "2.2",
+  "org.joda" % "joda-convert" % "1.2",
+  "org.scalatest" %% "scalatest" % "2.2.4" % "test",
+  "junit" % "junit" % "4.8.1" % "test",
+  "com.wordnik.swagger" %% "swagger-async-httpclient" % "0.3.5"
+)
+
+resolvers ++= Seq(
+  Resolver.mavenLocal
+)
+
+scalacOptions := Seq(
+  "-unchecked",
+  "-deprecation",
+  "-feature"
+)
+
+publishArtifact in (Compile, packageDoc) := false
+

samples/client/petstore-security-test/scala/pom.xml

@@ -209,6 +209,11 @@
       <artifactId>joda-convert</artifactId>
       <version>${joda-version}</version>
     </dependency>
+    <dependency>
+      <groupId>com.wordnik.swagger</groupId>
+      <artifactId>swagger-async-httpclient_2.10</artifactId>
+      <version>${swagger-async-httpclient-version}</version>
+    </dependency>
   </dependencies>
   <properties>
     <scala-version>2.10.4</scala-version>
@@ -223,6 +228,7 @@
     <junit-version>4.8.1</junit-version>
     <scala-maven-plugin-version>3.1.5</scala-maven-plugin-version>
     <scala-test-version>2.2.4</scala-test-version>
+    <swagger-async-httpclient-version>0.3.5</swagger-async-httpclient-version>
 
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
   </properties>

samples/client/petstore-security-test/scala/src/main/scala/io/swagger/client/ApiInvoker.scala

@@ -63,6 +63,9 @@ class ApiInvoker(val mapper: ObjectMapper = ScalaJsonUtil.getJsonMapper,
   def escape(value: String): String = {
     URLEncoder.encode(value, "utf-8").replaceAll("\\+", "%20")
   }
+  def escape(values: List[String]): String = {
+     values.map(escape).mkString(",")
+  }
 
   def escape(value: Long): String = value.toString
   def escape(value: Double): String = value.toString

samples/client/petstore-security-test/scala/src/main/scala/io/swagger/client/AsyncClient.scala

@@ -0,0 +1,20 @@
+package io.swagger.client
+
+import io.swagger.client.api._
+
+import com.wordnik.swagger.client._
+
+import java.io.Closeable
+
+class AsyncClient(config: SwaggerConfig) extends Closeable {
+  val locator = config.locator
+  val name = config.name
+
+  private[this] val client = transportClient
+
+  protected def transportClient: TransportClient = new RestClient(config)
+
+  def close() {
+    client.close()
+  }
+}

samples/client/petstore-security-test/scala/src/main/scala/io/swagger/client/api/FakeApi.scala

@@ -12,8 +12,9 @@
 
 package io.swagger.client.api
 
-import io.swagger.client.ApiInvoker
-import io.swagger.client.ApiException
+import java.text.SimpleDateFormat
+
+import io.swagger.client.{ApiInvoker, ApiException}
 
 import com.sun.jersey.multipart.FormDataMultiPart
 import com.sun.jersey.multipart.file.FileDataBodyPart
@@ -25,12 +26,41 @@ import java.util.Date
 
 import scala.collection.mutable.HashMap
 
+import com.wordnik.swagger.client._
+import scala.concurrent.Future
+import collection.mutable
+
+import java.net.URI
+
+import com.wordnik.swagger.client.ClientResponseReaders.Json4sFormatsReader._
+import com.wordnik.swagger.client.RequestWriters.Json4sFormatsWriter._
+
+import scala.concurrent.ExecutionContext.Implicits.global
+import scala.concurrent._
+import scala.concurrent.duration._
+import scala.util.{Failure, Success, Try}
+
 class FakeApi(val defBasePath: String = "https://petstore.swagger.io *_/ ' \" =end -- \\r\\n \\n \\r/v2 *_/ ' \" =end -- \\r\\n \\n \\r",
                         defApiInvoker: ApiInvoker = ApiInvoker) {
+
+  implicit val formats = new org.json4s.DefaultFormats {
+    override def dateFormatter = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS+0000")
+  }
+  implicit val stringReader = ClientResponseReaders.StringReader
+  implicit val unitReader = ClientResponseReaders.UnitReader
+  implicit val jvalueReader = ClientResponseReaders.JValueReader
+  implicit val jsonReader = JsonFormatsReader
+  implicit val stringWriter = RequestWriters.StringWriter
+  implicit val jsonWriter = JsonFormatsWriter
+
   var basePath = defBasePath
   var apiInvoker = defApiInvoker
 
-  def addHeader(key: String, value: String) = apiInvoker.defaultHeaders += key -> value 
+  def addHeader(key: String, value: String) = apiInvoker.defaultHeaders += key -> value
+
+  val config = SwaggerConfig.forUrl(new URI(defBasePath))
+  val client = new RestClient(config)
+  val helper = new FakeApiAsyncHelper(client, config)
 
   /**
    * To test code injection *_/ ' \" =end -- \\r\\n \\n \\r
@@ -39,37 +69,43 @@ class FakeApi(val defBasePath: String = "https://petstore.swagger.io *_/ ' \" =e
    * @return void
    */
   def testCodeInject * ' " =end  rn n r(testCodeInjectEndRnNR: Option[String] = None) = {
-    // create path and map variables
-    val path = "/fake".replaceAll("\\{format\\}", "json")
+    val await = Try(Await.result(testCodeInject * ' " =end  rn n rAsync(testCodeInjectEndRnNR), Duration.Inf))
+    await match {
+      case Success(i) => Some(await.get)
+      case Failure(t) => None
+    }
+  }
 
-    val contentTypes = List("application/json", "*_/ '  =end --       ")
-    val contentType = contentTypes(0)
+  /**
+   * To test code injection *_/ ' \" =end -- \\r\\n \\n \\r asynchronously
+   * 
+   * @param testCodeInjectEndRnNR To test code injection *_/ ' \" =end -- \\r\\n \\n \\r (optional)
+   * @return Future(void)
+  */
+  def testCodeInject * ' " =end  rn n rAsync(testCodeInjectEndRnNR: Option[String] = None) = {
+      helper.testCodeInject * ' " =end  rn n r(testCodeInjectEndRnNR)
+  }
 
-    val queryParams = new HashMap[String, String]
-    val headerParams = new HashMap[String, String]
-    val formParams = new HashMap[String, String]
 
-    
+}
 
-    var postBody: AnyRef = null
+class FakeApiAsyncHelper(client: TransportClient, config: SwaggerConfig) extends ApiClient(client, config) {
 
-    if (contentType.startsWith("multipart/form-data")) {
-      val mp = new FormDataMultiPart
-      testCodeInjectEndRnNR.map(paramVal => mp.field("test code inject */ ' " =end -- \r\n \n \r", paramVal.toString, MediaType.MULTIPART_FORM_DATA_TYPE))
-      postBody = mp
-    } else {
-      testCodeInjectEndRnNR.map(paramVal => formParams += "test code inject */ ' " =end -- \r\n \n \r" -> paramVal.toString)
-    }
+  def testCodeInject * ' " =end  rn n r(testCodeInjectEndRnNR: Option[String] = None
+    )(implicit reader: ClientResponseReader[Unit]): Future[Unit] = {
+    // create path and map variables
+    val path = (addFmt("/fake"))
+
+    // query params
+    val queryParams = new mutable.HashMap[String, String]
+    val headerParams = new mutable.HashMap[String, String]
 
-    try {
-      apiInvoker.invokeApi(basePath, path, "PUT", queryParams.toMap, formParams.toMap, postBody, headerParams.toMap, contentType) match {
-        case s: String =>
-                  case _ => None
-      }
-    } catch {
-      case ex: ApiException if ex.code == 404 => None
-      case ex: ApiException => throw ex
+
+    val resFuture = client.submit("PUT", path, queryParams.toMap, headerParams.toMap, "")
+    resFuture flatMap { resp =>
+      process(reader.read(resp))
     }
   }
 
+
 }

samples/client/petstore/scala/src/main/scala/io/swagger/client/ApiInvoker.scala

@@ -63,6 +63,9 @@ class ApiInvoker(val mapper: ObjectMapper = ScalaJsonUtil.getJsonMapper,
   def escape(value: String): String = {
     URLEncoder.encode(value, "utf-8").replaceAll("\\+", "%20")
   }
+  def escape(values: List[String]): String = {
+     values.map(escape).mkString(",")
+  }
 
   def escape(value: Long): String = value.toString
   def escape(value: Double): String = value.toString