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.ActivityPub.SideEffectsTest do
6 use Oban.Testing, repo: Pleroma.Repo
10 alias Pleroma.Notification
13 alias Pleroma.Tests.ObanHelpers
15 alias Pleroma.Web.ActivityPub.ActivityPub
16 alias Pleroma.Web.ActivityPub.Builder
17 alias Pleroma.Web.ActivityPub.SideEffects
18 alias Pleroma.Web.ActivityPub.Utils
19 alias Pleroma.Web.CommonAPI
22 import Pleroma.Factory
24 describe "handle_after_transaction" do
25 test "it streams out notifications and streams" do
26 author = insert(:user, local: true)
27 recipient = insert(:user, local: true)
29 {:ok, note_data, _meta} =
30 Builder.note(%Pleroma.Web.CommonAPI.ActivityDraft{
32 to: [recipient.ap_id],
33 mentions: [recipient],
35 extra: %{"id" => Utils.generate_object_id()}
38 {:ok, create_activity_data, _meta} =
39 Builder.create(author, note_data["id"], [recipient.ap_id])
41 {:ok, create_activity, _meta} = ActivityPub.persist(create_activity_data, local: false)
43 {:ok, _create_activity, meta} =
44 SideEffects.handle(create_activity, local: false, object_data: note_data)
46 assert [notification] = meta[:notifications]
53 stream: fn _, _ -> nil end
64 SideEffects.handle_after_transaction(meta)
66 assert called(Pleroma.Web.Streamer.stream(["user", "user:notification"], notification))
67 assert called(Pleroma.Web.Push.send(notification))
72 describe "blocking users" do
75 blocked = insert(:user)
76 User.follow(blocked, user)
77 User.follow(user, blocked)
79 {:ok, block_data, []} = Builder.block(user, blocked)
80 {:ok, block, _meta} = ActivityPub.persist(block_data, local: true)
82 %{user: user, blocked: blocked, block: block}
85 test "it unfollows and blocks", %{user: user, blocked: blocked, block: block} do
86 assert User.following?(user, blocked)
87 assert User.following?(blocked, user)
89 {:ok, _, _} = SideEffects.handle(block)
91 refute User.following?(user, blocked)
92 refute User.following?(blocked, user)
93 assert User.blocks?(user, blocked)
96 test "it updates following relationship", %{user: user, blocked: blocked, block: block} do
97 {:ok, _, _} = SideEffects.handle(block)
99 refute Pleroma.FollowingRelationship.get(user, blocked)
100 assert User.get_follow_state(user, blocked) == nil
101 assert User.get_follow_state(blocked, user) == nil
102 assert User.get_follow_state(user, blocked, nil) == nil
103 assert User.get_follow_state(blocked, user, nil) == nil
106 test "it blocks but does not unfollow if the relevant setting is set", %{
111 clear_config([:activitypub, :unfollow_blocked], false)
112 assert User.following?(user, blocked)
113 assert User.following?(blocked, user)
115 {:ok, _, _} = SideEffects.handle(block)
117 refute User.following?(user, blocked)
118 assert User.following?(blocked, user)
119 assert User.blocks?(user, blocked)
123 describe "update users" do
125 user = insert(:user, local: false)
127 {:ok, update_data, []} =
128 Builder.update(user, %{"id" => user.ap_id, "type" => "Person", "name" => "new name!"})
130 {:ok, update, _meta} = ActivityPub.persist(update_data, local: true)
132 %{user: user, update_data: update_data, update: update}
135 test "it updates the user", %{user: user, update: update} do
136 {:ok, _, _} = SideEffects.handle(update)
137 user = User.get_by_id(user.id)
138 assert user.name == "new name!"
141 test "it uses a given changeset to update", %{user: user, update: update} do
142 changeset = Ecto.Changeset.change(user, %{default_scope: "direct"})
144 assert user.default_scope == "public"
145 {:ok, _, _} = SideEffects.handle(update, user_update_changeset: changeset)
146 user = User.get_by_id(user.id)
147 assert user.default_scope == "direct"
151 describe "update notes" do
154 Pleroma.Web.ActivityPub.Utils.make_date()
158 note = insert(:note, user: user, data: %{"published" => make_time.()})
159 _note_activity = insert(:note_activity, note: note)
163 |> Map.put("summary", "edited summary")
164 |> Map.put("content", "edited content")
165 |> Map.put("updated", make_time.())
167 {:ok, update_data, []} = Builder.update(user, updated_note)
168 {:ok, update, _meta} = ActivityPub.persist(update_data, local: true)
174 update_data: update_data,
176 updated_note: updated_note
180 test "it updates the note", %{
181 object_id: object_id,
183 updated_note: updated_note
185 {:ok, _, _} = SideEffects.handle(update, object_data: updated_note)
186 updated_time = updated_note["updated"]
188 new_note = Pleroma.Object.get_by_id(object_id)
191 "summary" => "edited summary",
192 "content" => "edited content",
193 "updated" => ^updated_time
197 test "it rejects updates with no updated attribute in object", %{
198 object_id: object_id,
200 updated_note: updated_note
202 old_note = Pleroma.Object.get_by_id(object_id)
203 updated_note = Map.drop(updated_note, ["updated"])
204 {:ok, _, _} = SideEffects.handle(update, object_data: updated_note)
205 new_note = Pleroma.Object.get_by_id(object_id)
206 assert old_note.data == new_note.data
209 test "it rejects updates with updated attribute older than what we have in the original object",
211 object_id: object_id,
213 updated_note: updated_note
215 old_note = Pleroma.Object.get_by_id(object_id)
216 {:ok, creation_time, _} = DateTime.from_iso8601(old_note.data["published"])
219 Map.put(updated_note, "updated", DateTime.to_iso8601(DateTime.add(creation_time, -10)))
221 {:ok, _, _} = SideEffects.handle(update, object_data: updated_note)
222 new_note = Pleroma.Object.get_by_id(object_id)
223 assert old_note.data == new_note.data
226 test "it rejects updates with updated attribute older than the last Update", %{
227 object_id: object_id,
229 updated_note: updated_note
231 old_note = Pleroma.Object.get_by_id(object_id)
232 {:ok, creation_time, _} = DateTime.from_iso8601(old_note.data["published"])
235 Map.put(updated_note, "updated", DateTime.to_iso8601(DateTime.add(creation_time, +10)))
237 {:ok, _, _} = SideEffects.handle(update, object_data: updated_note)
239 old_note = Pleroma.Object.get_by_id(object_id)
240 {:ok, update_time, _} = DateTime.from_iso8601(old_note.data["updated"])
243 Map.put(updated_note, "updated", DateTime.to_iso8601(DateTime.add(update_time, -5)))
245 {:ok, _, _} = SideEffects.handle(update, object_data: updated_note)
247 new_note = Pleroma.Object.get_by_id(object_id)
248 assert old_note.data == new_note.data
251 test "it updates using object_data", %{
252 object_id: object_id,
254 updated_note: updated_note
256 updated_note = Map.put(updated_note, "summary", "mew mew")
257 {:ok, _, _} = SideEffects.handle(update, object_data: updated_note)
258 new_note = Pleroma.Object.get_by_id(object_id)
259 assert %{"summary" => "mew mew", "content" => "edited content"} = new_note.data
262 test "it records the original note in formerRepresentations", %{
264 object_id: object_id,
266 updated_note: updated_note
268 {:ok, _, _} = SideEffects.handle(update, object_data: updated_note)
269 %{data: new_note} = Pleroma.Object.get_by_id(object_id)
270 assert %{"summary" => "edited summary", "content" => "edited content"} = new_note
272 assert [Map.drop(note.data, ["id", "formerRepresentations"])] ==
273 new_note["formerRepresentations"]["orderedItems"]
275 assert new_note["formerRepresentations"]["totalItems"] == 1
278 test "it puts the original note at the front of formerRepresentations", %{
281 object_id: object_id,
283 updated_note: updated_note
285 {:ok, _, _} = SideEffects.handle(update, object_data: updated_note)
286 %{data: first_edit} = Pleroma.Object.get_by_id(object_id)
288 second_updated_note =
290 |> Map.put("summary", "edited summary 2")
291 |> Map.put("content", "edited content 2")
294 first_edit["updated"]
295 |> DateTime.from_iso8601()
298 |> DateTime.to_iso8601()
301 {:ok, second_update_data, []} = Builder.update(user, second_updated_note)
302 {:ok, update, _meta} = ActivityPub.persist(second_update_data, local: true)
303 {:ok, _, _} = SideEffects.handle(update, object_data: second_updated_note)
304 %{data: new_note} = Pleroma.Object.get_by_id(object_id)
305 assert %{"summary" => "edited summary 2", "content" => "edited content 2"} = new_note
307 original_version = Map.drop(note.data, ["id", "formerRepresentations"])
308 first_edit = Map.drop(first_edit, ["id", "formerRepresentations"])
310 assert [first_edit, original_version] ==
311 new_note["formerRepresentations"]["orderedItems"]
313 assert new_note["formerRepresentations"]["totalItems"] == 2
316 test "it does not prepend to formerRepresentations if no actual changes are made", %{
318 object_id: object_id,
320 updated_note: updated_note
322 {:ok, _, _} = SideEffects.handle(update, object_data: updated_note)
323 %{data: first_edit} = Pleroma.Object.get_by_id(object_id)
329 first_edit["updated"]
330 |> DateTime.from_iso8601()
333 |> DateTime.to_iso8601()
336 {:ok, _, _} = SideEffects.handle(update, object_data: updated_note)
337 %{data: new_note} = Pleroma.Object.get_by_id(object_id)
338 assert %{"summary" => "edited summary", "content" => "edited content"} = new_note
340 original_version = Map.drop(note.data, ["id", "formerRepresentations"])
342 assert [original_version] ==
343 new_note["formerRepresentations"]["orderedItems"]
345 assert new_note["formerRepresentations"]["totalItems"] == 1
349 describe "update questions" do
356 data: %{"published" => Pleroma.Web.ActivityPub.Utils.make_date()}
359 %{user: user, data: question.data, id: question.id}
362 test "allows updating choice count without generating edit history", %{
369 |> Enum.map(fn choice -> put_in(choice, ["replies", "totalItems"], 5) end)
373 |> Map.put("oneOf", new_choices)
374 |> Map.put("updated", Pleroma.Web.ActivityPub.Utils.make_date())
376 {:ok, update_data, []} = Builder.update(user, updated_question)
377 {:ok, update, _meta} = ActivityPub.persist(update_data, local: true)
379 {:ok, _, _} = SideEffects.handle(update, object_data: updated_question)
381 %{data: new_question} = Pleroma.Object.get_by_id(id)
383 assert [%{"replies" => %{"totalItems" => 5}}, %{"replies" => %{"totalItems" => 5}}] =
384 new_question["oneOf"]
386 refute Map.has_key?(new_question, "formerRepresentations")
389 test "allows updating choice count without updated field", %{
396 |> Enum.map(fn choice -> put_in(choice, ["replies", "totalItems"], 5) end)
400 |> Map.put("oneOf", new_choices)
402 {:ok, update_data, []} = Builder.update(user, updated_question)
403 {:ok, update, _meta} = ActivityPub.persist(update_data, local: true)
405 {:ok, _, _} = SideEffects.handle(update, object_data: updated_question)
407 %{data: new_question} = Pleroma.Object.get_by_id(id)
409 assert [%{"replies" => %{"totalItems" => 5}}, %{"replies" => %{"totalItems" => 5}}] =
410 new_question["oneOf"]
412 refute Map.has_key?(new_question, "formerRepresentations")
415 test "allows updating choice count with updated field same as the creation date", %{
422 |> Enum.map(fn choice -> put_in(choice, ["replies", "totalItems"], 5) end)
426 |> Map.put("oneOf", new_choices)
427 |> Map.put("updated", data["published"])
429 {:ok, update_data, []} = Builder.update(user, updated_question)
430 {:ok, update, _meta} = ActivityPub.persist(update_data, local: true)
432 {:ok, _, _} = SideEffects.handle(update, object_data: updated_question)
434 %{data: new_question} = Pleroma.Object.get_by_id(id)
436 assert [%{"replies" => %{"totalItems" => 5}}, %{"replies" => %{"totalItems" => 5}}] =
437 new_question["oneOf"]
439 refute Map.has_key?(new_question, "formerRepresentations")
443 describe "EmojiReact objects" do
445 poster = insert(:user)
448 {:ok, post} = CommonAPI.post(poster, %{status: "hey"})
450 {:ok, emoji_react_data, []} = Builder.emoji_react(user, post.object, "👌")
451 {:ok, emoji_react, _meta} = ActivityPub.persist(emoji_react_data, local: true)
453 %{emoji_react: emoji_react, user: user, poster: poster}
456 test "adds the reaction to the object", %{emoji_react: emoji_react, user: user} do
457 {:ok, emoji_react, _} = SideEffects.handle(emoji_react)
458 object = Object.get_by_ap_id(emoji_react.data["object"])
460 assert object.data["reaction_count"] == 1
461 assert ["👌", [user.ap_id], nil] in object.data["reactions"]
464 test "creates a notification", %{emoji_react: emoji_react, poster: poster} do
465 {:ok, emoji_react, _} = SideEffects.handle(emoji_react)
466 assert Repo.get_by(Notification, user_id: poster.id, activity_id: emoji_react.id)
470 describe "Question objects" do
473 question = build(:question, user: user)
474 question_activity = build(:question_activity, question: question)
475 activity_data = Map.put(question_activity.data, "object", question.data["id"])
476 meta = [object_data: question.data, local: false]
478 {:ok, activity, meta} = ActivityPub.persist(activity_data, meta)
480 %{activity: activity, meta: meta}
483 test "enqueues the poll end", %{activity: activity, meta: meta} do
484 {:ok, activity, meta} = SideEffects.handle(activity, meta)
487 worker: Pleroma.Workers.PollWorker,
488 args: %{op: "poll_end", activity_id: activity.id},
489 scheduled_at: NaiveDateTime.from_iso8601!(meta[:object_data]["closed"])
494 describe "delete users with confirmation pending" do
496 user = insert(:user, is_confirmed: false)
497 {:ok, delete_user_data, _meta} = Builder.delete(user, user.ap_id)
498 {:ok, delete_user, _meta} = ActivityPub.persist(delete_user_data, local: true)
499 {:ok, delete: delete_user, user: user}
502 test "when activation is required", %{delete: delete, user: user} do
503 clear_config([:instance, :account_activation_required], true)
504 {:ok, _, _} = SideEffects.handle(delete)
505 ObanHelpers.perform_all()
507 refute User.get_cached_by_id(user.id)
511 describe "Undo objects" do
513 poster = insert(:user)
515 {:ok, post} = CommonAPI.post(poster, %{status: "hey"})
516 {:ok, like} = CommonAPI.favorite(user, post.id)
517 {:ok, reaction} = CommonAPI.react_with_emoji(post.id, user, "👍")
518 {:ok, announce} = CommonAPI.repeat(post.id, user)
519 {:ok, block} = CommonAPI.block(user, poster)
521 {:ok, undo_data, _meta} = Builder.undo(user, like)
522 {:ok, like_undo, _meta} = ActivityPub.persist(undo_data, local: true)
524 {:ok, undo_data, _meta} = Builder.undo(user, reaction)
525 {:ok, reaction_undo, _meta} = ActivityPub.persist(undo_data, local: true)
527 {:ok, undo_data, _meta} = Builder.undo(user, announce)
528 {:ok, announce_undo, _meta} = ActivityPub.persist(undo_data, local: true)
530 {:ok, undo_data, _meta} = Builder.undo(user, block)
531 {:ok, block_undo, _meta} = ActivityPub.persist(undo_data, local: true)
534 like_undo: like_undo,
537 reaction_undo: reaction_undo,
539 announce_undo: announce_undo,
541 block_undo: block_undo,
548 test "deletes the original block", %{
549 block_undo: block_undo,
552 {:ok, _block_undo, _meta} = SideEffects.handle(block_undo)
554 refute Activity.get_by_id(block.id)
557 test "unblocks the blocked user", %{block_undo: block_undo, block: block} do
558 blocker = User.get_by_ap_id(block.data["actor"])
559 blocked = User.get_by_ap_id(block.data["object"])
561 {:ok, _block_undo, _} = SideEffects.handle(block_undo)
562 refute User.blocks?(blocker, blocked)
565 test "an announce undo removes the announce from the object", %{
566 announce_undo: announce_undo,
569 {:ok, _announce_undo, _} = SideEffects.handle(announce_undo)
571 object = Object.get_by_ap_id(post.data["object"])
573 assert object.data["announcement_count"] == 0
574 assert object.data["announcements"] == []
577 test "deletes the original announce", %{announce_undo: announce_undo, announce: announce} do
578 {:ok, _announce_undo, _} = SideEffects.handle(announce_undo)
579 refute Activity.get_by_id(announce.id)
582 test "a reaction undo removes the reaction from the object", %{
583 reaction_undo: reaction_undo,
586 {:ok, _reaction_undo, _} = SideEffects.handle(reaction_undo)
588 object = Object.get_by_ap_id(post.data["object"])
590 assert object.data["reaction_count"] == 0
591 assert object.data["reactions"] == []
594 test "deletes the original reaction", %{reaction_undo: reaction_undo, reaction: reaction} do
595 {:ok, _reaction_undo, _} = SideEffects.handle(reaction_undo)
596 refute Activity.get_by_id(reaction.id)
599 test "a like undo removes the like from the object", %{like_undo: like_undo, post: post} do
600 {:ok, _like_undo, _} = SideEffects.handle(like_undo)
602 object = Object.get_by_ap_id(post.data["object"])
604 assert object.data["like_count"] == 0
605 assert object.data["likes"] == []
608 test "deletes the original like", %{like_undo: like_undo, like: like} do
609 {:ok, _like_undo, _} = SideEffects.handle(like_undo)
610 refute Activity.get_by_id(like.id)
614 describe "like objects" do
616 poster = insert(:user)
618 {:ok, post} = CommonAPI.post(poster, %{status: "hey"})
620 {:ok, like_data, _meta} = Builder.like(user, post.object)
621 {:ok, like, _meta} = ActivityPub.persist(like_data, local: true)
623 %{like: like, user: user, poster: poster}
626 test "add the like to the original object", %{like: like, user: user} do
627 {:ok, like, _} = SideEffects.handle(like)
628 object = Object.get_by_ap_id(like.data["object"])
629 assert object.data["like_count"] == 1
630 assert user.ap_id in object.data["likes"]
633 test "creates a notification", %{like: like, poster: poster} do
634 {:ok, like, _} = SideEffects.handle(like)
635 assert Repo.get_by(Notification, user_id: poster.id, activity_id: like.id)
639 describe "announce objects" do
641 poster = insert(:user)
643 {:ok, post} = CommonAPI.post(poster, %{status: "hey"})
644 {:ok, private_post} = CommonAPI.post(poster, %{status: "hey", visibility: "private"})
646 {:ok, announce_data, _meta} = Builder.announce(user, post.object, public: true)
648 {:ok, private_announce_data, _meta} =
649 Builder.announce(user, private_post.object, public: false)
651 {:ok, relay_announce_data, _meta} =
652 Builder.announce(Pleroma.Web.ActivityPub.Relay.get_actor(), post.object, public: true)
654 {:ok, announce, _meta} = ActivityPub.persist(announce_data, local: true)
655 {:ok, private_announce, _meta} = ActivityPub.persist(private_announce_data, local: true)
656 {:ok, relay_announce, _meta} = ActivityPub.persist(relay_announce_data, local: true)
662 private_announce: private_announce,
663 relay_announce: relay_announce
667 test "adds the announce to the original object", %{announce: announce, user: user} do
668 {:ok, announce, _} = SideEffects.handle(announce)
669 object = Object.get_by_ap_id(announce.data["object"])
670 assert object.data["announcement_count"] == 1
671 assert user.ap_id in object.data["announcements"]
674 test "does not add the announce to the original object if the actor is a service actor", %{
675 relay_announce: announce
677 {:ok, announce, _} = SideEffects.handle(announce)
678 object = Object.get_by_ap_id(announce.data["object"])
679 assert object.data["announcement_count"] == nil
682 test "creates a notification", %{announce: announce, poster: poster} do
683 {:ok, announce, _} = SideEffects.handle(announce)
684 assert Repo.get_by(Notification, user_id: poster.id, activity_id: announce.id)
687 test "it streams out the announce", %{announce: announce} do
690 Pleroma.Web.Streamer,
693 stream: fn _, _ -> nil end
700 send: fn _ -> nil end
704 {:ok, announce, _} = SideEffects.handle(announce)
707 Pleroma.Web.Streamer.stream(["user", "list", "public", "public:local"], announce)
710 assert called(Pleroma.Web.Push.send(:_))
715 describe "removing a follower" do
718 followed = insert(:user)
720 {:ok, _, _, follow_activity} = CommonAPI.follow(user, followed)
722 {:ok, reject_data, []} = Builder.reject(followed, follow_activity)
723 {:ok, reject, _meta} = ActivityPub.persist(reject_data, local: true)
725 %{user: user, followed: followed, reject: reject}
728 test "", %{user: user, followed: followed, reject: reject} do
729 assert User.following?(user, followed)
730 assert Pleroma.FollowingRelationship.get(user, followed)
732 {:ok, _, _} = SideEffects.handle(reject)
734 refute User.following?(user, followed)
735 refute Pleroma.FollowingRelationship.get(user, followed)
736 assert User.get_follow_state(user, followed) == nil
737 assert User.get_follow_state(user, followed, nil) == nil
741 describe "removing a follower from remote" do
744 followed = insert(:user, local: false)
746 # Mock a local-to-remote follow
747 {:ok, follow_data, []} = Builder.follow(user, followed)
751 |> Map.put("state", "accept")
753 {:ok, follow, _meta} = ActivityPub.persist(follow_data, local: true)
754 {:ok, _, _} = SideEffects.handle(follow)
756 # Mock a remote-to-local accept
757 {:ok, accept_data, _} = Builder.accept(followed, follow)
758 {:ok, accept, _} = ActivityPub.persist(accept_data, local: false)
759 {:ok, _, _} = SideEffects.handle(accept)
761 # Mock a remote-to-local reject
762 {:ok, reject_data, []} = Builder.reject(followed, follow)
763 {:ok, reject, _meta} = ActivityPub.persist(reject_data, local: false)
765 %{user: user, followed: followed, reject: reject}
768 test "", %{user: user, followed: followed, reject: reject} do
769 assert User.following?(user, followed)
770 assert Pleroma.FollowingRelationship.get(user, followed)
772 {:ok, _, _} = SideEffects.handle(reject)
774 refute User.following?(user, followed)
775 refute Pleroma.FollowingRelationship.get(user, followed)
777 assert Pleroma.Web.ActivityPub.Utils.fetch_latest_follow(user, followed).data["state"] ==
780 assert User.get_follow_state(user, followed) == nil
781 assert User.get_follow_state(user, followed, nil) == nil