Feature/http3 support 4.4

pom.xml

@@ -98,6 +98,11 @@
       <groupId>io.netty</groupId>
       <artifactId>netty-codec-http2</artifactId>
     </dependency>
+    <dependency>
+      <groupId>io.netty.incubator</groupId>
+      <artifactId>netty-incubator-codec-http3</artifactId>
+      <version>0.0.28.Final</version>
+    </dependency>
     <dependency>
       <groupId>io.netty</groupId>
       <artifactId>netty-resolver</artifactId>

src/main/generated/io/vertx/core/http/HttpClientOptionsConverter.java

@@ -165,11 +165,6 @@ static void fromJson(Iterable<java.util.Map.Entry<String, Object>> json, HttpCli
             obj.setPoolEventLoopSize(((Number)member.getValue()).intValue());
           }
           break;
-        case "protocolVersion":
-          if (member.getValue() instanceof String) {
-            obj.setProtocolVersion(io.vertx.core.http.HttpVersion.valueOf((String)member.getValue()));
-          }
-          break;
         case "sendUnmaskedFrames":
           if (member.getValue() instanceof Boolean) {
             obj.setSendUnmaskedFrames((Boolean)member.getValue());
@@ -274,9 +269,6 @@ static void toJson(HttpClientOptions obj, java.util.Map<String, Object> json) {
     json.put("pipeliningLimit", obj.getPipeliningLimit());
     json.put("poolCleanerPeriod", obj.getPoolCleanerPeriod());
     json.put("poolEventLoopSize", obj.getPoolEventLoopSize());
-    if (obj.getProtocolVersion() != null) {
-      json.put("protocolVersion", obj.getProtocolVersion().name());
-    }
     json.put("sendUnmaskedFrames", obj.isSendUnmaskedFrames());
     json.put("shared", obj.isShared());
     if (obj.getTracingPolicy() != null) {

src/main/generated/io/vertx/core/net/ClientOptionsBaseConverter.java

@@ -45,6 +45,11 @@ static void fromJson(Iterable<java.util.Map.Entry<String, Object>> json, ClientO
             obj.setNonProxyHosts(list);
           }
           break;
+        case "protocolVersion":
+          if (member.getValue() instanceof String) {
+            obj.setProtocolVersion(io.vertx.core.http.HttpVersion.valueOf((String)member.getValue()));
+          }
+          break;
         case "proxyOptions":
           if (member.getValue() instanceof JsonObject) {
             obj.setProxyOptions(new io.vertx.core.net.ProxyOptions((io.vertx.core.json.JsonObject)member.getValue()));
@@ -76,6 +81,9 @@ static void toJson(ClientOptionsBase obj, java.util.Map<String, Object> json) {
       obj.getNonProxyHosts().forEach(item -> array.add(item));
       json.put("nonProxyHosts", array);
     }
+    if (obj.getProtocolVersion() != null) {
+      json.put("protocolVersion", obj.getProtocolVersion().name());
+    }
     if (obj.getProxyOptions() != null) {
       json.put("proxyOptions", obj.getProxyOptions().toJson());
     }

src/main/generated/io/vertx/core/net/SSLOptionsConverter.java

@@ -54,6 +54,11 @@ static void fromJson(Iterable<java.util.Map.Entry<String, Object>> json, SSLOpti
             obj.setEnabledSecureTransportProtocols(list);
           }
           break;
+        case "http3":
+          if (member.getValue() instanceof Boolean) {
+            obj.setHttp3((Boolean)member.getValue());
+          }
+          break;
         case "sslHandshakeTimeout":
           if (member.getValue() instanceof Number) {
             obj.setSslHandshakeTimeout(((Number)member.getValue()).longValue());
@@ -98,6 +103,7 @@ static void toJson(SSLOptions obj, java.util.Map<String, Object> json) {
       obj.getEnabledSecureTransportProtocols().forEach(item -> array.add(item));
       json.put("enabledSecureTransportProtocols", array);
     }
+    json.put("http3", obj.isHttp3());
     json.put("sslHandshakeTimeout", obj.getSslHandshakeTimeout());
     if (obj.getSslHandshakeTimeoutUnit() != null) {
       json.put("sslHandshakeTimeoutUnit", obj.getSslHandshakeTimeoutUnit().name());

src/main/java/examples/HTTP2Examples.java

@@ -113,17 +113,18 @@ public void example6(HttpServerRequest request) {
   public void example7(Vertx vertx) {
 
     HttpClientOptions options = new HttpClientOptions().
-        setProtocolVersion(HttpVersion.HTTP_2).
         setSsl(true).
         setUseAlpn(true).
         setTrustAll(true);
+    options.setProtocolVersion(HttpVersion.HTTP_2);
 
     HttpClient client = vertx.createHttpClient(options);
   }
 
   public void example8(Vertx vertx) {
 
-    HttpClientOptions options = new HttpClientOptions().setProtocolVersion(HttpVersion.HTTP_2);
+    HttpClientOptions options = new HttpClientOptions();
+    options.setProtocolVersion(HttpVersion.HTTP_2);
 
     HttpClient client = vertx.createHttpClient(options);
   }

src/main/java/examples/HTTP3Examples.java

@@ -0,0 +1,81 @@
+/*
+ * Copyright (c) 2011-2019 Contributors to the Eclipse Foundation
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License 2.0 which is available at
+ * http://www.eclipse.org/legal/epl-2.0, or the Apache License, Version 2.0
+ * which is available at https://www.apache.org/licenses/LICENSE-2.0.
+ *
+ * SPDX-License-Identifier: EPL-2.0 OR Apache-2.0
+ */
+
+package examples;
+
+import io.netty.incubator.codec.http3.DefaultHttp3SettingsFrame;
+import io.netty.incubator.codec.http3.Http3SettingsFrame;
+import io.vertx.core.Vertx;
+import io.vertx.core.http.HttpClient;
+import io.vertx.core.http.HttpClientOptions;
+import io.vertx.core.http.HttpClientResponse;
+import io.vertx.core.http.HttpMethod;
+import io.vertx.core.http.HttpVersion;
+
+/**
+ * @author <a href="mailto:[email protected]">Iman Zolfaghari</a>
+ */
+public class HTTP3Examples {
+
+  public void example01(Vertx vertx) {
+
+    DefaultHttp3SettingsFrame settings = new DefaultHttp3SettingsFrame();
+    settings.put(Http3SettingsFrame.HTTP3_SETTINGS_MAX_FIELD_SECTION_SIZE,
+      100000000000L);
+
+    HttpClientOptions options = new HttpClientOptions().
+      setSsl(true).
+      setUseAlpn(true).
+      setHttp3InitialSettings(settings).
+      setTrustAll(true);
+    options.setProtocolVersion(HttpVersion.HTTP_3);
+
+    HttpClient client = vertx.createHttpClient(options);
+
+    client.request(HttpMethod.GET, 443, "www.google.com", "/")
+//    client.request(HttpMethod.GET, 9999, NetUtil.LOCALHOST4.getHostAddress(), "/")
+//    client.request(HttpMethod.GET, 443, "www.mozilla.org", "/")
+//    client.request(HttpMethod.GET, 443, "www.bing.com", "/")
+//    client.request(HttpMethod.GET, 443, "www.yahoo.com", "/")
+//    client.request(HttpMethod.GET, 443, "http3.is", "/")
+      .compose(req -> {
+
+        req.connection().goAwayHandler(goAway -> {
+          System.out.println(" Received goAway from server! ");
+        });
+
+        req.connection().shutdownHandler(v -> {
+          System.out.println(" Received shutdown signal! ");
+          req.connection().close();
+          vertx.close();
+        });
+
+        return req
+          .end()
+          .compose(res -> req
+            .response()
+            .onSuccess(resp -> {
+              System.out.println("The returned headers are: " + resp.headers());
+              System.out.println("The returned Alt-Svc is: " + resp.headers().get(
+                "Alt-Svc"));
+            }).compose(HttpClientResponse::body).onSuccess(body ->
+              System.out.println("The response body is: " + body.toString()))
+          );
+      })
+      .onFailure(Throwable::printStackTrace)
+      .onComplete(event -> vertx.close())
+    ;
+  }
+
+  public static void main(String[] args) {
+    new HTTP3Examples().example01(Vertx.vertx());
+  }
+}

src/main/java/io/vertx/core/http/Http2StreamPriority.java

@@ -0,0 +1,65 @@
+package io.vertx.core.http;
+
+public class Http2StreamPriority implements StreamPriorityBase {
+  private final StreamPriority streamPriority;
+
+  public Http2StreamPriority(StreamPriority streamPriority) {
+    this.streamPriority = streamPriority;
+  }
+
+  public Http2StreamPriority() {
+    this(new StreamPriority());
+  }
+
+  public short getWeight() {
+    return this.streamPriority.getWeight();
+  }
+
+  public Http2StreamPriority setWeight(short weight) {
+    this.streamPriority.setWeight(weight);
+    return this;
+  }
+
+  public int getDependency() {
+    return this.streamPriority.getDependency();
+  }
+
+  public Http2StreamPriority setDependency(int dependency) {
+    this.streamPriority.setDependency(dependency);
+    return this;
+  }
+
+  public boolean isExclusive() {
+    return this.streamPriority.isExclusive();
+  }
+
+  public Http2StreamPriority setExclusive(boolean exclusive) {
+    this.streamPriority.setExclusive(exclusive);
+    return this;
+  }
+
+  @Override
+  public int urgency() {
+    throw new RuntimeException("Not Http3 Priority!");
+  }
+
+  @Override
+  public boolean isIncremental() {
+    throw new RuntimeException("Not Http3 Priority!");
+  }
+
+  @Override
+  public int hashCode() {
+    return this.streamPriority.hashCode();
+  }
+
+  @Override
+  public boolean equals(Object obj) {
+    return obj instanceof Http2StreamPriority && this.streamPriority.equals(((Http2StreamPriority) obj).streamPriority);
+  }
+
+  @Override
+  public String toString() {
+    return this.streamPriority.toString();
+  }
+}

src/main/java/io/vertx/core/http/Http3StreamPriority.java

@@ -0,0 +1,64 @@
+package io.vertx.core.http;
+
+import io.netty.incubator.codec.quic.QuicStreamPriority;
+
+public class Http3StreamPriority implements StreamPriorityBase {
+  private final QuicStreamPriority quicStreamPriority;
+
+  public Http3StreamPriority(QuicStreamPriority quicStreamPriority) {
+    this.quicStreamPriority = quicStreamPriority;
+  }
+
+  public int urgency() {
+    return this.quicStreamPriority.urgency();
+  }
+
+  public boolean isIncremental() {
+    return this.quicStreamPriority.isIncremental();
+  }
+
+  @Override
+  public short getWeight() {
+    throw new RuntimeException("Not Http2 Priority!");
+  }
+
+  @Override
+  public StreamPriorityBase setWeight(short weight) {
+    throw new RuntimeException("Not Http2 Priority!");
+  }
+
+  @Override
+  public int getDependency() {
+    throw new RuntimeException("Not Http2 Priority!");
+  }
+
+  @Override
+  public StreamPriorityBase setDependency(int dependency) {
+    throw new RuntimeException("Not Http2 Priority!");
+  }
+
+  @Override
+  public boolean isExclusive() {
+    throw new RuntimeException("Not Http2 Priority!");
+  }
+
+  @Override
+  public StreamPriorityBase setExclusive(boolean exclusive) {
+    throw new RuntimeException("Not Http2 Priority!");
+  }
+
+  @Override
+  public int hashCode() {
+    return this.quicStreamPriority.hashCode();
+  }
+
+  @Override
+  public boolean equals(Object obj) {
+    return obj instanceof Http3StreamPriority && this.quicStreamPriority.equals(((Http3StreamPriority) obj).quicStreamPriority);
+  }
+
+  @Override
+  public String toString() {
+    return this.quicStreamPriority.toString();
+  }
+}