style: fix code formatting for CI

Author: GSMLG-BOT

lib/phoenix/session_process/cleanup.ex

@@ -101,7 +101,8 @@ defmodule Phoenix.SessionProcess.Cleanup do
   @impl true
   def handle_info({:cleanup_session, session_id}, state) do
     # Check if session is actually expired (might have been refreshed)
-    if ActivityTracker.expired?(session_id) and ProcessSupervisor.session_process_started?(session_id) do
+    if ActivityTracker.expired?(session_id) and
+         ProcessSupervisor.session_process_started?(session_id) do
       session_pid = ProcessSupervisor.session_process_pid(session_id)
 
       Telemetry.emit_auto_cleanup_event(

lib/phoenix/session_process/rate_limiter.ex

@@ -114,9 +114,10 @@ defmodule Phoenix.SessionProcess.RateLimiter do
     window_start = now - @window_size_ms
 
     # Count sessions created in the last minute
-    recent_count = :ets.select_count(@table_name, [
-      {{:_, :"$1"}, [{:>=, :"$1", window_start}], [true]}
-    ])
+    recent_count =
+      :ets.select_count(@table_name, [
+        {{:_, :"$1"}, [{:>=, :"$1", window_start}], [true]}
+      ])
 
     duration = System.monotonic_time() - start_time
 
@@ -140,9 +141,10 @@ defmodule Phoenix.SessionProcess.RateLimiter do
     now = System.system_time(:millisecond)
     window_start = now - @window_size_ms
 
-    count = :ets.select_count(@table_name, [
-      {{:_, :"$1"}, [{:>=, :"$1", window_start}], [true]}
-    ])
+    count =
+      :ets.select_count(@table_name, [
+        {{:_, :"$1"}, [{:>=, :"$1", window_start}], [true]}
+      ])
 
     {:reply, count, state}
   end
@@ -171,9 +173,10 @@ defmodule Phoenix.SessionProcess.RateLimiter do
     window_start = now - @window_size_ms
 
     # Delete entries older than the sliding window
-    deleted_count = :ets.select_delete(@table_name, [
-      {{:_, :"$1"}, [{:<, :"$1", window_start}], [true]}
-    ])
+    deleted_count =
+      :ets.select_delete(@table_name, [
+        {{:_, :"$1"}, [{:<, :"$1", window_start}], [true]}
+      ])
 
     if deleted_count > 0 do
       Logger.debug("RateLimiter: Cleaned up #{deleted_count} old entries")

lib/phoenix/session_process/redux.ex

@@ -381,7 +381,11 @@ defmodule Phoenix.SessionProcess.Redux do
         end
       end)
 
-    new_redux = %{redux | current_state: target_state, history: Enum.drop(redux.history, steps_back)}
+    new_redux = %{
+      redux
+      | current_state: target_state,
+        history: Enum.drop(redux.history, steps_back)
+    }
 
     # Notify subscriptions of state change
     notify_subscriptions(new_redux)
@@ -577,7 +581,7 @@ defmodule Phoenix.SessionProcess.Redux do
       unsubscribe.()
 
   """
-  @spec subscribe_to_broadcasts(module(), String.t(), (map() -> any())) :: (() -> :ok)
+  @spec subscribe_to_broadcasts(module(), String.t(), (map() -> any())) :: (-> :ok)
   def subscribe_to_broadcasts(pubsub_module, topic, callback) do
     Phoenix.PubSub.subscribe(pubsub_module, topic)
 

lib/phoenix/session_process/redux/selector.ex

@@ -92,15 +92,16 @@ defmodule Phoenix.SessionProcess.Redux.Selector do
     state = Redux.get_state(redux)
 
     # Extract values from dependency selectors recursively
-    dep_values = Enum.map(deps, fn dep ->
-      # Handle both simple selectors and composed selectors
-      if is_function(dep, 1) do
-        dep.(state)
-      else
-        # Recursively select for composed dependency
-        select(redux, dep)
-      end
-    end)
+    dep_values =
+      Enum.map(deps, fn dep ->
+        # Handle both simple selectors and composed selectors
+        if is_function(dep, 1) do
+          dep.(state)
+        else
+          # Recursively select for composed dependency
+          select(redux, dep)
+        end
+      end)
 
     # Check cache
     case get_cached_result(cache_key, dep_values) do

lib/phoenix/session_process/redux/subscription.ex

@@ -252,6 +252,7 @@ defmodule Phoenix.SessionProcess.Redux.Subscription do
       pubsub_topic: nil,
       subscriptions: []
     }
+
     Selector.select(redux, selector)
   end