From: Uk Chukundah <uk@juicyway.com>
Date: Sun, 5 Jan 2025 09:58:10 +0000 (+0100)
Subject: Format
X-Git-Url: http://git.entropealabs.com/?a=commitdiff_plain;h=809a841184f7c025bea66eb92cca5c082696034f;p=wampex_client.git

Format
---

diff --git a/lib/client.ex b/lib/client.ex
index 0b6ca6a..651d0a0 100644
--- a/lib/client.ex
+++ b/lib/client.ex
@@ -25,28 +25,17 @@ defmodule Wampex.Client do
 
   @spec init({atom(), Sess.t(), boolean()}) ::
           {:ok, {:supervisor.sup_flags(), [:supervisor.child_spec()]}} | :ignore
-  def init(
-        {name, %Sess{url: url, transport: t, serializer: s, protocol: p} = session_data,
-         reconnect}
-      ) do
+  def init({name, %Sess{url: url, transport: t, serializer: s, protocol: p} = session_data, reconnect}) do
     subscriber_registry = subscriber_registry_name(name)
     callee_registry = callee_registry_name(name)
     dependent_registry = dependent_registry_name(name)
     session_data = %Sess{session_data | name: name, roles: [Peer | session_data.roles]}
 
     children = [
-      {Registry,
-       [keys: :duplicate, name: subscriber_registry, partitions: System.schedulers_online()]},
+      {Registry, [keys: :duplicate, name: subscriber_registry, partitions: System.schedulers_online()]},
       {Registry, [keys: :unique, name: callee_registry, partitions: System.schedulers_online()]},
-      {Registry,
-       [keys: :unique, name: dependent_registry, partitions: System.schedulers_online()]},
-      {t,
-       name: name,
-       url: url,
-       session_data: session_data,
-       protocol: p,
-       serializer: s,
-       reconnect: reconnect}
+      {Registry, [keys: :unique, name: dependent_registry, partitions: System.schedulers_online()]},
+      {t, name: name, url: url, session_data: session_data, protocol: p, serializer: s, reconnect: reconnect}
     ]
 
     Supervisor.init(children, strategy: :one_for_one)
diff --git a/lib/client/handler.ex b/lib/client/handler.ex
index b153f93..d25430d 100644
--- a/lib/client/handler.ex
+++ b/lib/client/handler.ex
@@ -92,9 +92,7 @@ defmodule Wampex.Client.Handler do
     procedures = Module.get_attribute(env.module, :procedures) |> Enum.uniq()
     topics = Module.get_attribute(env.module, :topics) |> Enum.uniq()
 
-    Logger.info(
-      "#{env.module} | Registering topics: #{inspect(topics)}, procedures: #{inspect(procedures)}"
-    )
+    Logger.info("#{env.module} | Registering topics: #{inspect(topics)}, procedures: #{inspect(procedures)}")
 
     quote do
       require Logger
diff --git a/lib/client/session.ex b/lib/client/session.ex
index 7755b44..d2c0421 100644
--- a/lib/client/session.ex
+++ b/lib/client/session.ex
@@ -247,8 +247,7 @@ defmodule Wampex.Client.Session do
       send(pid, {:connected, name})
     end)
 
-    {:ok, %SL{sl | data: %Sess{session | connected: true}},
-     [{:next_event, :internal, :established}]}
+    {:ok, %SL{sl | data: %Sess{session | connected: true}}, [{:next_event, :internal, :established}]}
   end
 
   @impl true
@@ -379,8 +378,7 @@ defmodule Wampex.Client.Session do
 
   @impl true
   def handle_info({:set_message, message}, _, %SL{data: %Sess{} = sess} = data) do
-    {:ok, %SL{data | data: %Sess{sess | message: message}},
-     [{:next_event, :internal, :message_received}]}
+    {:ok, %SL{data | data: %Sess{sess | message: message}}, [{:next_event, :internal, :message_received}]}
   end
 
   @impl true