git.squeep.com Git - akkoma/blob - test/web/federator_test.exs

   1 # Pleroma: A lightweight social networking server
   2 # Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
   3 # SPDX-License-Identifier: AGPL-3.0-only
   4
   5 defmodule Pleroma.Web.FederatorTest do
   6   alias Pleroma.Instances
   7   alias Pleroma.Tests.ObanHelpers
   8   alias Pleroma.Web.CommonAPI
   9   alias Pleroma.Web.Federator
  10   alias Pleroma.Workers.PublisherWorker
  11
  12   use Pleroma.DataCase
  13   use Oban.Testing, repo: Pleroma.Repo
  14
  15   import Pleroma.Factory
  16   import Mock
  17
  18   setup_all do
  19     Tesla.Mock.mock_global(fn env -> apply(HttpRequestMock, :request, [env]) end)
  20
  21     :ok
  22   end
  23
  24   clear_config_all([:instance, :federating]) do
  25     Pleroma.Config.put([:instance, :federating], true)
  26   end
  27
  28   clear_config([:instance, :allow_relay])
  29   clear_config([:instance, :rewrite_policy])
  30   clear_config([:mrf_keyword])
  31
  32   describe "Publish an activity" do
  33     setup do
  34       user = insert(:user)
  35       {:ok, activity} = CommonAPI.post(user, %{"status" => "HI"})
  36
  37       relay_mock = {
  38         Pleroma.Web.ActivityPub.Relay,
  39         [],
  40         [publish: fn _activity -> send(self(), :relay_publish) end]
  41       }
  42
  43       %{activity: activity, relay_mock: relay_mock}
  44     end
  45
  46     test "with relays active, it publishes to the relay", %{
  47       activity: activity,
  48       relay_mock: relay_mock
  49     } do
  50       with_mocks([relay_mock]) do
  51         Federator.publish(activity)
  52         ObanHelpers.perform(all_enqueued(worker: PublisherWorker))
  53       end
  54
  55       assert_received :relay_publish
  56     end
  57
  58     test "with relays deactivated, it does not publish to the relay", %{
  59       activity: activity,
  60       relay_mock: relay_mock
  61     } do
  62       Pleroma.Config.put([:instance, :allow_relay], false)
  63
  64       with_mocks([relay_mock]) do
  65         Federator.publish(activity)
  66         ObanHelpers.perform(all_enqueued(worker: PublisherWorker))
  67       end
  68
  69       refute_received :relay_publish
  70     end
  71   end
  72
  73   describe "Targets reachability filtering in `publish`" do
  74     test "it federates only to reachable instances via AP" do
  75       user = insert(:user)
  76
  77       {inbox1, inbox2} =
  78         {"https://domain.com/users/nick1/inbox", "https://domain2.com/users/nick2/inbox"}
  79
  80       insert(:user, %{
  81         local: false,
  82         nickname: "nick1@domain.com",
  83         ap_id: "https://domain.com/users/nick1",
  84         source_data: %{"inbox" => inbox1},
  85         ap_enabled: true
  86       })
  87
  88       insert(:user, %{
  89         local: false,
  90         nickname: "nick2@domain2.com",
  91         ap_id: "https://domain2.com/users/nick2",
  92         source_data: %{"inbox" => inbox2},
  93         ap_enabled: true
  94       })
  95
  96       dt = NaiveDateTime.utc_now()
  97       Instances.set_unreachable(inbox1, dt)
  98
  99       Instances.set_consistently_unreachable(URI.parse(inbox2).host)
 100
 101       {:ok, _activity} =
 102         CommonAPI.post(user, %{"status" => "HI @nick1@domain.com, @nick2@domain2.com!"})
 103
 104       expected_dt = NaiveDateTime.to_iso8601(dt)
 105
 106       ObanHelpers.perform(all_enqueued(worker: PublisherWorker))
 107
 108       assert ObanHelpers.member?(
 109                %{
 110                  "op" => "publish_one",
 111                  "params" => %{"inbox" => inbox1, "unreachable_since" => expected_dt}
 112                },
 113                all_enqueued(worker: PublisherWorker)
 114              )
 115     end
 116
 117     test "it federates only to reachable instances via Websub" do
 118       user = insert(:user)
 119       websub_topic = Pleroma.Web.OStatus.feed_path(user)
 120
 121       sub1 =
 122         insert(:websub_subscription, %{
 123           topic: websub_topic,
 124           state: "active",
 125           callback: "http://pleroma.soykaf.com/cb"
 126         })
 127
 128       sub2 =
 129         insert(:websub_subscription, %{
 130           topic: websub_topic,
 131           state: "active",
 132           callback: "https://pleroma2.soykaf.com/cb"
 133         })
 134
 135       dt = NaiveDateTime.utc_now()
 136       Instances.set_unreachable(sub2.callback, dt)
 137
 138       Instances.set_consistently_unreachable(sub1.callback)
 139
 140       {:ok, _activity} = CommonAPI.post(user, %{"status" => "HI"})
 141
 142       expected_callback = sub2.callback
 143       expected_dt = NaiveDateTime.to_iso8601(dt)
 144
 145       ObanHelpers.perform(all_enqueued(worker: PublisherWorker))
 146
 147       assert ObanHelpers.member?(
 148                %{
 149                  "op" => "publish_one",
 150                  "params" => %{
 151                    "callback" => expected_callback,
 152                    "unreachable_since" => expected_dt
 153                  }
 154                },
 155                all_enqueued(worker: PublisherWorker)
 156              )
 157     end
 158
 159     test "it federates only to reachable instances via Salmon" do
 160       user = insert(:user)
 161
 162       _remote_user1 =
 163         insert(:user, %{
 164           local: false,
 165           nickname: "nick1@domain.com",
 166           ap_id: "https://domain.com/users/nick1",
 167           salmon: "https://domain.com/salmon"
 168         })
 169
 170       remote_user2 =
 171         insert(:user, %{
 172           local: false,
 173           nickname: "nick2@domain2.com",
 174           ap_id: "https://domain2.com/users/nick2",
 175           salmon: "https://domain2.com/salmon"
 176         })
 177
 178       remote_user2_id = remote_user2.id
 179
 180       dt = NaiveDateTime.utc_now()
 181       Instances.set_unreachable(remote_user2.ap_id, dt)
 182
 183       Instances.set_consistently_unreachable("domain.com")
 184
 185       {:ok, _activity} =
 186         CommonAPI.post(user, %{"status" => "HI @nick1@domain.com, @nick2@domain2.com!"})
 187
 188       expected_dt = NaiveDateTime.to_iso8601(dt)
 189
 190       ObanHelpers.perform(all_enqueued(worker: PublisherWorker))
 191
 192       assert ObanHelpers.member?(
 193                %{
 194                  "op" => "publish_one",
 195                  "params" => %{
 196                    "recipient_id" => remote_user2_id,
 197                    "unreachable_since" => expected_dt
 198                  }
 199                },
 200                all_enqueued(worker: PublisherWorker)
 201              )
 202     end
 203   end
 204
 205   describe "Receive an activity" do
 206     test "successfully processes incoming AP docs with correct origin" do
 207       params = %{
 208         "@context" => "https://www.w3.org/ns/activitystreams",
 209         "actor" => "http://mastodon.example.org/users/admin",
 210         "type" => "Create",
 211         "id" => "http://mastodon.example.org/users/admin/activities/1",
 212         "object" => %{
 213           "type" => "Note",
 214           "content" => "hi world!",
 215           "id" => "http://mastodon.example.org/users/admin/objects/1",
 216           "attributedTo" => "http://mastodon.example.org/users/admin"
 217         },
 218         "to" => ["https://www.w3.org/ns/activitystreams#Public"]
 219       }
 220
 221       assert {:ok, job} = Federator.incoming_ap_doc(params)
 222       assert {:ok, _activity} = ObanHelpers.perform(job)
 223     end
 224
 225     test "rejects incoming AP docs with incorrect origin" do
 226       params = %{
 227         "@context" => "https://www.w3.org/ns/activitystreams",
 228         "actor" => "https://niu.moe/users/rye",
 229         "type" => "Create",
 230         "id" => "http://mastodon.example.org/users/admin/activities/1",
 231         "object" => %{
 232           "type" => "Note",
 233           "content" => "hi world!",
 234           "id" => "http://mastodon.example.org/users/admin/objects/1",
 235           "attributedTo" => "http://mastodon.example.org/users/admin"
 236         },
 237         "to" => ["https://www.w3.org/ns/activitystreams#Public"]
 238       }
 239
 240       assert {:ok, job} = Federator.incoming_ap_doc(params)
 241       assert :error = ObanHelpers.perform(job)
 242     end
 243
 244     test "it does not crash if MRF rejects the post" do
 245       Pleroma.Config.put([:mrf_keyword, :reject], ["lain"])
 246
 247       Pleroma.Config.put(
 248         [:instance, :rewrite_policy],
 249         Pleroma.Web.ActivityPub.MRF.KeywordPolicy
 250       )
 251
 252       params =
 253         File.read!("test/fixtures/mastodon-post-activity.json")
 254         |> Poison.decode!()
 255
 256       assert {:ok, job} = Federator.incoming_ap_doc(params)
 257       assert :error = ObanHelpers.perform(job)
 258     end
 259   end
 260 end