graham/aprs.me
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix: unsubscribe from pubsub topics on LiveView terminate; catch-all handle_info in ConnectionManager

Browse source
This commit is contained in:
Graham McIntire 2026-04-17 13:24:57 -05:00
parent 177b88c3f3
commit 0b178d45ba
No known key found for this signature in database
GPG key ID: F4ABF488E6029E59
2 changed files with 7 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
lib/aprsme/cluster/connection_manager.ex
View file

@ -56,6 +56,9 @@ defmodule Aprsme.Cluster.ConnectionManager do
end end
end end
@impl true
def handle_info(_msg, state), do: {:noreply, state}
@impl true @impl true
def terminate(_reason, _state) do def terminate(_reason, _state) do
Phoenix.PubSub.unsubscribe(Aprsme.PubSub, "cluster:leadership") Phoenix.PubSub.unsubscribe(Aprsme.PubSub, "cluster:leadership")

4
lib/aprsme_web/live/map_live/index.ex
View file

@ -1878,6 +1878,10 @@ defmodule AprsmeWeb.MapLive.Index do
# Unsubscribe from StreamingPacketsPubSub # Unsubscribe from StreamingPacketsPubSub
Aprsme.StreamingPacketsPubSub.unsubscribe(self()) Aprsme.StreamingPacketsPubSub.unsubscribe(self())
# Unsubscribe from Endpoint/PubSub topics subscribed in mount
Endpoint.unsubscribe("aprs_messages")
Phoenix.PubSub.unsubscribe(Aprsme.PubSub, "postgres:aprsme_packets")
if socket.assigns.buffer_timer, do: Process.cancel_timer(socket.assigns.buffer_timer) if socket.assigns.buffer_timer, do: Process.cancel_timer(socket.assigns.buffer_timer)
# Clean up any pending bounds update timer # Clean up any pending bounds update timer
if socket.assigns[:bounds_update_timer] do if socket.assigns[:bounds_update_timer] do