1 defmodule Pleroma.Web.ActivityPub.TransmogrifierTest do
3 alias Pleroma.Web.ActivityPub.Transmogrifier
4 alias Pleroma.Web.ActivityPub.Utils
5 alias Pleroma.Web.ActivityPub.ActivityPub
6 alias Pleroma.Web.OStatus
10 alias Pleroma.Web.Websub.WebsubClientSubscription
11 alias Pleroma.Web.Websub.WebsubServerSubscription
14 import Pleroma.Factory
15 alias Pleroma.Web.CommonAPI
17 describe "handle_incoming" do
18 test "it ignores an incoming notice if we already have it" do
19 activity = insert(:note_activity)
22 File.read!("test/fixtures/mastodon-post-activity.json")
24 |> Map.put("object", activity.data["object"])
26 {:ok, returned_activity} = Transmogrifier.handle_incoming(data)
28 assert activity == returned_activity
31 test "it fetches replied-to activities if we don't have them" do
33 File.read!("test/fixtures/mastodon-post-activity.json")
38 |> Map.put("inReplyTo", "https://shitposter.club/notice/2827873")
42 |> Map.put("object", object)
44 {:ok, returned_activity} = Transmogrifier.handle_incoming(data)
47 Activity.get_create_activity_by_object_ap_id(
48 "tag:shitposter.club,2017-05-05:noticeId=2827873:objectType=comment"
51 assert returned_activity.data["object"]["inReplyToAtomUri"] ==
52 "https://shitposter.club/notice/2827873"
54 assert returned_activity.data["object"]["inReplyToStatusId"] == activity.id
57 test "it works for incoming notices" do
58 data = File.read!("test/fixtures/mastodon-post-activity.json") |> Poison.decode!()
60 {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)
63 "http://mastodon.example.org/users/admin/statuses/99512778738411822/activity"
65 assert data["context"] ==
66 "tag:mastodon.example.org,2018-02-12:objectId=20:objectType=Conversation"
68 assert data["to"] == ["https://www.w3.org/ns/activitystreams#Public"]
70 assert data["cc"] == [
71 "http://mastodon.example.org/users/admin/followers",
72 "http://localtesting.pleroma.lol/users/lain"
75 assert data["actor"] == "http://mastodon.example.org/users/admin"
77 object = data["object"]
78 assert object["id"] == "http://mastodon.example.org/users/admin/statuses/99512778738411822"
80 assert object["to"] == ["https://www.w3.org/ns/activitystreams#Public"]
82 assert object["cc"] == [
83 "http://mastodon.example.org/users/admin/followers",
84 "http://localtesting.pleroma.lol/users/lain"
87 assert object["actor"] == "http://mastodon.example.org/users/admin"
88 assert object["attributedTo"] == "http://mastodon.example.org/users/admin"
90 assert object["context"] ==
91 "tag:mastodon.example.org,2018-02-12:objectId=20:objectType=Conversation"
93 assert object["sensitive"] == true
95 user = User.get_by_ap_id(object["actor"])
97 assert user.info["note_count"] == 1
100 test "it works for incoming notices with hashtags" do
101 data = File.read!("test/fixtures/mastodon-post-activity-hashtag.json") |> Poison.decode!()
103 {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)
104 assert Enum.at(data["object"]["tag"], 2) == "moo"
107 test "it works for incoming follow requests" do
111 File.read!("test/fixtures/mastodon-follow-activity.json")
113 |> Map.put("object", user.ap_id)
115 {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)
117 assert data["actor"] == "http://mastodon.example.org/users/admin"
118 assert data["type"] == "Follow"
119 assert data["id"] == "http://mastodon.example.org/users/admin#follows/2"
120 assert User.following?(User.get_by_ap_id(data["actor"]), user)
123 test "it works for incoming follow requests from hubzilla" do
127 File.read!("test/fixtures/hubzilla-follow-activity.json")
129 |> Map.put("object", user.ap_id)
130 |> Utils.normalize_params()
132 {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)
134 assert data["actor"] == "https://hubzilla.example.org/channel/kaniini"
135 assert data["type"] == "Follow"
136 assert data["id"] == "https://hubzilla.example.org/channel/kaniini#follows/2"
137 assert User.following?(User.get_by_ap_id(data["actor"]), user)
140 test "it works for incoming likes" do
142 {:ok, activity} = CommonAPI.post(user, %{"status" => "hello"})
145 File.read!("test/fixtures/mastodon-like.json")
147 |> Map.put("object", activity.data["object"]["id"])
149 {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)
151 assert data["actor"] == "http://mastodon.example.org/users/admin"
152 assert data["type"] == "Like"
153 assert data["id"] == "http://mastodon.example.org/users/admin#likes/2"
154 assert data["object"] == activity.data["object"]["id"]
157 test "it returns an error for incoming unlikes wihout a like activity" do
159 {:ok, activity} = CommonAPI.post(user, %{"status" => "leave a like pls"})
162 File.read!("test/fixtures/mastodon-undo-like.json")
164 |> Map.put("object", activity.data["object"]["id"])
166 assert Transmogrifier.handle_incoming(data) == :error
169 test "it works for incoming unlikes with an existing like activity" do
171 {:ok, activity} = CommonAPI.post(user, %{"status" => "leave a like pls"})
174 File.read!("test/fixtures/mastodon-like.json")
176 |> Map.put("object", activity.data["object"]["id"])
178 {:ok, %Activity{data: like_data, local: false}} = Transmogrifier.handle_incoming(like_data)
181 File.read!("test/fixtures/mastodon-undo-like.json")
183 |> Map.put("object", like_data)
184 |> Map.put("actor", like_data["actor"])
186 {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)
188 assert data["actor"] == "http://mastodon.example.org/users/admin"
189 assert data["type"] == "Undo"
190 assert data["id"] == "http://mastodon.example.org/users/admin#likes/2/undo"
191 assert data["object"]["id"] == "http://mastodon.example.org/users/admin#likes/2"
194 test "it works for incoming announces" do
195 data = File.read!("test/fixtures/mastodon-announce.json") |> Poison.decode!()
197 {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)
199 assert data["actor"] == "http://mastodon.example.org/users/admin"
200 assert data["type"] == "Announce"
203 "http://mastodon.example.org/users/admin/statuses/99542391527669785/activity"
205 assert data["object"] ==
206 "http://mastodon.example.org/users/admin/statuses/99541947525187367"
208 assert Activity.get_create_activity_by_object_ap_id(data["object"])
211 test "it works for incoming announces with an existing activity" do
213 {:ok, activity} = CommonAPI.post(user, %{"status" => "hey"})
216 File.read!("test/fixtures/mastodon-announce.json")
218 |> Map.put("object", activity.data["object"]["id"])
220 {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)
222 assert data["actor"] == "http://mastodon.example.org/users/admin"
223 assert data["type"] == "Announce"
226 "http://mastodon.example.org/users/admin/statuses/99542391527669785/activity"
228 assert data["object"] == activity.data["object"]["id"]
230 assert Activity.get_create_activity_by_object_ap_id(data["object"]).id == activity.id
233 test "it works for incoming update activities" do
234 data = File.read!("test/fixtures/mastodon-post-activity.json") |> Poison.decode!()
236 {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)
237 update_data = File.read!("test/fixtures/mastodon-update.json") |> Poison.decode!()
240 update_data["object"]
241 |> Map.put("actor", data["actor"])
242 |> Map.put("id", data["actor"])
246 |> Map.put("actor", data["actor"])
247 |> Map.put("object", object)
249 {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(update_data)
251 user = User.get_cached_by_ap_id(data["actor"])
252 assert user.name == "gargle"
254 assert user.avatar["url"] == [
257 "https://cd.niu.moe/accounts/avatars/000/033/323/original/fd7f8ae0b3ffedc9.jpeg"
261 assert user.info["banner"]["url"] == [
264 "https://cd.niu.moe/accounts/headers/000/033/323/original/850b3448fa5fd477.png"
268 assert user.bio == "<p>Some bio</p>"
271 test "it works for incoming deletes" do
272 activity = insert(:note_activity)
275 File.read!("test/fixtures/mastodon-delete.json")
280 |> Map.put("id", activity.data["object"]["id"])
284 |> Map.put("object", object)
285 |> Map.put("actor", activity.data["actor"])
287 {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)
289 refute Repo.get(Activity, activity.id)
292 test "it works for incoming unannounces with an existing notice" do
294 {:ok, activity} = CommonAPI.post(user, %{"status" => "hey"})
297 File.read!("test/fixtures/mastodon-announce.json")
299 |> Map.put("object", activity.data["object"]["id"])
301 {:ok, %Activity{data: announce_data, local: false}} =
302 Transmogrifier.handle_incoming(announce_data)
305 File.read!("test/fixtures/mastodon-undo-announce.json")
307 |> Map.put("object", announce_data)
308 |> Map.put("actor", announce_data["actor"])
310 {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)
312 assert data["type"] == "Undo"
313 assert data["object"]["type"] == "Announce"
314 assert data["object"]["object"] == activity.data["object"]["id"]
316 assert data["object"]["id"] ==
317 "http://mastodon.example.org/users/admin/statuses/99542391527669785/activity"
320 test "it works for incomming unfollows with an existing follow" do
324 File.read!("test/fixtures/mastodon-follow-activity.json")
326 |> Map.put("object", user.ap_id)
328 {:ok, %Activity{data: _, local: false}} = Transmogrifier.handle_incoming(follow_data)
331 File.read!("test/fixtures/mastodon-unfollow-activity.json")
333 |> Map.put("object", follow_data)
335 {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)
337 assert data["type"] == "Undo"
338 assert data["object"]["type"] == "Follow"
339 assert data["object"]["object"] == user.ap_id
340 assert data["actor"] == "http://mastodon.example.org/users/admin"
342 refute User.following?(User.get_by_ap_id(data["actor"]), user)
345 test "it works for incoming blocks" do
349 File.read!("test/fixtures/mastodon-block-activity.json")
351 |> Map.put("object", user.ap_id)
353 {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)
355 assert data["type"] == "Block"
356 assert data["object"] == user.ap_id
357 assert data["actor"] == "http://mastodon.example.org/users/admin"
359 blocker = User.get_by_ap_id(data["actor"])
361 assert User.blocks?(blocker, user)
364 test "it works for incoming unblocks with an existing block" do
368 File.read!("test/fixtures/mastodon-block-activity.json")
370 |> Map.put("object", user.ap_id)
372 {:ok, %Activity{data: _, local: false}} = Transmogrifier.handle_incoming(block_data)
375 File.read!("test/fixtures/mastodon-unblock-activity.json")
377 |> Map.put("object", block_data)
379 {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)
380 assert data["type"] == "Undo"
381 assert data["object"]["type"] == "Block"
382 assert data["object"]["object"] == user.ap_id
383 assert data["actor"] == "http://mastodon.example.org/users/admin"
385 blocker = User.get_by_ap_id(data["actor"])
387 refute User.blocks?(blocker, user)
390 test "it works for incoming accepts which were pre-accepted" do
391 follower = insert(:user)
392 followed = insert(:user)
394 {:ok, follower} = User.follow(follower, followed)
395 assert User.following?(follower, followed) == true
398 File.read!("test/fixtures/mastodon-accept-activity.json")
400 |> Map.put("actor", followed.ap_id)
403 Map.put(accept_data, "object", Map.put(accept_data["object"], "actor", follower.ap_id))
405 {:ok, %Activity{data: _}} = Transmogrifier.handle_incoming(accept_data)
407 follower = Repo.get(User, follower.id)
409 assert User.following?(follower, followed) == true
412 test "it works for incoming accepts which were orphaned" do
413 follower = insert(:user)
414 followed = insert(:user, %{info: %{"locked" => true}})
416 {:ok, follow_activity} = ActivityPub.follow(follower, followed)
419 File.read!("test/fixtures/mastodon-accept-activity.json")
421 |> Map.put("actor", followed.ap_id)
424 Map.put(accept_data, "object", Map.put(accept_data["object"], "actor", follower.ap_id))
426 {:ok, %Activity{data: _}} = Transmogrifier.handle_incoming(accept_data)
428 follower = Repo.get(User, follower.id)
430 assert User.following?(follower, followed) == true
433 test "it works for incoming accepts which are referenced by IRI only" do
434 follower = insert(:user)
435 followed = insert(:user, %{info: %{"locked" => true}})
437 {:ok, follow_activity} = ActivityPub.follow(follower, followed)
440 File.read!("test/fixtures/mastodon-accept-activity.json")
442 |> Map.put("actor", followed.ap_id)
443 |> Map.put("object", follow_activity.data["id"])
445 {:ok, %Activity{data: _}} = Transmogrifier.handle_incoming(accept_data)
447 follower = Repo.get(User, follower.id)
449 assert User.following?(follower, followed) == true
452 test "it works for incoming rejects which are orphaned" do
453 follower = insert(:user)
454 followed = insert(:user, %{info: %{"locked" => true}})
456 {:ok, follower} = User.follow(follower, followed)
457 {:ok, follow_activity} = ActivityPub.follow(follower, followed)
459 assert User.following?(follower, followed) == true
462 File.read!("test/fixtures/mastodon-reject-activity.json")
464 |> Map.put("actor", followed.ap_id)
467 Map.put(reject_data, "object", Map.put(reject_data["object"], "actor", follower.ap_id))
469 {:ok, %Activity{data: _}} = Transmogrifier.handle_incoming(reject_data)
471 follower = Repo.get(User, follower.id)
473 assert User.following?(follower, followed) == false
476 test "it works for incoming rejects which are referenced by IRI only" do
477 follower = insert(:user)
478 followed = insert(:user, %{info: %{"locked" => true}})
480 {:ok, follower} = User.follow(follower, followed)
481 {:ok, follow_activity} = ActivityPub.follow(follower, followed)
483 assert User.following?(follower, followed) == true
486 File.read!("test/fixtures/mastodon-reject-activity.json")
488 |> Map.put("actor", followed.ap_id)
489 |> Map.put("object", follow_activity.data["id"])
491 {:ok, %Activity{data: _}} = Transmogrifier.handle_incoming(reject_data)
493 follower = Repo.get(User, follower.id)
495 assert User.following?(follower, followed) == false
499 describe "prepare outgoing" do
500 test "it turns mentions into tags" do
502 other_user = insert(:user)
505 CommonAPI.post(user, %{"status" => "hey, @#{other_user.nickname}, how are ya? #2hu"})
507 {:ok, modified} = Transmogrifier.prepare_outgoing(activity.data)
508 object = modified["object"]
510 expected_mention = %{
511 "href" => other_user.ap_id,
512 "name" => "@#{other_user.nickname}",
517 "href" => Pleroma.Web.Endpoint.url() <> "/tags/2hu",
522 assert Enum.member?(object["tag"], expected_tag)
523 assert Enum.member?(object["tag"], expected_mention)
526 test "it adds the sensitive property" do
529 {:ok, activity} = CommonAPI.post(user, %{"status" => "#nsfw hey"})
530 {:ok, modified} = Transmogrifier.prepare_outgoing(activity.data)
532 assert modified["object"]["sensitive"]
535 test "it adds the json-ld context and the conversation property" do
538 {:ok, activity} = CommonAPI.post(user, %{"status" => "hey"})
539 {:ok, modified} = Transmogrifier.prepare_outgoing(activity.data)
541 assert modified["@context"] == "https://www.w3.org/ns/activitystreams"
542 assert modified["object"]["conversation"] == modified["context"]
545 test "it sets the 'attributedTo' property to the actor of the object if it doesn't have one" do
548 {:ok, activity} = CommonAPI.post(user, %{"status" => "hey"})
549 {:ok, modified} = Transmogrifier.prepare_outgoing(activity.data)
551 assert modified["object"]["actor"] == modified["object"]["attributedTo"]
554 test "it translates ostatus IDs to external URLs" do
555 incoming = File.read!("test/fixtures/incoming_note_activity.xml")
556 {:ok, [referent_activity]} = OStatus.handle_incoming(incoming)
560 {:ok, activity, _} = CommonAPI.favorite(referent_activity.id, user)
561 {:ok, modified} = Transmogrifier.prepare_outgoing(activity.data)
563 assert modified["object"] == "http://gs.example.org:4040/index.php/notice/29"
566 test "it translates ostatus reply_to IDs to external URLs" do
567 incoming = File.read!("test/fixtures/incoming_note_activity.xml")
568 {:ok, [referred_activity]} = OStatus.handle_incoming(incoming)
573 CommonAPI.post(user, %{"status" => "HI!", "in_reply_to_status_id" => referred_activity.id})
575 {:ok, modified} = Transmogrifier.prepare_outgoing(activity.data)
577 assert modified["object"]["inReplyTo"] == "http://gs.example.org:4040/index.php/notice/29"
581 describe "user upgrade" do
582 test "it upgrades a user to activitypub" do
585 nickname: "rye@niu.moe",
587 ap_id: "https://niu.moe/users/rye",
588 follower_address: User.ap_followers(%User{nickname: "rye@niu.moe"})
591 user_two = insert(:user, %{following: [user.follower_address]})
593 {:ok, activity} = CommonAPI.post(user, %{"status" => "test"})
594 {:ok, unrelated_activity} = CommonAPI.post(user_two, %{"status" => "test"})
595 assert "http://localhost:4001/users/rye@niu.moe/followers" in activity.recipients
597 user = Repo.get(User, user.id)
598 assert user.info["note_count"] == 1
600 {:ok, user} = Transmogrifier.upgrade_user_from_ap_id("https://niu.moe/users/rye")
601 assert user.info["ap_enabled"]
602 assert user.info["note_count"] == 1
603 assert user.follower_address == "https://niu.moe/users/rye/followers"
605 # Wait for the background task
608 user = Repo.get(User, user.id)
609 assert user.info["note_count"] == 1
611 activity = Repo.get(Activity, activity.id)
612 assert user.follower_address in activity.recipients
618 "https://cdn.niu.moe/accounts/avatars/000/033/323/original/fd7f8ae0b3ffedc9.jpeg"
627 "https://cdn.niu.moe/accounts/headers/000/033/323/original/850b3448fa5fd477.png"
630 } = user.info["banner"]
632 refute "..." in activity.recipients
634 unrelated_activity = Repo.get(Activity, unrelated_activity.id)
635 refute user.follower_address in unrelated_activity.recipients
637 user_two = Repo.get(User, user_two.id)
638 assert user.follower_address in user_two.following
639 refute "..." in user_two.following
643 describe "maybe_retire_websub" do
644 test "it deletes all websub client subscripitions with the user as topic" do
645 subscription = %WebsubClientSubscription{topic: "https://niu.moe/users/rye.atom"}
646 {:ok, ws} = Repo.insert(subscription)
648 subscription = %WebsubClientSubscription{topic: "https://niu.moe/users/pasty.atom"}
649 {:ok, ws2} = Repo.insert(subscription)
651 Transmogrifier.maybe_retire_websub("https://niu.moe/users/rye")
653 refute Repo.get(WebsubClientSubscription, ws.id)
654 assert Repo.get(WebsubClientSubscription, ws2.id)
658 describe "actor rewriting" do
659 test "it fixes the actor URL property to be a proper URI" do
661 "url" => %{"href" => "http://example.com"}
664 rewritten = Transmogrifier.maybe_fix_user_object(data)
665 assert rewritten["url"] == "http://example.com"