Add adobe/styler

Author: general-CbIC

.credo.exs

@@ -97,7 +97,7 @@
           {Credo.Check.Readability.AliasOrder, []},
           {Credo.Check.Readability.FunctionNames, []},
           {Credo.Check.Readability.LargeNumbers, []},
-          {Credo.Check.Readability.MaxLineLength, [priority: :low, max_length: 120]},
+          {Credo.Check.Readability.MaxLineLength, [priority: :low, max_length: 140]},
           {Credo.Check.Readability.ModuleAttributeNames, []},
           {Credo.Check.Readability.ModuleDoc, []},
           {Credo.Check.Readability.ModuleNames, []},

.formatter.exs

@@ -1,4 +1,5 @@
 # Used by "mix format"
 [
-  inputs: ["{mix,.formatter}.exs", "{config,lib,test}/**/*.{ex,exs}"]
+  inputs: ["{mix,.formatter}.exs", "{config,lib,test}/**/*.{ex,exs}"],
+  plugins: [Styler]
 ]

lib/poolex.ex

@@ -195,8 +195,7 @@ defmodule Poolex do
     try do
       GenServer.call(pool_id, {:get_idle_worker, caller_reference}, checkout_timeout)
     catch
-      :exit,
-      {:timeout, {GenServer, :call, [_pool_id, {:get_idle_worker, ^caller_reference}, _timeout]}} ->
+      :exit, {:timeout, {GenServer, :call, [_pool_id, {:get_idle_worker, ^caller_reference}, _timeout]}} ->
         {:error, :checkout_timeout}
     after
       GenServer.cast(pool_id, {:cancel_waiting, caller_reference})
@@ -264,8 +263,7 @@ defmodule Poolex do
     raise ArgumentError, message
   end
 
-  def add_idle_workers!(pool_id, workers_count)
-      when is_atom(pool_id) and is_integer(workers_count) do
+  def add_idle_workers!(pool_id, workers_count) when is_atom(pool_id) and is_integer(workers_count) do
     GenServer.call(pool_id, {:add_idle_workers, workers_count})
   end
 
@@ -280,8 +278,7 @@ defmodule Poolex do
     raise ArgumentError, message
   end
 
-  def remove_idle_workers!(pool_id, workers_count)
-      when is_atom(pool_id) and is_integer(workers_count) do
+  def remove_idle_workers!(pool_id, workers_count) when is_atom(pool_id) and is_integer(workers_count) do
     GenServer.call(pool_id, {:remove_idle_workers, workers_count})
   end
 
@@ -461,10 +458,7 @@ defmodule Poolex do
   end
 
   @impl GenServer
-  def handle_info(
-        {:DOWN, monitoring_reference, _process, dead_process_pid, _reason},
-        %State{} = state
-      ) do
+  def handle_info({:DOWN, monitoring_reference, _process, dead_process_pid, _reason}, %State{} = state) do
     case Monitoring.remove(state.monitor_pid, monitoring_reference) do
       :worker ->
         {:noreply, handle_down_worker(state, dead_process_pid)}

lib/poolex/private/busy_workers.ex

@@ -23,10 +23,7 @@ defmodule Poolex.Private.BusyWorkers do
 
   @doc false
   @spec remove(State.t(), Poolex.worker()) :: State.t()
-  def remove(
-        %State{busy_workers_impl: impl, busy_workers_state: busy_workers_state} = state,
-        worker
-      ) do
+  def remove(%State{busy_workers_impl: impl, busy_workers_state: busy_workers_state} = state, worker) do
     %State{state | busy_workers_state: impl.remove(busy_workers_state, worker)}
   end
 

lib/poolex/private/idle_workers.ex

@@ -17,10 +17,7 @@ defmodule Poolex.Private.IdleWorkers do
 
   @doc false
   @spec remove(State.t(), Poolex.worker()) :: State.t()
-  def remove(
-        %State{idle_workers_impl: impl, idle_workers_state: idle_workers_state} = state,
-        worker
-      ) do
+  def remove(%State{idle_workers_impl: impl, idle_workers_state: idle_workers_state} = state, worker) do
     %State{state | idle_workers_state: impl.remove(idle_workers_state, worker)}
   end
 

lib/poolex/private/waiting_callers.ex

@@ -11,10 +11,7 @@ defmodule Poolex.Private.WaitingCallers do
 
   @doc false
   @spec add(State.t(), Poolex.Caller.t()) :: State.t()
-  def add(
-        %State{waiting_callers_impl: impl, waiting_callers_state: waiting_callers_state} = state,
-        caller
-      ) do
+  def add(%State{waiting_callers_impl: impl, waiting_callers_state: waiting_callers_state} = state, caller) do
     %State{state | waiting_callers_state: impl.add(waiting_callers_state, caller)}
   end
 
@@ -26,9 +23,7 @@ defmodule Poolex.Private.WaitingCallers do
 
   @doc false
   @spec pop(State.t()) :: {Poolex.Caller.t(), State.t()} | :empty
-  def pop(
-        %State{waiting_callers_impl: impl, waiting_callers_state: waiting_callers_state} = state
-      ) do
+  def pop(%State{waiting_callers_impl: impl, waiting_callers_state: waiting_callers_state} = state) do
     case impl.pop(waiting_callers_state) do
       {caller, new_waiting_callers_state} ->
         {caller, %State{state | waiting_callers_state: new_waiting_callers_state}}
@@ -40,10 +35,7 @@ defmodule Poolex.Private.WaitingCallers do
 
   @doc false
   @spec remove_by_pid(State.t(), caller_pid :: pid()) :: State.t()
-  def remove_by_pid(
-        %State{waiting_callers_impl: impl, waiting_callers_state: waiting_callers_state} = state,
-        caller
-      ) do
+  def remove_by_pid(%State{waiting_callers_impl: impl, waiting_callers_state: waiting_callers_state} = state, caller) do
     %State{state | waiting_callers_state: impl.remove_by_pid(waiting_callers_state, caller)}
   end
 

mix.exs

@@ -38,7 +38,8 @@ defmodule Poolex.MixProject do
       {:doctor, ">= 0.0.0", only: [:dev], runtime: false},
       {:ex_check, "~> 0.16.0", only: [:dev], runtime: false},
       {:ex_doc, ">= 0.0.0", only: [:dev], runtime: false},
-      {:makeup_diff, ">= 0.0.0", only: [:dev], runtime: false}
+      {:makeup_diff, ">= 0.0.0", only: [:dev], runtime: false},
+      {:styler, "~> 1.1", only: [:dev, :test], runtime: false}
     ]
   end
 

mix.lock

@@ -15,6 +15,7 @@
   "makeup_elixir": {:hex, :makeup_elixir, "0.16.2", "627e84b8e8bf22e60a2579dad15067c755531fea049ae26ef1020cad58fe9578", [:mix], [{:makeup, "~> 1.0", [hex: :makeup, repo: "hexpm", optional: false]}, {:nimble_parsec, "~> 1.2.3 or ~> 1.3", [hex: :nimble_parsec, repo: "hexpm", optional: false]}], "hexpm", "41193978704763f6bbe6cc2758b84909e62984c7752b3784bd3c218bb341706b"},
   "makeup_erlang": {:hex, :makeup_erlang, "1.0.0", "6f0eff9c9c489f26b69b61440bf1b238d95badae49adac77973cbacae87e3c2e", [:mix], [{:makeup, "~> 1.0", [hex: :makeup, repo: "hexpm", optional: false]}], "hexpm", "ea7a9307de9d1548d2a72d299058d1fd2339e3d398560a0e46c27dab4891e4d2"},
   "nimble_parsec": {:hex, :nimble_parsec, "1.4.0", "51f9b613ea62cfa97b25ccc2c1b4216e81df970acd8e16e8d1bdc58fef21370d", [:mix], [], "hexpm", "9c565862810fb383e9838c1dd2d7d2c437b3d13b267414ba6af33e50d2d1cf28"},
+  "styler": {:hex, :styler, "1.1.2", "d5b14cd4f8f7cc45624d9485cd0edb277ec92583b118409cfcbcb7c78efa5f4b", [:mix], [], "hexpm", "b46edab1f129d0c839d426755e172cf92118e5fac877456d074156b335f1f80b"},
   "telemetry": {:hex, :telemetry, "1.3.0", "fedebbae410d715cf8e7062c96a1ef32ec22e764197f70cda73d82778d61e7a2", [:rebar3], [], "hexpm", "7015fc8919dbe63764f4b4b87a95b7c0996bd539e0d499be6ec9d7f3875b79e6"},
   "telemetry_poller": {:hex, :telemetry_poller, "1.1.0", "58fa7c216257291caaf8d05678c8d01bd45f4bdbc1286838a28c4bb62ef32999", [:rebar3], [{:telemetry, "~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "9eb9d9cbfd81cbd7cdd24682f8711b6e2b691289a0de6826e58452f28c103c8f"},
 }

test/poolex_test.exs

@@ -1,11 +1,12 @@
 defmodule PoolexTest do
   use ExUnit.Case, async: false
-  import PoolHelpers
 
-  doctest Poolex
+  import PoolHelpers
 
   alias Poolex.Private.DebugInfo
 
+  doctest Poolex
+
   describe "debug info" do
     test "valid after initialization" do
       initial_fun = fn -> 0 end
@@ -202,12 +203,9 @@ defmodule PoolexTest do
     test "works on callers" do
       pool_name = start_pool(worker_module: SomeWorker, workers_count: 1)
 
-      1..10
-      |> Enum.each(fn _ ->
+      Enum.each(1..10, fn _ ->
         spawn(fn ->
-          Poolex.run(pool_name, fn pid ->
-            GenServer.call(pid, {:do_some_work_with_delay, :timer.seconds(4)})
-          end)
+          Poolex.run(pool_name, fn pid -> GenServer.call(pid, {:do_some_work_with_delay, :timer.seconds(4)}) end)
         end)
       end)
 
@@ -523,21 +521,13 @@ defmodule PoolexTest do
       assert Poolex.child_spec(pool_id: :test_pool, worker_module: SomeWorker, workers_count: 5) ==
                %{
                  id: :test_pool,
-                 start:
-                   {Poolex, :start_link,
-                    [[pool_id: :test_pool, worker_module: SomeWorker, workers_count: 5]]}
+                 start: {Poolex, :start_link, [[pool_id: :test_pool, worker_module: SomeWorker, workers_count: 5]]}
                }
 
-      assert Poolex.child_spec(
-               pool_id: {:global, :biba},
-               worker_module: SomeWorker,
-               workers_count: 10
-             ) ==
+      assert Poolex.child_spec(pool_id: {:global, :biba}, worker_module: SomeWorker, workers_count: 10) ==
                %{
                  id: {:global, :biba},
-                 start:
-                   {Poolex, :start_link,
-                    [[pool_id: {:global, :biba}, worker_module: SomeWorker, workers_count: 10]]}
+                 start: {Poolex, :start_link, [[pool_id: {:global, :biba}, worker_module: SomeWorker, workers_count: 10]]}
                }
     end
   end
@@ -681,9 +671,7 @@ defmodule PoolexTest do
       ExUnit.Callbacks.start_supervised({Registry, [keys: :unique, name: TestRegistry]})
       name = {:via, Registry, {TestRegistry, "pool"}}
 
-      ExUnit.Callbacks.start_supervised(
-        {Poolex, [pool_id: name, worker_module: SomeWorker, workers_count: 5]}
-      )
+      ExUnit.Callbacks.start_supervised({Poolex, [pool_id: name, worker_module: SomeWorker, workers_count: 5]})
 
       state = Poolex.get_state(name)
 

test/support/metrics_case.ex

@@ -48,8 +48,7 @@ defmodule Poolex.MetricsCase do
             Enum.each(Map.get(groups, name, []), fn metric ->
               send(
                 self,
-                {:metric, metric.name, Map.get(measurements, metric.measurement),
-                 extract_tags(metric, metadata)}
+                {:metric, metric.name, Map.get(measurements, metric.measurement), extract_tags(metric, metadata)}
               )
             end)
           end