git.squeep.com Git - akkoma/blob - test/web/pleroma_api/controllers/pleroma_api_controller_test.exs

   1 # Pleroma: A lightweight social networking server
   2 # Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
   3 # SPDX-License-Identifier: AGPL-3.0-only
   4
   5 defmodule Pleroma.Web.PleromaAPI.PleromaAPIControllerTest do
   6   use Pleroma.Web.ConnCase
   7
   8   alias Pleroma.Conversation.Participation
   9   alias Pleroma.Notification
  10   alias Pleroma.Repo
  11   alias Pleroma.User
  12   alias Pleroma.Web.CommonAPI
  13
  14   import Pleroma.Factory
  15
  16   test "/api/v1/pleroma/conversations/:id" do
  17     user = insert(:user)
  18     %{user: other_user, conn: conn} = oauth_access(["read:statuses"])
  19
  20     {:ok, _activity} =
  21       CommonAPI.post(user, %{status: "Hi @#{other_user.nickname}!", visibility: "direct"})
  22
  23     [participation] = Participation.for_user(other_user)
  24
  25     result =
  26       conn
  27       |> get("/api/v1/pleroma/conversations/#{participation.id}")
  28       |> json_response_and_validate_schema(200)
  29
  30     assert result["id"] == participation.id |> to_string()
  31   end
  32
  33   test "/api/v1/pleroma/conversations/:id/statuses" do
  34     user = insert(:user)
  35     %{user: other_user, conn: conn} = oauth_access(["read:statuses"])
  36     third_user = insert(:user)
  37
  38     {:ok, _activity} =
  39       CommonAPI.post(user, %{status: "Hi @#{third_user.nickname}!", visibility: "direct"})
  40
  41     {:ok, activity} =
  42       CommonAPI.post(user, %{status: "Hi @#{other_user.nickname}!", visibility: "direct"})
  43
  44     [participation] = Participation.for_user(other_user)
  45
  46     {:ok, activity_two} =
  47       CommonAPI.post(other_user, %{
  48         status: "Hi!",
  49         in_reply_to_status_id: activity.id,
  50         in_reply_to_conversation_id: participation.id
  51       })
  52
  53     result =
  54       conn
  55       |> get("/api/v1/pleroma/conversations/#{participation.id}/statuses")
  56       |> json_response_and_validate_schema(200)
  57
  58     assert length(result) == 2
  59
  60     id_one = activity.id
  61     id_two = activity_two.id
  62     assert [%{"id" => ^id_one}, %{"id" => ^id_two}] = result
  63
  64     {:ok, %{id: id_three}} =
  65       CommonAPI.post(other_user, %{
  66         status: "Bye!",
  67         in_reply_to_status_id: activity.id,
  68         in_reply_to_conversation_id: participation.id
  69       })
  70
  71     assert [%{"id" => ^id_two}, %{"id" => ^id_three}] =
  72              conn
  73              |> get("/api/v1/pleroma/conversations/#{participation.id}/statuses?limit=2")
  74              |> json_response_and_validate_schema(:ok)
  75
  76     assert [%{"id" => ^id_three}] =
  77              conn
  78              |> get("/api/v1/pleroma/conversations/#{participation.id}/statuses?min_id=#{id_two}")
  79              |> json_response_and_validate_schema(:ok)
  80   end
  81
  82   test "PATCH /api/v1/pleroma/conversations/:id" do
  83     %{user: user, conn: conn} = oauth_access(["write:conversations"])
  84     other_user = insert(:user)
  85
  86     {:ok, _activity} = CommonAPI.post(user, %{status: "Hi", visibility: "direct"})
  87
  88     [participation] = Participation.for_user(user)
  89
  90     participation = Repo.preload(participation, :recipients)
  91
  92     user = User.get_cached_by_id(user.id)
  93     assert [user] == participation.recipients
  94     assert other_user not in participation.recipients
  95
  96     query = "recipients[]=#{user.id}&recipients[]=#{other_user.id}"
  97
  98     result =
  99       conn
 100       |> patch("/api/v1/pleroma/conversations/#{participation.id}?#{query}")
 101       |> json_response_and_validate_schema(200)
 102
 103     assert result["id"] == participation.id |> to_string
 104
 105     [participation] = Participation.for_user(user)
 106     participation = Repo.preload(participation, :recipients)
 107
 108     assert user in participation.recipients
 109     assert other_user in participation.recipients
 110   end
 111
 112   test "POST /api/v1/pleroma/conversations/read" do
 113     user = insert(:user)
 114     %{user: other_user, conn: conn} = oauth_access(["write:conversations"])
 115
 116     {:ok, _activity} =
 117       CommonAPI.post(user, %{status: "Hi @#{other_user.nickname}", visibility: "direct"})
 118
 119     {:ok, _activity} =
 120       CommonAPI.post(user, %{status: "Hi @#{other_user.nickname}", visibility: "direct"})
 121
 122     [participation2, participation1] = Participation.for_user(other_user)
 123     assert Participation.get(participation2.id).read == false
 124     assert Participation.get(participation1.id).read == false
 125     assert User.get_cached_by_id(other_user.id).unread_conversation_count == 2
 126
 127     [%{"unread" => false}, %{"unread" => false}] =
 128       conn
 129       |> post("/api/v1/pleroma/conversations/read", %{})
 130       |> json_response_and_validate_schema(200)
 131
 132     [participation2, participation1] = Participation.for_user(other_user)
 133     assert Participation.get(participation2.id).read == true
 134     assert Participation.get(participation1.id).read == true
 135     assert User.get_cached_by_id(other_user.id).unread_conversation_count == 0
 136   end
 137
 138   describe "POST /api/v1/pleroma/notifications/read" do
 139     setup do: oauth_access(["write:notifications"])
 140
 141     test "it marks a single notification as read", %{user: user1, conn: conn} do
 142       user2 = insert(:user)
 143       {:ok, activity1} = CommonAPI.post(user2, %{status: "hi @#{user1.nickname}"})
 144       {:ok, activity2} = CommonAPI.post(user2, %{status: "hi @#{user1.nickname}"})
 145       {:ok, [notification1]} = Notification.create_notifications(activity1)
 146       {:ok, [notification2]} = Notification.create_notifications(activity2)
 147
 148       response =
 149         conn
 150         |> post("/api/v1/pleroma/notifications/read?id=#{notification1.id}")
 151         |> json_response_and_validate_schema(:ok)
 152
 153       assert %{"pleroma" => %{"is_seen" => true}} = response
 154       assert Repo.get(Notification, notification1.id).seen
 155       refute Repo.get(Notification, notification2.id).seen
 156     end
 157
 158     test "it marks multiple notifications as read", %{user: user1, conn: conn} do
 159       user2 = insert(:user)
 160       {:ok, _activity1} = CommonAPI.post(user2, %{status: "hi @#{user1.nickname}"})
 161       {:ok, _activity2} = CommonAPI.post(user2, %{status: "hi @#{user1.nickname}"})
 162       {:ok, _activity3} = CommonAPI.post(user2, %{status: "HIE @#{user1.nickname}"})
 163
 164       [notification3, notification2, notification1] = Notification.for_user(user1, %{limit: 3})
 165
 166       [response1, response2] =
 167         conn
 168         |> post("/api/v1/pleroma/notifications/read?max_id=#{notification2.id}")
 169         |> json_response_and_validate_schema(:ok)
 170
 171       assert %{"pleroma" => %{"is_seen" => true}} = response1
 172       assert %{"pleroma" => %{"is_seen" => true}} = response2
 173       assert Repo.get(Notification, notification1.id).seen
 174       assert Repo.get(Notification, notification2.id).seen
 175       refute Repo.get(Notification, notification3.id).seen
 176     end
 177
 178     test "it returns error when notification not found", %{conn: conn} do
 179       response =
 180         conn
 181         |> post("/api/v1/pleroma/notifications/read?id=22222222222222")
 182         |> json_response_and_validate_schema(:bad_request)
 183
 184       assert response == %{"error" => "Cannot get notification"}
 185     end
 186   end
 187 end