diff options
author | lain <lain@soykaf.club> | 2019-11-05 12:02:45 +0000 |
---|---|---|
committer | lain <lain@soykaf.club> | 2019-11-05 12:02:45 +0000 |
commit | 21716aa594064d5f4f4a91a8b40a679775709e1d (patch) | |
tree | 660f575029e4eaf8cf5577049ab67ed1902a04a2 /test/web/streamer | |
parent | a43b899e94c499a9b5cb1a072fe4b96f0f02696f (diff) | |
parent | b7de4ad0828078ed5aa03d243319855ce3eb95f8 (diff) | |
download | pleroma-1.1.4.tar.gz |
Merge branch 'release/1.1.4' into 'stable'v1.1.4
Release/1.1.4 - user.info fix plus NOT NULL for user.info
See merge request pleroma/pleroma!1927
Diffstat (limited to 'test/web/streamer')
-rw-r--r-- | test/web/streamer/streamer_test.exs | 18 |
1 files changed, 18 insertions, 0 deletions
diff --git a/test/web/streamer/streamer_test.exs b/test/web/streamer/streamer_test.exs index 313567bfd..601f6df49 100644 --- a/test/web/streamer/streamer_test.exs +++ b/test/web/streamer/streamer_test.exs @@ -110,6 +110,24 @@ defmodule Pleroma.Web.StreamerTest do Streamer.stream("user:notification", notif) Task.await(task) end + + test "it sends follow activities to the 'user:notification' stream", %{ + user: user + } do + user2 = insert(:user) + task = Task.async(fn -> assert_receive {:text, _}, 4_000 end) + + Streamer.add_socket( + "user:notification", + %{transport_pid: task.pid, assigns: %{user: user}} + ) + + {:ok, _follower, _followed, _activity} = CommonAPI.follow(user2, user) + + # We don't directly pipe the notification to the streamer as it's already + # generated as a side effect of CommonAPI.follow(). + Task.await(task) + end end test "it sends to public" do |