Update to latest Req

config/config.exs

@@ -5,5 +5,3 @@ import Config
 config :logger, :level, :warning
 
 config :phoenix, :json_library, Jason
-
-config :req, legacy_headers_as_lists: true

lib/absinthe_client/web_socket.ex

@@ -70,7 +70,7 @@ defmodule AbsintheClient.WebSocket do
       will be prepended to this path. The default value is
       `"/socket/websocket"`.
 
-    * `:headers` - list of headers to send on the initial
+    * `:headers` - headers to send on the initial
       HTTP request. Defaults to `[]`.
 
     * `:connect_options` - list of options given to
@@ -206,7 +206,7 @@ defmodule AbsintheClient.WebSocket do
 
     config_options = [
       uri: req.url,
-      headers: req.headers,
+      headers: Req.get_headers_list(req),
       mint_opts: [
         protocols: [:http1],
         transport_opts: transport_opts

lib/absinthe_client/web_socket/absinthe_ws.ex

@@ -117,16 +117,16 @@ defmodule AbsintheClient.WebSocket.AbsintheWs do
   defp reply(%Push{} = push, push_ref, result),
     do: reply(%Reply{event: push.event, ref: push.ref, push_ref: push_ref}, result)
 
-  defp reply(reply, :ok), do: %Reply{reply | status: :ok, payload: nil}
-  defp reply(reply, :error), do: %Reply{reply | status: :error, payload: nil}
+  defp reply(%Reply{} = reply, :ok), do: %{reply | status: :ok, payload: nil}
+  defp reply(%Reply{} = reply, :error), do: %{reply | status: :error, payload: nil}
 
-  defp reply(reply, {:ok, payload}),
-    do: %Reply{reply | status: :ok, payload: payload(reply, payload)}
+  defp reply(%Reply{} = reply, {:ok, payload}),
+    do: %{reply | status: :ok, payload: payload(reply, payload)}
 
-  defp reply(reply, {:error, payload}),
-    do: %Reply{reply | status: :error, payload: error_payload(reply, payload)}
+  defp reply(%Reply{} = reply, {:error, payload}),
+    do: %{reply | status: :error, payload: error_payload(reply, payload)}
 
-  defp payload(reply, %{"subscriptionId" => subscription_id}) do
+  defp payload(%Reply{} = reply, %{"subscriptionId" => subscription_id}) do
     %AbsintheClient.Subscription{
       socket: self(),
       ref: reply.ref,

mix.exs

@@ -16,11 +16,6 @@ defmodule Absinthe.Socket.MixProject do
       aliases: [
         "test.all": ["test --include integration"]
       ],
-      preferred_cli_env: [
-        "test.all": :test,
-        docs: :docs,
-        "hex.publish": :docs
-      ],
       test_coverage: [summary: [threshold: 80]]
     ]
   end
@@ -32,6 +27,10 @@ defmodule Absinthe.Socket.MixProject do
     ]
   end
 
+  def cli do
+    [preferred_envs: ["test.all": :test, docs: :docs, "hex.publish": :docs]]
+  end
+
   defp package do
     [
       description: "AbsintheClient is a GraphQL client designed for Elixir Absinthe.",