summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorrinpatch <rinpatch@sdf.org>2020-09-23 17:38:17 +0300
committerrinpatch <rinpatch@sdf.org>2020-09-23 17:38:17 +0300
commit8ae1920504060e912ff490dbc423ba86b2d32191 (patch)
treecf06d43ffe5ff69951f9c2701df27d81463b2d7f
parente2fdf0e6dcf71ca43822689900aaaf9aab4f625e (diff)
-rw-r--r--lib/pleroma/web/fed_sockets/adapter.ex10
1 files changed, 7 insertions, 3 deletions
diff --git a/lib/pleroma/web/fed_sockets/adapter.ex b/lib/pleroma/web/fed_sockets/adapter.ex
index 3e260cc49..0dd41a1d2 100644
--- a/lib/pleroma/web/fed_sockets/adapter.ex
+++ b/lib/pleroma/web/fed_sockets/adapter.ex
@@ -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}