summaryrefslogtreecommitdiff
path: root/test/web/streamer
diff options
context:
space:
mode:
authorfeld <feld@feld.me>2020-04-01 17:05:09 +0000
committerfeld <feld@feld.me>2020-04-01 17:05:09 +0000
commitef7d2b0f11a9bf74e982b73ae4cec632f93fbebc (patch)
tree2058bf1189b7a7ba12b1a160c27a9e92f3fa28bb /test/web/streamer
parentbfec45bf740f9fcfcea92bbded6bd2c146dc64c1 (diff)
parent1fcdcb12a717fa3dbd54a5c3778bd216df6449ad (diff)
downloadpleroma-ef7d2b0f11a9bf74e982b73ae4cec632f93fbebc.tar.gz
pleroma-ef7d2b0f11a9bf74e982b73ae4cec632f93fbebc.zip
Merge branch 'gun' into 'develop'
Gun adapter Closes #945 See merge request pleroma/pleroma!1861
Diffstat (limited to 'test/web/streamer')
-rw-r--r--test/web/streamer/streamer_test.exs12
1 files changed, 12 insertions, 0 deletions
diff --git a/test/web/streamer/streamer_test.exs b/test/web/streamer/streamer_test.exs
index a5d6e8ecf..5b928629b 100644
--- a/test/web/streamer/streamer_test.exs
+++ b/test/web/streamer/streamer_test.exs
@@ -121,6 +121,18 @@ defmodule Pleroma.Web.StreamerTest do
test "it sends follow activities to the 'user:notification' stream", %{
user: user
} do
+ user_url = user.ap_id
+
+ body =
+ File.read!("test/fixtures/users_mock/localhost.json")
+ |> String.replace("{{nickname}}", user.nickname)
+ |> Jason.encode!()
+
+ Tesla.Mock.mock_global(fn
+ %{method: :get, url: ^user_url} ->
+ %Tesla.Env{status: 200, body: body}
+ end)
+
user2 = insert(:user)
task = Task.async(fn -> assert_receive {:text, _}, @streamer_timeout end)