Add test for :http1 + :http2

Author: wojtekmach

test/req_test.exs

@@ -1,6 +1,6 @@
 defmodule ReqTest do
   use ExUnit.Case, async: true
-  import TestHelper, only: [start_http_server: 1]
+  import TestHelper, only: [start_http_server: 1, start_https_server: 1]
 
   doctest Req,
     only: [
@@ -96,4 +96,21 @@ defmodule ReqTest do
     resp = Req.get!(origin_url, into: :self)
     assert Req.put!(echo_url, body: resp.body).body == "foobarbaz"
   end
+
+  test "http1 + http2" do
+    %{url: url} =
+      start_https_server(fn conn ->
+        assert Plug.Conn.get_http_protocol(conn) == :"HTTP/2"
+        Plug.Conn.send_resp(conn, 200, "ok")
+      end)
+
+    assert Req.get!(
+             url,
+             connect_options: [
+               transport_opts: [cacertfile: "#{__DIR__}/support/ca.pem"],
+               protocols: [:http1, :http2]
+             ],
+             retry: false
+           ).body == "ok"
+  end
 end

test/support/ca.pem

@@ -0,0 +1,17 @@
+-----BEGIN CERTIFICATE-----
+MIICyjCCAbICCQCRKhJFmW6v0zANBgkqhkiG9w0BAQsFADAnMQswCQYDVQQGEwJV
+UzEYMBYGA1UEAwwPRXhhbXBsZS1Sb290LUNBMB4XDTIxMDYwNjAzMDcxMVoXDTI3
+MDExNDAzMDcxMVowJzELMAkGA1UEBhMCVVMxGDAWBgNVBAMMD0V4YW1wbGUtUm9v
+dC1DQTCCASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoCggEBAOdFzns6VXOtAsVw
+CxAVWFbfEEDzzJemaCmcnW7xxcPu/NutEKbrZzDPUW8FcRTK90i81rffcT12hEFV
+k66zVWVOxYFAGxqYhvrOaJlehwlWdmGCl2740UdsvXsziNXuKFYmZi3/8+rV4UJY
+s/Ipv61a8x/2KagCYykr2G03iAiF/C2j//xpjrUfSuGMu/lapDXxQfDsAGtd7qSc
+HHEMzBvLq8cLuwVJFQEBqvEU3Nkn3gAeW7gC6myGRH3c68mbWmY/r5RcS7KdFjsD
+BVMGZXOtzLozXzQqI/G4DmTxKvYqFN/pjz9PZ8vQFkr9ddrC09kNmxCcCbC3WQfa
+3FihVM0CAwEAATANBgkqhkiG9w0BAQsFAAOCAQEA1oErpO9Co61Wb+6mqYyFMZpy
+Bedyf3SIQzQlDig+R/+avs7ZMmZtu0A7LjMPdgpfrJhlBK/1ThkNRYRsMbnyku+F
+qC1XEnrfRG9PXYcxigH6DLTaHSfYVE5QQFQAZequiQb6K0LVWUcuPVkzZNGMl3RR
+qb9/pM2hCwwNApnZYi4SzH6tfhF6OFi5dNexCEqqtKd00ZZh09ERhnqZpR62jQS/
+SERs6ZS9K9D+A9f/4cRSJOFB9gSfil0sqxBC5GhO6Bse5HEprlPkHPeoHMD1Mj1K
+zH1twf4Amnz3p9OGRZZ6qspkXhT+8gTIfzlcX/wJpv7c53uI/OAIxRwogI0w7Q==
+-----END CERTIFICATE-----

test/support/cert.pem

@@ -0,0 +1,21 @@
+-----BEGIN CERTIFICATE-----
+MIIDijCCAnKgAwIBAgIJAI8sEm5tQlsrMA0GCSqGSIb3DQEBCwUAMCcxCzAJBgNV
+BAYTAlVTMRgwFgYDVQQDDA9FeGFtcGxlLVJvb3QtQ0EwHhcNMjEwNjA2MDMwODMw
+WhcNNDgxMDIyMDMwODMwWjBtMQswCQYDVQQGEwJVUzESMBAGA1UECAwJWW91clN0
+YXRlMREwDwYDVQQHDAhZb3VyQ2l0eTEdMBsGA1UECgwURXhhbXBsZS1DZXJ0aWZp
+Y2F0ZXMxGDAWBgNVBAMMD2xvY2FsaG9zdC5sb2NhbDCCASIwDQYJKoZIhvcNAQEB
+BQADggEPADCCAQoCggEBAPN+9Lo3Z1DGmMLzj/5nb+48Wx4Ra4xBooeMyO22IqEu
+93y4clasT8YZYoUh283AUUGajZaggia19HKSKAzmu2SFi4fRoqYYtyztsvm2qih2
+ORPGOJo0UUE7q5alM4RtgnNoAuPnjZ2eYAMEflt80K0X8TYAAfZ3wvfHEL5y8NDd
+8LrBKsSVmE14bq7OzHMNPGuHEsTk/ESjBtJehQkQ1eT02TCgPPudTIky4jkkFQ/F
+OiMurScH+GsauKRZqSbhzv8a30FBl/50cTbnQb9KSfg0DjKEbP51NIX+PuSt9KlL
+49r7AsKpSNqmpuVGSmInRVx+XOo4Ytt2Deu6lQAUzU8CAwEAAaNzMHEwQQYDVR0j
+BDowOKErpCkwJzELMAkGA1UEBhMCVVMxGDAWBgNVBAMMD0V4YW1wbGUtUm9vdC1D
+QYIJAJEqEkWZbq/TMAkGA1UdEwQCMAAwCwYDVR0PBAQDAgTwMBQGA1UdEQQNMAuC
+CWxvY2FsaG9zdDANBgkqhkiG9w0BAQsFAAOCAQEAuTlHn/ytxq0QVtvFlEUXfWFi
+z0JUxTty7cwXPVVqxIYh5fVip6GYjlJgaQiMPeMneWbne6DtXckLvsje4XrjGeZO
+BYrsA4i6Ik6idxw3/AVyncJsNeA8fkEzyxFRUoAOLRrS7pb1EkuakgGuVv3c/gTa
+E1bAHzqQyEWW3i2H5hKBSjy5KD61MMcmD006dmypxmwaLmted28cgvqVR9fdU/5p
+vl6rnqUxEmTnKzX9LX4NQQR3lodyhj7zMVcL8ozC39YQ15oOSneDtMOweWmMAgE6
+idRfFBX/fBaprJKRAR9TGCCXcOO/cA9QTkI31iCdWCuqeCpKHtFSbpI8cehMZQ==
+-----END CERTIFICATE-----

test/support/key.pem

@@ -0,0 +1,28 @@
+-----BEGIN PRIVATE KEY-----
+MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQDzfvS6N2dQxpjC
+84/+Z2/uPFseEWuMQaKHjMjttiKhLvd8uHJWrE/GGWKFIdvNwFFBmo2WoIImtfRy
+kigM5rtkhYuH0aKmGLcs7bL5tqoodjkTxjiaNFFBO6uWpTOEbYJzaALj542dnmAD
+BH5bfNCtF/E2AAH2d8L3xxC+cvDQ3fC6wSrElZhNeG6uzsxzDTxrhxLE5PxEowbS
+XoUJENXk9NkwoDz7nUyJMuI5JBUPxTojLq0nB/hrGrikWakm4c7/Gt9BQZf+dHE2
+50G/Skn4NA4yhGz+dTSF/j7krfSpS+Pa+wLCqUjapqblRkpiJ0VcflzqOGLbdg3r
+upUAFM1PAgMBAAECggEAL2mEC5JoKqFQ83zrh9TqRZA5CcTIlTnehNhT831ohswX
+YpCjqt7IdcFRnqy2GP0elVCbyz2buh/p5jkxVTnEOVGLlrmqGv9rA3ORSvBXd6N1
+f7U0JkqTm8kboyytuFZ+dSxGi8v1lkBVX6ELXZMTKvEjhalAuJYfP5HiX8MPwwti
+540zHN4fQ9cgDkpjLyR+g4us1iBtYmbx/+BHeE6tsN5I0dc4Ee/LxXLkBRqNhB4K
+g6wWynqLtX12py/TFaBfs8DSMY1IfdCxJDxiahtGCXFokfsQbqBySpLrdx41ela4
+IG5qr0u9/XyX4Y6pm4chNxKMwqRRF9bllGXEI2HySQKBgQD/pY43H3gPM/8IMzcT
+f3YvBX1KliU26xdbjPGrp+lAsUcAEv0gNmYsr6lUFZNd3RmsqfYR7Rt2GE468i95
+gfgRmTXUrDbZKeu92qvZNfd9f3HJYsjcHhSNNtRSYNubjpwniU4zyl78Jjz4jv44
+xNjEtmQ//FNTIIaKAr5zQ8lTxQKBgQDz1RoFwkJs38+LfLotjmNcmV7vC4Q4H3ZG
+m6mRNTfAiwFy9kbF16d4+fZ/byoHxSAOEjH08sKjQ1koH0moFQaFXWDW7/gwIiq3
+ErKO8ZE53uazFGOhNmHMdkdaTwb/Hn5/DKJBBexY/2O8S+tIZchhB0hluiz3QKSo
+p/rbcDiqAwKBgQDAXDFrltk/D0/qOqdJm5IxBX9mPR4ZecHkmGRMVpczn3EeRCuF
+LompPDA8XdO6QCEOhADtMi2EqftLbWp9kmc3zsHrmf3XYCzLeZvvYCUuoFPdReB/
+iH7MVyJiLhFwtlkXgsB+Rds8/gTIvsfZrXyyX8+FOfb0yLeTZ0co8iuuRQKBgCgG
+hT0IxGqm2qTlFpK/2uOqcYD//PZRg9LXXqBtgfdjWhuK/dcgLWeYcLQ+hUG9RCPL
+LNQuvXCbb5k8eZTTzrw5tdnSjoUoNqbStOjuEo7TXj9rS2d9S9SKXfAfJODgGpe0
+dTYDSObbFX4lYDwEKT50OZgpVZRI0j61RGKdK1ANAoGBAKoO8Sbm6O9KTfvgVuQf
+t/L1c47JI6GnX1i9JCgQxRapmEYEupt0hRJh36zSvnip+iy8J22useJFtCcxeZUj
+XOH1WOWwQn8qDSUPA3PVO3TZb+k4Z8VlIKzrEWHLl56zWPO5Su7AHXseJhY1Z4Bz
+WmUvA9kdCmStQ7RMH89NRnh8
+-----END PRIVATE KEY-----

test/test_helper.exs

@@ -1,5 +1,5 @@
 defmodule TestHelper do
-  def start_http_server(plug) do
+  def start_http_server(plug) when is_function(plug, 1) do
     options = [
       scheme: :http,
       port: 0,
@@ -13,6 +13,22 @@ defmodule TestHelper do
     %{pid: pid, url: URI.new!("http://localhost:#{port}")}
   end
 
+  def start_https_server(plug) when is_function(plug, 1) do
+    options = [
+      scheme: :https,
+      port: 0,
+      plug: fn conn, _ -> plug.(conn) end,
+      startup_log: false,
+      http_options: [compress: false],
+      certfile: "#{__DIR__}/support/cert.pem",
+      keyfile: "#{__DIR__}/support/key.pem"
+    ]
+
+    pid = ExUnit.Callbacks.start_supervised!({Bandit, options})
+    {:ok, {_ip, port}} = ThousandIsland.listener_info(pid)
+    %{pid: pid, url: URI.new!("https://localhost:#{port}")}
+  end
+
   def start_tcp_server(fun) do
     {:ok, listen_socket} = :gen_tcp.listen(0, mode: :binary, active: false)
     {:ok, port} = :inet.port(listen_socket)