Use current protocol version in Via identifier

Author: serialseb

src/OpenRasta.Plugins.ReverseProxy/ReverseProxy.cs

@@ -77,7 +77,7 @@ public async Task<ReverseProxyResponse> Send(ICommunicationContext context, stri
     string AppendViaHeaderToRequest(ICommunicationContext context, HttpRequestMessage requestMessage)
     {
       var viaIdentifier = _viaIdentifier ?? $"{context.Request.Uri.Host}:{context.Request.Uri.Port}";
-      requestMessage.Headers.Add("via", $"1.1 {viaIdentifier}");
+      requestMessage.Headers.Add("via", $"{context.PipelineData.Owin.RequestProtocol} {viaIdentifier}");
       return viaIdentifier;
     }
 

src/OpenRasta.Plugins.ReverseProxy/ReverseProxyResponseCodec.cs

@@ -12,12 +12,14 @@ namespace OpenRasta.Plugins.ReverseProxy
   public class ReverseProxyResponseCodec : IMediaTypeWriterAsync
   {
     readonly IResponse _response;
+    string _protocol;
     public object Configuration { get; set; }
 
 
     public ReverseProxyResponseCodec(ICommunicationContext context)
     {
       _response = context.Response;
+      _protocol = context.PipelineData.Owin.RequestProtocol;
     }
 
     public async Task WriteTo(object entity, IHttpEntity response, IEnumerable<string> codecParameters)
@@ -28,7 +30,7 @@ public async Task WriteTo(object entity, IHttpEntity response, IEnumerable<strin
         _response.StatusCode = proxyResponse.StatusCode;
 
         if (proxyResponse.Via != null)
-          response.Headers.Add("via", proxyResponse.Via);
+          response.Headers.Add("via", $"{_protocol} {proxyResponse.Via}");
 
         if (proxyResponse.ResponseMessage != null)
         {

src/Tests/Plugins.ReverseProxy/via_headers/default_via_header.cs

@@ -14,7 +14,7 @@ public async Task request_domain_and_port_is_used()
         .FromServer("/proxy")
         .ToServer("/proxied", async ctx => ctx.Request.Headers["Via"])
         .GetAsync("http://source.example/proxy");
-      response.Content.ShouldBe("1.1 source.example:80");
+      response.Content.ShouldBe("HTTP/2.0 source.example:80");
 
       var via = response.Message.Headers.Via.ShouldHaveSingleItem();
       via.ReceivedBy.ShouldBe("source.example:80");

src/Tests/Plugins.ReverseProxy/via_headers/pseudonym_via_header_request_absent.cs

@@ -14,7 +14,7 @@ public async Task rp_is_added()
         .FromServer("/proxy", options=>options.Via.Pseudonym = "componentName")
         .ToServer("/proxied", async ctx => ctx.Request.Headers["Via"])
         .GetAsync("proxy");
-      response.Content.ShouldBe("1.1 componentName");
+      response.Content.ShouldBe("HTTP/2.0 componentName");
     }
   }
 }

src/Tests/Plugins.ReverseProxy/via_headers/pseudonym_via_header_request_present.cs

@@ -15,7 +15,7 @@ public async Task rp_is_appended()
         .ToServer("/proxied", async ctx => ctx.Request.Headers["Via"])
         .AddHeader("Via", "1.1 identifier")
         .GetAsync("proxy");
-      response.Content.ShouldBe("1.1 identifier,1.1 componentName");
+      response.Content.ShouldBe("1.1 identifier,HTTP/2.0 componentName");
     }
   }
 }