我正在尝试获取凤凰控制器中的状态列表,但我需要套接字才能使用该功能Presence.list(socket)
。
有人知道如何在控制器中使用Presence.list(socket)
吗?我尝试这样做的原因是我想在我的数据库中找到一个与连接到频道(状态列表)的用户不同的用户。
我发现的最好的方法是:Phoenix.Presence.list(MyApp.MyChannel, "my_topic")
有参考:凤凰城.存在.列表
你为什么不问通道,只是生成同步任务,将任务连接到你期望接收结果的组,然后将消息推送到通道,然后将结果作为任务完成结果返回给控制器。
假设这是控制器操作
defmodule SomeController do
#...
def some_action(conn, params) do
task = Task.async(fn ->
MyApp.Endpoint.subscribe("topic:123:presence_list")
MyApp.Endpoint.broadcast("topic:123", :presence_list, %{})
receive do
{:presence_list, list} ->
{:ok, list}
after
5000 ->
{:error, timeout}
end
end)
{:ok, list} = Task.await(task)
# do something with a list
end
end
然后在频道中只需处理广播并返回Presence.list(socket)
这应该是更清洁的方式,而不是屈尊进入未来可能改变的存在内部。
第二种选择是创建您自己的跟踪器并将其插入应用程序,然后要求您的跟踪器为您提供特定频道的当前用户列表。您可以在此处找到有关如何实现跟踪器行为的一些详细信息