1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.Web.PleromaAPI.PleromaAPIControllerTest do
6 use Pleroma.Web.ConnCase
8 alias Pleroma.Conversation.Participation
9 alias Pleroma.Notification
13 alias Pleroma.Web.CommonAPI
15 import Pleroma.Factory
17 test "POST /api/v1/pleroma/statuses/:id/react_with_emoji", %{conn: conn} do
19 other_user = insert(:user)
21 {:ok, activity} = CommonAPI.post(user, %{"status" => "#cofe"})
25 |> assign(:user, other_user)
26 |> post("/api/v1/pleroma/statuses/#{activity.id}/react_with_emoji", %{"emoji" => "☕"})
28 assert %{"id" => id} = json_response(result, 200)
29 assert to_string(activity.id) == id
32 test "POST /api/v1/pleroma/statuses/:id/unreact_with_emoji", %{conn: conn} do
34 other_user = insert(:user)
36 {:ok, activity} = CommonAPI.post(user, %{"status" => "#cofe"})
37 {:ok, activity, _object} = CommonAPI.react_with_emoji(activity.id, other_user, "☕")
41 |> assign(:user, other_user)
42 |> post("/api/v1/pleroma/statuses/#{activity.id}/unreact_with_emoji", %{"emoji" => "☕"})
44 assert %{"id" => id} = json_response(result, 200)
45 assert to_string(activity.id) == id
47 object = Object.normalize(activity)
49 assert object.data["reaction_count"] == 0
52 test "GET /api/v1/pleroma/statuses/:id/emoji_reactions_by", %{conn: conn} do
54 other_user = insert(:user)
56 {:ok, activity} = CommonAPI.post(user, %{"status" => "#cofe"})
60 |> get("/api/v1/pleroma/statuses/#{activity.id}/emoji_reactions_by")
65 {:ok, _, _} = CommonAPI.react_with_emoji(activity.id, other_user, "🎅")
69 |> get("/api/v1/pleroma/statuses/#{activity.id}/emoji_reactions_by")
72 [represented_user] = result["🎅"]
73 assert represented_user["id"] == other_user.id
76 test "/api/v1/pleroma/conversations/:id", %{conn: conn} do
78 other_user = insert(:user)
81 CommonAPI.post(user, %{"status" => "Hi @#{other_user.nickname}!", "visibility" => "direct"})
83 [participation] = Participation.for_user(other_user)
87 |> assign(:user, other_user)
88 |> get("/api/v1/pleroma/conversations/#{participation.id}")
91 assert result["id"] == participation.id |> to_string()
94 test "/api/v1/pleroma/conversations/:id/statuses", %{conn: conn} do
96 other_user = insert(:user)
97 third_user = insert(:user)
100 CommonAPI.post(user, %{"status" => "Hi @#{third_user.nickname}!", "visibility" => "direct"})
103 CommonAPI.post(user, %{"status" => "Hi @#{other_user.nickname}!", "visibility" => "direct"})
105 [participation] = Participation.for_user(other_user)
107 {:ok, activity_two} =
108 CommonAPI.post(other_user, %{
110 "in_reply_to_status_id" => activity.id,
111 "in_reply_to_conversation_id" => participation.id
116 |> assign(:user, other_user)
117 |> get("/api/v1/pleroma/conversations/#{participation.id}/statuses")
118 |> json_response(200)
120 assert length(result) == 2
123 id_two = activity_two.id
124 assert [%{"id" => ^id_one}, %{"id" => ^id_two}] = result
127 test "PATCH /api/v1/pleroma/conversations/:id", %{conn: conn} do
129 other_user = insert(:user)
131 {:ok, _activity} = CommonAPI.post(user, %{"status" => "Hi", "visibility" => "direct"})
133 [participation] = Participation.for_user(user)
135 participation = Repo.preload(participation, :recipients)
137 user = User.get_cached_by_id(user.id)
138 assert [user] == participation.recipients
139 assert other_user not in participation.recipients
143 |> assign(:user, user)
144 |> patch("/api/v1/pleroma/conversations/#{participation.id}", %{
145 "recipients" => [user.id, other_user.id]
147 |> json_response(200)
149 assert result["id"] == participation.id |> to_string
151 [participation] = Participation.for_user(user)
152 participation = Repo.preload(participation, :recipients)
154 assert user in participation.recipients
155 assert other_user in participation.recipients
158 describe "POST /api/v1/pleroma/notifications/read" do
159 test "it marks a single notification as read", %{conn: conn} do
160 user1 = insert(:user)
161 user2 = insert(:user)
162 {:ok, activity1} = CommonAPI.post(user2, %{"status" => "hi @#{user1.nickname}"})
163 {:ok, activity2} = CommonAPI.post(user2, %{"status" => "hi @#{user1.nickname}"})
164 {:ok, [notification1]} = Notification.create_notifications(activity1)
165 {:ok, [notification2]} = Notification.create_notifications(activity2)
169 |> assign(:user, user1)
170 |> post("/api/v1/pleroma/notifications/read", %{"id" => "#{notification1.id}"})
171 |> json_response(:ok)
173 assert %{"pleroma" => %{"is_seen" => true}} = response
174 assert Repo.get(Notification, notification1.id).seen
175 refute Repo.get(Notification, notification2.id).seen
178 test "it marks multiple notifications as read", %{conn: conn} do
179 user1 = insert(:user)
180 user2 = insert(:user)
181 {:ok, _activity1} = CommonAPI.post(user2, %{"status" => "hi @#{user1.nickname}"})
182 {:ok, _activity2} = CommonAPI.post(user2, %{"status" => "hi @#{user1.nickname}"})
183 {:ok, _activity3} = CommonAPI.post(user2, %{"status" => "HIE @#{user1.nickname}"})
185 [notification3, notification2, notification1] = Notification.for_user(user1, %{limit: 3})
187 [response1, response2] =
189 |> assign(:user, user1)
190 |> post("/api/v1/pleroma/notifications/read", %{"max_id" => "#{notification2.id}"})
191 |> json_response(:ok)
193 assert %{"pleroma" => %{"is_seen" => true}} = response1
194 assert %{"pleroma" => %{"is_seen" => true}} = response2
195 assert Repo.get(Notification, notification1.id).seen
196 assert Repo.get(Notification, notification2.id).seen
197 refute Repo.get(Notification, notification3.id).seen
200 test "it returns error when notification not found", %{conn: conn} do
201 user1 = insert(:user)
205 |> assign(:user, user1)
206 |> post("/api/v1/pleroma/notifications/read", %{"id" => "22222222222222"})
207 |> json_response(:bad_request)
209 assert response == %{"error" => "Cannot get notification"}