|
|
|
@ -201,11 +201,8 @@ defmodule Pleroma.Web.Streamer.Worker do
|
|
|
|
|
# Get the current user so we have up-to-date blocks etc.
|
|
|
|
|
if socket_user do
|
|
|
|
|
user = User.get_cached_by_ap_id(socket_user.ap_id)
|
|
|
|
|
blocks = user.info.blocks || []
|
|
|
|
|
mutes = user.info.mutes || []
|
|
|
|
|
|
|
|
|
|
with true <- Enum.all?([blocks, mutes], &(item.actor not in &1)),
|
|
|
|
|
true <- thread_containment(item, user) do
|
|
|
|
|
if should_send?(user, item) do
|
|
|
|
|
send(transport_pid, {:text, StreamerView.render("update.json", item, user)})
|
|
|
|
|
end
|
|
|
|
|
else
|
|
|
|
|