live_beats/lib/live_beats_web/channels/presence.ex
Chris McCord 826cf1d4f9 Add pings
2022-01-31 08:21:27 -05:00

87 lines
2.7 KiB
Elixir

defmodule LiveBeatsWeb.Presence do
@moduledoc """
Provides presence tracking to channels and processes.
See the [`Phoenix.Presence`](http://hexdocs.pm/phoenix/Phoenix.Presence.html)
docs for more details.
"""
use Phoenix.Presence,
otp_app: :live_beats,
pubsub_server: LiveBeats.PubSub
import Phoenix.LiveView.Helpers
import LiveBeatsWeb.LiveHelpers
alias LiveBeats.{Accounts, MediaLibrary}
def subscribe(%MediaLibrary.Profile{} = profile) do
LiveBeats.PresenceClient.subscribe(profile)
end
def fetch(_topic, presences) do
users =
presences
|> Map.keys()
|> Accounts.get_users_map()
|> Enum.into(%{})
for {key, %{metas: metas}} <- presences, into: %{} do
{key, %{metas: metas, user: users[String.to_integer(key)]}}
end
end
end
defmodule LiveBeatsWeb.Presence.BadgeListComponent do
use LiveBeatsWeb, :live_component
def render(assigns) do
~H"""
<div class="px-4 mt-6 sm:px-6 lg:px-8"> <!-- users -->
<h2 class="text-gray-500 text-xs font-medium uppercase tracking-wide">Listening now</h2>
<ul
id="listening-now"
phx-update="prepend"
role="list"
x-max="1"
class="grid grid-cols-1 gap-4 sm:gap-4 sm:grid-cols-2 xl:grid-cols-5 mt-3"
>
<%= for presence <- @presences do %>
<li id={"presence-#{presence.id}"} class="relative col-span-1 flex shadow-sm rounded-md overflow-hidden">
<.link navigate={profile_path(presence)} class="flex-1 flex items-center justify-between border-t border-r border-b border-gray-200 bg-white rounded-r-md truncate">
<img class="w-12 h-12 flex-shrink-0 flex items-center justify-center rounded-l-md bg-purple-600" src={presence.avatar_url} alt="">
<div class="flex-1 flex items-center justify-between text-gray-900 text-sm font-medium hover:text-gray-600 pl-3">
<div class="flex-1 py-1 text-sm truncate">
<%= render_slot(@inner_block, %{user: presence, ping: @pings[presence.id], region: @regions[presence.id]}) %>
</div>
</div>
</.link>
</li>
<% end %>
</ul>
</div>
"""
end
def mount(socket) do
{:ok, socket, temporary_assigns: [presences: [], pings: %{}, regions: %{}]}
end
def update(%{action: {:ping, action}}, socket) do
%{user: user, ping: ping, region: region} = action
{:ok,
socket
|> assign(:presences, [user])
|> update(:pings, &Map.put(&1, user.id, ping))
|> update(:regions, &Map.put(&1, user.id, region))}
end
def update(assigns, socket) do
{:ok,
socket
|> assign(assigns)
|> assign_new(:pings, fn -> %{} end)
|> assign_new(:regions, fn -> %{} end)}
end
end