diff options
author | kaniini <nenolod@gmail.com> | 2019-01-20 23:06:21 +0000 |
---|---|---|
committer | kaniini <nenolod@gmail.com> | 2019-01-20 23:06:21 +0000 |
commit | 5803672ae5c66f08ecec2d1e850cb4b4ccea3474 (patch) | |
tree | e9511c7388694bcd8b03d828e532a05e38031588 /test | |
parent | 501fba33d6bb02cca586cfeeac9fdcfec5c7436d (diff) | |
parent | cf1f35a93a096311dee62ee5ac142a1bb3cfb844 (diff) | |
download | pleroma-5803672ae5c66f08ecec2d1e850cb4b4ccea3474.tar.gz |
Merge branch '116-send-delete-event' into 'develop'
Send delete event over Mastodon streaming api
Closes #116
See merge request pleroma/pleroma!688
Diffstat (limited to 'test')
-rw-r--r-- | test/web/streamer_test.exs | 25 |
1 files changed, 24 insertions, 1 deletions
diff --git a/test/web/streamer_test.exs b/test/web/streamer_test.exs index 905e29d06..16d7b9c24 100644 --- a/test/web/streamer_test.exs +++ b/test/web/streamer_test.exs @@ -6,7 +6,8 @@ defmodule Pleroma.Web.StreamerTest do use Pleroma.DataCase alias Pleroma.Web.Streamer - alias Pleroma.{List, User} + alias Pleroma.List + alias Pleroma.User alias Pleroma.Web.CommonAPI import Pleroma.Factory @@ -35,6 +36,28 @@ defmodule Pleroma.Web.StreamerTest do Streamer.push_to_socket(topics, "public", activity) Task.await(task) + + task = + Task.async(fn -> + assert_receive {:text, _}, 4_000 + end) + + fake_socket = %{ + transport_pid: task.pid, + assigns: %{ + user: user + } + } + + {:ok, activity} = CommonAPI.delete(activity.id, other_user) + + topics = %{ + "public" => [fake_socket] + } + + Streamer.push_to_socket(topics, "public", activity) + + Task.await(task) end test "it doesn't send to blocked users" do |