forked from AkkomaGang/akkoma
streamer: worker: actually use should_send? consistently
This commit is contained in:
parent
d0e874c7f2
commit
abb967671a
1 changed files with 1 additions and 4 deletions
|
@ -201,11 +201,8 @@ def push_to_socket(topics, topic, item) 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
|
||||
|
|
Loading…
Reference in a new issue