Add HttpConnection#protocolVersion to indicate the version of the HTTP protocol of a connection.

Author: vietj

vertx-core/src/main/java/io/vertx/core/http/HttpConnection.java

@@ -39,6 +39,11 @@
 @VertxGen
 public interface HttpConnection {
 
+  /**
+   * @return the version of the protocol of this connection
+   */
+  HttpVersion protocolVersion();
+
   /**
    * @return the current connection window size or {@code -1} for HTTP/1.x
    */

vertx-core/src/main/java/io/vertx/core/http/impl/UnpooledHttpClientConnection.java

@@ -89,6 +89,11 @@ public HttpConnection setWindowSize(int windowSize) {
     return actual.setWindowSize(windowSize);
   }
 
+  @Override
+  public HttpVersion protocolVersion() {
+    return actual.protocolVersion();
+  }
+
   @Override
   @Fluent
   public HttpConnection goAway(long errorCode) {

vertx-core/src/main/java/io/vertx/core/http/impl/http1x/Http1xConnection.java

@@ -27,6 +27,7 @@
 import io.vertx.core.http.GoAway;
 import io.vertx.core.http.Http2Settings;
 import io.vertx.core.http.HttpConnection;
+import io.vertx.core.http.HttpVersion;
 import io.vertx.core.internal.ContextInternal;
 import io.vertx.core.net.impl.VertxConnection;
 
@@ -94,6 +95,11 @@ public Http1xConnection closeHandler(Handler<Void> handler) {
     return (Http1xConnection) super.closeHandler(handler);
   }
 
+  @Override
+  public HttpVersion protocolVersion() {
+    return HttpVersion.HTTP_1_1;
+  }
+
   @Override
   public Http1xConnection exceptionHandler(Handler<Throwable> handler) {
     return (Http1xConnection) super.exceptionHandler(handler);

vertx-core/src/main/java/io/vertx/core/http/impl/http1x/Http2UpgradeClientConnection.java

@@ -821,6 +821,11 @@ public HttpClientConnection alternativeServicesHandler(Handler<String> handler)
     return this;
   }
 
+  @Override
+  public HttpVersion protocolVersion() {
+    return current.protocolVersion();
+  }
+
   @Override
   public HttpConnection goAway(long errorCode, int lastStreamId, Buffer debugData) {
     return current.goAway(errorCode, lastStreamId, debugData);

vertx-core/src/main/java/io/vertx/core/http/impl/http2/codec/Http2ConnectionImpl.java

@@ -28,6 +28,7 @@
 import io.vertx.core.Promise;
 import io.vertx.core.VertxException;
 import io.vertx.core.buffer.Buffer;
+import io.vertx.core.http.HttpVersion;
 import io.vertx.core.http.impl.HttpUtils;
 import io.vertx.core.http.impl.http2.Http2Connection;
 import io.vertx.core.http.impl.http2.Http2Stream;
@@ -337,6 +338,11 @@ public HttpConnection setWindowSize(int windowSize) {
     }
   }
 
+  @Override
+  public HttpVersion protocolVersion() {
+    return HttpVersion.HTTP_2;
+  }
+
   @Override
   public HttpConnection goAway(long errorCode, int lastStreamId, Buffer debugData) {
     if (errorCode < 0) {

vertx-core/src/main/java/io/vertx/core/http/impl/http2/multiplex/Http2MultiplexConnection.java

@@ -202,6 +202,11 @@ public void writePriorityFrame(int streamId, StreamPriority priority, Promise<Vo
     promise.fail("Unsupported");
   }
 
+  @Override
+  public HttpVersion protocolVersion() {
+    return HttpVersion.HTTP_2;
+  }
+
   @Override
   public HttpConnection goAway(long errorCode, int lastStreamId, Buffer debugData) {
     handler.writeGoAway(errorCode, debugData != null ? ((BufferInternal)debugData).getByteBuf() : Unpooled.EMPTY_BUFFER, context.promise());

vertx-core/src/test/java/io/vertx/tests/http/HttpTest.java

@@ -6441,4 +6441,20 @@ public void testServerShutdown() throws Exception {
     fut.await();
     assertTrue((System.currentTimeMillis() - now) < timeout / 4);
   }
+
+  @Test
+  public void testConnectionVersion() throws Exception {
+    server.requestHandler(request -> {
+      assertEquals(request.version(), request.connection().protocolVersion());
+      request.response().end();
+    });
+    startServer(testAddress);
+    client.request(requestOptions)
+      .compose(req -> req
+        .send()
+        .expecting(HttpResponseExpectation.SC_OK)
+        .compose(HttpClientResponse::end))
+      .await();
+  }
+
 }