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
15 skip_thread_containment = Pleroma.Config.get([:instance, :skip_thread_containment])
18 Pleroma.Config.put([:instance, :skip_thread_containment], skip_thread_containment)
24 test "it sends to public" do
26 other_user = insert(:user)
30 assert_receive {:text, _}, 4_000
34 transport_pid: task.pid,
40 {:ok, activity} = CommonAPI.post(other_user, %{"status" => "Test"})
43 "public" => [fake_socket]
46 Streamer.push_to_socket(topics, "public", activity)
55 "payload" => activity.id
59 assert_receive {:text, received_event}, 4_000
60 assert received_event == expected_event
64 transport_pid: task.pid,
70 {:ok, activity} = CommonAPI.delete(activity.id, other_user)
73 "public" => [fake_socket]
76 Streamer.push_to_socket(topics, "public", activity)
81 describe "thread_containment" do
82 test "it doesn't send to user if recipients invalid and thread containment is enabled" do
83 Pleroma.Config.put([:instance, :skip_thread_containment], false)
84 author = insert(:user)
85 user = insert(:user, following: [author.ap_id])
88 insert(:note_activity,
92 data: %{"to" => ["TEST-FFF"]}
96 task = Task.async(fn -> refute_receive {:text, _}, 1_000 end)
97 fake_socket = %{transport_pid: task.pid, assigns: %{user: user}}
98 topics = %{"public" => [fake_socket]}
99 Streamer.push_to_socket(topics, "public", activity)
104 test "it sends message if recipients invalid and thread containment is disabled" do
105 Pleroma.Config.put([:instance, :skip_thread_containment], true)
106 author = insert(:user)
107 user = insert(:user, following: [author.ap_id])
110 insert(:note_activity,
114 data: %{"to" => ["TEST-FFF"]}
118 task = Task.async(fn -> assert_receive {:text, _}, 1_000 end)
119 fake_socket = %{transport_pid: task.pid, assigns: %{user: user}}
120 topics = %{"public" => [fake_socket]}
121 Streamer.push_to_socket(topics, "public", activity)
126 test "it sends message if recipients invalid and thread containment is enabled but user's thread containment is disabled" do
127 Pleroma.Config.put([:instance, :skip_thread_containment], false)
128 author = insert(:user)
129 user = insert(:user, following: [author.ap_id], info: %{skip_thread_containment: true})
132 insert(:note_activity,
136 data: %{"to" => ["TEST-FFF"]}
140 task = Task.async(fn -> assert_receive {:text, _}, 1_000 end)
141 fake_socket = %{transport_pid: task.pid, assigns: %{user: user}}
142 topics = %{"public" => [fake_socket]}
143 Streamer.push_to_socket(topics, "public", activity)
149 test "it doesn't send to blocked users" do
151 blocked_user = insert(:user)
152 {:ok, user} = User.block(user, blocked_user)
156 refute_receive {:text, _}, 1_000
160 transport_pid: task.pid,
166 {:ok, activity} = CommonAPI.post(blocked_user, %{"status" => "Test"})
169 "public" => [fake_socket]
172 Streamer.push_to_socket(topics, "public", activity)
177 test "it doesn't send unwanted DMs to list" do
178 user_a = insert(:user)
179 user_b = insert(:user)
180 user_c = insert(:user)
182 {:ok, user_a} = User.follow(user_a, user_b)
184 {:ok, list} = List.create("Test", user_a)
185 {:ok, list} = List.follow(list, user_b)
189 refute_receive {:text, _}, 1_000
193 transport_pid: task.pid,
200 CommonAPI.post(user_b, %{
201 "status" => "@#{user_c.nickname} Test",
202 "visibility" => "direct"
206 "list:#{list.id}" => [fake_socket]
209 Streamer.handle_cast(%{action: :stream, topic: "list", item: activity}, topics)
214 test "it doesn't send unwanted private posts to list" do
215 user_a = insert(:user)
216 user_b = insert(:user)
218 {:ok, list} = List.create("Test", user_a)
219 {:ok, list} = List.follow(list, user_b)
223 refute_receive {:text, _}, 1_000
227 transport_pid: task.pid,
234 CommonAPI.post(user_b, %{
236 "visibility" => "private"
240 "list:#{list.id}" => [fake_socket]
243 Streamer.handle_cast(%{action: :stream, topic: "list", item: activity}, topics)
248 test "it send wanted private posts to list" do
249 user_a = insert(:user)
250 user_b = insert(:user)
252 {:ok, user_a} = User.follow(user_a, user_b)
254 {:ok, list} = List.create("Test", user_a)
255 {:ok, list} = List.follow(list, user_b)
259 assert_receive {:text, _}, 1_000
263 transport_pid: task.pid,
270 CommonAPI.post(user_b, %{
272 "visibility" => "private"
276 "list:#{list.id}" => [fake_socket]
279 Streamer.handle_cast(%{action: :stream, topic: "list", item: activity}, topics)
284 test "it doesn't send muted reblogs" do
285 user1 = insert(:user)
286 user2 = insert(:user)
287 user3 = insert(:user)
288 CommonAPI.hide_reblogs(user1, user2)
292 refute_receive {:text, _}, 1_000
296 transport_pid: task.pid,
302 {:ok, create_activity} = CommonAPI.post(user3, %{"status" => "I'm kawen"})
303 {:ok, announce_activity, _} = CommonAPI.repeat(create_activity.id, user2)
306 "public" => [fake_socket]
309 Streamer.push_to_socket(topics, "public", announce_activity)