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.PublisherTest do
6 use Pleroma.Web.ConnCase
8 import ExUnit.CaptureLog
13 alias Pleroma.Activity
14 alias Pleroma.Instances
16 alias Pleroma.Web.ActivityPub.Publisher
17 alias Pleroma.Web.CommonAPI
19 @as_public "https://www.w3.org/ns/activitystreams#Public"
22 mock(fn env -> apply(HttpRequestMock, :request, [env]) end)
26 setup_all do: clear_config([:instance, :federating], true)
28 describe "gather_webfinger_links/1" do
29 test "it returns links" do
33 %{"href" => user.ap_id, "rel" => "self", "type" => "application/activity+json"},
37 "type" => "application/ld+json; profile=\"https://www.w3.org/ns/activitystreams\""
40 "rel" => "http://ostatus.org/schema/1.0/subscribe",
41 "template" => "#{Pleroma.Web.base_url()}/ostatus_subscribe?acct={uri}"
45 assert expected_links == Publisher.gather_webfinger_links(user)
49 describe "determine_inbox/2" do
50 test "it returns sharedInbox for messages involving as:Public in to" do
51 user = insert(:user, %{shared_inbox: "http://example.com/inbox"})
54 data: %{"to" => [@as_public], "cc" => [user.follower_address]}
57 assert Publisher.determine_inbox(activity, user) == "http://example.com/inbox"
60 test "it returns sharedInbox for messages involving as:Public in cc" do
61 user = insert(:user, %{shared_inbox: "http://example.com/inbox"})
64 data: %{"cc" => [@as_public], "to" => [user.follower_address]}
67 assert Publisher.determine_inbox(activity, user) == "http://example.com/inbox"
70 test "it returns sharedInbox for messages involving multiple recipients in to" do
71 user = insert(:user, %{shared_inbox: "http://example.com/inbox"})
72 user_two = insert(:user)
73 user_three = insert(:user)
76 data: %{"cc" => [], "to" => [user.ap_id, user_two.ap_id, user_three.ap_id]}
79 assert Publisher.determine_inbox(activity, user) == "http://example.com/inbox"
82 test "it returns sharedInbox for messages involving multiple recipients in cc" do
83 user = insert(:user, %{shared_inbox: "http://example.com/inbox"})
84 user_two = insert(:user)
85 user_three = insert(:user)
88 data: %{"to" => [], "cc" => [user.ap_id, user_two.ap_id, user_three.ap_id]}
91 assert Publisher.determine_inbox(activity, user) == "http://example.com/inbox"
94 test "it returns sharedInbox for messages involving multiple recipients in total" do
97 shared_inbox: "http://example.com/inbox",
98 inbox: "http://example.com/personal-inbox"
101 user_two = insert(:user)
103 activity = %Activity{
104 data: %{"to" => [user_two.ap_id], "cc" => [user.ap_id]}
107 assert Publisher.determine_inbox(activity, user) == "http://example.com/inbox"
110 test "it returns inbox for messages involving single recipients in total" do
113 shared_inbox: "http://example.com/inbox",
114 inbox: "http://example.com/personal-inbox"
117 activity = %Activity{
118 data: %{"to" => [user.ap_id], "cc" => []}
121 assert Publisher.determine_inbox(activity, user) == "http://example.com/personal-inbox"
125 describe "publish_one/1" do
126 test_with_mock "calls `Instances.set_reachable` on successful federation if `unreachable_since` is not specified",
130 actor = insert(:user)
131 inbox = "http://200.site/users/nick1/inbox"
133 assert {:ok, _} = Publisher.publish_one(%{inbox: inbox, json: "{}", actor: actor, id: 1})
135 assert called(Instances.set_reachable(inbox))
138 test_with_mock "calls `Instances.set_reachable` on successful federation if `unreachable_since` is set",
142 actor = insert(:user)
143 inbox = "http://200.site/users/nick1/inbox"
146 Publisher.publish_one(%{
151 unreachable_since: NaiveDateTime.utc_now()
154 assert called(Instances.set_reachable(inbox))
157 test_with_mock "does NOT call `Instances.set_reachable` on successful federation if `unreachable_since` is nil",
161 actor = insert(:user)
162 inbox = "http://200.site/users/nick1/inbox"
165 Publisher.publish_one(%{
170 unreachable_since: nil
173 refute called(Instances.set_reachable(inbox))
176 test_with_mock "calls `Instances.set_unreachable` on target inbox on non-2xx HTTP response code",
180 actor = insert(:user)
181 inbox = "http://404.site/users/nick1/inbox"
183 assert {:error, _} = Publisher.publish_one(%{inbox: inbox, json: "{}", actor: actor, id: 1})
185 assert called(Instances.set_unreachable(inbox))
188 test_with_mock "it calls `Instances.set_unreachable` on target inbox on request error of any kind",
192 actor = insert(:user)
193 inbox = "http://connrefused.site/users/nick1/inbox"
195 assert capture_log(fn ->
197 Publisher.publish_one(%{inbox: inbox, json: "{}", actor: actor, id: 1})
198 end) =~ "connrefused"
200 assert called(Instances.set_unreachable(inbox))
203 test_with_mock "does NOT call `Instances.set_unreachable` if target is reachable",
207 actor = insert(:user)
208 inbox = "http://200.site/users/nick1/inbox"
210 assert {:ok, _} = Publisher.publish_one(%{inbox: inbox, json: "{}", actor: actor, id: 1})
212 refute called(Instances.set_unreachable(inbox))
215 test_with_mock "does NOT call `Instances.set_unreachable` if target instance has non-nil `unreachable_since`",
219 actor = insert(:user)
220 inbox = "http://connrefused.site/users/nick1/inbox"
222 assert capture_log(fn ->
224 Publisher.publish_one(%{
229 unreachable_since: NaiveDateTime.utc_now()
231 end) =~ "connrefused"
233 refute called(Instances.set_unreachable(inbox))
237 describe "publish/2" do
238 test_with_mock "publishes an activity with BCC to all relevant peers.",
239 Pleroma.Web.Federator.Publisher,
245 inbox: "https://domain.com/users/nick1/inbox",
249 actor = insert(:user, follower_address: follower.ap_id)
252 {:ok, _follower_one} = Pleroma.User.follow(follower, actor)
253 actor = refresh_record(actor)
256 insert(:note_activity,
257 recipients: [follower.ap_id],
258 data_attrs: %{"bcc" => [user.ap_id]}
261 res = Publisher.publish(actor, note_activity)
265 Pleroma.Web.Federator.Publisher.enqueue_one(Publisher, %{
266 inbox: "https://domain.com/users/nick1/inbox",
268 id: note_activity.data["id"]
273 test_with_mock "publishes a delete activity to peers who signed fetch requests to the create acitvity/object.",
274 Pleroma.Web.Federator.Publisher,
280 inbox: "https://domain.com/users/nick1/inbox",
287 inbox: "https://domain2.com/users/nick1/inbox",
291 actor = insert(:user)
293 note_activity = insert(:note_activity, user: actor)
294 object = Object.normalize(note_activity)
296 activity_path = String.trim_leading(note_activity.data["id"], Pleroma.Web.Endpoint.url())
297 object_path = String.trim_leading(object.data["id"], Pleroma.Web.Endpoint.url())
300 |> put_req_header("accept", "application/activity+json")
301 |> assign(:user, fetcher)
303 |> json_response(200)
306 |> put_req_header("accept", "application/activity+json")
307 |> assign(:user, another_fetcher)
308 |> get(activity_path)
309 |> json_response(200)
311 {:ok, delete} = CommonAPI.delete(note_activity.id, actor)
313 res = Publisher.publish(actor, delete)
317 Pleroma.Web.Federator.Publisher.enqueue_one(Publisher, %{
318 inbox: "https://domain.com/users/nick1/inbox",
320 id: delete.data["id"]
325 Pleroma.Web.Federator.Publisher.enqueue_one(Publisher, %{
326 inbox: "https://domain2.com/users/nick1/inbox",
328 id: delete.data["id"]