Skip to content

Commit 2f7aae2

Browse files
committed
fix: Fix format
1 parent 6f8b8a1 commit 2f7aae2

File tree

3 files changed

+54
-28
lines changed

3 files changed

+54
-28
lines changed

lib/phoenix/session_process.ex

Lines changed: 35 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -52,26 +52,41 @@ defmodule Phoenix.SessionProcess do
5252
@spec start(binary()) :: :ignore | {:error, any()} | {:ok, pid()} | {:ok, pid(), any()}
5353
defdelegate start(session_id), to: Phoenix.SessionProcess.ProcessSupervisor, as: :start_session
5454
@spec start(binary(), atom()) :: :ignore | {:error, any()} | {:ok, pid()} | {:ok, pid(), any()}
55-
defdelegate start(session_id, module), to: Phoenix.SessionProcess.ProcessSupervisor, as: :start_session
55+
defdelegate start(session_id, module),
56+
to: Phoenix.SessionProcess.ProcessSupervisor,
57+
as: :start_session
58+
5659
@spec start(binary(), atom(), any()) ::
5760
:ignore | {:error, any()} | {:ok, pid()} | {:ok, pid(), any()}
58-
defdelegate start(session_id, module, arg), to: Phoenix.SessionProcess.ProcessSupervisor, as: :start_session
61+
defdelegate start(session_id, module, arg),
62+
to: Phoenix.SessionProcess.ProcessSupervisor,
63+
as: :start_session
5964

6065
@spec started?(binary()) :: boolean()
61-
defdelegate started?(session_id), to: Phoenix.SessionProcess.ProcessSupervisor, as: :session_process_started?
66+
defdelegate started?(session_id),
67+
to: Phoenix.SessionProcess.ProcessSupervisor,
68+
as: :session_process_started?
6269

6370
@spec terminate(binary()) :: :ok | {:error, :not_found}
64-
defdelegate terminate(session_id), to: Phoenix.SessionProcess.ProcessSupervisor, as: :terminate_session
71+
defdelegate terminate(session_id),
72+
to: Phoenix.SessionProcess.ProcessSupervisor,
73+
as: :terminate_session
6574

6675
@spec call(binary(), any(), :infinity | non_neg_integer()) :: any()
67-
defdelegate call(session_id, request, timeout \\ 15_000), to: Phoenix.SessionProcess.ProcessSupervisor, as: :call_on_session
76+
defdelegate call(session_id, request, timeout \\ 15_000),
77+
to: Phoenix.SessionProcess.ProcessSupervisor,
78+
as: :call_on_session
6879

6980
@spec cast(binary(), any()) :: :ok
70-
defdelegate cast(session_id, request), to: Phoenix.SessionProcess.ProcessSupervisor, as: :cast_on_session
81+
defdelegate cast(session_id, request),
82+
to: Phoenix.SessionProcess.ProcessSupervisor,
83+
as: :cast_on_session
7184

7285
@spec list_session() :: [{binary(), pid()}, ...]
7386
def list_session() do
74-
Registry.select(Phoenix.SessionProcess.Registry, [{{:"$1", :"$2", :_}, [], [{{:"$1", :"$2"}}]}])
87+
Registry.select(Phoenix.SessionProcess.Registry, [
88+
{{:"$1", :"$2", :_}, [], [{{:"$1", :"$2"}}]}
89+
])
7590
end
7691

7792
defmacro __using__(:process) do
@@ -81,13 +96,17 @@ defmodule Phoenix.SessionProcess do
8196
def start_link(name: name, arg: arg) do
8297
GenServer.start_link(__MODULE__, arg, name: name)
8398
end
99+
84100
def start_link(name: name) do
85101
GenServer.start_link(__MODULE__, %{}, name: name)
86102
end
87103

88104
def get_session_id() do
89105
current_pid = self()
90-
Registry.select(Phoenix.SessionProcess.Registry, [{{:"$1", :"$2", :_}, [{:"==", :"$2", current_pid}], [{{:"$1", :"$2"}}]}])
106+
107+
Registry.select(Phoenix.SessionProcess.Registry, [
108+
{{:"$1", :"$2", :_}, [{:==, :"$2", current_pid}], [{{:"$1", :"$2"}}]}
109+
])
91110
|> Enum.at(0)
92111
|> elem(0)
93112
end
@@ -101,6 +120,7 @@ defmodule Phoenix.SessionProcess do
101120
def start_link(name: name, args: args) do
102121
GenServer.start_link(__MODULE__, args, name: name)
103122
end
123+
104124
def start_link(name: name) do
105125
GenServer.start_link(__MODULE__, %{}, name: name)
106126
end
@@ -113,7 +133,10 @@ defmodule Phoenix.SessionProcess do
113133

114134
def get_session_id() do
115135
current_pid = self()
116-
Registry.select(Phoenix.SessionProcess.Registry, [{{:"$1", :"$2", :_}, [{:"==", :"$2", current_pid}], [{{:"$1", :"$2"}}]}])
136+
137+
Registry.select(Phoenix.SessionProcess.Registry, [
138+
{{:"$1", :"$2", :_}, [{:==, :"$2", current_pid}], [{{:"$1", :"$2"}}]}
139+
])
117140
|> Enum.at(0)
118141
|> elem(0)
119142
end
@@ -129,7 +152,9 @@ defmodule Phoenix.SessionProcess do
129152
end
130153

131154
def handle_info({:DOWN, _ref, :process, pid, _reason}, state) do
132-
state = state |> Map.update(:__live_view__, [], fn views -> views |> Enum.filter(&(&1 != pid)) end)
155+
state =
156+
state
157+
|> Map.update(:__live_view__, [], fn views -> views |> Enum.filter(&(&1 != pid)) end)
133158

134159
{:noreply, state}
135160
end

lib/phoenix/session_process/process_superviser.ex

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -54,6 +54,7 @@ defmodule Phoenix.SessionProcess.ProcessSupervisor do
5454
@spec terminate_session(binary()) :: :ok | {:error, :not_found}
5555
def terminate_session(session_id) do
5656
Logger.debug("End Session: #{inspect(session_id)}")
57+
5758
session_id
5859
|> session_process_pid()
5960
|> terminate_child()

lib/phoenix/session_process/session_id.ex

Lines changed: 18 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -8,27 +8,27 @@ defmodule Phoenix.SessionProcess.SessionId do
88
plug Phoenix.SessionProcess.SessionId
99
1010
"""
11-
@behaviour Plug
11+
@behaviour Plug
1212

13-
import Plug.Conn
13+
import Plug.Conn
1414

15-
@impl true
16-
def init(default), do: default
15+
@impl true
16+
def init(default), do: default
1717

18-
@impl true
19-
def call(conn, _config) do
20-
case get_session(conn, :session_id) do
21-
nil ->
22-
session_id = generate_unique_session_id()
23-
put_session(conn, :session_id, session_id)
18+
@impl true
19+
def call(conn, _config) do
20+
case get_session(conn, :session_id) do
21+
nil ->
22+
session_id = generate_unique_session_id()
23+
put_session(conn, :session_id, session_id)
2424

25-
_session_id ->
26-
conn
27-
end
28-
end
25+
_session_id ->
26+
conn
27+
end
28+
end
2929

30-
@spec generate_unique_session_id() :: binary()
31-
def generate_unique_session_id() do
32-
:crypto.strong_rand_bytes(16) |> Base.encode16()
33-
end
30+
@spec generate_unique_session_id() :: binary()
31+
def generate_unique_session_id() do
32+
:crypto.strong_rand_bytes(16) |> Base.encode16()
33+
end
3434
end

0 commit comments

Comments
 (0)