mirror of
https://github.com/fly-apps/live_beats.git
synced 2024-11-29 11:11:02 +00:00
update active users with a hook
change users sidebar from function component to live
This commit is contained in:
parent
f23539c6da
commit
d93bb8e810
2 changed files with 15 additions and 7 deletions
|
@ -1,6 +1,4 @@
|
||||||
defmodule LiveBeats.UserTracker do
|
defmodule LiveBeats.UserTracker do
|
||||||
|
|
||||||
require Logger
|
|
||||||
use GenServer
|
use GenServer
|
||||||
@pubsub LiveBeats.PubSub
|
@pubsub LiveBeats.PubSub
|
||||||
@poll_interval :timer.seconds(5)
|
@poll_interval :timer.seconds(5)
|
||||||
|
|
|
@ -1,16 +1,26 @@
|
||||||
defmodule LiveBeatsWeb.Nav do
|
defmodule LiveBeatsWeb.Nav do
|
||||||
import Phoenix.LiveView
|
import Phoenix.LiveView
|
||||||
|
|
||||||
alias LiveBeats.MediaLibrary
|
|
||||||
alias LiveBeatsWeb.{ProfileLive, SettingsLive}
|
alias LiveBeatsWeb.{ProfileLive, SettingsLive}
|
||||||
|
|
||||||
def on_mount(:default, _params, _session, socket) do
|
def on_mount(:default, _params, _session, socket) do
|
||||||
{:cont,
|
if connected?(socket) do
|
||||||
|
LiveBeats.UserTracker.subscribe()
|
||||||
|
end
|
||||||
|
|
||||||
socket
|
socket
|
||||||
|> assign(active_users: MediaLibrary.list_active_profiles(limit: 20))
|
|> assign(:active_users, [])
|
||||||
|> assign(:region, System.get_env("FLY_REGION"))
|
|> assign(:region, System.get_env("FLY_REGION"))
|
||||||
|> attach_hook(:active_tab, :handle_params, &handle_active_tab_params/3)
|
|> attach_hook(:active_tab, :handle_params, &handle_active_tab_params/3)
|
||||||
|> attach_hook(:ping, :handle_event, &handle_event/3)}
|
|> attach_hook(:ping, :handle_event, &handle_event/3)
|
||||||
|
|> attach_hook(:actie_users, :handle_info, fn
|
||||||
|
{LiveBeats.UserTracker, %{active_users: users}}, socket ->
|
||||||
|
{:halt, assign(socket, :active_users, users)}
|
||||||
|
|
||||||
|
_params, socket ->
|
||||||
|
{:cont, socket}
|
||||||
|
|
||||||
|
end)
|
||||||
|
{:cont, socket}
|
||||||
end
|
end
|
||||||
|
|
||||||
defp handle_active_tab_params(params, _url, socket) do
|
defp handle_active_tab_params(params, _url, socket) do
|
||||||
|
|
Loading…
Reference in a new issue