diff options
author | lain <lain@soykaf.club> | 2020-07-02 09:50:26 +0200 |
---|---|---|
committer | lain <lain@soykaf.club> | 2020-07-02 09:50:26 +0200 |
commit | 311b7c19d0a34654b785116fe22823132d5a9284 (patch) | |
tree | a46182cbb0793c5cd225b6d6fd7c730eb1674bbf /test | |
parent | 61fe94d698a6f73e7a3f6224ed4be93b30ba0e54 (diff) | |
download | pleroma-311b7c19d0a34654b785116fe22823132d5a9284.tar.gz pleroma-311b7c19d0a34654b785116fe22823132d5a9284.zip |
Streamer: Align announce streaming with polling.
Diffstat (limited to 'test')
-rw-r--r-- | test/web/streamer/streamer_test.exs | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/test/web/streamer/streamer_test.exs b/test/web/streamer/streamer_test.exs index 245f6e63f..dfe341b34 100644 --- a/test/web/streamer/streamer_test.exs +++ b/test/web/streamer/streamer_test.exs @@ -116,6 +116,18 @@ defmodule Pleroma.Web.StreamerTest do refute Streamer.filtered_by_user?(user, announce) end + test "it does not stream 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) + + assert Streamer.filtered_by_user?(user, announce) + end + test "it streams boosts of mastodon user in the 'user' stream", %{user: user} do Streamer.get_topic_and_add_socket("user", user) |