mirrors/pleroma
1
0
Fork 0
mirror of https://git.pleroma.social/pleroma/pleroma.git synced 2024-06-10 09:19:34 +00:00
Code Issues Projects Releases Wiki Activity

tmp

Browse source
This commit is contained in:
rinpatch 2020-09-23 17:38:17 +03:00
parent e2fdf0e6dc
commit 8ae1920504
1 changed files with 7 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
lib/pleroma/web/fed_sockets/adapter.ex
View file

@ -29,10 +29,14 @@ defmodule Pleroma.Web.FedSockets.Adapter do
end
@spec publish(pid(), module(), adapter_state(), term(), timeout()) ::
{:ok, term()} | {:error, term()}
:ok | {:error, term()}
def publish(pid, adapter, adapter_state, data, timeout) do
data = %{action: :publish, data: data}
apply(adapter, :request, [pid, adapter_state, data, timeout])
case apply(adapter, :request, [pid, adapter_state, data, timeout]) do
{:ok, _} -> :ok
e -> e
end
end
@type origin :: String.t()
@ -65,7 +69,7 @@ defmodule Pleroma.Web.FedSockets.Adapter do
data = %{
"action" => "reply",
"uuid" => uuid,
"data" => "ok"
"data" => nil
}
{:reply, {:text, Jason.encode!(data)}, waiting_requests}