pleroma

follow_handling_test.exs (6882B)

# Pleroma: A lightweight social networking server
# Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
# SPDX-License-Identifier: AGPL-3.0-only
defmodule Pleroma.Web.ActivityPub.Transmogrifier.FollowHandlingTest do
  use Pleroma.DataCase
  alias Pleroma.Activity
  alias Pleroma.Notification
  alias Pleroma.Repo
  alias Pleroma.User
  alias Pleroma.Web.ActivityPub.Transmogrifier
  alias Pleroma.Web.ActivityPub.Utils
  import Pleroma.Factory
  import Ecto.Query
  import Mock
  setup_all do
    Tesla.Mock.mock_global(fn env -> apply(HttpRequestMock, :request, [env]) end)
    :ok
  end
  describe "handle_incoming" do
    setup do: clear_config([:user, :deny_follow_blocked])
    test "it works for osada follow request" do
      user = insert(:user)
      data =
        File.read!("test/fixtures/osada-follow-activity.json")
        |> Jason.decode!()
        |> Map.put("object", user.ap_id)
      {:ok, %Activity{data: data, local: false} = activity} = Transmogrifier.handle_incoming(data)
      assert data["actor"] == "https://apfed.club/channel/indio"
      assert data["type"] == "Follow"
      assert data["id"] == "https://apfed.club/follow/9"
      activity = Repo.get(Activity, activity.id)
      assert activity.data["state"] == "accept"
      assert User.following?(User.get_cached_by_ap_id(data["actor"]), user)
    end
    test "it works for incoming follow requests" do
      user = insert(:user)
      data =
        File.read!("test/fixtures/mastodon-follow-activity.json")
        |> Jason.decode!()
        |> Map.put("object", user.ap_id)
      {:ok, %Activity{data: data, local: false} = activity} = Transmogrifier.handle_incoming(data)
      assert data["actor"] == "http://mastodon.example.org/users/admin"
      assert data["type"] == "Follow"
      assert data["id"] == "http://mastodon.example.org/users/admin#follows/2"
      activity = Repo.get(Activity, activity.id)
      assert activity.data["state"] == "accept"
      assert User.following?(User.get_cached_by_ap_id(data["actor"]), user)
      [notification] = Notification.for_user(user)
      assert notification.type == "follow"
    end
    test "with locked accounts, it does create a Follow, but not an Accept" do
      user = insert(:user, is_locked: true)
      data =
        File.read!("test/fixtures/mastodon-follow-activity.json")
        |> Jason.decode!()
        |> Map.put("object", user.ap_id)
      {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)
      assert data["state"] == "pending"
      refute User.following?(User.get_cached_by_ap_id(data["actor"]), user)
      accepts =
        from(
          a in Activity,
          where: fragment("?->>'type' = ?", a.data, "Accept")
        )
        |> Repo.all()
      assert Enum.empty?(accepts)
      [notification] = Notification.for_user(user)
      assert notification.type == "follow_request"
    end
    test "it works for follow requests when you are already followed, creating a new accept activity" do
      # This is important because the remote might have the wrong idea about the
      # current follow status. This can lead to instance A thinking that x@A is
      # followed by y@B, but B thinks they are not. In this case, the follow can
      # never go through again because it will never get an Accept.
      user = insert(:user)
      data =
        File.read!("test/fixtures/mastodon-follow-activity.json")
        |> Jason.decode!()
        |> Map.put("object", user.ap_id)
      {:ok, %Activity{local: false}} = Transmogrifier.handle_incoming(data)
      accepts =
        from(
          a in Activity,
          where: fragment("?->>'type' = ?", a.data, "Accept")
        )
        |> Repo.all()
      assert length(accepts) == 1
      data =
        File.read!("test/fixtures/mastodon-follow-activity.json")
        |> Jason.decode!()
        |> Map.put("id", String.replace(data["id"], "2", "3"))
        |> Map.put("object", user.ap_id)
      {:ok, %Activity{local: false}} = Transmogrifier.handle_incoming(data)
      accepts =
        from(
          a in Activity,
          where: fragment("?->>'type' = ?", a.data, "Accept")
        )
        |> Repo.all()
      assert length(accepts) == 2
    end
    test "it rejects incoming follow requests from blocked users when deny_follow_blocked is enabled" do
      clear_config([:user, :deny_follow_blocked], true)
      user = insert(:user)
      {:ok, target} = User.get_or_fetch("http://mastodon.example.org/users/admin")
      {:ok, _user_relationship} = User.block(user, target)
      data =
        File.read!("test/fixtures/mastodon-follow-activity.json")
        |> Jason.decode!()
        |> Map.put("object", user.ap_id)
      {:ok, %Activity{data: %{"id" => id}}} = Transmogrifier.handle_incoming(data)
      %Activity{} = activity = Activity.get_by_ap_id(id)
      assert activity.data["state"] == "reject"
    end
    test "it rejects incoming follow requests if the following errors for some reason" do
      user = insert(:user)
      data =
        File.read!("test/fixtures/mastodon-follow-activity.json")
        |> Jason.decode!()
        |> Map.put("object", user.ap_id)
      with_mock Pleroma.User, [:passthrough], follow: fn _, _, _ -> {:error, :testing} end do
        {:ok, %Activity{data: %{"id" => id}}} = Transmogrifier.handle_incoming(data)
        %Activity{} = activity = Activity.get_by_ap_id(id)
        assert activity.data["state"] == "reject"
      end
    end
    test "it works for incoming follow requests from hubzilla" do
      user = insert(:user)
      data =
        File.read!("test/fixtures/hubzilla-follow-activity.json")
        |> Jason.decode!()
        |> Map.put("object", user.ap_id)
        |> Utils.normalize_params()
      {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)
      assert data["actor"] == "https://hubzilla.example.org/channel/kaniini"
      assert data["type"] == "Follow"
      assert data["id"] == "https://hubzilla.example.org/channel/kaniini#follows/2"
      assert User.following?(User.get_cached_by_ap_id(data["actor"]), user)
    end
    test "it works for incoming follows to locked account" do
      pending_follower = insert(:user, ap_id: "http://mastodon.example.org/users/admin")
      user = insert(:user, is_locked: true)
      data =
        File.read!("test/fixtures/mastodon-follow-activity.json")
        |> Jason.decode!()
        |> Map.put("object", user.ap_id)
      {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)
      assert data["type"] == "Follow"
      assert data["object"] == user.ap_id
      assert data["state"] == "pending"
      assert data["actor"] == "http://mastodon.example.org/users/admin"
      assert [^pending_follower] = User.get_follow_requests(user)
    end
  end
end