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.Web.CommonAPI
7 alias Pleroma.Web.Federator
8 alias Pleroma.Instances
10 import Pleroma.Factory
14 Tesla.Mock.mock_global(fn env -> apply(HttpRequestMock, :request, [env]) end)
18 test "enqueues an element according to priority" do
19 queue = [%{item: 1, priority: 2}]
21 new_queue = Federator.enqueue_sorted(queue, 2, 1)
22 assert new_queue == [%{item: 2, priority: 1}, %{item: 1, priority: 2}]
24 new_queue = Federator.enqueue_sorted(queue, 2, 3)
25 assert new_queue == [%{item: 1, priority: 2}, %{item: 2, priority: 3}]
28 test "pop first item" do
29 queue = [%{item: 2, priority: 1}, %{item: 1, priority: 2}]
31 assert {2, [%{item: 1, priority: 2}]} = Federator.queue_pop(queue)
34 describe "Publish an activity" do
37 {:ok, activity} = CommonAPI.post(user, %{"status" => "HI"})
40 Pleroma.Web.ActivityPub.Relay,
42 [publish: fn _activity -> send(self(), :relay_publish) end]
45 %{activity: activity, relay_mock: relay_mock}
48 test "with relays active, it publishes to the relay", %{
50 relay_mock: relay_mock
52 with_mocks([relay_mock]) do
53 Federator.handle(:publish, activity)
56 assert_received :relay_publish
59 test "with relays deactivated, it does not publish to the relay", %{
61 relay_mock: relay_mock
63 Pleroma.Config.put([:instance, :allow_relay], false)
65 with_mocks([relay_mock]) do
66 Federator.handle(:publish, activity)
69 refute_received :relay_publish
71 Pleroma.Config.put([:instance, :allow_relay], true)
75 describe "Targets reachability filtering in `publish`" do
76 test_with_mock "it federates only to reachable instances via AP",
83 {"https://domain.com/users/nick1/inbox", "https://domain2.com/users/nick2/inbox"}
87 nickname: "nick1@domain.com",
88 ap_id: "https://domain.com/users/nick1",
89 info: %{ap_enabled: true, source_data: %{"inbox" => inbox1}}
94 nickname: "nick2@domain2.com",
95 ap_id: "https://domain2.com/users/nick2",
96 info: %{ap_enabled: true, source_data: %{"inbox" => inbox2}}
99 dt = NaiveDateTime.utc_now()
100 Instances.set_unreachable(inbox1, dt)
102 Instances.set_consistently_unreachable(URI.parse(inbox2).host)
105 CommonAPI.post(user, %{"status" => "HI @nick1@domain.com, @nick2@domain2.com!"})
108 Federator.enqueue(:publish_single_ap, %{inbox: inbox1, unreachable_since: dt})
111 refute called(Federator.enqueue(:publish_single_ap, %{inbox: inbox2}))
114 test_with_mock "it federates only to reachable instances via Websub",
119 websub_topic = Pleroma.Web.OStatus.feed_path(user)
122 insert(:websub_subscription, %{
125 callback: "http://pleroma.soykaf.com/cb"
129 insert(:websub_subscription, %{
132 callback: "https://pleroma2.soykaf.com/cb"
135 dt = NaiveDateTime.utc_now()
136 Instances.set_unreachable(sub2.callback, dt)
138 Instances.set_consistently_unreachable(sub1.callback)
140 {:ok, _activity} = CommonAPI.post(user, %{"status" => "HI"})
143 Federator.enqueue(:publish_single_websub, %{
144 callback: sub2.callback,
145 unreachable_since: dt
149 refute called(Federator.enqueue(:publish_single_websub, %{callback: sub1.callback}))
152 test_with_mock "it federates only to reachable instances via Salmon",
161 nickname: "nick1@domain.com",
162 ap_id: "https://domain.com/users/nick1",
163 info: %{salmon: "https://domain.com/salmon"}
169 nickname: "nick2@domain2.com",
170 ap_id: "https://domain2.com/users/nick2",
171 info: %{salmon: "https://domain2.com/salmon"}
174 dt = NaiveDateTime.utc_now()
175 Instances.set_unreachable(remote_user2.ap_id, dt)
177 Instances.set_consistently_unreachable("domain.com")
180 CommonAPI.post(user, %{"status" => "HI @nick1@domain.com, @nick2@domain2.com!"})
183 Federator.enqueue(:publish_single_salmon, %{
184 recipient: remote_user2,
185 unreachable_since: dt
189 refute called(Federator.enqueue(:publish_single_websub, %{recipient: remote_user1}))
193 describe "Receive an activity" do
194 test "successfully processes incoming AP docs with correct origin" do
196 "@context" => "https://www.w3.org/ns/activitystreams",
197 "actor" => "http://mastodon.example.org/users/admin",
199 "id" => "http://mastodon.example.org/users/admin/activities/1",
202 "content" => "hi world!",
203 "id" => "http://mastodon.example.org/users/admin/objects/1",
204 "attributedTo" => "http://mastodon.example.org/users/admin"
206 "to" => ["https://www.w3.org/ns/activitystreams#Public"]
209 {:ok, _activity} = Federator.handle(:incoming_ap_doc, params)
212 test "rejects incoming AP docs with incorrect origin" do
214 "@context" => "https://www.w3.org/ns/activitystreams",
215 "actor" => "https://niu.moe/users/rye",
217 "id" => "http://mastodon.example.org/users/admin/activities/1",
220 "content" => "hi world!",
221 "id" => "http://mastodon.example.org/users/admin/objects/1",
222 "attributedTo" => "http://mastodon.example.org/users/admin"
224 "to" => ["https://www.w3.org/ns/activitystreams#Public"]
227 :error = Federator.handle(:incoming_ap_doc, params)