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/web/streamer_test.exs | |
| parent | 501fba33d6bb02cca586cfeeac9fdcfec5c7436d (diff) | |
| parent | cf1f35a93a096311dee62ee5ac142a1bb3cfb844 (diff) | |
| download | pleroma-5803672ae5c66f08ecec2d1e850cb4b4ccea3474.tar.gz pleroma-5803672ae5c66f08ecec2d1e850cb4b4ccea3474.zip | |
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/web/streamer_test.exs')
| -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 | 
