1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2018 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.Web.StreamerTest do
10 alias Pleroma.Web.CommonAPI
11 alias Pleroma.Web.Streamer
12 import Pleroma.Factory
14 test "it sends to public" do
16 other_user = insert(:user)
20 assert_receive {:text, _}, 4_000
24 transport_pid: task.pid,
30 {:ok, activity} = CommonAPI.post(other_user, %{"status" => "Test"})
33 "public" => [fake_socket]
36 Streamer.push_to_socket(topics, "public", activity)
45 "payload" => activity.id
49 assert_receive {:text, received_event}, 4_000
50 assert received_event == expected_event
54 transport_pid: task.pid,
60 {:ok, activity} = CommonAPI.delete(activity.id, other_user)
63 "public" => [fake_socket]
66 Streamer.push_to_socket(topics, "public", activity)
71 test "it doesn't send to blocked users" do
73 blocked_user = insert(:user)
74 {:ok, user} = User.block(user, blocked_user)
78 refute_receive {:text, _}, 1_000
82 transport_pid: task.pid,
88 {:ok, activity} = CommonAPI.post(blocked_user, %{"status" => "Test"})
91 "public" => [fake_socket]
94 Streamer.push_to_socket(topics, "public", activity)
99 test "it doesn't send unwanted DMs to list" do
100 user_a = insert(:user)
101 user_b = insert(:user)
102 user_c = insert(:user)
104 {:ok, user_a} = User.follow(user_a, user_b)
106 {:ok, list} = List.create("Test", user_a)
107 {:ok, list} = List.follow(list, user_b)
111 refute_receive {:text, _}, 1_000
115 transport_pid: task.pid,
122 CommonAPI.post(user_b, %{
123 "status" => "@#{user_c.nickname} Test",
124 "visibility" => "direct"
128 "list:#{list.id}" => [fake_socket]
131 Streamer.handle_cast(%{action: :stream, topic: "list", item: activity}, topics)
136 test "it doesn't send unwanted private posts to list" do
137 user_a = insert(:user)
138 user_b = insert(:user)
140 {:ok, list} = List.create("Test", user_a)
141 {:ok, list} = List.follow(list, user_b)
145 refute_receive {:text, _}, 1_000
149 transport_pid: task.pid,
156 CommonAPI.post(user_b, %{
158 "visibility" => "private"
162 "list:#{list.id}" => [fake_socket]
165 Streamer.handle_cast(%{action: :stream, topic: "list", item: activity}, topics)
170 test "it send wanted private posts to list" do
171 user_a = insert(:user)
172 user_b = insert(:user)
174 {:ok, user_a} = User.follow(user_a, user_b)
176 {:ok, list} = List.create("Test", user_a)
177 {:ok, list} = List.follow(list, user_b)
181 assert_receive {:text, _}, 1_000
185 transport_pid: task.pid,
192 CommonAPI.post(user_b, %{
194 "visibility" => "private"
198 "list:#{list.id}" => [fake_socket]
201 Streamer.handle_cast(%{action: :stream, topic: "list", item: activity}, topics)
206 test "it doesn't send muted reblogs" do
207 user1 = insert(:user)
208 user2 = insert(:user)
209 user3 = insert(:user)
210 CommonAPI.hide_reblogs(user1, user2)
214 refute_receive {:text, _}, 1_000
218 transport_pid: task.pid,
224 {:ok, create_activity} = CommonAPI.post(user3, %{"status" => "I'm kawen"})
225 {:ok, announce_activity, _} = CommonAPI.repeat(create_activity.id, user2)
228 "public" => [fake_socket]
231 Streamer.push_to_socket(topics, "public", announce_activity)