1 defmodule Pleroma.Web.MastodonAPI.MastodonAPIControllerTest do
2 use Pleroma.Web.ConnCase
4 alias Pleroma.Web.TwitterAPI.TwitterAPI
5 alias Pleroma.{Repo, User, Activity, Notification}
6 alias Pleroma.Web.{OStatus, CommonAPI}
9 import ExUnit.CaptureLog
11 test "the home timeline", %{conn: conn} do
13 following = insert(:user)
15 {:ok, _activity} = TwitterAPI.create_status(following, %{"status" => "test"})
19 |> assign(:user, user)
20 |> get("/api/v1/timelines/home")
22 assert length(json_response(conn, 200)) == 0
24 {:ok, user} = User.follow(user, following)
28 |> assign(:user, user)
29 |> get("/api/v1/timelines/home")
31 assert [%{"content" => "test"}] = json_response(conn, 200)
34 test "the public timeline", %{conn: conn} do
35 following = insert(:user)
38 {:ok, _activity} = TwitterAPI.create_status(following, %{"status" => "test"})
41 OStatus.fetch_activity_from_url("https://shitposter.club/notice/2827873")
45 |> get("/api/v1/timelines/public", %{"local" => "False"})
47 assert length(json_response(conn, 200)) == 2
51 |> get("/api/v1/timelines/public", %{"local" => "True"})
53 assert [%{"content" => "test"}] = json_response(conn, 200)
57 |> get("/api/v1/timelines/public", %{"local" => "1"})
59 assert [%{"content" => "test"}] = json_response(conn, 200)
63 test "posting a status", %{conn: conn} do
66 idempotency_key = "Pikachu rocks!"
70 |> assign(:user, user)
71 |> put_req_header("idempotency-key", idempotency_key)
72 |> post("/api/v1/statuses", %{
74 "spoiler_text" => "2hu",
75 "sensitive" => "false"
78 {:ok, ttl} = Cachex.ttl(:idempotency_cache, idempotency_key)
80 assert ttl > :timer.seconds(6 * 60 * 60 - 1)
82 assert %{"content" => "cofe", "id" => id, "spoiler_text" => "2hu", "sensitive" => false} =
83 json_response(conn_one, 200)
85 assert Repo.get(Activity, id)
89 |> assign(:user, user)
90 |> put_req_header("idempotency-key", idempotency_key)
91 |> post("/api/v1/statuses", %{
93 "spoiler_text" => "2hu",
94 "sensitive" => "false"
97 assert %{"id" => second_id} = json_response(conn_two, 200)
99 assert id == second_id
103 |> assign(:user, user)
104 |> post("/api/v1/statuses", %{
106 "spoiler_text" => "2hu",
107 "sensitive" => "false"
110 assert %{"id" => third_id} = json_response(conn_three, 200)
112 refute id == third_id
115 test "posting a sensitive status", %{conn: conn} do
120 |> assign(:user, user)
121 |> post("/api/v1/statuses", %{"status" => "cofe", "sensitive" => true})
123 assert %{"content" => "cofe", "id" => id, "sensitive" => true} = json_response(conn, 200)
124 assert Repo.get(Activity, id)
127 test "posting a direct status", %{conn: conn} do
128 user1 = insert(:user)
129 user2 = insert(:user)
130 content = "direct cofe @#{user2.nickname}"
134 |> assign(:user, user1)
135 |> post("api/v1/statuses", %{"status" => content, "visibility" => "direct"})
137 assert %{"id" => id, "visibility" => "direct"} = json_response(conn, 200)
138 assert activity = Repo.get(Activity, id)
139 assert user2.follower_address not in activity.data["to"]
142 test "direct timeline", %{conn: conn} do
143 dm = insert(:direct_note_activity)
144 reg_note = insert(:note_activity)
146 recipient = User.get_by_ap_id(hd(dm.recipients))
150 |> assign(:user, recipient)
151 |> get("api/v1/timelines/direct")
153 resp = json_response(conn, 200)
154 first_status = hd(resp)
156 assert length(resp) == 1
157 assert %{"visibility" => "direct"} = first_status
158 assert first_status["url"] != reg_note.data["id"]
161 test "replying to a status", %{conn: conn} do
164 {:ok, replied_to} = TwitterAPI.create_status(user, %{"status" => "cofe"})
168 |> assign(:user, user)
169 |> post("/api/v1/statuses", %{"status" => "xD", "in_reply_to_id" => replied_to.id})
171 assert %{"content" => "xD", "id" => id} = json_response(conn, 200)
173 activity = Repo.get(Activity, id)
175 assert activity.data["context"] == replied_to.data["context"]
176 assert activity.data["object"]["inReplyToStatusId"] == replied_to.id
179 test "verify_credentials", %{conn: conn} do
184 |> assign(:user, user)
185 |> get("/api/v1/accounts/verify_credentials")
187 assert %{"id" => id} = json_response(conn, 200)
188 assert id == to_string(user.id)
191 test "get a status", %{conn: conn} do
192 activity = insert(:note_activity)
196 |> get("/api/v1/statuses/#{activity.id}")
198 assert %{"id" => id} = json_response(conn, 200)
199 assert id == to_string(activity.id)
202 describe "deleting a status" do
203 test "when you created it", %{conn: conn} do
204 activity = insert(:note_activity)
205 author = User.get_by_ap_id(activity.data["actor"])
209 |> assign(:user, author)
210 |> delete("/api/v1/statuses/#{activity.id}")
212 assert %{} = json_response(conn, 200)
214 assert Repo.get(Activity, activity.id) == nil
217 test "when you didn't create it", %{conn: conn} do
218 activity = insert(:note_activity)
223 |> assign(:user, user)
224 |> delete("/api/v1/statuses/#{activity.id}")
226 assert %{"error" => _} = json_response(conn, 403)
228 assert Repo.get(Activity, activity.id) == activity
232 describe "notifications" do
233 test "list of notifications", %{conn: conn} do
235 other_user = insert(:user)
238 TwitterAPI.create_status(other_user, %{"status" => "hi @#{user.nickname}"})
240 {:ok, [_notification]} = Notification.create_notifications(activity)
244 |> assign(:user, user)
245 |> get("/api/v1/notifications")
248 "hi <span><a href=\"#{user.ap_id}\">@<span>#{user.nickname}</span></a></span>"
250 assert [%{"status" => %{"content" => response}} | _rest] = json_response(conn, 200)
251 assert response == expected_response
254 test "getting a single notification", %{conn: conn} do
256 other_user = insert(:user)
259 TwitterAPI.create_status(other_user, %{"status" => "hi @#{user.nickname}"})
261 {:ok, [notification]} = Notification.create_notifications(activity)
265 |> assign(:user, user)
266 |> get("/api/v1/notifications/#{notification.id}")
269 "hi <span><a href=\"#{user.ap_id}\">@<span>#{user.nickname}</span></a></span>"
271 assert %{"status" => %{"content" => response}} = json_response(conn, 200)
272 assert response == expected_response
275 test "dismissing a single notification", %{conn: conn} do
277 other_user = insert(:user)
280 TwitterAPI.create_status(other_user, %{"status" => "hi @#{user.nickname}"})
282 {:ok, [notification]} = Notification.create_notifications(activity)
286 |> assign(:user, user)
287 |> post("/api/v1/notifications/dismiss", %{"id" => notification.id})
289 assert %{} = json_response(conn, 200)
292 test "clearing all notifications", %{conn: conn} do
294 other_user = insert(:user)
297 TwitterAPI.create_status(other_user, %{"status" => "hi @#{user.nickname}"})
299 {:ok, [_notification]} = Notification.create_notifications(activity)
303 |> assign(:user, user)
304 |> post("/api/v1/notifications/clear")
306 assert %{} = json_response(conn, 200)
310 |> assign(:user, user)
311 |> get("/api/v1/notifications")
313 assert all = json_response(conn, 200)
318 describe "reblogging" do
319 test "reblogs and returns the reblogged status", %{conn: conn} do
320 activity = insert(:note_activity)
325 |> assign(:user, user)
326 |> post("/api/v1/statuses/#{activity.id}/reblog")
328 assert %{"reblog" => %{"id" => id, "reblogged" => true, "reblogs_count" => 1}} =
329 json_response(conn, 200)
331 assert to_string(activity.id) == id
335 describe "unreblogging" do
336 test "unreblogs and returns the unreblogged status", %{conn: conn} do
337 activity = insert(:note_activity)
340 {:ok, _, _} = CommonAPI.repeat(activity.id, user)
344 |> assign(:user, user)
345 |> post("/api/v1/statuses/#{activity.id}/unreblog")
347 assert %{"id" => id, "reblogged" => false, "reblogs_count" => 0} = json_response(conn, 200)
349 assert to_string(activity.id) == id
353 describe "favoriting" do
354 test "favs a status and returns it", %{conn: conn} do
355 activity = insert(:note_activity)
360 |> assign(:user, user)
361 |> post("/api/v1/statuses/#{activity.id}/favourite")
363 assert %{"id" => id, "favourites_count" => 1, "favourited" => true} =
364 json_response(conn, 200)
366 assert to_string(activity.id) == id
370 describe "unfavoriting" do
371 test "unfavorites a status and returns it", %{conn: conn} do
372 activity = insert(:note_activity)
375 {:ok, _, _} = CommonAPI.favorite(activity.id, user)
379 |> assign(:user, user)
380 |> post("/api/v1/statuses/#{activity.id}/unfavourite")
382 assert %{"id" => id, "favourites_count" => 0, "favourited" => false} =
383 json_response(conn, 200)
385 assert to_string(activity.id) == id
389 describe "user timelines" do
390 test "gets a users statuses", %{conn: conn} do
391 user_one = insert(:user)
392 user_two = insert(:user)
393 user_three = insert(:user)
395 {:ok, user_three} = User.follow(user_three, user_one)
397 {:ok, activity} = CommonAPI.post(user_one, %{"status" => "HI!!!"})
399 {:ok, direct_activity} =
400 CommonAPI.post(user_one, %{
401 "status" => "Hi, @#{user_two.nickname}.",
402 "visibility" => "direct"
405 {:ok, private_activity} =
406 CommonAPI.post(user_one, %{"status" => "private", "visibility" => "private"})
410 |> get("/api/v1/accounts/#{user_one.id}/statuses")
412 assert [%{"id" => id}] = json_response(resp, 200)
413 assert id == to_string(activity.id)
417 |> assign(:user, user_two)
418 |> get("/api/v1/accounts/#{user_one.id}/statuses")
420 assert [%{"id" => id_one}, %{"id" => id_two}] = json_response(resp, 200)
421 assert id_one == to_string(direct_activity.id)
422 assert id_two == to_string(activity.id)
426 |> assign(:user, user_three)
427 |> get("/api/v1/accounts/#{user_one.id}/statuses")
429 assert [%{"id" => id_one}, %{"id" => id_two}] = json_response(resp, 200)
430 assert id_one == to_string(private_activity.id)
431 assert id_two == to_string(activity.id)
434 test "unimplemented pinned statuses feature", %{conn: conn} do
435 note = insert(:note_activity)
436 user = User.get_by_ap_id(note.data["actor"])
440 |> get("/api/v1/accounts/#{user.id}/statuses?pinned=true")
442 assert json_response(conn, 200) == []
445 test "gets an users media", %{conn: conn} do
446 note = insert(:note_activity)
447 user = User.get_by_ap_id(note.data["actor"])
450 content_type: "image/jpg",
451 path: Path.absname("test/fixtures/image.jpg"),
452 filename: "an_image.jpg"
456 TwitterAPI.upload(file, "json")
460 TwitterAPI.create_status(user, %{"status" => "cofe", "media_ids" => [media["media_id"]]})
464 |> get("/api/v1/accounts/#{user.id}/statuses", %{"only_media" => "true"})
466 assert [%{"id" => id}] = json_response(conn, 200)
467 assert id == to_string(image_post.id)
471 |> get("/api/v1/accounts/#{user.id}/statuses", %{"only_media" => "1"})
473 assert [%{"id" => id}] = json_response(conn, 200)
474 assert id == to_string(image_post.id)
478 describe "user relationships" do
479 test "returns the relationships for the current user", %{conn: conn} do
481 other_user = insert(:user)
482 {:ok, user} = User.follow(user, other_user)
486 |> assign(:user, user)
487 |> get("/api/v1/accounts/relationships", %{"id" => [other_user.id]})
489 assert [relationship] = json_response(conn, 200)
491 assert to_string(other_user.id) == relationship["id"]
495 test "account fetching", %{conn: conn} do
500 |> get("/api/v1/accounts/#{user.id}")
502 assert %{"id" => id} = json_response(conn, 200)
503 assert id == to_string(user.id)
507 |> get("/api/v1/accounts/-1")
509 assert %{"error" => "Can't find user"} = json_response(conn, 404)
512 test "media upload", %{conn: conn} do
514 content_type: "image/jpg",
515 path: Path.absname("test/fixtures/image.jpg"),
516 filename: "an_image.jpg"
523 |> assign(:user, user)
524 |> post("/api/v1/media", %{"file" => file})
526 assert media = json_response(conn, 200)
528 assert media["type"] == "image"
531 test "hashtag timeline", %{conn: conn} do
532 following = insert(:user)
535 {:ok, activity} = TwitterAPI.create_status(following, %{"status" => "test #2hu"})
538 OStatus.fetch_activity_from_url("https://shitposter.club/notice/2827873")
542 |> get("/api/v1/timelines/tag/2hu")
544 assert [%{"id" => id}] = json_response(conn, 200)
546 assert id == to_string(activity.id)
550 test "getting followers", %{conn: conn} do
552 other_user = insert(:user)
553 {:ok, user} = User.follow(user, other_user)
557 |> get("/api/v1/accounts/#{other_user.id}/followers")
559 assert [%{"id" => id}] = json_response(conn, 200)
560 assert id == to_string(user.id)
563 test "getting following", %{conn: conn} do
565 other_user = insert(:user)
566 {:ok, user} = User.follow(user, other_user)
570 |> get("/api/v1/accounts/#{user.id}/following")
572 assert [%{"id" => id}] = json_response(conn, 200)
573 assert id == to_string(other_user.id)
576 test "following / unfollowing a user", %{conn: conn} do
578 other_user = insert(:user)
582 |> assign(:user, user)
583 |> post("/api/v1/accounts/#{other_user.id}/follow")
585 assert %{"id" => _id, "following" => true} = json_response(conn, 200)
587 user = Repo.get(User, user.id)
591 |> assign(:user, user)
592 |> post("/api/v1/accounts/#{other_user.id}/unfollow")
594 assert %{"id" => _id, "following" => false} = json_response(conn, 200)
596 user = Repo.get(User, user.id)
600 |> assign(:user, user)
601 |> post("/api/v1/follows", %{"uri" => other_user.nickname})
603 assert %{"id" => id} = json_response(conn, 200)
604 assert id == to_string(other_user.id)
607 test "blocking / unblocking a user", %{conn: conn} do
609 other_user = insert(:user)
613 |> assign(:user, user)
614 |> post("/api/v1/accounts/#{other_user.id}/block")
616 assert %{"id" => _id, "blocking" => true} = json_response(conn, 200)
618 user = Repo.get(User, user.id)
622 |> assign(:user, user)
623 |> post("/api/v1/accounts/#{other_user.id}/unblock")
625 assert %{"id" => _id, "blocking" => false} = json_response(conn, 200)
628 test "getting a list of blocks", %{conn: conn} do
630 other_user = insert(:user)
632 {:ok, user} = User.block(user, other_user)
636 |> assign(:user, user)
637 |> get("/api/v1/blocks")
639 other_user_id = to_string(other_user.id)
640 assert [%{"id" => ^other_user_id}] = json_response(conn, 200)
643 test "unimplemented mute endpoints" do
645 other_user = insert(:user)
648 |> Enum.each(fn endpoint ->
651 |> assign(:user, user)
652 |> post("/api/v1/accounts/#{other_user.id}/#{endpoint}")
654 assert %{"id" => id} = json_response(conn, 200)
655 assert id == to_string(other_user.id)
659 test "unimplemented mutes, follow_requests, blocks, domain blocks" do
662 ["blocks", "domain_blocks", "mutes", "follow_requests"]
663 |> Enum.each(fn endpoint ->
666 |> assign(:user, user)
667 |> get("/api/v1/#{endpoint}")
669 assert [] = json_response(conn, 200)
673 test "account search", %{conn: conn} do
675 user_two = insert(:user, %{nickname: "shp@shitposter.club"})
676 user_three = insert(:user, %{nickname: "shp@heldscal.la", name: "I love 2hu"})
680 |> assign(:user, user)
681 |> get("/api/v1/accounts/search", %{"q" => "shp"})
682 |> json_response(200)
684 result_ids = for result <- results, do: result["acct"]
686 assert user_two.nickname in result_ids
687 assert user_three.nickname in result_ids
691 |> assign(:user, user)
692 |> get("/api/v1/accounts/search", %{"q" => "2hu"})
693 |> json_response(200)
695 result_ids = for result <- results, do: result["acct"]
697 assert user_three.nickname in result_ids
700 test "search", %{conn: conn} do
702 user_two = insert(:user, %{nickname: "shp@shitposter.club"})
703 user_three = insert(:user, %{nickname: "shp@heldscal.la", name: "I love 2hu"})
705 {:ok, activity} = CommonAPI.post(user, %{"status" => "This is about 2hu"})
708 CommonAPI.post(user, %{
709 "status" => "This is about 2hu, but private",
710 "visibility" => "private"
713 {:ok, _} = CommonAPI.post(user_two, %{"status" => "This isn't"})
717 |> get("/api/v1/search", %{"q" => "2hu"})
719 assert results = json_response(conn, 200)
721 [account | _] = results["accounts"]
722 assert account["id"] == to_string(user_three.id)
724 assert results["hashtags"] == []
726 [status] = results["statuses"]
727 assert status["id"] == to_string(activity.id)
730 test "search fetches remote statuses", %{conn: conn} do
734 |> get("/api/v1/search", %{"q" => "https://shitposter.club/notice/2827873"})
736 assert results = json_response(conn, 200)
738 [status] = results["statuses"]
739 assert status["uri"] == "tag:shitposter.club,2017-05-05:noticeId=2827873:objectType=comment"
743 test "search fetches remote accounts", %{conn: conn} do
746 |> get("/api/v1/search", %{"q" => "shp@social.heldscal.la", "resolve" => "true"})
748 assert results = json_response(conn, 200)
749 [account] = results["accounts"]
750 assert account["acct"] == "shp@social.heldscal.la"
753 test "returns the favorites of a user", %{conn: conn} do
755 other_user = insert(:user)
757 {:ok, _} = CommonAPI.post(other_user, %{"status" => "bla"})
758 {:ok, activity} = CommonAPI.post(other_user, %{"status" => "traps are happy"})
760 {:ok, _, _} = CommonAPI.favorite(activity.id, user)
764 |> assign(:user, user)
765 |> get("/api/v1/favourites")
767 assert [status] = json_response(conn, 200)
768 assert status["id"] == to_string(activity.id)
771 describe "updating credentials" do
772 test "updates the user's bio", %{conn: conn} do
777 |> assign(:user, user)
778 |> patch("/api/v1/accounts/update_credentials", %{"note" => "I drink #cofe"})
780 assert user = json_response(conn, 200)
781 assert user["note"] == "I drink #cofe"
784 test "updates the user's name", %{conn: conn} do
789 |> assign(:user, user)
790 |> patch("/api/v1/accounts/update_credentials", %{"display_name" => "markorepairs"})
792 assert user = json_response(conn, 200)
793 assert user["display_name"] == "markorepairs"
796 test "updates the user's avatar", %{conn: conn} do
799 new_avatar = %Plug.Upload{
800 content_type: "image/jpg",
801 path: Path.absname("test/fixtures/image.jpg"),
802 filename: "an_image.jpg"
807 |> assign(:user, user)
808 |> patch("/api/v1/accounts/update_credentials", %{"avatar" => new_avatar})
810 assert user = json_response(conn, 200)
811 assert user["avatar"] != "https://placehold.it/48x48"
814 test "updates the user's banner", %{conn: conn} do
817 new_header = %Plug.Upload{
818 content_type: "image/jpg",
819 path: Path.absname("test/fixtures/image.jpg"),
820 filename: "an_image.jpg"
825 |> assign(:user, user)
826 |> patch("/api/v1/accounts/update_credentials", %{"header" => new_header})
828 assert user = json_response(conn, 200)
829 assert user["header"] != "https://placehold.it/700x335"
833 test "get instance information", %{conn: conn} do
834 insert(:user, %{local: true})
835 user = insert(:user, %{local: true})
836 insert(:user, %{local: false})
838 {:ok, _} = TwitterAPI.create_status(user, %{"status" => "cofe"})
840 Pleroma.Stats.update_stats()
844 |> get("/api/v1/instance")
846 assert result = json_response(conn, 200)
848 assert result["stats"]["user_count"] == 2
849 assert result["stats"]["status_count"] == 1