diff options
author | rinpatch <rinpatch@sdf.org> | 2019-08-15 17:37:30 +0300 |
---|---|---|
committer | rinpatch <rinpatch@sdf.org> | 2019-08-15 17:37:30 +0300 |
commit | a4a3e3becd5e008dbfa9a23157ae4b16a0652bce (patch) | |
tree | d0bddc82e989c0000c2c8cd2c7162e34f1fafaeb /test/web/streamer_test.exs | |
parent | 27b747546a7796de57e88f454b2c2810c7523f97 (diff) | |
download | pleroma-a4a3e3becd5e008dbfa9a23157ae4b16a0652bce.tar.gz pleroma-a4a3e3becd5e008dbfa9a23157ae4b16a0652bce.zip |
Hide muted theads from home/public timelines unless `with_muted` is set
Diffstat (limited to 'test/web/streamer_test.exs')
-rw-r--r-- | test/web/streamer_test.exs | 20 |
1 files changed, 20 insertions, 0 deletions
diff --git a/test/web/streamer_test.exs b/test/web/streamer_test.exs index d47b37efb..5b7fe44d4 100644 --- a/test/web/streamer_test.exs +++ b/test/web/streamer_test.exs @@ -414,6 +414,26 @@ defmodule Pleroma.Web.StreamerTest do Task.await(task) end + test "it doesn't send posts from muted threads" do + user = insert(:user) + user2 = insert(:user) + {:ok, user2, user, _activity} = CommonAPI.follow(user2, user) + + {:ok, activity} = CommonAPI.post(user, %{"status" => "super hot take"}) + + {:ok, activity} = CommonAPI.add_mute(user2, activity) + + task = Task.async(fn -> refute_receive {:text, _}, 4_000 end) + + Streamer.add_socket( + "user", + %{transport_pid: task.pid, assigns: %{user: user2}} + ) + + Streamer.stream("user", activity) + Task.await(task) + end + describe "direct streams" do setup do GenServer.start(Streamer, %{}, name: Streamer) |