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.FederatorTest do
6 alias Pleroma.Instances
7 alias Pleroma.Web.CommonAPI
8 alias Pleroma.Web.Federator
11 use Oban.Testing, repo: Pleroma.Repo
13 import Pleroma.Factory
17 Tesla.Mock.mock_global(fn env -> apply(HttpRequestMock, :request, [env]) end)
19 config_path = [:instance, :federating]
20 initial_setting = Pleroma.Config.get(config_path)
22 Pleroma.Config.put(config_path, true)
23 on_exit(fn -> Pleroma.Config.put(config_path, initial_setting) end)
28 describe "Publish an activity" do
31 {:ok, activity} = CommonAPI.post(user, %{"status" => "HI"})
34 Pleroma.Web.ActivityPub.Relay,
36 [publish: fn _activity -> send(self(), :relay_publish) end]
39 %{activity: activity, relay_mock: relay_mock}
42 test "with relays active, it publishes to the relay", %{
44 relay_mock: relay_mock
46 with_mocks([relay_mock]) do
47 Federator.publish(activity)
50 assert_received :relay_publish
53 test "with relays deactivated, it does not publish to the relay", %{
55 relay_mock: relay_mock
57 Pleroma.Config.put([:instance, :allow_relay], false)
59 with_mocks([relay_mock]) do
60 Federator.publish(activity)
63 refute_received :relay_publish
65 Pleroma.Config.put([:instance, :allow_relay], true)
69 describe "Targets reachability filtering in `publish`" do
70 test "it federates only to reachable instances via AP" do
74 {"https://domain.com/users/nick1/inbox", "https://domain2.com/users/nick2/inbox"}
78 nickname: "nick1@domain.com",
79 ap_id: "https://domain.com/users/nick1",
80 info: %{ap_enabled: true, source_data: %{"inbox" => inbox1}}
85 nickname: "nick2@domain2.com",
86 ap_id: "https://domain2.com/users/nick2",
87 info: %{ap_enabled: true, source_data: %{"inbox" => inbox2}}
90 dt = NaiveDateTime.utc_now()
91 Instances.set_unreachable(inbox1, dt)
93 Instances.set_consistently_unreachable(URI.parse(inbox2).host)
96 CommonAPI.post(user, %{"status" => "HI @nick1@domain.com, @nick2@domain2.com!"})
98 expected_dt = NaiveDateTime.to_iso8601(dt)
100 assert [%{args: %{"params" => %{"inbox" => ^inbox1, "unreachable_since" => ^expected_dt}}}] =
101 all_enqueued(worker: Pleroma.Workers.Publisher)
104 test "it federates only to reachable instances via Websub" do
106 websub_topic = Pleroma.Web.OStatus.feed_path(user)
109 insert(:websub_subscription, %{
112 callback: "http://pleroma.soykaf.com/cb"
116 insert(:websub_subscription, %{
119 callback: "https://pleroma2.soykaf.com/cb"
122 dt = NaiveDateTime.utc_now()
123 Instances.set_unreachable(sub2.callback, dt)
125 Instances.set_consistently_unreachable(sub1.callback)
127 {:ok, _activity} = CommonAPI.post(user, %{"status" => "HI"})
129 expected_callback = sub2.callback
130 expected_dt = NaiveDateTime.to_iso8601(dt)
136 "callback" => ^expected_callback,
137 "unreachable_since" => ^expected_dt
141 ] = all_enqueued(worker: Pleroma.Workers.Publisher)
144 test "it federates only to reachable instances via Salmon" do
150 nickname: "nick1@domain.com",
151 ap_id: "https://domain.com/users/nick1",
152 info: %{salmon: "https://domain.com/salmon"}
158 nickname: "nick2@domain2.com",
159 ap_id: "https://domain2.com/users/nick2",
160 info: %{salmon: "https://domain2.com/salmon"}
163 remote_user2_id = remote_user2.id
165 dt = NaiveDateTime.utc_now()
166 Instances.set_unreachable(remote_user2.ap_id, dt)
168 Instances.set_consistently_unreachable("domain.com")
171 CommonAPI.post(user, %{"status" => "HI @nick1@domain.com, @nick2@domain2.com!"})
173 expected_dt = NaiveDateTime.to_iso8601(dt)
179 "recipient_id" => ^remote_user2_id,
180 "unreachable_since" => ^expected_dt
184 ] = all_enqueued(worker: Pleroma.Workers.Publisher)
188 describe "Receive an activity" do
189 test "successfully processes incoming AP docs with correct origin" do
191 "@context" => "https://www.w3.org/ns/activitystreams",
192 "actor" => "http://mastodon.example.org/users/admin",
194 "id" => "http://mastodon.example.org/users/admin/activities/1",
197 "content" => "hi world!",
198 "id" => "http://mastodon.example.org/users/admin/objects/1",
199 "attributedTo" => "http://mastodon.example.org/users/admin"
201 "to" => ["https://www.w3.org/ns/activitystreams#Public"]
204 {:ok, _activity} = Federator.incoming_ap_doc(params)
207 test "rejects incoming AP docs with incorrect origin" do
209 "@context" => "https://www.w3.org/ns/activitystreams",
210 "actor" => "https://niu.moe/users/rye",
212 "id" => "http://mastodon.example.org/users/admin/activities/1",
215 "content" => "hi world!",
216 "id" => "http://mastodon.example.org/users/admin/objects/1",
217 "attributedTo" => "http://mastodon.example.org/users/admin"
219 "to" => ["https://www.w3.org/ns/activitystreams#Public"]
222 :error = Federator.incoming_ap_doc(params)