mirrors/live_beats
1
0
Fork 0
mirror of https://github.com/fly-apps/live_beats.git synced 2024-11-21 15:41:00 +00:00
Code Issues Projects Releases Wiki Activity

keep client state in the phoenix presence client

Browse source
This commit is contained in:
Berenice Medel Sánchez 2021-12-14 10:27:55 -06:00 committed by Chris McCord
parent 9b5587d484
commit 028c619047
2 changed files with 10 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
lib/live_beats/presence/phoenix_presence_client.ex
View file

@ -24,7 +24,7 @@ defmodule Phoenix.Presence.Client do
def init(opts) do
client = Keyword.fetch!(opts, :client)
client_state = client.init(%{})
{:ok, client_state} = client.init(%{})
state = %{
topics: %{},
@ -104,13 +104,18 @@ defmodule Phoenix.Presence.Client do
updated_state =
update_topics_state(:add_new_presence_or_metas, state, topic, joined_key, joined_meta)
state.client.handle_join(topic, joined_key, joined_meta, state)
{:ok, updated_client_state} = state.client.handle_join(topic, joined_key, joined_meta, state.client_state)
updated_state = Map.put(updated_state, :client_state, updated_client_state)
{updated_state, topic}
end
defp handle_leave({left_key, meta}, {state, topic}) do
updated_state = update_topics_state(:remove_presence_or_metas, state, topic, left_key, meta)
state.client.handle_leave(topic, left_key, meta, state)
{:ok, updated_client_state} = state.client.handle_leave(topic, left_key, meta, state.client_state)
updated_state = Map.put(updated_state, :client_state, updated_client_state)
{updated_state, topic}
end

4
lib/live_beats/presence/presence_client.ex
View file

@ -23,7 +23,7 @@ defmodule LiveBeats.PresenceClient do
|> profile_identifier()
|> active_users_topic()
Phoenix.PubSub.broadcast!(@pubsub, active_users_topic, {__MODULE__, %{user_joined: key}})
Phoenix.PubSub.local_broadcast(@pubsub, active_users_topic, {__MODULE__, %{user_joined: key}})
{:ok, state}
end
@ -34,7 +34,7 @@ defmodule LiveBeats.PresenceClient do
|> profile_identifier()
|> active_users_topic()
Phoenix.PubSub.broadcast!(@pubsub, active_users_topic, {__MODULE__, %{user_left: key}})
Phoenix.PubSub.local_broadcast(@pubsub, active_users_topic, {__MODULE__, %{user_left: key}})
{:ok, state}
end