Elixir 1.12 and update deps (#82)

.credo.exs

@@ -33,7 +33,7 @@
       # If you want to enforce a style guide and need a more traditional linting
       # experience, you can change `strict` to `true` below:
       #
-      strict: false,
+      strict: true,
       #
       # If you want to use uncolored output by default, you can change `color`
       # to `false` below:

.dialyzerignore

@@ -1,3 +0,0 @@
-:0: Unknown function 'Elixir.ExUnit.Callbacks':'__merge__'/3
-:0: Unknown function 'Elixir.ExUnit.Callbacks':on_exit/1
-:0: Unknown function 'Elixir.ExUnit.CaseTemplate':'__proxy__'/2

Dockerfile

@@ -1,4 +1,4 @@
-FROM public.ecr.aws/prima/elixir:1.11.2-1
+FROM public.ecr.aws/prima/elixir:1.12.0-1
 
 WORKDIR /code
 

mix.exs

@@ -5,7 +5,7 @@ defmodule Amqpx.MixProject do
     [
       app: :amqpx,
       name: "amqpx",
-      version: "5.5.0",
+      version: "5.6.0",
       elixir: "~> 1.7",
       elixirc_paths: elixirc_paths(Mix.env()),
       start_permanent: Mix.env() == :production,
@@ -37,24 +37,25 @@ defmodule Amqpx.MixProject do
     [
       check: [
         "format --check-formatted mix.exs \"lib/**/*.{ex,exs}\" \"test/**/*.{ex,exs}\" \"priv/**/*.{ex,exs}\" \"config/**/*.{ex,exs}\"",
+        "deps.unlock --check-unused",
         "credo",
         "dialyzer"
       ],
       "format.all": [
-        "format mix.exs \"lib/**/*.{ex,exs}\" \"test/**/*.{ex,exs}\" \"priv/**/*.{ex,exs}\" \"config/**/*.{ex,exs}\""
+        "format mix.exs \"lib/**/*.{ex,exs}\" \"test/**/*.{ex,exs}\" \"config/**/*.{ex,exs}\""
       ]
     ]
   end
 
   # Run "mix help deps" to learn about dependencies.
   defp deps do
     [
-      {:amqp_client, "~> 3.7.20"},
-      {:rabbit_common, "~> 3.7.20"},
-      {:elixir_uuid, "~> 1.1"},
-      {:credo, "~> 1.1", only: [:dev, :test]},
-      {:mock, "~> 0.3.0", only: :test},
-      {:dialyxir, "~> 1.0.0-rc", only: [:dev, :test], runtime: false},
+      {:amqp_client, "~> 3.8"},
+      {:rabbit_common, "~> 3.8"},
+      {:elixir_uuid, "~> 1.2"},
+      {:credo, "~> 1.5", only: [:dev, :test]},
+      {:mock, "~> 0.3.7", only: :test},
+      {:dialyxir, "~> 1.1", only: [:dev, :test], runtime: false},
       {:ex_doc, ">= 0.0.0", only: :dev, runtime: false}
     ]
   end

mix.lock

@@ -1,24 +1,24 @@
 %{
-  "amqp_client": {:hex, :amqp_client, "3.7.24", "9d336f9a425cbb5f6ffefa586012c3d3f68a72e934c9ef0f41e2764fa92dc84c", [:make, :rebar3], [{:rabbit_common, "3.7.24", [hex: :rabbit_common, repo: "hexpm", optional: false]}], "hexpm", "27fcbbd7b43498a4041b4869837e2b2c1d27ab730c9b58a84d633360f9e0b4af"},
+  "amqp_client": {:hex, :amqp_client, "3.8.14", "7569517aefb47e0d1c41bca2f4768dc8a2d88487daf7819fecca0d78943f293c", [:make, :rebar3], [{:rabbit_common, "3.8.14", [hex: :rabbit_common, repo: "hexpm", optional: false]}], "hexpm", "e5ba3ac18abbe34a1d990a6bcac25633dc7061ab8f8d101c7dcff97f49f4c523"},
   "bunt": {:hex, :bunt, "0.2.0", "951c6e801e8b1d2cbe58ebbd3e616a869061ddadcc4863d0a2182541acae9a38", [:mix], [], "hexpm", "7af5c7e09fe1d40f76c8e4f9dd2be7cebd83909f31fee7cd0e9eadc567da8353"},
-  "credentials_obfuscation": {:hex, :credentials_obfuscation, "1.1.0", "513793cc20c18afc9e03e584b436192a751a8344890e03a8741c65c8d6866fab", [:rebar3], [], "hexpm", "2d1bc574d129ff76309a03874c245193c6375bc766734e008888e636b250d5df"},
-  "credo": {:hex, :credo, "1.3.2", "08d456dcf3c24da162d02953fb07267e444469d8dad3a2ae47794938ea467b3a", [:mix], [{:bunt, "~> 0.2.0", [hex: :bunt, repo: "hexpm", optional: false]}, {:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: false]}], "hexpm", "b11d28cce1f1f399dddffd42d8e21dcad783309e230f84b70267b1a5546468b6"},
-  "dialyxir": {:hex, :dialyxir, "1.0.0", "6a1fa629f7881a9f5aaf3a78f094b2a51a0357c843871b8bc98824e7342d00a5", [:mix], [{:erlex, ">= 0.2.6", [hex: :erlex, repo: "hexpm", optional: false]}], "hexpm", "aeb06588145fac14ca08d8061a142d52753dbc2cf7f0d00fc1013f53f8654654"},
+  "credentials_obfuscation": {:hex, :credentials_obfuscation, "2.4.0", "9fb57683b84899ca3546b384e59ab5d3054a9f334eba50d74c82cd0ae82dd6ca", [:rebar3], [], "hexpm", "d28a89830e30698b075de9a4dbe683a20685c6bed1e3b7df744a0c06e6ff200a"},
+  "credo": {:hex, :credo, "1.5.5", "e8f422026f553bc3bebb81c8e8bf1932f498ca03339856c7fec63d3faac8424b", [:mix], [{:bunt, "~> 0.2.0", [hex: :bunt, repo: "hexpm", optional: false]}, {:file_system, "~> 0.2.8", [hex: :file_system, repo: "hexpm", optional: false]}, {:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: false]}], "hexpm", "dd8623ab7091956a855dc9f3062486add9c52d310dfd62748779c4315d8247de"},
+  "dialyxir": {:hex, :dialyxir, "1.1.0", "c5aab0d6e71e5522e77beff7ba9e08f8e02bad90dfbeffae60eaf0cb47e29488", [:mix], [{:erlex, ">= 0.2.6", [hex: :erlex, repo: "hexpm", optional: false]}], "hexpm", "07ea8e49c45f15264ebe6d5b93799d4dd56a44036cf42d0ad9c960bc266c0b9a"},
   "earmark_parser": {:hex, :earmark_parser, "1.4.13", "0c98163e7d04a15feb62000e1a891489feb29f3d10cb57d4f845c405852bbef8", [:mix], [], "hexpm", "d602c26af3a0af43d2f2645613f65841657ad6efc9f0e361c3b6c06b578214ba"},
   "elixir_uuid": {:hex, :elixir_uuid, "1.2.1", "dce506597acb7e6b0daeaff52ff6a9043f5919a4c3315abb4143f0b00378c097", [:mix], [], "hexpm", "f7eba2ea6c3555cea09706492716b0d87397b88946e6380898c2889d68585752"},
   "erlex": {:hex, :erlex, "0.2.6", "c7987d15e899c7a2f34f5420d2a2ea0d659682c06ac607572df55a43753aa12e", [:mix], [], "hexpm", "2ed2e25711feb44d52b17d2780eabf998452f6efda104877a3881c2f8c0c0c75"},
   "ex_doc": {:hex, :ex_doc, "0.24.2", "e4c26603830c1a2286dae45f4412a4d1980e1e89dc779fcd0181ed1d5a05c8d9", [:mix], [{:earmark_parser, "~> 1.4.0", [hex: :earmark_parser, repo: "hexpm", optional: false]}, {:makeup_elixir, "~> 0.14", [hex: :makeup_elixir, repo: "hexpm", optional: false]}, {:makeup_erlang, "~> 0.1", [hex: :makeup_erlang, repo: "hexpm", optional: false]}], "hexpm", "e134e1d9e821b8d9e4244687fb2ace58d479b67b282de5158333b0d57c6fb7da"},
+  "file_system": {:hex, :file_system, "0.2.10", "fb082005a9cd1711c05b5248710f8826b02d7d1784e7c3451f9c1231d4fc162d", [:mix], [], "hexpm", "41195edbfb562a593726eda3b3e8b103a309b733ad25f3d642ba49696bf715dc"},
   "goldrush": {:hex, :goldrush, "0.1.9", "f06e5d5f1277da5c413e84d5a2924174182fb108dabb39d5ec548b27424cd106", [:rebar3], [], "hexpm", "99cb4128cffcb3227581e5d4d803d5413fa643f4eb96523f77d9e6937d994ceb"},
-  "jason": {:hex, :jason, "1.2.0", "10043418c42d2493d0ee212d3fddd25d7ffe484380afad769a0a38795938e448", [:mix], [{:decimal, "~> 1.0", [hex: :decimal, repo: "hexpm", optional: true]}], "hexpm", "116747dbe057794c3a3e4e143b7c8390b29f634e16c78a7f59ba75bfa6852e7f"},
-  "jsx": {:hex, :jsx, "2.9.0", "d2f6e5f069c00266cad52fb15d87c428579ea4d7d73a33669e12679e203329dd", [:mix, :rebar3], [], "hexpm", "8ee1db1cabafdd578a2776a6aaae87c2a8ce54b47b59e9ec7dab5d7eb71cd8dc"},
-  "lager": {:hex, :lager, "3.8.0", "3402b9a7e473680ca179fc2f1d827cab88dd37dd1e6113090c6f45ef05228a1c", [:rebar3], [{:goldrush, "0.1.9", [hex: :goldrush, repo: "hexpm", optional: false]}], "hexpm", "f6cb541b688eab60730d8d286eb77256a5a9ad06eac10d43beaf55d07e68bbb6"},
+  "jason": {:hex, :jason, "1.2.2", "ba43e3f2709fd1aa1dce90aaabfd039d000469c05c56f0b8e31978e03fa39052", [:mix], [{:decimal, "~> 1.0 or ~> 2.0", [hex: :decimal, repo: "hexpm", optional: true]}], "hexpm", "18a228f5f0058ee183f29f9eae0805c6e59d61c3b006760668d8d18ff0d12179"},
+  "jsx": {:hex, :jsx, "2.11.0", "08154624050333919b4ac1b789667d5f4db166dc50e190c4d778d1587f102ee0", [:rebar3], [], "hexpm", "eed26a0d04d217f9eecefffb89714452556cf90eb38f290a27a4d45b9988f8c0"},
+  "lager": {:hex, :lager, "3.8.2", "b180b814fd8b7082b6ca8aaf287e55a908d304cfc7a240d32f4db2d07092b7d0", [:rebar3], [{:goldrush, "0.1.9", [hex: :goldrush, repo: "hexpm", optional: false]}], "hexpm", "73329ce700410b423f64aafc5f94583073904899098e4461f3558ed2980462ab"},
   "makeup": {:hex, :makeup, "1.0.5", "d5a830bc42c9800ce07dd97fa94669dfb93d3bf5fcf6ea7a0c67b2e0e4a7f26c", [:mix], [{:nimble_parsec, "~> 0.5 or ~> 1.0", [hex: :nimble_parsec, repo: "hexpm", optional: false]}], "hexpm", "cfa158c02d3f5c0c665d0af11512fed3fba0144cf1aadee0f2ce17747fba2ca9"},
   "makeup_elixir": {:hex, :makeup_elixir, "0.15.1", "b5888c880d17d1cc3e598f05cdb5b5a91b7b17ac4eaf5f297cb697663a1094dd", [:mix], [{:makeup, "~> 1.0", [hex: :makeup, repo: "hexpm", optional: false]}, {:nimble_parsec, "~> 1.1", [hex: :nimble_parsec, repo: "hexpm", optional: false]}], "hexpm", "db68c173234b07ab2a07f645a5acdc117b9f99d69ebf521821d89690ae6c6ec8"},
   "makeup_erlang": {:hex, :makeup_erlang, "0.1.1", "3fcb7f09eb9d98dc4d208f49cc955a34218fc41ff6b84df7c75b3e6e533cc65f", [:mix], [{:makeup, "~> 1.0", [hex: :makeup, repo: "hexpm", optional: false]}], "hexpm", "174d0809e98a4ef0b3309256cbf97101c6ec01c4ab0b23e926a9e17df2077cbb"},
-  "meck": {:hex, :meck, "0.8.13", "ffedb39f99b0b99703b8601c6f17c7f76313ee12de6b646e671e3188401f7866", [:rebar3], [], "hexpm", "d34f013c156db51ad57cc556891b9720e6a1c1df5fe2e15af999c84d6cebeb1a"},
-  "mock": {:hex, :mock, "0.3.4", "c5862eb3b8c64237f45f586cf00c9d892ba07bb48305a43319d428ce3c2897dd", [:mix], [{:meck, "~> 0.8.13", [hex: :meck, repo: "hexpm", optional: false]}], "hexpm", "e6d886252f1a41f4ba06ecf2b4c8d38760b34b1c08a11c28f7397b2e03995964"},
+  "meck": {:hex, :meck, "0.9.2", "85ccbab053f1db86c7ca240e9fc718170ee5bda03810a6292b5306bf31bae5f5", [:rebar3], [], "hexpm", "81344f561357dc40a8344afa53767c32669153355b626ea9fcbc8da6b3045826"},
+  "mock": {:hex, :mock, "0.3.7", "75b3bbf1466d7e486ea2052a73c6e062c6256fb429d6797999ab02fa32f29e03", [:mix], [{:meck, "~> 0.9.2", [hex: :meck, repo: "hexpm", optional: false]}], "hexpm", "4da49a4609e41fd99b7836945c26f373623ea968cfb6282742bcb94440cf7e5c"},
   "nimble_parsec": {:hex, :nimble_parsec, "1.1.0", "3a6fca1550363552e54c216debb6a9e95bd8d32348938e13de5eda962c0d7f89", [:mix], [], "hexpm", "08eb32d66b706e913ff748f11694b17981c0b04a33ef470e33e11b3d3ac8f54b"},
-  "rabbit_common": {:hex, :rabbit_common, "3.7.24", "d06fa24492daa5c39f1811437f908448f189d965935e7e8070d67856dcb9c3ce", [:make, :rebar3], [{:credentials_obfuscation, "1.1.0", [hex: :credentials_obfuscation, repo: "hexpm", optional: false]}, {:jsx, "2.9.0", [hex: :jsx, repo: "hexpm", optional: false]}, {:lager, "3.8.0", [hex: :lager, repo: "hexpm", optional: false]}, {:ranch, "1.7.1", [hex: :ranch, repo: "hexpm", optional: false]}, {:recon, "2.5.0", [hex: :recon, repo: "hexpm", optional: false]}], "hexpm", "012185b70d520b2faddd427902e6cc793657cc659d527f098f457fa3c3dee2a7"},
-  "ranch": {:hex, :ranch, "1.7.1", "6b1fab51b49196860b733a49c07604465a47bdb78aa10c1c16a3d199f7f8c881", [:rebar3], [], "hexpm", "451d8527787df716d99dc36162fca05934915db0b6141bbdac2ea8d3c7afc7d7"},
-  "recon": {:hex, :recon, "2.5.0", "2f7fcbec2c35034bade2f9717f77059dc54eb4e929a3049ca7ba6775c0bd66cd", [:mix, :rebar3], [], "hexpm", "72f3840fedd94f06315c523f6cecf5b4827233bed7ae3fe135b2a0ebeab5e196"},
+  "rabbit_common": {:hex, :rabbit_common, "3.8.14", "cc1604891295cd82f34597f1526ac611ea7b6a0e57b3dd79b41cb4224bcc6ec5", [:make, :rebar3], [{:credentials_obfuscation, "2.4.0", [hex: :credentials_obfuscation, repo: "hexpm", optional: false]}, {:jsx, "2.11.0", [hex: :jsx, repo: "hexpm", optional: false]}, {:lager, "3.8.2", [hex: :lager, repo: "hexpm", optional: false]}, {:recon, "2.5.1", [hex: :recon, repo: "hexpm", optional: false]}], "hexpm", "27409e425413cdd3fc2c077cf08226c4a307d56b1467883f26ab3789b2e106d0"},
+  "recon": {:hex, :recon, "2.5.1", "430ffa60685ac1efdfb1fe4c97b8767c92d0d92e6e7c3e8621559ba77598678a", [:mix, :rebar3], [], "hexpm", "5721c6b6d50122d8f68cccac712caa1231f97894bab779eff5ff0f886cb44648"},
 }

test/basic_test.exs

@@ -4,7 +4,7 @@ defmodule BasicTest do
   alias Amqpx.{Basic, Connection, Channel, Queue}
 
   setup do
-    {:ok, conn} = Connection.open(Application.get_env(:amqpx, :amqp_connection))
+    {:ok, conn} = Connection.open(Application.fetch_env!(:amqpx, :amqp_connection))
     {:ok, chan} = Channel.open(conn)
 
     on_exit(fn ->

test/channel_test.exs

@@ -4,7 +4,7 @@ defmodule ChannelTest do
   alias Amqpx.{Channel, Connection}
 
   setup do
-    {:ok, conn} = Connection.open(Application.get_env(:amqpx, :amqp_connection))
+    {:ok, conn} = Connection.open(Application.fetch_env!(:amqpx, :amqp_connection))
     on_exit(fn -> :ok = Connection.close(conn) end)
     {:ok, conn: conn}
   end

test/confirm_test.exs

@@ -4,7 +4,7 @@ defmodule ConfirmTest do
   alias Amqpx.{Basic, Confirm, Connection, Channel}
 
   setup do
-    {:ok, conn} = Connection.open(Application.get_env(:amqpx, :amqp_connection))
+    {:ok, conn} = Connection.open(Application.fetch_env!(:amqpx, :amqp_connection))
     {:ok, chan} = Channel.open(conn)
     :ok = Confirm.select(chan)
 

test/exchange_test.exs

@@ -4,7 +4,7 @@ defmodule ExchangeTest do
   alias Amqpx.{Channel, Connection, Exchange}
 
   setup do
-    {:ok, conn} = Connection.open(Application.get_env(:amqpx, :amqp_connection))
+    {:ok, conn} = Connection.open(Application.fetch_env!(:amqpx, :amqp_connection))
     {:ok, chan} = Channel.open(conn)
     on_exit(fn -> :ok = Connection.close(conn) end)
     {:ok, conn: conn, chan: chan}

test/gen_test.exs

@@ -1,18 +1,23 @@
 defmodule Amqpx.Test.AmqpxTest do
   use ExUnit.Case
 
-  alias Amqpx.Test.Support.{Consumer1, Consumer2, Producer1, Producer2, Producer3}
+  alias Amqpx.Test.Support.Consumer1
+  alias Amqpx.Test.Support.Consumer2
+  alias Amqpx.Test.Support.Producer1
+  alias Amqpx.Test.Support.Producer2
+  alias Amqpx.Test.Support.Producer3
+
   import Mock
 
   setup_all do
     Amqpx.Gen.ConnectionManager.start_link(%{
-      connection_params: Application.get_env(:amqpx, :amqp_connection)
+      connection_params: Application.fetch_env!(:amqpx, :amqp_connection)
     })
 
-    {:ok, _} = Amqpx.Gen.Producer.start_link(Application.get_env(:amqpx, :producer))
-    {:ok, _} = Amqpx.Gen.Producer.start_link(Application.get_env(:amqpx, :producer2))
+    {:ok, _} = Amqpx.Gen.Producer.start_link(Application.fetch_env!(:amqpx, :producer))
+    {:ok, _} = Amqpx.Gen.Producer.start_link(Application.fetch_env!(:amqpx, :producer2))
 
-    Enum.each(Application.get_env(:amqpx, :consumers), &Amqpx.Gen.Consumer.start_link(&1))
+    Enum.each(Application.fetch_env!(:amqpx, :consumers), &Amqpx.Gen.Consumer.start_link(&1))
 
     :timer.sleep(1_000)
     :ok

test/queue_test.exs

@@ -4,7 +4,7 @@ defmodule QueueTest do
   alias Amqpx.{Channel, Connection, Exchange, Queue}
 
   setup do
-    {:ok, conn} = Connection.open(Application.get_env(:amqpx, :amqp_connection))
+    {:ok, conn} = Connection.open(Application.fetch_env!(:amqpx, :amqp_connection))
     {:ok, chan} = Channel.open(conn)
     on_exit(fn -> :ok = Connection.close(conn) end)
     {:ok, conn: conn, chan: chan}

test/return_test.exs

@@ -4,7 +4,7 @@ defmodule ReturnTest do
   alias Amqpx.{Basic, Confirm, Connection, Channel}
 
   setup do
-    {:ok, conn} = Connection.open(Application.get_env(:amqpx, :amqp_connection))
+    {:ok, conn} = Connection.open(Application.fetch_env!(:amqpx, :amqp_connection))
     {:ok, chan} = Channel.open(conn)
     :ok = Confirm.select(chan)
 

test/support/consumer/consumer_1.ex

@@ -2,14 +2,12 @@ defmodule Amqpx.Test.Support.Consumer1 do
   @moduledoc nil
   @behaviour Amqpx.Gen.Consumer
 
-  alias Amqpx.{Basic, Helper}
-
-  @config Application.get_env(:amqpx, __MODULE__)
-  @queue Application.get_env(:amqpx, __MODULE__)[:queue]
+  alias Amqpx.Basic
+  alias Amqpx.Helper
 
   def setup(channel) do
-    Helper.declare(channel, @config)
-    Basic.consume(channel, @queue, self())
+    Helper.declare(channel, Application.fetch_env!(:amqpx, __MODULE__))
+    Basic.consume(channel, Application.fetch_env!(:amqpx, __MODULE__)[:queue], self())
     {:ok, %{}}
   end
 

test/support/consumer/consumer_2.ex

@@ -2,14 +2,12 @@ defmodule Amqpx.Test.Support.Consumer2 do
   @moduledoc nil
   @behaviour Amqpx.Gen.Consumer
 
-  alias Amqpx.{Basic, Helper}
-
-  @config Application.get_env(:amqpx, __MODULE__)
-  @queue Application.get_env(:amqpx, __MODULE__)[:queue]
+  alias Amqpx.Basic
+  alias Amqpx.Helper
 
   def setup(channel) do
-    Helper.declare(channel, @config)
-    Basic.consume(channel, @queue, self())
+    Helper.declare(channel, Application.fetch_env!(:amqpx, __MODULE__))
+    Basic.consume(channel, Application.fetch_env!(:amqpx, __MODULE__)[:queue], self())
     {:ok, %{}}
   end
 

test/support/consumer/consumer_3.ex

@@ -2,14 +2,12 @@ defmodule Amqpx.Test.Support.Consumer3 do
   @moduledoc nil
   @behaviour Amqpx.Gen.Consumer
 
-  alias Amqpx.{Basic, Helper}
-
-  @config Application.get_env(:amqpx, __MODULE__)
-  @queue Application.get_env(:amqpx, __MODULE__)[:queue]
+  alias Amqpx.Basic
+  alias Amqpx.Helper
 
   def setup(channel) do
-    Helper.declare(channel, @config)
-    Basic.consume(channel, @queue, self())
+    Helper.declare(channel, Application.fetch_env!(:amqpx, __MODULE__))
+    Basic.consume(channel, Application.fetch_env!(:amqpx, __MODULE__)[:queue], self())
     {:ok, %{}}
   end
 

test/support/producer/producer_1.ex

@@ -1,8 +1,6 @@
 defmodule Amqpx.Test.Support.Producer1 do
   @moduledoc nil
 
-  require Logger
-
   alias Amqpx.Gen.Producer
 
   @spec send_payload(map) :: :ok | :error

test/support/producer/producer_2.ex

@@ -1,8 +1,6 @@
 defmodule Amqpx.Test.Support.Producer2 do
   @moduledoc nil
 
-  require Logger
-
   alias Amqpx.Gen.Producer
 
   @spec send_payload(map) :: :ok | :error

test/support/producer/producer_3.ex

@@ -1,8 +1,6 @@
 defmodule Amqpx.Test.Support.Producer3 do
   @moduledoc nil
 
-  require Logger
-
   alias Amqpx.Gen.Producer
 
   @spec send_payload(map) :: :ok | :error