1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2020 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
11 alias Pleroma.ChatMessageReference
12 alias Pleroma.Notification
15 alias Pleroma.Tests.ObanHelpers
17 alias Pleroma.Web.ActivityPub.ActivityPub
18 alias Pleroma.Web.ActivityPub.Builder
19 alias Pleroma.Web.ActivityPub.SideEffects
20 alias Pleroma.Web.CommonAPI
22 import Pleroma.Factory
25 describe "handle_after_transaction" do
26 test "it streams out notifications" do
27 author = insert(:user, local: true)
28 recipient = insert(:user, local: true)
30 {:ok, chat_message_data, _meta} = Builder.chat_message(author, recipient.ap_id, "hey")
32 {:ok, create_activity_data, _meta} =
33 Builder.create(author, chat_message_data["id"], [recipient.ap_id])
35 {:ok, create_activity, _meta} = ActivityPub.persist(create_activity_data, local: false)
37 {:ok, _create_activity, meta} =
38 SideEffects.handle(create_activity, local: false, object_data: chat_message_data)
40 assert [notification] = meta[:created_notifications]
47 stream: fn _, _ -> nil end
58 SideEffects.handle_after_transaction(meta)
60 assert called(Pleroma.Web.Streamer.stream(["user", "user:notification"], notification))
61 assert called(Pleroma.Web.Push.send(notification))
66 describe "delete objects" do
69 other_user = insert(:user)
71 {:ok, op} = CommonAPI.post(other_user, %{status: "big oof"})
72 {:ok, post} = CommonAPI.post(user, %{status: "hey", in_reply_to_id: op})
73 {:ok, favorite} = CommonAPI.favorite(user, post.id)
74 object = Object.normalize(post)
75 {:ok, delete_data, _meta} = Builder.delete(user, object.data["id"])
76 {:ok, delete_user_data, _meta} = Builder.delete(user, user.ap_id)
77 {:ok, delete, _meta} = ActivityPub.persist(delete_data, local: true)
78 {:ok, delete_user, _meta} = ActivityPub.persist(delete_user_data, local: true)
85 delete_user: delete_user,
91 test "it handles object deletions", %{
99 with_mock Pleroma.Web.ActivityPub.ActivityPub, [:passthrough],
100 stream_out: fn _ -> nil end,
101 stream_out_participations: fn _, _ -> nil end do
102 {:ok, delete, _} = SideEffects.handle(delete)
103 user = User.get_cached_by_ap_id(object.data["actor"])
105 assert called(Pleroma.Web.ActivityPub.ActivityPub.stream_out(delete))
106 assert called(Pleroma.Web.ActivityPub.ActivityPub.stream_out_participations(object, user))
109 object = Object.get_by_id(object.id)
110 assert object.data["type"] == "Tombstone"
111 refute Activity.get_by_id(post.id)
112 refute Activity.get_by_id(favorite.id)
114 user = User.get_by_id(user.id)
115 assert user.note_count == 0
117 object = Object.normalize(op.data["object"], false)
119 assert object.data["repliesCount"] == 0
122 test "it handles object deletions when the object itself has been pruned", %{
129 with_mock Pleroma.Web.ActivityPub.ActivityPub, [:passthrough],
130 stream_out: fn _ -> nil end,
131 stream_out_participations: fn _, _ -> nil end do
132 {:ok, delete, _} = SideEffects.handle(delete)
133 user = User.get_cached_by_ap_id(object.data["actor"])
135 assert called(Pleroma.Web.ActivityPub.ActivityPub.stream_out(delete))
136 assert called(Pleroma.Web.ActivityPub.ActivityPub.stream_out_participations(object, user))
139 object = Object.get_by_id(object.id)
140 assert object.data["type"] == "Tombstone"
141 refute Activity.get_by_id(post.id)
143 user = User.get_by_id(user.id)
144 assert user.note_count == 0
146 object = Object.normalize(op.data["object"], false)
148 assert object.data["repliesCount"] == 0
151 test "it handles user deletions", %{delete_user: delete, user: user} do
152 {:ok, _delete, _} = SideEffects.handle(delete)
153 ObanHelpers.perform_all()
155 assert User.get_cached_by_ap_id(user.ap_id).deactivated
159 describe "EmojiReact objects" do
161 poster = insert(:user)
164 {:ok, post} = CommonAPI.post(poster, %{status: "hey"})
166 {:ok, emoji_react_data, []} = Builder.emoji_react(user, post.object, "👌")
167 {:ok, emoji_react, _meta} = ActivityPub.persist(emoji_react_data, local: true)
169 %{emoji_react: emoji_react, user: user, poster: poster}
172 test "adds the reaction to the object", %{emoji_react: emoji_react, user: user} do
173 {:ok, emoji_react, _} = SideEffects.handle(emoji_react)
174 object = Object.get_by_ap_id(emoji_react.data["object"])
176 assert object.data["reaction_count"] == 1
177 assert ["👌", [user.ap_id]] in object.data["reactions"]
180 test "creates a notification", %{emoji_react: emoji_react, poster: poster} do
181 {:ok, emoji_react, _} = SideEffects.handle(emoji_react)
182 assert Repo.get_by(Notification, user_id: poster.id, activity_id: emoji_react.id)
186 describe "delete users with confirmation pending" do
188 user = insert(:user, confirmation_pending: true)
189 {:ok, delete_user_data, _meta} = Builder.delete(user, user.ap_id)
190 {:ok, delete_user, _meta} = ActivityPub.persist(delete_user_data, local: true)
191 {:ok, delete: delete_user, user: user}
194 test "when activation is not required", %{delete: delete, user: user} do
195 clear_config([:instance, :account_activation_required], false)
196 {:ok, _, _} = SideEffects.handle(delete)
197 ObanHelpers.perform_all()
199 assert User.get_cached_by_id(user.id).deactivated
202 test "when activation is required", %{delete: delete, user: user} do
203 clear_config([:instance, :account_activation_required], true)
204 {:ok, _, _} = SideEffects.handle(delete)
205 ObanHelpers.perform_all()
207 refute User.get_cached_by_id(user.id)
211 describe "Undo objects" do
213 poster = insert(:user)
215 {:ok, post} = CommonAPI.post(poster, %{status: "hey"})
216 {:ok, like} = CommonAPI.favorite(user, post.id)
217 {:ok, reaction} = CommonAPI.react_with_emoji(post.id, user, "👍")
218 {:ok, announce} = CommonAPI.repeat(post.id, user)
219 {:ok, block} = ActivityPub.block(user, poster)
220 User.block(user, poster)
222 {:ok, undo_data, _meta} = Builder.undo(user, like)
223 {:ok, like_undo, _meta} = ActivityPub.persist(undo_data, local: true)
225 {:ok, undo_data, _meta} = Builder.undo(user, reaction)
226 {:ok, reaction_undo, _meta} = ActivityPub.persist(undo_data, local: true)
228 {:ok, undo_data, _meta} = Builder.undo(user, announce)
229 {:ok, announce_undo, _meta} = ActivityPub.persist(undo_data, local: true)
231 {:ok, undo_data, _meta} = Builder.undo(user, block)
232 {:ok, block_undo, _meta} = ActivityPub.persist(undo_data, local: true)
235 like_undo: like_undo,
238 reaction_undo: reaction_undo,
240 announce_undo: announce_undo,
242 block_undo: block_undo,
249 test "deletes the original block", %{block_undo: block_undo, block: block} do
250 {:ok, _block_undo, _} = SideEffects.handle(block_undo)
251 refute Activity.get_by_id(block.id)
254 test "unblocks the blocked user", %{block_undo: block_undo, block: block} do
255 blocker = User.get_by_ap_id(block.data["actor"])
256 blocked = User.get_by_ap_id(block.data["object"])
258 {:ok, _block_undo, _} = SideEffects.handle(block_undo)
259 refute User.blocks?(blocker, blocked)
262 test "an announce undo removes the announce from the object", %{
263 announce_undo: announce_undo,
266 {:ok, _announce_undo, _} = SideEffects.handle(announce_undo)
268 object = Object.get_by_ap_id(post.data["object"])
270 assert object.data["announcement_count"] == 0
271 assert object.data["announcements"] == []
274 test "deletes the original announce", %{announce_undo: announce_undo, announce: announce} do
275 {:ok, _announce_undo, _} = SideEffects.handle(announce_undo)
276 refute Activity.get_by_id(announce.id)
279 test "a reaction undo removes the reaction from the object", %{
280 reaction_undo: reaction_undo,
283 {:ok, _reaction_undo, _} = SideEffects.handle(reaction_undo)
285 object = Object.get_by_ap_id(post.data["object"])
287 assert object.data["reaction_count"] == 0
288 assert object.data["reactions"] == []
291 test "deletes the original reaction", %{reaction_undo: reaction_undo, reaction: reaction} do
292 {:ok, _reaction_undo, _} = SideEffects.handle(reaction_undo)
293 refute Activity.get_by_id(reaction.id)
296 test "a like undo removes the like from the object", %{like_undo: like_undo, post: post} do
297 {:ok, _like_undo, _} = SideEffects.handle(like_undo)
299 object = Object.get_by_ap_id(post.data["object"])
301 assert object.data["like_count"] == 0
302 assert object.data["likes"] == []
305 test "deletes the original like", %{like_undo: like_undo, like: like} do
306 {:ok, _like_undo, _} = SideEffects.handle(like_undo)
307 refute Activity.get_by_id(like.id)
311 describe "like objects" do
313 poster = insert(:user)
315 {:ok, post} = CommonAPI.post(poster, %{status: "hey"})
317 {:ok, like_data, _meta} = Builder.like(user, post.object)
318 {:ok, like, _meta} = ActivityPub.persist(like_data, local: true)
320 %{like: like, user: user, poster: poster}
323 test "add the like to the original object", %{like: like, user: user} do
324 {:ok, like, _} = SideEffects.handle(like)
325 object = Object.get_by_ap_id(like.data["object"])
326 assert object.data["like_count"] == 1
327 assert user.ap_id in object.data["likes"]
330 test "creates a notification", %{like: like, poster: poster} do
331 {:ok, like, _} = SideEffects.handle(like)
332 assert Repo.get_by(Notification, user_id: poster.id, activity_id: like.id)
336 describe "creation of ChatMessages" do
337 test "notifies the recipient" do
338 author = insert(:user, local: false)
339 recipient = insert(:user, local: true)
341 {:ok, chat_message_data, _meta} = Builder.chat_message(author, recipient.ap_id, "hey")
343 {:ok, create_activity_data, _meta} =
344 Builder.create(author, chat_message_data["id"], [recipient.ap_id])
346 {:ok, create_activity, _meta} = ActivityPub.persist(create_activity_data, local: false)
348 {:ok, _create_activity, _meta} =
349 SideEffects.handle(create_activity, local: false, object_data: chat_message_data)
351 assert Repo.get_by(Notification, user_id: recipient.id, activity_id: create_activity.id)
354 test "it streams the created ChatMessage" do
355 author = insert(:user, local: true)
356 recipient = insert(:user, local: true)
358 {:ok, chat_message_data, _meta} = Builder.chat_message(author, recipient.ap_id, "hey")
360 {:ok, create_activity_data, _meta} =
361 Builder.create(author, chat_message_data["id"], [recipient.ap_id])
363 {:ok, create_activity, _meta} = ActivityPub.persist(create_activity_data, local: false)
365 with_mock Pleroma.Web.Streamer, [],
366 stream: fn _, payload ->
369 assert cm_ref.unread == false
371 {^recipient, cm_ref} ->
372 assert cm_ref.unread == true
375 Pleroma.Web.PleromaAPI.ChatView.render("show.json",
376 last_message: cm_ref,
380 assert view.unread == 1
386 {:ok, _create_activity, _meta} =
387 SideEffects.handle(create_activity, local: false, object_data: chat_message_data)
389 assert called(Pleroma.Web.Streamer.stream(["user", "user:pleroma_chat"], {author, :_}))
390 assert called(Pleroma.Web.Streamer.stream(["user", "user:pleroma_chat"], {recipient, :_}))
394 test "it creates a Chat and ChatMessageReferences for the local users and bumps the unread count, except for the author" do
395 author = insert(:user, local: true)
396 recipient = insert(:user, local: true)
398 {:ok, chat_message_data, _meta} = Builder.chat_message(author, recipient.ap_id, "hey")
400 {:ok, create_activity_data, _meta} =
401 Builder.create(author, chat_message_data["id"], [recipient.ap_id])
403 {:ok, create_activity, _meta} = ActivityPub.persist(create_activity_data, local: false)
407 Pleroma.Web.Streamer,
410 stream: fn _, _ -> nil end
417 send: fn _ -> nil end
421 {:ok, _create_activity, meta} =
422 SideEffects.handle(create_activity, local: false, object_data: chat_message_data)
424 # The notification gets created
425 assert [notification] = meta[:created_notifications]
426 assert notification.activity_id == create_activity.id
428 # But it is not sent out
429 refute called(Pleroma.Web.Streamer.stream(["user", "user:notification"], notification))
430 refute called(Pleroma.Web.Push.send(notification))
432 chat = Chat.get(author.id, recipient.ap_id)
434 [cm_ref] = ChatMessageReference.for_chat_query(chat) |> Repo.all()
436 assert cm_ref.object.data["content"] == "hey"
437 assert cm_ref.unread == false
439 chat = Chat.get(recipient.id, author.ap_id)
441 [cm_ref] = ChatMessageReference.for_chat_query(chat) |> Repo.all()
443 assert cm_ref.object.data["content"] == "hey"
444 assert cm_ref.unread == true
448 test "it creates a Chat for the local users and bumps the unread count" do
449 author = insert(:user, local: false)
450 recipient = insert(:user, local: true)
452 {:ok, chat_message_data, _meta} = Builder.chat_message(author, recipient.ap_id, "hey")
454 {:ok, create_activity_data, _meta} =
455 Builder.create(author, chat_message_data["id"], [recipient.ap_id])
457 {:ok, create_activity, _meta} = ActivityPub.persist(create_activity_data, local: false)
459 {:ok, _create_activity, _meta} =
460 SideEffects.handle(create_activity, local: false, object_data: chat_message_data)
462 # An object is created
463 assert Object.get_by_ap_id(chat_message_data["id"])
465 # The remote user won't get a chat
466 chat = Chat.get(author.id, recipient.ap_id)
469 # The local user will get a chat
470 chat = Chat.get(recipient.id, author.ap_id)
473 author = insert(:user, local: true)
474 recipient = insert(:user, local: true)
476 {:ok, chat_message_data, _meta} = Builder.chat_message(author, recipient.ap_id, "hey")
478 {:ok, create_activity_data, _meta} =
479 Builder.create(author, chat_message_data["id"], [recipient.ap_id])
481 {:ok, create_activity, _meta} = ActivityPub.persist(create_activity_data, local: false)
483 {:ok, _create_activity, _meta} =
484 SideEffects.handle(create_activity, local: false, object_data: chat_message_data)
486 # Both users are local and get the chat
487 chat = Chat.get(author.id, recipient.ap_id)
490 chat = Chat.get(recipient.id, author.ap_id)
495 describe "announce objects" do
497 poster = insert(:user)
499 {:ok, post} = CommonAPI.post(poster, %{status: "hey"})
500 {:ok, private_post} = CommonAPI.post(poster, %{status: "hey", visibility: "private"})
502 {:ok, announce_data, _meta} = Builder.announce(user, post.object, public: true)
504 {:ok, private_announce_data, _meta} =
505 Builder.announce(user, private_post.object, public: false)
507 {:ok, relay_announce_data, _meta} =
508 Builder.announce(Pleroma.Web.ActivityPub.Relay.get_actor(), post.object, public: true)
510 {:ok, announce, _meta} = ActivityPub.persist(announce_data, local: true)
511 {:ok, private_announce, _meta} = ActivityPub.persist(private_announce_data, local: true)
512 {:ok, relay_announce, _meta} = ActivityPub.persist(relay_announce_data, local: true)
518 private_announce: private_announce,
519 relay_announce: relay_announce
523 test "adds the announce to the original object", %{announce: announce, user: user} do
524 {:ok, announce, _} = SideEffects.handle(announce)
525 object = Object.get_by_ap_id(announce.data["object"])
526 assert object.data["announcement_count"] == 1
527 assert user.ap_id in object.data["announcements"]
530 test "does not add the announce to the original object if the actor is a service actor", %{
531 relay_announce: announce
533 {:ok, announce, _} = SideEffects.handle(announce)
534 object = Object.get_by_ap_id(announce.data["object"])
535 assert object.data["announcement_count"] == nil
538 test "creates a notification", %{announce: announce, poster: poster} do
539 {:ok, announce, _} = SideEffects.handle(announce)
540 assert Repo.get_by(Notification, user_id: poster.id, activity_id: announce.id)
543 test "it streams out the announce", %{announce: announce} do
544 with_mock Pleroma.Web.ActivityPub.ActivityPub, [:passthrough], stream_out: fn _ -> nil end do
545 {:ok, announce, _} = SideEffects.handle(announce)
547 assert called(Pleroma.Web.ActivityPub.ActivityPub.stream_out(announce))