From cc6808f70e6f3d2d56384340aa98be598dba4f92 Mon Sep 17 00:00:00 2001 From: lain Date: Sat, 26 Dec 2020 11:57:04 +0100 Subject: Streamer Test: Add test for self-dms. --- test/pleroma/web/streamer_test.exs | 22 ++++++++++++++++++++++ 1 file changed, 22 insertions(+) diff --git a/test/pleroma/web/streamer_test.exs b/test/pleroma/web/streamer_test.exs index ad66ddc9d..cddda10e0 100644 --- a/test/pleroma/web/streamer_test.exs +++ b/test/pleroma/web/streamer_test.exs @@ -746,6 +746,28 @@ test "it filters posts from muted threads" do describe "direct streams" do setup do: oauth_access(["read"]) + test "it sends conversation update to the 'direct' stream, for self-dms", %{ + user: user, + token: oauth_token + } do + Streamer.get_topic_and_add_socket("direct", user, oauth_token) + + {:ok, _create_activity} = + CommonAPI.post(user, %{ + status: "hey @#{user.nickname}", + visibility: "direct" + }) + + assert_receive {:text, received_event} + + assert %{"event" => "conversation", "payload" => received_payload} = + Jason.decode!(received_event) + + assert %{"last_status" => last_status} = Jason.decode!(received_payload) + [participation] = Participation.for_user(user) + assert last_status["pleroma"]["direct_conversation_id"] == participation.id + end + test "it sends conversation update to the 'direct' stream", %{user: user, token: oauth_token} do another_user = insert(:user) -- cgit v1.2.3