1 defmodule Pleroma.Web.StreamerTest do
4 alias Pleroma.Web.Streamer
6 alias Pleroma.Web.CommonAPI
9 test "it sends to public" do
11 other_user = insert(:user)
15 assert_receive {:text, _}, 4_000
19 transport_pid: task.pid,
25 {:ok, activity} = CommonAPI.post(other_user, %{"status" => "Test"})
28 "public" => [fake_socket]
31 Streamer.push_to_socket(topics, "public", activity)
36 test "it doesn't send to blocked users" do
38 blocked_user = insert(:user)
39 {:ok, user} = User.block(user, blocked_user)
43 refute_receive {:text, _}, 1_000
47 transport_pid: task.pid,
53 {:ok, activity} = CommonAPI.post(blocked_user, %{"status" => "Test"})
56 "public" => [fake_socket]
59 Streamer.push_to_socket(topics, "public", activity)