aboutsummaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorlain <lain@soykaf.club>2020-07-02 09:50:26 +0200
committerlain <lain@soykaf.club>2020-07-02 09:50:26 +0200
commit311b7c19d0a34654b785116fe22823132d5a9284 (patch)
treea46182cbb0793c5cd225b6d6fd7c730eb1674bbf /lib
parent61fe94d698a6f73e7a3f6224ed4be93b30ba0e54 (diff)
downloadpleroma-311b7c19d0a34654b785116fe22823132d5a9284.tar.gz
Streamer: Align announce streaming with polling.
Diffstat (limited to 'lib')
-rw-r--r--lib/pleroma/web/streamer/streamer.ex1
1 files changed, 1 insertions, 0 deletions
diff --git a/lib/pleroma/web/streamer/streamer.ex b/lib/pleroma/web/streamer/streamer.ex
index d1d2c9b9c..73ee3e1e1 100644
--- a/lib/pleroma/web/streamer/streamer.ex
+++ b/lib/pleroma/web/streamer/streamer.ex
@@ -116,6 +116,7 @@ defmodule Pleroma.Web.Streamer do
true <-
Enum.all?([blocked_ap_ids, muted_ap_ids], &(item.actor not in &1)),
true <- item.data["type"] != "Announce" || item.actor not in reblog_muted_ap_ids,
+ true <- !(item.data["type"] == "Announce" && parent.data["actor"] == user.ap_id),
true <- Enum.all?([blocked_ap_ids, muted_ap_ids], &(parent.data["actor"] not in &1)),
true <- MapSet.disjoint?(recipients, recipient_blocks),
%{host: item_host} <- URI.parse(item.actor),