diff options
author | lain <lain@soykaf.club> | 2020-07-04 17:11:37 +0200 |
---|---|---|
committer | lain <lain@soykaf.club> | 2020-07-04 17:11:37 +0200 |
commit | cf566556147975d45958d2d87a5ce23831eb91df (patch) | |
tree | 1876f7352480065565b3062b06ed00be07f02744 /test | |
parent | c2a052a346d5104c3657343a885255d4d7179c75 (diff) | |
download | pleroma-cf566556147975d45958d2d87a5ce23831eb91df.tar.gz pleroma-cf566556147975d45958d2d87a5ce23831eb91df.zip |
Streamer: Don't filter out announce notifications.
Diffstat (limited to 'test')
-rw-r--r-- | test/web/streamer/streamer_test.exs | 17 |
1 files changed, 17 insertions, 0 deletions
diff --git a/test/web/streamer/streamer_test.exs b/test/web/streamer/streamer_test.exs index dfe341b34..d56d74464 100644 --- a/test/web/streamer/streamer_test.exs +++ b/test/web/streamer/streamer_test.exs @@ -128,6 +128,23 @@ defmodule Pleroma.Web.StreamerTest do assert Streamer.filtered_by_user?(user, announce) end + test "it does stream notifications announces of the user's own posts in the 'user' stream", %{ + user: user + } do + Streamer.get_topic_and_add_socket("user", user) + + other_user = insert(:user) + {:ok, activity} = CommonAPI.post(user, %{status: "hey"}) + {:ok, announce} = CommonAPI.repeat(activity.id, other_user) + + notification = + Pleroma.Notification + |> Repo.get_by(%{user_id: user.id, activity_id: announce.id}) + |> Repo.preload(:activity) + + refute Streamer.filtered_by_user?(user, notification) + end + test "it streams boosts of mastodon user in the 'user' stream", %{user: user} do Streamer.get_topic_and_add_socket("user", user) |