1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2018 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.Web.ActivityPub.ActivityPubControllerTest do
6 use Pleroma.Web.ConnCase
9 alias Pleroma.Instances
12 alias Pleroma.Web.ActivityPub.ObjectView
13 alias Pleroma.Web.ActivityPub.UserView
14 alias Pleroma.Web.ActivityPub.Utils
17 Tesla.Mock.mock_global(fn env -> apply(HttpRequestMock, :request, [env]) end)
22 test "with the relay active, it returns the relay user", %{conn: conn} do
25 |> get(activity_pub_path(conn, :relay))
28 assert res["id"] =~ "/relay"
31 test "with the relay disabled, it returns 404", %{conn: conn} do
32 Pleroma.Config.put([:instance, :allow_relay], false)
35 |> get(activity_pub_path(conn, :relay))
39 Pleroma.Config.put([:instance, :allow_relay], true)
43 describe "/users/:nickname" do
44 test "it returns a json representation of the user with accept application/json", %{
51 |> put_req_header("accept", "application/json")
52 |> get("/users/#{user.nickname}")
54 user = User.get_cached_by_id(user.id)
56 assert json_response(conn, 200) == UserView.render("user.json", %{user: user})
59 test "it returns a json representation of the user with accept application/activity+json", %{
66 |> put_req_header("accept", "application/activity+json")
67 |> get("/users/#{user.nickname}")
69 user = User.get_cached_by_id(user.id)
71 assert json_response(conn, 200) == UserView.render("user.json", %{user: user})
74 test "it returns a json representation of the user with accept application/ld+json", %{
83 "application/ld+json; profile=\"https://www.w3.org/ns/activitystreams\""
85 |> get("/users/#{user.nickname}")
87 user = User.get_cached_by_id(user.id)
89 assert json_response(conn, 200) == UserView.render("user.json", %{user: user})
93 describe "/object/:uuid" do
94 test "it returns a json representation of the object with accept application/json", %{
98 uuid = String.split(note.data["id"], "/") |> List.last()
102 |> put_req_header("accept", "application/json")
103 |> get("/objects/#{uuid}")
105 assert json_response(conn, 200) == ObjectView.render("object.json", %{object: note})
108 test "it returns a json representation of the object with accept application/activity+json",
111 uuid = String.split(note.data["id"], "/") |> List.last()
115 |> put_req_header("accept", "application/activity+json")
116 |> get("/objects/#{uuid}")
118 assert json_response(conn, 200) == ObjectView.render("object.json", %{object: note})
121 test "it returns a json representation of the object with accept application/ld+json", %{
125 uuid = String.split(note.data["id"], "/") |> List.last()
131 "application/ld+json; profile=\"https://www.w3.org/ns/activitystreams\""
133 |> get("/objects/#{uuid}")
135 assert json_response(conn, 200) == ObjectView.render("object.json", %{object: note})
138 test "it returns 404 for non-public messages", %{conn: conn} do
139 note = insert(:direct_note)
140 uuid = String.split(note.data["id"], "/") |> List.last()
144 |> put_req_header("accept", "application/activity+json")
145 |> get("/objects/#{uuid}")
147 assert json_response(conn, 404)
150 test "it returns 404 for tombstone objects", %{conn: conn} do
151 tombstone = insert(:tombstone)
152 uuid = String.split(tombstone.data["id"], "/") |> List.last()
156 |> put_req_header("accept", "application/activity+json")
157 |> get("/objects/#{uuid}")
159 assert json_response(conn, 404)
163 describe "/object/:uuid/likes" do
164 test "it returns the like activities in a collection", %{conn: conn} do
165 like = insert(:like_activity)
166 uuid = String.split(like.data["object"], "/") |> List.last()
170 |> put_req_header("accept", "application/activity+json")
171 |> get("/objects/#{uuid}/likes")
172 |> json_response(200)
174 assert List.first(result["first"]["orderedItems"])["id"] == like.data["id"]
178 describe "/activities/:uuid" do
179 test "it returns a json representation of the activity", %{conn: conn} do
180 activity = insert(:note_activity)
181 uuid = String.split(activity.data["id"], "/") |> List.last()
185 |> put_req_header("accept", "application/activity+json")
186 |> get("/activities/#{uuid}")
188 assert json_response(conn, 200) == ObjectView.render("object.json", %{object: activity})
191 test "it returns 404 for non-public activities", %{conn: conn} do
192 activity = insert(:direct_note_activity)
193 uuid = String.split(activity.data["id"], "/") |> List.last()
197 |> put_req_header("accept", "application/activity+json")
198 |> get("/activities/#{uuid}")
200 assert json_response(conn, 404)
205 test "it inserts an incoming activity into the database", %{conn: conn} do
206 data = File.read!("test/fixtures/mastodon-post-activity.json") |> Poison.decode!()
210 |> assign(:valid_signature, true)
211 |> put_req_header("content-type", "application/activity+json")
212 |> post("/inbox", data)
214 assert "ok" == json_response(conn, 200)
216 assert Activity.get_by_ap_id(data["id"])
219 test "it clears `unreachable` federation status of the sender", %{conn: conn} do
220 data = File.read!("test/fixtures/mastodon-post-activity.json") |> Poison.decode!()
222 sender_url = data["actor"]
223 Instances.set_consistently_unreachable(sender_url)
224 refute Instances.reachable?(sender_url)
228 |> assign(:valid_signature, true)
229 |> put_req_header("content-type", "application/activity+json")
230 |> post("/inbox", data)
232 assert "ok" == json_response(conn, 200)
233 assert Instances.reachable?(sender_url)
237 describe "/users/:nickname/inbox" do
240 File.read!("test/fixtures/mastodon-post-activity.json")
246 test "it inserts an incoming activity into the database", %{conn: conn, data: data} do
248 data = Map.put(data, "bcc", [user.ap_id])
252 |> assign(:valid_signature, true)
253 |> put_req_header("content-type", "application/activity+json")
254 |> post("/users/#{user.nickname}/inbox", data)
256 assert "ok" == json_response(conn, 200)
258 assert Activity.get_by_ap_id(data["id"])
261 test "it accepts messages from actors that are followed by the user", %{
265 recipient = insert(:user)
266 actor = insert(:user, %{ap_id: "http://mastodon.example.org/users/actor"})
268 {:ok, recipient} = User.follow(recipient, actor)
272 |> Map.put("attributedTo", actor.ap_id)
276 |> Map.put("actor", actor.ap_id)
277 |> Map.put("object", object)
281 |> assign(:valid_signature, true)
282 |> put_req_header("content-type", "application/activity+json")
283 |> post("/users/#{recipient.nickname}/inbox", data)
285 assert "ok" == json_response(conn, 200)
287 assert Activity.get_by_ap_id(data["id"])
290 test "it rejects reads from other users", %{conn: conn} do
292 otheruser = insert(:user)
296 |> assign(:user, otheruser)
297 |> put_req_header("accept", "application/activity+json")
298 |> get("/users/#{user.nickname}/inbox")
300 assert json_response(conn, 403)
303 test "it returns a note activity in a collection", %{conn: conn} do
304 note_activity = insert(:direct_note_activity)
305 user = User.get_cached_by_ap_id(hd(note_activity.data["to"]))
309 |> assign(:user, user)
310 |> put_req_header("accept", "application/activity+json")
311 |> get("/users/#{user.nickname}/inbox")
313 assert response(conn, 200) =~ note_activity.data["object"]["content"]
316 test "it clears `unreachable` federation status of the sender", %{conn: conn, data: data} do
318 data = Map.put(data, "bcc", [user.ap_id])
320 sender_host = URI.parse(data["actor"]).host
321 Instances.set_consistently_unreachable(sender_host)
322 refute Instances.reachable?(sender_host)
326 |> assign(:valid_signature, true)
327 |> put_req_header("content-type", "application/activity+json")
328 |> post("/users/#{user.nickname}/inbox", data)
330 assert "ok" == json_response(conn, 200)
331 assert Instances.reachable?(sender_host)
334 test "it removes all follower collections but actor's", %{conn: conn} do
335 [actor, recipient] = insert_pair(:user)
338 File.read!("test/fixtures/activitypub-client-post-activity.json")
341 object = Map.put(data["object"], "attributedTo", actor.ap_id)
345 |> Map.put("id", Utils.generate_object_id())
346 |> Map.put("actor", actor.ap_id)
347 |> Map.put("object", object)
349 recipient.follower_address,
350 actor.follower_address
354 recipient.follower_address,
355 "https://www.w3.org/ns/activitystreams#Public"
359 |> assign(:valid_signature, true)
360 |> put_req_header("content-type", "application/activity+json")
361 |> post("/users/#{recipient.nickname}/inbox", data)
362 |> json_response(200)
364 activity = Activity.get_by_ap_id(data["id"])
367 assert actor.follower_address in activity.recipients
368 assert actor.follower_address in activity.data["cc"]
370 refute recipient.follower_address in activity.recipients
371 refute recipient.follower_address in activity.data["cc"]
372 refute recipient.follower_address in activity.data["to"]
376 describe "/users/:nickname/outbox" do
377 test "it will not bomb when there is no activity", %{conn: conn} do
382 |> put_req_header("accept", "application/activity+json")
383 |> get("/users/#{user.nickname}/outbox")
385 result = json_response(conn, 200)
386 assert user.ap_id <> "/outbox" == result["id"]
389 test "it returns a note activity in a collection", %{conn: conn} do
390 note_activity = insert(:note_activity)
391 user = User.get_cached_by_ap_id(note_activity.data["actor"])
395 |> put_req_header("accept", "application/activity+json")
396 |> get("/users/#{user.nickname}/outbox")
398 assert response(conn, 200) =~ note_activity.data["object"]["content"]
401 test "it returns an announce activity in a collection", %{conn: conn} do
402 announce_activity = insert(:announce_activity)
403 user = User.get_cached_by_ap_id(announce_activity.data["actor"])
407 |> put_req_header("accept", "application/activity+json")
408 |> get("/users/#{user.nickname}/outbox")
410 assert response(conn, 200) =~ announce_activity.data["object"]
413 test "it rejects posts from other users", %{conn: conn} do
414 data = File.read!("test/fixtures/activitypub-client-post-activity.json") |> Poison.decode!()
416 otheruser = insert(:user)
420 |> assign(:user, otheruser)
421 |> put_req_header("content-type", "application/activity+json")
422 |> post("/users/#{user.nickname}/outbox", data)
424 assert json_response(conn, 403)
427 test "it inserts an incoming create activity into the database", %{conn: conn} do
428 data = File.read!("test/fixtures/activitypub-client-post-activity.json") |> Poison.decode!()
433 |> assign(:user, user)
434 |> put_req_header("content-type", "application/activity+json")
435 |> post("/users/#{user.nickname}/outbox", data)
437 result = json_response(conn, 201)
438 assert Activity.get_by_ap_id(result["id"])
441 test "it rejects an incoming activity with bogus type", %{conn: conn} do
442 data = File.read!("test/fixtures/activitypub-client-post-activity.json") |> Poison.decode!()
447 |> Map.put("type", "BadType")
451 |> assign(:user, user)
452 |> put_req_header("content-type", "application/activity+json")
453 |> post("/users/#{user.nickname}/outbox", data)
455 assert json_response(conn, 400)
458 test "it erects a tombstone when receiving a delete activity", %{conn: conn} do
459 note_activity = insert(:note_activity)
460 user = User.get_cached_by_ap_id(note_activity.data["actor"])
465 id: note_activity.data["object"]["id"]
471 |> assign(:user, user)
472 |> put_req_header("content-type", "application/activity+json")
473 |> post("/users/#{user.nickname}/outbox", data)
475 result = json_response(conn, 201)
476 assert Activity.get_by_ap_id(result["id"])
478 object = Object.get_by_ap_id(note_activity.data["object"]["id"])
480 assert object.data["type"] == "Tombstone"
483 test "it rejects delete activity of object from other actor", %{conn: conn} do
484 note_activity = insert(:note_activity)
490 id: note_activity.data["object"]["id"]
496 |> assign(:user, user)
497 |> put_req_header("content-type", "application/activity+json")
498 |> post("/users/#{user.nickname}/outbox", data)
500 assert json_response(conn, 400)
503 test "it increases like count when receiving a like action", %{conn: conn} do
504 note_activity = insert(:note_activity)
505 user = User.get_cached_by_ap_id(note_activity.data["actor"])
510 id: note_activity.data["object"]["id"]
516 |> assign(:user, user)
517 |> put_req_header("content-type", "application/activity+json")
518 |> post("/users/#{user.nickname}/outbox", data)
520 result = json_response(conn, 201)
521 assert Activity.get_by_ap_id(result["id"])
523 object = Object.get_by_ap_id(note_activity.data["object"]["id"])
525 assert object.data["like_count"] == 1
529 describe "/users/:nickname/followers" do
530 test "it returns the followers in a collection", %{conn: conn} do
532 user_two = insert(:user)
533 User.follow(user, user_two)
537 |> get("/users/#{user_two.nickname}/followers")
538 |> json_response(200)
540 assert result["first"]["orderedItems"] == [user.ap_id]
543 test "it returns returns empty if the user has 'hide_followers' set", %{conn: conn} do
545 user_two = insert(:user, %{info: %{hide_followers: true}})
546 User.follow(user, user_two)
550 |> get("/users/#{user_two.nickname}/followers")
551 |> json_response(200)
553 assert result["first"]["orderedItems"] == []
554 assert result["totalItems"] == 0
557 test "it works for more than 10 users", %{conn: conn} do
560 Enum.each(1..15, fn _ ->
561 other_user = insert(:user)
562 User.follow(other_user, user)
567 |> get("/users/#{user.nickname}/followers")
568 |> json_response(200)
570 assert length(result["first"]["orderedItems"]) == 10
571 assert result["first"]["totalItems"] == 15
572 assert result["totalItems"] == 15
576 |> get("/users/#{user.nickname}/followers?page=2")
577 |> json_response(200)
579 assert length(result["orderedItems"]) == 5
580 assert result["totalItems"] == 15
584 describe "/users/:nickname/following" do
585 test "it returns the following in a collection", %{conn: conn} do
587 user_two = insert(:user)
588 User.follow(user, user_two)
592 |> get("/users/#{user.nickname}/following")
593 |> json_response(200)
595 assert result["first"]["orderedItems"] == [user_two.ap_id]
598 test "it returns returns empty if the user has 'hide_follows' set", %{conn: conn} do
599 user = insert(:user, %{info: %{hide_follows: true}})
600 user_two = insert(:user)
601 User.follow(user, user_two)
605 |> get("/users/#{user.nickname}/following")
606 |> json_response(200)
608 assert result["first"]["orderedItems"] == []
609 assert result["totalItems"] == 0
612 test "it works for more than 10 users", %{conn: conn} do
615 Enum.each(1..15, fn _ ->
616 user = User.get_cached_by_id(user.id)
617 other_user = insert(:user)
618 User.follow(user, other_user)
623 |> get("/users/#{user.nickname}/following")
624 |> json_response(200)
626 assert length(result["first"]["orderedItems"]) == 10
627 assert result["first"]["totalItems"] == 15
628 assert result["totalItems"] == 15
632 |> get("/users/#{user.nickname}/following?page=2")
633 |> json_response(200)
635 assert length(result["orderedItems"]) == 5
636 assert result["totalItems"] == 15