Set version to 4.4.9-SNAPSHOT

pom.xml

@@ -10,7 +10,7 @@
 
   <artifactId>vertx-lang-kotlin-parent</artifactId>
 
-  <version>4.4.9</version>
+  <version>4.4.10-SNAPSHOT</version>
   <packaging>pom</packaging>
 
   <modules>
@@ -24,7 +24,7 @@
     <kotlin.coroutines.version>1.6.4</kotlin.coroutines.version>
     <kotlin.version>1.7.21</kotlin.version>
     <junit.version>4.13.2</junit.version>
-    <stack.version>4.4.9</stack.version>
+    <stack.version>4.4.10-SNAPSHOT</stack.version>
   </properties>
 
   <dependencyManagement>

vertx-lang-kotlin-coroutines/pom.xml

@@ -7,7 +7,7 @@
   <parent>
     <artifactId>vertx-lang-kotlin-parent</artifactId>
     <groupId>io.vertx</groupId>
-    <version>4.4.9</version>
+    <version>4.4.10-SNAPSHOT</version>
   </parent>
 
   <properties>

vertx-lang-kotlin-gen/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <artifactId>vertx-lang-kotlin-parent</artifactId>
     <groupId>io.vertx</groupId>
-    <version>4.4.9</version>
+    <version>4.4.10-SNAPSHOT</version>
   </parent>
 
   <artifactId>vertx-lang-kotlin-gen</artifactId>

vertx-lang-kotlin/pom.xml

@@ -8,7 +8,7 @@
   <parent>
     <artifactId>vertx-lang-kotlin-parent</artifactId>
     <groupId>io.vertx</groupId>
-    <version>4.4.9</version>
+    <version>4.4.10-SNAPSHOT</version>
   </parent>
 
   <artifactId>vertx-lang-kotlin</artifactId>

vertx-lang-kotlin/src/main/kotlin/io/vertx/kotlin/core/file/AsyncFile.kt

@@ -21,6 +21,20 @@ import io.vertx.core.file.AsyncFileLock
 import io.vertx.core.streams.WriteStream
 import io.vertx.kotlin.coroutines.awaitResult
 
+/**
+ * Suspending version of method [io.vertx.core.file.AsyncFile.pipeTo]
+ *
+ * @param dst the destination write stream
+ *
+ * NOTE: This function has been automatically generated from [io.vertx.core.file.AsyncFile] using Vert.x codegen.
+ */
+@Deprecated(message = "Instead use pipeTo returning a future and chain with await()", replaceWith = ReplaceWith("pipeTo(dst).await()"))
+suspend fun AsyncFile.pipeToAwait(dst: WriteStream<Buffer>): Unit {
+  return awaitResult {
+    this.pipeTo(dst, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
+  }
+}
+
 /**
  * Suspending version of method [io.vertx.core.file.AsyncFile.write]
  *
@@ -62,20 +76,6 @@ suspend fun AsyncFile.endAwait(data: Buffer): Unit {
   }
 }
 
-/**
- * Suspending version of method [io.vertx.core.file.AsyncFile.pipeTo]
- *
- * @param dst the destination write stream
- *
- * NOTE: This function has been automatically generated from [io.vertx.core.file.AsyncFile] using Vert.x codegen.
- */
-@Deprecated(message = "Instead use pipeTo returning a future and chain with await()", replaceWith = ReplaceWith("pipeTo(dst).await()"))
-suspend fun AsyncFile.pipeToAwait(dst: WriteStream<Buffer>): Unit {
-  return awaitResult {
-    this.pipeTo(dst, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
-  }
-}
-
 /**
  * Suspending version of method [io.vertx.core.file.AsyncFile.close]
  *

vertx-lang-kotlin/src/main/kotlin/io/vertx/kotlin/core/http/HttpServerOptions.kt

@@ -64,6 +64,8 @@ import java.util.concurrent.TimeUnit
  * @param logActivity  Set to true to enabled network activity logging: Netty's pipeline is configured for logging on Netty's logger.
  * @param maxChunkSize  Set the maximum HTTP chunk size that [io.vertx.core.http.HttpServerRequest] will receive
  * @param maxFormAttributeSize  Set the maximum size of a form attribute. Set to <code>-1</code> to allow unlimited length
+ * @param maxFormBufferedBytes  Set the maximum number of bytes a server can buffer when decoding a form. Set to <code>-1</code> to allow unlimited length
+ * @param maxFormFields  Set the maximum number of fields of a form. Set to <code>-1</code> to allow unlimited number of attributes
  * @param maxHeaderSize  Set the maximum length of all headers for HTTP/1.x .
  * @param maxInitialLineLength  Set the maximum length of the initial line for HTTP/1.x (e.g. <code>"GET / HTTP/1.0"</code>)
  * @param maxWebSocketFrameSize  Set the maximum WebSocket frames size
@@ -144,6 +146,8 @@ fun httpServerOptionsOf(
   logActivity: Boolean? = null,
   maxChunkSize: Int? = null,
   maxFormAttributeSize: Int? = null,
+  maxFormBufferedBytes: Int? = null,
+  maxFormFields: Int? = null,
   maxHeaderSize: Int? = null,
   maxInitialLineLength: Int? = null,
   maxWebSocketFrameSize: Int? = null,
@@ -284,6 +288,12 @@ fun httpServerOptionsOf(
   if (maxFormAttributeSize != null) {
     this.setMaxFormAttributeSize(maxFormAttributeSize)
   }
+  if (maxFormBufferedBytes != null) {
+    this.setMaxFormBufferedBytes(maxFormBufferedBytes)
+  }
+  if (maxFormFields != null) {
+    this.setMaxFormFields(maxFormFields)
+  }
   if (maxHeaderSize != null) {
     this.setMaxHeaderSize(maxHeaderSize)
   }

vertx-lang-kotlin/src/main/kotlin/io/vertx/kotlin/core/http/ServerWebSocket.kt

@@ -23,44 +23,44 @@ import io.vertx.core.streams.WriteStream
 import io.vertx.kotlin.coroutines.awaitResult
 
 /**
- * Suspending version of method [io.vertx.core.http.ServerWebSocket.write]
+ * Suspending version of method [io.vertx.core.http.ServerWebSocket.pipeTo]
  *
- * @param data 
+ * @param dst the destination write stream
  *
  * NOTE: This function has been automatically generated from [io.vertx.core.http.ServerWebSocket] using Vert.x codegen.
  */
-@Deprecated(message = "Instead use write returning a future and chain with await()", replaceWith = ReplaceWith("write(data).await()"))
-suspend fun ServerWebSocket.writeAwait(data: Buffer): Unit {
+@Deprecated(message = "Instead use pipeTo returning a future and chain with await()", replaceWith = ReplaceWith("pipeTo(dst).await()"))
+suspend fun ServerWebSocket.pipeToAwait(dst: WriteStream<Buffer>): Unit {
   return awaitResult {
-    this.write(data, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
+    this.pipeTo(dst, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
   }
 }
 
 /**
- * Suspending version of method [io.vertx.core.http.ServerWebSocket.end]
+ * Suspending version of method [io.vertx.core.http.ServerWebSocket.write]
  *
  * @param data 
  *
  * NOTE: This function has been automatically generated from [io.vertx.core.http.ServerWebSocket] using Vert.x codegen.
  */
-@Deprecated(message = "Instead use end returning a future and chain with await()", replaceWith = ReplaceWith("end(data).await()"))
-suspend fun ServerWebSocket.endAwait(data: Buffer): Unit {
+@Deprecated(message = "Instead use write returning a future and chain with await()", replaceWith = ReplaceWith("write(data).await()"))
+suspend fun ServerWebSocket.writeAwait(data: Buffer): Unit {
   return awaitResult {
-    this.end(data, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
+    this.write(data, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
   }
 }
 
 /**
- * Suspending version of method [io.vertx.core.http.ServerWebSocket.pipeTo]
+ * Suspending version of method [io.vertx.core.http.ServerWebSocket.end]
  *
- * @param dst the destination write stream
+ * @param data 
  *
  * NOTE: This function has been automatically generated from [io.vertx.core.http.ServerWebSocket] using Vert.x codegen.
  */
-@Deprecated(message = "Instead use pipeTo returning a future and chain with await()", replaceWith = ReplaceWith("pipeTo(dst).await()"))
-suspend fun ServerWebSocket.pipeToAwait(dst: WriteStream<Buffer>): Unit {
+@Deprecated(message = "Instead use end returning a future and chain with await()", replaceWith = ReplaceWith("end(data).await()"))
+suspend fun ServerWebSocket.endAwait(data: Buffer): Unit {
   return awaitResult {
-    this.pipeTo(dst, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
+    this.end(data, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
   }
 }
 

vertx-lang-kotlin/src/main/kotlin/io/vertx/kotlin/core/http/WebSocket.kt

@@ -22,44 +22,44 @@ import io.vertx.core.streams.WriteStream
 import io.vertx.kotlin.coroutines.awaitResult
 
 /**
- * Suspending version of method [io.vertx.core.http.WebSocket.write]
+ * Suspending version of method [io.vertx.core.http.WebSocket.pipeTo]
  *
- * @param data 
+ * @param dst the destination write stream
  *
  * NOTE: This function has been automatically generated from [io.vertx.core.http.WebSocket] using Vert.x codegen.
  */
-@Deprecated(message = "Instead use write returning a future and chain with await()", replaceWith = ReplaceWith("write(data).await()"))
-suspend fun WebSocket.writeAwait(data: Buffer): Unit {
+@Deprecated(message = "Instead use pipeTo returning a future and chain with await()", replaceWith = ReplaceWith("pipeTo(dst).await()"))
+suspend fun WebSocket.pipeToAwait(dst: WriteStream<Buffer>): Unit {
   return awaitResult {
-    this.write(data, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
+    this.pipeTo(dst, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
   }
 }
 
 /**
- * Suspending version of method [io.vertx.core.http.WebSocket.end]
+ * Suspending version of method [io.vertx.core.http.WebSocket.write]
  *
  * @param data 
  *
  * NOTE: This function has been automatically generated from [io.vertx.core.http.WebSocket] using Vert.x codegen.
  */
-@Deprecated(message = "Instead use end returning a future and chain with await()", replaceWith = ReplaceWith("end(data).await()"))
-suspend fun WebSocket.endAwait(data: Buffer): Unit {
+@Deprecated(message = "Instead use write returning a future and chain with await()", replaceWith = ReplaceWith("write(data).await()"))
+suspend fun WebSocket.writeAwait(data: Buffer): Unit {
   return awaitResult {
-    this.end(data, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
+    this.write(data, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
   }
 }
 
 /**
- * Suspending version of method [io.vertx.core.http.WebSocket.pipeTo]
+ * Suspending version of method [io.vertx.core.http.WebSocket.end]
  *
- * @param dst the destination write stream
+ * @param data 
  *
  * NOTE: This function has been automatically generated from [io.vertx.core.http.WebSocket] using Vert.x codegen.
  */
-@Deprecated(message = "Instead use pipeTo returning a future and chain with await()", replaceWith = ReplaceWith("pipeTo(dst).await()"))
-suspend fun WebSocket.pipeToAwait(dst: WriteStream<Buffer>): Unit {
+@Deprecated(message = "Instead use end returning a future and chain with await()", replaceWith = ReplaceWith("end(data).await()"))
+suspend fun WebSocket.endAwait(data: Buffer): Unit {
   return awaitResult {
-    this.pipeTo(dst, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
+    this.end(data, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
   }
 }
 

vertx-lang-kotlin/src/main/kotlin/io/vertx/kotlin/core/http/WebSocketBase.kt

@@ -22,44 +22,44 @@ import io.vertx.core.streams.WriteStream
 import io.vertx.kotlin.coroutines.awaitResult
 
 /**
- * Suspending version of method [io.vertx.core.http.WebSocketBase.write]
+ * Suspending version of method [io.vertx.core.http.WebSocketBase.pipeTo]
  *
- * @param data 
+ * @param dst the destination write stream
  *
  * NOTE: This function has been automatically generated from [io.vertx.core.http.WebSocketBase] using Vert.x codegen.
  */
-@Deprecated(message = "Instead use write returning a future and chain with await()", replaceWith = ReplaceWith("write(data).await()"))
-suspend fun WebSocketBase.writeAwait(data: Buffer): Unit {
+@Deprecated(message = "Instead use pipeTo returning a future and chain with await()", replaceWith = ReplaceWith("pipeTo(dst).await()"))
+suspend fun WebSocketBase.pipeToAwait(dst: WriteStream<Buffer>): Unit {
   return awaitResult {
-    this.write(data, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
+    this.pipeTo(dst, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
   }
 }
 
 /**
- * Suspending version of method [io.vertx.core.http.WebSocketBase.end]
+ * Suspending version of method [io.vertx.core.http.WebSocketBase.write]
  *
  * @param data 
  *
  * NOTE: This function has been automatically generated from [io.vertx.core.http.WebSocketBase] using Vert.x codegen.
  */
-@Deprecated(message = "Instead use end returning a future and chain with await()", replaceWith = ReplaceWith("end(data).await()"))
-suspend fun WebSocketBase.endAwait(data: Buffer): Unit {
+@Deprecated(message = "Instead use write returning a future and chain with await()", replaceWith = ReplaceWith("write(data).await()"))
+suspend fun WebSocketBase.writeAwait(data: Buffer): Unit {
   return awaitResult {
-    this.end(data, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
+    this.write(data, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
   }
 }
 
 /**
- * Suspending version of method [io.vertx.core.http.WebSocketBase.pipeTo]
+ * Suspending version of method [io.vertx.core.http.WebSocketBase.end]
  *
- * @param dst the destination write stream
+ * @param data 
  *
  * NOTE: This function has been automatically generated from [io.vertx.core.http.WebSocketBase] using Vert.x codegen.
  */
-@Deprecated(message = "Instead use pipeTo returning a future and chain with await()", replaceWith = ReplaceWith("pipeTo(dst).await()"))
-suspend fun WebSocketBase.pipeToAwait(dst: WriteStream<Buffer>): Unit {
+@Deprecated(message = "Instead use end returning a future and chain with await()", replaceWith = ReplaceWith("end(data).await()"))
+suspend fun WebSocketBase.endAwait(data: Buffer): Unit {
   return awaitResult {
-    this.pipeTo(dst, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
+    this.end(data, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
   }
 }
 

vertx-lang-kotlin/src/main/kotlin/io/vertx/kotlin/core/net/NetSocket.kt

@@ -21,30 +21,30 @@ import io.vertx.core.streams.WriteStream
 import io.vertx.kotlin.coroutines.awaitResult
 
 /**
- * Suspending version of method [io.vertx.core.net.NetSocket.end]
+ * Suspending version of method [io.vertx.core.net.NetSocket.pipeTo]
  *
- * @param data 
+ * @param dst the destination write stream
  *
  * NOTE: This function has been automatically generated from [io.vertx.core.net.NetSocket] using Vert.x codegen.
  */
-@Deprecated(message = "Instead use end returning a future and chain with await()", replaceWith = ReplaceWith("end(data).await()"))
-suspend fun NetSocket.endAwait(data: Buffer): Unit {
+@Deprecated(message = "Instead use pipeTo returning a future and chain with await()", replaceWith = ReplaceWith("pipeTo(dst).await()"))
+suspend fun NetSocket.pipeToAwait(dst: WriteStream<Buffer>): Unit {
   return awaitResult {
-    this.end(data, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
+    this.pipeTo(dst, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
   }
 }
 
 /**
- * Suspending version of method [io.vertx.core.net.NetSocket.pipeTo]
+ * Suspending version of method [io.vertx.core.net.NetSocket.end]
  *
- * @param dst the destination write stream
+ * @param data 
  *
  * NOTE: This function has been automatically generated from [io.vertx.core.net.NetSocket] using Vert.x codegen.
  */
-@Deprecated(message = "Instead use pipeTo returning a future and chain with await()", replaceWith = ReplaceWith("pipeTo(dst).await()"))
-suspend fun NetSocket.pipeToAwait(dst: WriteStream<Buffer>): Unit {
+@Deprecated(message = "Instead use end returning a future and chain with await()", replaceWith = ReplaceWith("end(data).await()"))
+suspend fun NetSocket.endAwait(data: Buffer): Unit {
   return awaitResult {
-    this.pipeTo(dst, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
+    this.end(data, io.vertx.core.Handler { ar -> it.handle(ar.mapEmpty()) })
   }
 }
 

vertx-lang-kotlin/src/main/kotlin/io/vertx/kotlin/ext/shell/term/HttpTermOptions.kt

@@ -68,6 +68,8 @@ import java.util.concurrent.TimeUnit
  * @param logActivity  Set to true to enabled network activity logging: Netty's pipeline is configured for logging on Netty's logger.
  * @param maxChunkSize  Set the maximum HTTP chunk size that  will receive
  * @param maxFormAttributeSize  Set the maximum size of a form attribute. Set to <code>-1</code> to allow unlimited length
+ * @param maxFormBufferedBytes  Set the maximum number of bytes a server can buffer when decoding a form. Set to <code>-1</code> to allow unlimited length
+ * @param maxFormFields  Set the maximum number of fields of a form. Set to <code>-1</code> to allow unlimited number of attributes
  * @param maxHeaderSize  Set the maximum length of all headers for HTTP/1.x .
  * @param maxInitialLineLength  Set the maximum length of the initial line for HTTP/1.x (e.g. <code>"GET / HTTP/1.0"</code>)
  * @param maxWebSocketFrameSize  Set the maximum WebSocket frames size
@@ -156,6 +158,8 @@ fun httpTermOptionsOf(
   logActivity: Boolean? = null,
   maxChunkSize: Int? = null,
   maxFormAttributeSize: Int? = null,
+  maxFormBufferedBytes: Int? = null,
+  maxFormFields: Int? = null,
   maxHeaderSize: Int? = null,
   maxInitialLineLength: Int? = null,
   maxWebSocketFrameSize: Int? = null,
@@ -310,6 +314,12 @@ fun httpTermOptionsOf(
   if (maxFormAttributeSize != null) {
     this.setMaxFormAttributeSize(maxFormAttributeSize)
   }
+  if (maxFormBufferedBytes != null) {
+    this.setMaxFormBufferedBytes(maxFormBufferedBytes)
+  }
+  if (maxFormFields != null) {
+    this.setMaxFormFields(maxFormFields)
+  }
   if (maxHeaderSize != null) {
     this.setMaxHeaderSize(maxHeaderSize)
   }