From 8ae1920504060e912ff490dbc423ba86b2d32191 Mon Sep 17 00:00:00 2001 From: rinpatch Date: Wed, 23 Sep 2020 17:38:17 +0300 Subject: tmp --- lib/pleroma/web/fed_sockets/adapter.ex | 10 +++++++--- 1 file 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} -- cgit v1.2.3