defmodule Front.UserChannel do
use Front.Web, :channel
def join("user:" <> user_id, _payload, socket) do
if Integer.to_string(socket.assigns[:user_id]) == user_id do
send(self(), :after_join)
{:ok, socket}
else
{:error, %{reason: "unauthorized"}}
end
end
def handle_info(:after_join, socket) do
Groups.associated_with(socket.assigns[:user_id])
|> Enum.each(fn group_id ->
%Phoenix.Socket{socket | topic: "group:#{group_id}", channel: Front.GroupChannel}
|> Phoenix.Channel.Server.join(%{})
end)
{:noreply, socket}
end
end
2条答案
按热度按时间cotxawn71#
不确定这是否是一个好的解决方案,可能它使用了一些非私有的内部API:
pu3pd22g2#
也许这个能帮上忙