diff options
| author | lain <lain@soykaf.club> | 2019-10-16 16:16:39 +0200 |
|---|---|---|
| committer | lain <lain@soykaf.club> | 2019-10-16 16:16:39 +0200 |
| commit | 6e4f52f8a2e510273149acbaf629521d1b4aec2e (patch) | |
| tree | 0f6210fe8dfe0b716f2fc9721df0d5a8f807294f /test/web/streamer | |
| parent | e3b4a3e96b2ffbc6d920155cd41687414045d4d6 (diff) | |
| download | pleroma-6e4f52f8a2e510273149acbaf629521d1b4aec2e.tar.gz pleroma-6e4f52f8a2e510273149acbaf629521d1b4aec2e.zip | |
Introduce new ingestion pipeline structure, implement internal Likes with it.
Diffstat (limited to 'test/web/streamer')
| -rw-r--r-- | test/web/streamer/streamer_test.exs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/test/web/streamer/streamer_test.exs b/test/web/streamer/streamer_test.exs index d33eb1e42..b363935a2 100644 --- a/test/web/streamer/streamer_test.exs +++ b/test/web/streamer/streamer_test.exs @@ -68,7 +68,7 @@ defmodule Pleroma.Web.StreamerTest do ) {:ok, activity} = CommonAPI.post(user, %{"status" => ":("}) - {:ok, notif, _} = CommonAPI.favorite(activity.id, blocked) + {:ok, notif} = CommonAPI.favorite(blocked, activity.id) Streamer.stream("user:notification", notif) Task.await(task) @@ -87,7 +87,7 @@ defmodule Pleroma.Web.StreamerTest do {:ok, activity} = CommonAPI.post(user, %{"status" => "super hot take"}) {:ok, activity} = CommonAPI.add_mute(user, activity) - {:ok, notif, _} = CommonAPI.favorite(activity.id, user2) + {:ok, notif} = CommonAPI.favorite(user2, activity.id) Streamer.stream("user:notification", notif) Task.await(task) end @@ -105,7 +105,7 @@ defmodule Pleroma.Web.StreamerTest do {:ok, user} = User.block_domain(user, "hecking-lewd-place.com") {:ok, activity} = CommonAPI.post(user, %{"status" => "super hot take"}) - {:ok, notif, _} = CommonAPI.favorite(activity.id, user2) + {:ok, notif} = CommonAPI.favorite(user2, activity.id) Streamer.stream("user:notification", notif) Task.await(task) |