revert 4a94c9a31ef11f63ea71ad9c1f085c18cf8ef083

[akkoma] / lib / pleroma / web / streamer.ex

diff --git a/lib/pleroma/web/streamer.ex b/lib/pleroma/web/streamer.ex
index f009fbd9e1853e01001209207e6cd83270ca1a89..c03e7fc30a569844cf7032ce4a93e0e8bc7a4903 100644 (file)
--- a/lib/pleroma/web/streamer.ex
+++ b/lib/pleroma/web/streamer.ex
@@ -17,7 +17,6 @@ defmodule Pleroma.Web.Streamer do
   alias Pleroma.Web.OAuth.Token
   alias Pleroma.Web.Plugs.OAuthScopesPlug
   alias Pleroma.Web.StreamerView
-  require Pleroma.Constants
 
   @mix_env Mix.env()
   @registry Pleroma.Web.StreamerRegistry
@@ -253,17 +252,7 @@ defmodule Pleroma.Web.Streamer do
       User.get_recipients_from_activity(item)
       |> Enum.map(fn %{id: id} -> "user:#{id}" end)
 
-    hashtag_recipients =
-      if Pleroma.Constants.as_public() in item.recipients do
-        Pleroma.Hashtag.get_recipients_for_activity(item)
-        |> Enum.map(fn id -> "user:#{id}" end)
-      else
-        []
-      end
-
-    all_recipients = Enum.uniq(recipient_topics ++ hashtag_recipients)
-
-    Enum.each(all_recipients, fn topic ->
+    Enum.each(recipient_topics, fn topic ->
       push_to_socket(topic, item)
     end)
   end