git.squeep.com Git - akkoma/blob - test/web/mastodon_api/controllers/conversation_controller_test.exs

   1 # Pleroma: A lightweight social networking server
   2 # Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
   3 # SPDX-License-Identifier: AGPL-3.0-only
   4
   5 defmodule Pleroma.Web.MastodonAPI.ConversationControllerTest do
   6   use Pleroma.Web.ConnCase
   7
   8   alias Pleroma.User
   9   alias Pleroma.Web.CommonAPI
  10
  11   import Pleroma.Factory
  12
  13   test "returns a list of conversations", %{conn: conn} do
  14     user_one = insert(:user)
  15     user_two = insert(:user)
  16     user_three = insert(:user)
  17
  18     {:ok, user_two} = User.follow(user_two, user_one)
  19
  20     assert User.get_cached_by_id(user_two.id).info.unread_conversation_count == 0
  21
  22     {:ok, direct} =
  23       CommonAPI.post(user_one, %{
  24         "status" => "Hi @#{user_two.nickname}, @#{user_three.nickname}!",
  25         "visibility" => "direct"
  26       })
  27
  28     assert User.get_cached_by_id(user_two.id).info.unread_conversation_count == 1
  29
  30     {:ok, _follower_only} =
  31       CommonAPI.post(user_one, %{
  32         "status" => "Hi @#{user_two.nickname}!",
  33         "visibility" => "private"
  34       })
  35
  36     res_conn =
  37       conn
  38       |> assign(:user, user_one)
  39       |> get("/api/v1/conversations")
  40
  41     assert response = json_response(res_conn, 200)
  42
  43     assert [
  44              %{
  45                "id" => res_id,
  46                "accounts" => res_accounts,
  47                "last_status" => res_last_status,
  48                "unread" => unread
  49              }
  50            ] = response
  51
  52     account_ids = Enum.map(res_accounts, & &1["id"])
  53     assert length(res_accounts) == 2
  54     assert user_two.id in account_ids
  55     assert user_three.id in account_ids
  56     assert is_binary(res_id)
  57     assert unread == true
  58     assert res_last_status["id"] == direct.id
  59     assert User.get_cached_by_id(user_one.id).info.unread_conversation_count == 1
  60   end
  61
  62   test "updates the last_status on reply", %{conn: conn} do
  63     user_one = insert(:user)
  64     user_two = insert(:user)
  65
  66     {:ok, direct} =
  67       CommonAPI.post(user_one, %{
  68         "status" => "Hi @#{user_two.nickname}",
  69         "visibility" => "direct"
  70       })
  71
  72     {:ok, direct_reply} =
  73       CommonAPI.post(user_two, %{
  74         "status" => "reply",
  75         "visibility" => "direct",
  76         "in_reply_to_status_id" => direct.id
  77       })
  78
  79     [%{"last_status" => res_last_status}] =
  80       conn
  81       |> assign(:user, user_one)
  82       |> get("/api/v1/conversations")
  83       |> json_response(200)
  84
  85     assert res_last_status["id"] == direct_reply.id
  86   end
  87
  88   test "the user marks a conversation as read", %{conn: conn} do
  89     user_one = insert(:user)
  90     user_two = insert(:user)
  91
  92     {:ok, direct} =
  93       CommonAPI.post(user_one, %{
  94         "status" => "Hi @#{user_two.nickname}",
  95         "visibility" => "direct"
  96       })
  97
  98     [%{"id" => direct_conversation_id, "unread" => true}] =
  99       conn
 100       |> assign(:user, user_one)
 101       |> get("/api/v1/conversations")
 102       |> json_response(200)
 103
 104     %{"unread" => false} =
 105       conn
 106       |> assign(:user, user_one)
 107       |> post("/api/v1/conversations/#{direct_conversation_id}/read")
 108       |> json_response(200)
 109
 110     assert User.get_cached_by_id(user_one.id).info.unread_conversation_count == 0
 111
 112     # The conversation is marked as unread on reply
 113     {:ok, _} =
 114       CommonAPI.post(user_two, %{
 115         "status" => "reply",
 116         "visibility" => "direct",
 117         "in_reply_to_status_id" => direct.id
 118       })
 119
 120     [%{"unread" => true}] =
 121       conn
 122       |> assign(:user, user_one)
 123       |> get("/api/v1/conversations")
 124       |> json_response(200)
 125
 126     assert User.get_cached_by_id(user_one.id).info.unread_conversation_count == 1
 127
 128     # A reply doesn't increment the user's unread_conversation_count if the conversation is unread
 129     {:ok, _} =
 130       CommonAPI.post(user_two, %{
 131         "status" => "reply",
 132         "visibility" => "direct",
 133         "in_reply_to_status_id" => direct.id
 134       })
 135
 136     assert User.get_cached_by_id(user_one.id).info.unread_conversation_count == 1
 137   end
 138
 139   test "(vanilla) Mastodon frontend behaviour", %{conn: conn} do
 140     user_one = insert(:user)
 141     user_two = insert(:user)
 142
 143     {:ok, direct} =
 144       CommonAPI.post(user_one, %{
 145         "status" => "Hi @#{user_two.nickname}!",
 146         "visibility" => "direct"
 147       })
 148
 149     res_conn =
 150       conn
 151       |> assign(:user, user_one)
 152       |> get("/api/v1/statuses/#{direct.id}/context")
 153
 154     assert %{"ancestors" => [], "descendants" => []} == json_response(res_conn, 200)
 155   end
 156 end