1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2021 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.Web.MastodonAPI.TimelineControllerTest do
6 use Pleroma.Web.ConnCase
12 alias Pleroma.Web.CommonAPI
15 mock(fn env -> apply(HttpRequestMock, :request, [env]) end)
20 setup do: oauth_access(["read:statuses"])
22 test "does NOT embed account/pleroma/relationship in statuses", %{
26 other_user = insert(:user)
28 {:ok, _} = CommonAPI.post(other_user, %{status: "hi @#{user.nickname}"})
32 |> assign(:user, user)
33 |> get("/api/v1/timelines/home")
34 |> json_response_and_validate_schema(200)
36 assert Enum.all?(response, fn n ->
37 get_in(n, ["account", "pleroma", "relationship"]) == %{}
41 test "the home timeline when the direct messages are excluded", %{user: user, conn: conn} do
42 {:ok, public_activity} = CommonAPI.post(user, %{status: ".", visibility: "public"})
43 {:ok, direct_activity} = CommonAPI.post(user, %{status: ".", visibility: "direct"})
45 {:ok, unlisted_activity} = CommonAPI.post(user, %{status: ".", visibility: "unlisted"})
47 {:ok, private_activity} = CommonAPI.post(user, %{status: ".", visibility: "private"})
49 conn = get(conn, "/api/v1/timelines/home?exclude_visibilities[]=direct")
51 assert status_ids = json_response_and_validate_schema(conn, :ok) |> Enum.map(& &1["id"])
52 assert public_activity.id in status_ids
53 assert unlisted_activity.id in status_ids
54 assert private_activity.id in status_ids
55 refute direct_activity.id in status_ids
58 test "muted emotions", %{user: user, conn: conn} do
59 other_user = insert(:user)
60 {:ok, activity} = CommonAPI.post(user, %{status: "."})
62 {:ok, _} = CommonAPI.react_with_emoji(activity.id, other_user, "🎅")
63 User.mute(user, other_user)
67 |> assign(:user, user)
68 |> get("/api/v1/timelines/home")
69 |> json_response_and_validate_schema(200)
74 "emoji_reactions" => []
81 |> assign(:user, user)
82 |> get("/api/v1/timelines/home?with_muted=true")
83 |> json_response_and_validate_schema(200)
88 "emoji_reactions" => [%{"count" => 1, "me" => false, "name" => "🎅"}]
94 test "filtering", %{conn: conn, user: user} do
95 local_user = insert(:user)
96 {:ok, user, local_user} = User.follow(user, local_user)
97 {:ok, local_activity} = CommonAPI.post(local_user, %{status: "Status"})
98 with_media = create_with_media_activity(local_user)
100 remote_user = insert(:user, local: false)
101 {:ok, _user, remote_user} = User.follow(user, remote_user)
102 remote_activity = create_remote_activity(remote_user)
106 |> get("/api/v1/timelines/home")
107 |> json_response_and_validate_schema(200)
108 |> Enum.map(& &1["id"])
110 assert local_activity.id in without_filter_ids
111 assert remote_activity.id in without_filter_ids
112 assert with_media.id in without_filter_ids
116 |> get("/api/v1/timelines/home?local=true")
117 |> json_response_and_validate_schema(200)
118 |> Enum.map(& &1["id"])
120 assert local_activity.id in only_local_ids
121 refute remote_activity.id in only_local_ids
122 assert with_media.id in only_local_ids
124 only_local_media_ids =
126 |> get("/api/v1/timelines/home?local=true&only_media=true")
127 |> json_response_and_validate_schema(200)
128 |> Enum.map(& &1["id"])
130 refute local_activity.id in only_local_media_ids
131 refute remote_activity.id in only_local_media_ids
132 assert with_media.id in only_local_media_ids
136 |> get("/api/v1/timelines/home?remote=true")
137 |> json_response_and_validate_schema(200)
138 |> Enum.map(& &1["id"])
140 refute local_activity.id in remote_ids
141 assert remote_activity.id in remote_ids
142 refute with_media.id in remote_ids
145 |> get("/api/v1/timelines/home?remote=true&only_media=true")
146 |> json_response_and_validate_schema(200) == []
149 |> get("/api/v1/timelines/home?remote=true&local=true")
150 |> json_response_and_validate_schema(200) == []
155 @tag capture_log: true
156 test "the public timeline", %{conn: conn} do
159 {:ok, activity} = CommonAPI.post(user, %{status: "test"})
160 with_media = create_with_media_activity(user)
162 remote = insert(:note_activity, local: false)
165 |> get("/api/v1/timelines/public?local=False")
166 |> json_response_and_validate_schema(:ok)
171 |> get("/api/v1/timelines/public?local=True")
172 |> json_response_and_validate_schema(:ok)
173 |> Enum.map(& &1["id"])
175 assert activity.id in local_ids
176 assert with_media.id in local_ids
177 refute remote.id in local_ids
181 |> get("/api/v1/timelines/public?local=True")
182 |> json_response_and_validate_schema(:ok)
183 |> Enum.map(& &1["id"])
185 assert activity.id in local_ids
186 assert with_media.id in local_ids
187 refute remote.id in local_ids
191 |> get("/api/v1/timelines/public?local=True&only_media=true")
192 |> json_response_and_validate_schema(:ok)
193 |> Enum.map(& &1["id"])
195 refute activity.id in local_ids
196 assert with_media.id in local_ids
197 refute remote.id in local_ids
201 |> get("/api/v1/timelines/public?local=1")
202 |> json_response_and_validate_schema(:ok)
203 |> Enum.map(& &1["id"])
205 assert activity.id in local_ids
206 assert with_media.id in local_ids
207 refute remote.id in local_ids
209 remote_id = remote.id
211 assert [%{"id" => ^remote_id}] =
213 |> get("/api/v1/timelines/public?remote=true")
214 |> json_response_and_validate_schema(:ok)
216 with_media_id = with_media.id
218 assert [%{"id" => ^with_media_id}] =
220 |> get("/api/v1/timelines/public?only_media=true")
221 |> json_response_and_validate_schema(:ok)
224 |> get("/api/v1/timelines/public?remote=true&only_media=true")
225 |> json_response_and_validate_schema(:ok) == []
227 # does not contain repeats
228 {:ok, _} = CommonAPI.repeat(activity.id, user)
232 |> get("/api/v1/timelines/public?local=true")
233 |> json_response_and_validate_schema(:ok)
236 test "the public timeline includes only public statuses for an authenticated user" do
237 %{user: user, conn: conn} = oauth_access(["read:statuses"])
239 {:ok, _activity} = CommonAPI.post(user, %{status: "test"})
240 {:ok, _activity} = CommonAPI.post(user, %{status: "test", visibility: "private"})
241 {:ok, _activity} = CommonAPI.post(user, %{status: "test", visibility: "unlisted"})
242 {:ok, _activity} = CommonAPI.post(user, %{status: "test", visibility: "direct"})
244 res_conn = get(conn, "/api/v1/timelines/public")
245 assert length(json_response_and_validate_schema(res_conn, 200)) == 1
248 test "doesn't return replies if follower is posting with blocked user" do
249 %{conn: conn, user: blocker} = oauth_access(["read:statuses"])
250 [blockee, friend] = insert_list(2, :user)
251 {:ok, blocker, friend} = User.follow(blocker, friend)
252 {:ok, _} = User.block(blocker, blockee)
254 conn = assign(conn, :user, blocker)
256 {:ok, %{id: activity_id} = activity} = CommonAPI.post(friend, %{status: "hey!"})
258 {:ok, reply_from_blockee} =
259 CommonAPI.post(blockee, %{status: "heya", in_reply_to_status_id: activity})
261 {:ok, _reply_from_friend} =
262 CommonAPI.post(friend, %{status: "status", in_reply_to_status_id: reply_from_blockee})
264 # Still shows replies from yourself
265 {:ok, %{id: reply_from_me}} =
266 CommonAPI.post(blocker, %{status: "status", in_reply_to_status_id: reply_from_blockee})
269 get(conn, "/api/v1/timelines/public")
270 |> json_response_and_validate_schema(200)
272 assert length(response) == 2
273 [%{"id" => ^reply_from_me}, %{"id" => ^activity_id}] = response
276 test "doesn't return posts from users who blocked you when :blockers_visible is disabled" do
277 clear_config([:activitypub, :blockers_visible], false)
279 %{conn: conn, user: blockee} = oauth_access(["read:statuses"])
280 blocker = insert(:user)
281 {:ok, _} = User.block(blocker, blockee)
283 conn = assign(conn, :user, blockee)
285 {:ok, _} = CommonAPI.post(blocker, %{status: "hey!"})
288 get(conn, "/api/v1/timelines/public")
289 |> json_response_and_validate_schema(200)
291 assert response == []
294 test "doesn't return replies if follow is posting with users from blocked domain" do
295 %{conn: conn, user: blocker} = oauth_access(["read:statuses"])
296 friend = insert(:user)
297 blockee = insert(:user, ap_id: "https://example.com/users/blocked")
298 {:ok, blocker, friend} = User.follow(blocker, friend)
299 {:ok, blocker} = User.block_domain(blocker, "example.com")
301 conn = assign(conn, :user, blocker)
303 {:ok, %{id: activity_id} = activity} = CommonAPI.post(friend, %{status: "hey!"})
305 {:ok, reply_from_blockee} =
306 CommonAPI.post(blockee, %{status: "heya", in_reply_to_status_id: activity})
308 {:ok, _reply_from_friend} =
309 CommonAPI.post(friend, %{status: "status", in_reply_to_status_id: reply_from_blockee})
311 res_conn = get(conn, "/api/v1/timelines/public")
313 activities = json_response_and_validate_schema(res_conn, 200)
314 [%{"id" => ^activity_id}] = activities
317 test "can be filtered by instance", %{conn: conn} do
318 user = insert(:user, ap_id: "https://lain.com/users/lain")
319 insert(:note_activity, local: false)
320 insert(:note_activity, local: false)
322 {:ok, _} = CommonAPI.post(user, %{status: "test"})
324 conn = get(conn, "/api/v1/timelines/public?instance=lain.com")
326 assert length(json_response_and_validate_schema(conn, :ok)) == 1
329 test "muted emotions", %{conn: conn} do
331 token = insert(:oauth_token, user: user, scopes: ["read:statuses"])
335 |> assign(:user, user)
336 |> assign(:token, token)
338 other_user = insert(:user)
339 {:ok, activity} = CommonAPI.post(user, %{status: "."})
341 {:ok, _} = CommonAPI.react_with_emoji(activity.id, other_user, "🎅")
342 User.mute(user, other_user)
346 |> get("/api/v1/timelines/public")
347 |> json_response_and_validate_schema(200)
352 "emoji_reactions" => []
359 |> get("/api/v1/timelines/public?with_muted=true")
360 |> json_response_and_validate_schema(200)
365 "emoji_reactions" => [%{"count" => 1, "me" => false, "name" => "🎅"}]
371 test "should return local-only posts for authenticated users" do
373 %{user: _reader, conn: conn} = oauth_access(["read:statuses"])
375 {:ok, %{id: id}} = CommonAPI.post(user, %{status: "#2hu #2HU", visibility: "local"})
379 |> get("/api/v1/timelines/public")
380 |> json_response_and_validate_schema(200)
382 assert [%{"id" => ^id}] = result
385 test "should not return local-only posts for users without read:statuses" do
387 %{user: _reader, conn: conn} = oauth_access([])
389 {:ok, _activity} = CommonAPI.post(user, %{status: "#2hu #2HU", visibility: "local"})
393 |> get("/api/v1/timelines/public")
394 |> json_response_and_validate_schema(200)
399 test "should not return local-only posts for anonymous users" do
402 {:ok, _activity} = CommonAPI.post(user, %{status: "#2hu #2HU", visibility: "local"})
406 |> get("/api/v1/timelines/public")
407 |> json_response_and_validate_schema(200)
412 test "should return 404 if disabled" do
413 clear_config([:instance, :federated_timeline_available], false)
417 |> get("/api/v1/timelines/public")
418 |> json_response_and_validate_schema(404)
420 assert %{"error" => "Federated timeline is disabled"} = result
423 test "should not return 404 if local is specified" do
424 clear_config([:instance, :federated_timeline_available], false)
427 |> get("/api/v1/timelines/public?local=true")
428 |> json_response_and_validate_schema(200)
432 defp local_and_remote_activities do
433 insert(:note_activity)
434 insert(:note_activity, local: false)
438 describe "public with restrict unauthenticated timeline for local and federated timelines" do
439 setup do: local_and_remote_activities()
441 setup do: clear_config([:restrict_unauthenticated, :timelines, :local], true)
443 setup do: clear_config([:restrict_unauthenticated, :timelines, :federated], true)
445 test "if user is unauthenticated", %{conn: conn} do
446 res_conn = get(conn, "/api/v1/timelines/public?local=true")
448 assert json_response_and_validate_schema(res_conn, :unauthorized) == %{
449 "error" => "authorization required for timeline view"
452 res_conn = get(conn, "/api/v1/timelines/public?local=false")
454 assert json_response_and_validate_schema(res_conn, :unauthorized) == %{
455 "error" => "authorization required for timeline view"
459 test "if user is authenticated" do
460 %{conn: conn} = oauth_access(["read:statuses"])
462 res_conn = get(conn, "/api/v1/timelines/public?local=true")
463 assert length(json_response_and_validate_schema(res_conn, 200)) == 1
465 res_conn = get(conn, "/api/v1/timelines/public?local=false")
466 assert length(json_response_and_validate_schema(res_conn, 200)) == 2
470 describe "public with restrict unauthenticated timeline for local" do
471 setup do: local_and_remote_activities()
473 setup do: clear_config([:restrict_unauthenticated, :timelines, :local], true)
475 test "if user is unauthenticated", %{conn: conn} do
476 res_conn = get(conn, "/api/v1/timelines/public?local=true")
478 assert json_response_and_validate_schema(res_conn, :unauthorized) == %{
479 "error" => "authorization required for timeline view"
482 res_conn = get(conn, "/api/v1/timelines/public?local=false")
483 assert length(json_response_and_validate_schema(res_conn, 200)) == 2
486 test "if user is authenticated", %{conn: _conn} do
487 %{conn: conn} = oauth_access(["read:statuses"])
489 res_conn = get(conn, "/api/v1/timelines/public?local=true")
490 assert length(json_response_and_validate_schema(res_conn, 200)) == 1
492 res_conn = get(conn, "/api/v1/timelines/public?local=false")
493 assert length(json_response_and_validate_schema(res_conn, 200)) == 2
497 describe "public with restrict unauthenticated timeline for remote" do
498 setup do: local_and_remote_activities()
500 setup do: clear_config([:restrict_unauthenticated, :timelines, :federated], true)
502 test "if user is unauthenticated", %{conn: conn} do
503 res_conn = get(conn, "/api/v1/timelines/public?local=true")
504 assert length(json_response_and_validate_schema(res_conn, 200)) == 1
506 res_conn = get(conn, "/api/v1/timelines/public?local=false")
508 assert json_response_and_validate_schema(res_conn, :unauthorized) == %{
509 "error" => "authorization required for timeline view"
513 test "if user is authenticated", %{conn: _conn} do
514 %{conn: conn} = oauth_access(["read:statuses"])
516 res_conn = get(conn, "/api/v1/timelines/public?local=true")
517 assert length(json_response_and_validate_schema(res_conn, 200)) == 1
519 res_conn = get(conn, "/api/v1/timelines/public?local=false")
520 assert length(json_response_and_validate_schema(res_conn, 200)) == 2
525 test "direct timeline", %{conn: conn} do
526 user_one = insert(:user)
527 user_two = insert(:user)
529 {:ok, user_two, user_one} = User.follow(user_two, user_one)
532 CommonAPI.post(user_one, %{
533 status: "Hi @#{user_two.nickname}!",
537 {:ok, _follower_only} =
538 CommonAPI.post(user_one, %{
539 status: "Hi @#{user_two.nickname}!",
540 visibility: "private"
545 |> assign(:user, user_two)
546 |> assign(:token, insert(:oauth_token, user: user_two, scopes: ["read:statuses"]))
548 # Only direct should be visible here
549 res_conn = get(conn_user_two, "/api/v1/timelines/direct")
551 assert [status] = json_response_and_validate_schema(res_conn, :ok)
553 assert %{"visibility" => "direct"} = status
554 assert status["url"] != direct.data["id"]
556 # User should be able to see their own direct message
559 |> assign(:user, user_one)
560 |> assign(:token, insert(:oauth_token, user: user_one, scopes: ["read:statuses"]))
561 |> get("/api/v1/timelines/direct")
563 [status] = json_response_and_validate_schema(res_conn, :ok)
565 assert %{"visibility" => "direct"} = status
567 # Both should be visible here
568 res_conn = get(conn_user_two, "/api/v1/timelines/home")
570 [_s1, _s2] = json_response_and_validate_schema(res_conn, :ok)
573 Enum.each(1..20, fn _ ->
575 CommonAPI.post(user_one, %{
576 status: "Hi @#{user_two.nickname}!",
581 res_conn = get(conn_user_two, "/api/v1/timelines/direct")
583 statuses = json_response_and_validate_schema(res_conn, :ok)
584 assert length(statuses) == 20
586 max_id = List.last(statuses)["id"]
588 res_conn = get(conn_user_two, "/api/v1/timelines/direct?max_id=#{max_id}")
590 assert [status] = json_response_and_validate_schema(res_conn, :ok)
592 assert status["url"] != direct.data["id"]
595 test "doesn't include DMs from blocked users" do
596 %{user: blocker, conn: conn} = oauth_access(["read:statuses"])
597 blocked = insert(:user)
598 other_user = insert(:user)
599 {:ok, _user_relationship} = User.block(blocker, blocked)
601 {:ok, _blocked_direct} =
602 CommonAPI.post(blocked, %{
603 status: "Hi @#{blocker.nickname}!",
608 CommonAPI.post(other_user, %{
609 status: "Hi @#{blocker.nickname}!",
613 res_conn = get(conn, "/api/v1/timelines/direct")
615 [status] = json_response_and_validate_schema(res_conn, :ok)
616 assert status["id"] == direct.id
621 setup do: oauth_access(["read:lists"])
623 test "does not contain retoots", %{user: user, conn: conn} do
624 other_user = insert(:user)
625 {:ok, activity_one} = CommonAPI.post(user, %{status: "Marisa is cute."})
626 {:ok, activity_two} = CommonAPI.post(other_user, %{status: "Marisa is stupid."})
627 {:ok, _} = CommonAPI.repeat(activity_one.id, other_user)
629 {:ok, list} = Pleroma.List.create("name", user)
630 {:ok, list} = Pleroma.List.follow(list, other_user)
632 conn = get(conn, "/api/v1/timelines/list/#{list.id}")
634 assert [%{"id" => id}] = json_response_and_validate_schema(conn, :ok)
636 assert id == to_string(activity_two.id)
639 test "works with pagination", %{user: user, conn: conn} do
640 other_user = insert(:user)
641 {:ok, list} = Pleroma.List.create("name", user)
642 {:ok, list} = Pleroma.List.follow(list, other_user)
644 Enum.each(1..30, fn i ->
645 CommonAPI.post(other_user, %{status: "post number #{i}"})
649 get(conn, "/api/v1/timelines/list/#{list.id}?limit=1")
650 |> json_response_and_validate_schema(:ok)
652 assert length(res) == 1
657 get(conn, "/api/v1/timelines/list/#{list.id}?max_id=#{first["id"]}&limit=30")
658 |> json_response_and_validate_schema(:ok)
660 assert length(res) == 29
663 test "list timeline", %{user: user, conn: conn} do
664 other_user = insert(:user)
665 {:ok, _activity_one} = CommonAPI.post(user, %{status: "Marisa is cute."})
666 {:ok, activity_two} = CommonAPI.post(other_user, %{status: "Marisa is cute."})
667 {:ok, list} = Pleroma.List.create("name", user)
668 {:ok, list} = Pleroma.List.follow(list, other_user)
670 conn = get(conn, "/api/v1/timelines/list/#{list.id}")
672 assert [%{"id" => id}] = json_response_and_validate_schema(conn, :ok)
674 assert id == to_string(activity_two.id)
677 test "list timeline does not leak non-public statuses for unfollowed users", %{
681 other_user = insert(:user)
682 {:ok, activity_one} = CommonAPI.post(other_user, %{status: "Marisa is cute."})
684 {:ok, _activity_two} =
685 CommonAPI.post(other_user, %{
686 status: "Marisa is cute.",
687 visibility: "private"
690 {:ok, list} = Pleroma.List.create("name", user)
691 {:ok, list} = Pleroma.List.follow(list, other_user)
693 conn = get(conn, "/api/v1/timelines/list/#{list.id}")
695 assert [%{"id" => id}] = json_response_and_validate_schema(conn, :ok)
697 assert id == to_string(activity_one.id)
700 test "muted emotions", %{user: user, conn: conn} do
701 user2 = insert(:user)
702 user3 = insert(:user)
703 {:ok, activity} = CommonAPI.post(user2, %{status: "."})
705 {:ok, _} = CommonAPI.react_with_emoji(activity.id, user3, "🎅")
706 User.mute(user, user3)
708 {:ok, list} = Pleroma.List.create("name", user)
709 {:ok, list} = Pleroma.List.follow(list, user2)
713 |> get("/api/v1/timelines/list/#{list.id}")
714 |> json_response_and_validate_schema(200)
719 "emoji_reactions" => []
726 |> get("/api/v1/timelines/list/#{list.id}?with_muted=true")
727 |> json_response_and_validate_schema(200)
732 "emoji_reactions" => [%{"count" => 1, "me" => false, "name" => "🎅"}]
738 test "filtering", %{user: user, conn: conn} do
739 {:ok, list} = Pleroma.List.create("name", user)
741 local_user = insert(:user)
742 {:ok, local_activity} = CommonAPI.post(local_user, %{status: "Marisa is stupid."})
743 with_media = create_with_media_activity(local_user)
744 {:ok, list} = Pleroma.List.follow(list, local_user)
746 remote_user = insert(:user, local: false)
747 remote_activity = create_remote_activity(remote_user)
748 {:ok, list} = Pleroma.List.follow(list, remote_user)
752 |> get("/api/v1/timelines/list/#{list.id}")
753 |> json_response_and_validate_schema(200)
754 |> Enum.map(& &1["id"])
756 assert local_activity.id in all_ids
757 assert with_media.id in all_ids
758 assert remote_activity.id in all_ids
762 |> get("/api/v1/timelines/list/#{list.id}?local=true")
763 |> json_response_and_validate_schema(200)
764 |> Enum.map(& &1["id"])
766 assert local_activity.id in only_local_ids
767 assert with_media.id in only_local_ids
768 refute remote_activity.id in only_local_ids
770 only_local_media_ids =
772 |> get("/api/v1/timelines/list/#{list.id}?local=true&only_media=true")
773 |> json_response_and_validate_schema(200)
774 |> Enum.map(& &1["id"])
776 refute local_activity.id in only_local_media_ids
777 assert with_media.id in only_local_media_ids
778 refute remote_activity.id in only_local_media_ids
782 |> get("/api/v1/timelines/list/#{list.id}?remote=true")
783 |> json_response_and_validate_schema(200)
784 |> Enum.map(& &1["id"])
786 refute local_activity.id in remote_ids
787 refute with_media.id in remote_ids
788 assert remote_activity.id in remote_ids
791 |> get("/api/v1/timelines/list/#{list.id}?remote=true&only_media=true")
792 |> json_response_and_validate_schema(200) == []
796 |> get("/api/v1/timelines/list/#{list.id}?only_media=true")
797 |> json_response_and_validate_schema(200)
798 |> Enum.map(& &1["id"])
800 refute local_activity.id in only_media_ids
801 assert with_media.id in only_media_ids
802 refute remote_activity.id in only_media_ids
805 |> get("/api/v1/timelines/list/#{list.id}?only_media=true&local=true&remote=true")
806 |> json_response_and_validate_schema(200) == []
810 describe "hashtag" do
811 setup do: oauth_access(["n/a"])
813 @tag capture_log: true
814 test "hashtag timeline", %{conn: conn} do
815 following = insert(:user)
817 {:ok, activity} = CommonAPI.post(following, %{status: "test #2hu"})
818 with_media = create_with_media_activity(following)
820 remote = insert(:user, local: false)
821 remote_activity = create_remote_activity(remote)
825 |> get("/api/v1/timelines/tag/2hu")
826 |> json_response_and_validate_schema(:ok)
827 |> Enum.map(& &1["id"])
829 assert activity.id in all_ids
830 assert with_media.id in all_ids
831 assert remote_activity.id in all_ids
833 # works for different capitalization too
836 |> get("/api/v1/timelines/tag/2HU")
837 |> json_response_and_validate_schema(:ok)
838 |> Enum.map(& &1["id"])
840 assert activity.id in all_ids
841 assert with_media.id in all_ids
842 assert remote_activity.id in all_ids
846 |> get("/api/v1/timelines/tag/2hu?local=true")
847 |> json_response_and_validate_schema(:ok)
848 |> Enum.map(& &1["id"])
850 assert activity.id in local_ids
851 assert with_media.id in local_ids
852 refute remote_activity.id in local_ids
856 |> get("/api/v1/timelines/tag/2hu?remote=true")
857 |> json_response_and_validate_schema(:ok)
858 |> Enum.map(& &1["id"])
860 refute activity.id in remote_ids
861 refute with_media.id in remote_ids
862 assert remote_activity.id in remote_ids
866 |> get("/api/v1/timelines/tag/2hu?only_media=true")
867 |> json_response_and_validate_schema(:ok)
868 |> Enum.map(& &1["id"])
870 refute activity.id in media_ids
871 assert with_media.id in media_ids
872 refute remote_activity.id in media_ids
876 |> get("/api/v1/timelines/tag/2hu?only_media=true&local=true")
877 |> json_response_and_validate_schema(:ok)
878 |> Enum.map(& &1["id"])
880 refute activity.id in media_local_ids
881 assert with_media.id in media_local_ids
882 refute remote_activity.id in media_local_ids
886 |> get("/api/v1/timelines/tag/2hu?only_media=true&local=true&remote=true")
887 |> json_response_and_validate_schema(:ok)
888 |> Enum.map(& &1["id"])
890 refute activity.id in ids
891 refute with_media.id in ids
892 refute remote_activity.id in ids
895 |> get("/api/v1/timelines/tag/2hu?only_media=true&remote=true")
896 |> json_response_and_validate_schema(:ok) == []
899 test "multi-hashtag timeline", %{conn: conn} do
902 {:ok, activity_test} = CommonAPI.post(user, %{status: "#test"})
903 {:ok, activity_test1} = CommonAPI.post(user, %{status: "#test #test1"})
904 {:ok, activity_none} = CommonAPI.post(user, %{status: "#test #none"})
906 any_test = get(conn, "/api/v1/timelines/tag/test?any[]=test1")
908 [status_none, status_test1, status_test] = json_response_and_validate_schema(any_test, :ok)
910 assert to_string(activity_test.id) == status_test["id"]
911 assert to_string(activity_test1.id) == status_test1["id"]
912 assert to_string(activity_none.id) == status_none["id"]
914 restricted_test = get(conn, "/api/v1/timelines/tag/test?all[]=test1&none[]=none")
916 assert [status_test1] == json_response_and_validate_schema(restricted_test, :ok)
918 all_test = get(conn, "/api/v1/timelines/tag/test?all[]=none")
920 assert [status_none] == json_response_and_validate_schema(all_test, :ok)
923 test "muted emotions", %{conn: conn} do
925 token = insert(:oauth_token, user: user, scopes: ["read:statuses"])
929 |> assign(:user, user)
930 |> assign(:token, token)
932 other_user = insert(:user)
933 {:ok, activity} = CommonAPI.post(user, %{status: "test #2hu"})
935 {:ok, _} = CommonAPI.react_with_emoji(activity.id, other_user, "🎅")
936 User.mute(user, other_user)
940 |> get("/api/v1/timelines/tag/2hu")
941 |> json_response_and_validate_schema(200)
946 "emoji_reactions" => []
953 |> get("/api/v1/timelines/tag/2hu?with_muted=true")
954 |> json_response_and_validate_schema(200)
959 "emoji_reactions" => [%{"count" => 1, "me" => false, "name" => "🎅"}]
966 describe "hashtag timeline handling of :restrict_unauthenticated setting" do
969 {:ok, activity1} = CommonAPI.post(user, %{status: "test #tag1"})
970 {:ok, _activity2} = CommonAPI.post(user, %{status: "test #tag1"})
973 |> Ecto.Changeset.change(%{local: false})
974 |> Pleroma.Repo.update()
976 base_uri = "/api/v1/timelines/tag/tag1"
977 error_response = %{"error" => "authorization required for timeline view"}
979 %{base_uri: base_uri, error_response: error_response}
982 defp ensure_authenticated_access(base_uri) do
983 %{conn: auth_conn} = oauth_access(["read:statuses"])
985 res_conn = get(auth_conn, "#{base_uri}?local=true")
986 assert length(json_response_and_validate_schema(res_conn, 200)) == 1
988 res_conn = get(auth_conn, "#{base_uri}?local=false")
989 assert length(json_response_and_validate_schema(res_conn, 200)) == 2
992 test "with default settings on private instances, returns 403 for unauthenticated users", %{
995 error_response: error_response
997 clear_config([:instance, :public], false)
998 clear_config([:restrict_unauthenticated, :timelines])
1000 for local <- [true, false] do
1001 res_conn = get(conn, "#{base_uri}?local=#{local}")
1003 assert json_response_and_validate_schema(res_conn, :unauthorized) == error_response
1006 ensure_authenticated_access(base_uri)
1009 test "with `%{local: true, federated: true}`, returns 403 for unauthenticated users", %{
1012 error_response: error_response
1014 clear_config([:restrict_unauthenticated, :timelines, :local], true)
1015 clear_config([:restrict_unauthenticated, :timelines, :federated], true)
1017 for local <- [true, false] do
1018 res_conn = get(conn, "#{base_uri}?local=#{local}")
1020 assert json_response_and_validate_schema(res_conn, :unauthorized) == error_response
1023 ensure_authenticated_access(base_uri)
1026 test "with `%{local: false, federated: true}`, forbids unauthenticated access to federated timeline",
1027 %{conn: conn, base_uri: base_uri, error_response: error_response} do
1028 clear_config([:restrict_unauthenticated, :timelines, :local], false)
1029 clear_config([:restrict_unauthenticated, :timelines, :federated], true)
1031 res_conn = get(conn, "#{base_uri}?local=true")
1032 assert length(json_response_and_validate_schema(res_conn, 200)) == 1
1034 res_conn = get(conn, "#{base_uri}?local=false")
1035 assert json_response_and_validate_schema(res_conn, :unauthorized) == error_response
1037 ensure_authenticated_access(base_uri)
1040 test "with `%{local: true, federated: false}`, forbids unauthenticated access to public timeline",
1041 %{conn: conn, base_uri: base_uri, error_response: error_response} do
1042 # (but not to local public activities which are delivered as part of federated timeline)
1043 clear_config([:restrict_unauthenticated, :timelines, :local], true)
1044 clear_config([:restrict_unauthenticated, :timelines, :federated], false)
1046 res_conn = get(conn, "#{base_uri}?local=true")
1047 assert json_response_and_validate_schema(res_conn, :unauthorized) == error_response
1049 # Note: local activities get delivered as part of federated timeline
1050 res_conn = get(conn, "#{base_uri}?local=false")
1051 assert length(json_response_and_validate_schema(res_conn, 200)) == 2
1053 ensure_authenticated_access(base_uri)
1057 describe "bubble" do
1059 %{conn: conn, user: user} = oauth_access(["read:statuses"])
1060 clear_config([:instance, :local_bubble], [])
1061 # our endpoint host has a port in it so let's set the AP ID
1062 local_user = insert(:user, %{ap_id: "https://localhost/users/user"})
1063 remote_user = insert(:user, %{ap_id: "https://example.com/users/remote_user"})
1064 {:ok, user, local_user} = User.follow(user, local_user)
1065 {:ok, _user, remote_user} = User.follow(user, remote_user)
1067 {:ok, local_activity} = CommonAPI.post(local_user, %{status: "Status"})
1068 remote_activity = create_remote_activity(remote_user)
1070 # If nothing, only include ours
1071 clear_config([:instance, :local_bubble], [])
1075 |> get("/api/v1/timelines/bubble")
1076 |> json_response_and_validate_schema(200)
1077 |> Enum.map(& &1["id"])
1079 assert local_activity.id in one_instance
1081 # If we have others, also include theirs
1082 clear_config([:instance, :local_bubble], ["example.com"])
1086 |> get("/api/v1/timelines/bubble")
1087 |> json_response_and_validate_schema(200)
1088 |> Enum.map(& &1["id"])
1090 assert local_activity.id in two_instances
1091 assert remote_activity.id in two_instances
1094 test "restrict_unauthenticated with bubble timeline", %{conn: conn} do
1095 clear_config([:restrict_unauthenticated, :timelines, :bubble], true)
1098 |> get("/api/v1/timelines/bubble")
1099 |> json_response_and_validate_schema(:unauthorized)
1101 clear_config([:restrict_unauthenticated, :timelines, :bubble], false)
1104 |> get("/api/v1/timelines/bubble")
1105 |> json_response_and_validate_schema(200)
1109 defp create_remote_activity(user) do
1114 "https://www.w3.org/ns/activitystreams#Public",
1115 User.ap_followers(user)
1121 insert(:note_activity, %{
1124 "https://www.w3.org/ns/activitystreams#Public",
1125 User.ap_followers(user)
1132 defp create_with_media_activity(user) do
1133 obj = insert(:attachment_note, user: user)
1135 insert(:note_activity, %{
1137 recipients: ["https://www.w3.org/ns/activitystreams#Public", User.ap_followers(user)],