254 lines
8.1 KiB
Elixir
254 lines
8.1 KiB
Elixir
defmodule Mobilizon.Federation.ActivityPub.Transmogrifier.FollowTest do
|
|
use Mobilizon.DataCase
|
|
import Mox
|
|
import ExUnit.CaptureLog
|
|
import Mobilizon.Factory
|
|
alias Mobilizon.Actors
|
|
alias Mobilizon.Actors.Follower
|
|
alias Mobilizon.Federation.ActivityPub.{Actions, Activity, Transmogrifier}
|
|
alias Mobilizon.Service.HTTP.ActivityPub.Mock
|
|
|
|
describe "handle incoming follow requests" do
|
|
test "it works only for groups" do
|
|
actor = insert(:actor)
|
|
|
|
actor_data =
|
|
File.read!("test/fixtures/mastodon-actor.json")
|
|
|> Jason.decode!()
|
|
|
|
Mock
|
|
|> expect(:call, fn
|
|
%{method: :get, url: "https://social.tcit.fr/users/tcit"}, _opts ->
|
|
{:ok,
|
|
%Tesla.Env{
|
|
status: 200,
|
|
body: Map.put(actor_data, "id", "https://social.tcit.fr/users/tcit")
|
|
}}
|
|
end)
|
|
|
|
data =
|
|
File.read!("test/fixtures/mastodon-follow-activity.json")
|
|
|> Jason.decode!()
|
|
|> Map.put("object", actor.url)
|
|
|
|
assert capture_log(fn ->
|
|
:error = Transmogrifier.handle_incoming(data)
|
|
end) =~ "Only group and instances can be followed"
|
|
|
|
actor = Actors.get_actor_with_preload(actor.id)
|
|
refute Actors.check_follow(Actors.get_actor_by_url!(data["actor"], true), actor)
|
|
end
|
|
|
|
test "it works for incoming follow requests" do
|
|
actor = insert(:group)
|
|
|
|
actor_data =
|
|
File.read!("test/fixtures/mastodon-actor.json")
|
|
|> Jason.decode!()
|
|
|
|
Mock
|
|
|> expect(:call, fn
|
|
%{method: :get, url: "https://social.tcit.fr/users/tcit"}, _opts ->
|
|
{:ok,
|
|
%Tesla.Env{
|
|
status: 200,
|
|
body: Map.put(actor_data, "id", "https://social.tcit.fr/users/tcit")
|
|
}}
|
|
end)
|
|
|
|
data =
|
|
File.read!("test/fixtures/mastodon-follow-activity.json")
|
|
|> Jason.decode!()
|
|
|> Map.put("object", actor.url)
|
|
|
|
{:ok, %Activity{data: data, local: false}, _} = Transmogrifier.handle_incoming(data)
|
|
|
|
assert data["actor"] == "https://social.tcit.fr/users/tcit"
|
|
assert data["type"] == "Follow"
|
|
assert data["id"] == "https://social.tcit.fr/users/tcit#follows/2"
|
|
|
|
actor = Actors.get_actor_with_preload(actor.id)
|
|
assert Actors.check_follow(Actors.get_actor_by_url!(data["actor"], true), actor)
|
|
end
|
|
|
|
test "it rejects activities without a valid ID" do
|
|
actor = insert(:group)
|
|
|
|
data =
|
|
File.read!("test/fixtures/mastodon-follow-activity.json")
|
|
|> Jason.decode!()
|
|
|> Map.put("object", actor.url)
|
|
|> Map.put("id", "")
|
|
|
|
:error = Transmogrifier.handle_incoming(data)
|
|
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.check_follow(User.get_by_ap_id(data["actor"]), user)
|
|
# end
|
|
end
|
|
|
|
describe "handle incoming follow accept activities" do
|
|
test "it works for incoming accepts" do
|
|
follower = insert(:actor)
|
|
followed = insert(:group, manually_approves_followers: false)
|
|
|
|
refute Actors.check_follow(follower, followed)
|
|
|
|
{:ok, follow_activity, _} = Actions.Follow.follow(follower, followed)
|
|
assert Actors.check_follow(follower, followed)
|
|
|
|
follow_object_id = follow_activity.data["id"]
|
|
|
|
assert %Follower{} = Actors.get_follower_by_url(follow_object_id)
|
|
|
|
accept_data =
|
|
File.read!("test/fixtures/mastodon-accept-activity.json")
|
|
|> Jason.decode!()
|
|
|> Map.put("actor", followed.url)
|
|
|
|
object =
|
|
accept_data["object"]
|
|
|> Map.put("actor", follower.url)
|
|
|> Map.put("id", follow_object_id)
|
|
|
|
accept_data = Map.put(accept_data, "object", object)
|
|
|
|
:error = Transmogrifier.handle_incoming(accept_data)
|
|
|
|
{:ok, follower} = Actors.get_actor_by_url(follower.url)
|
|
|
|
assert Actors.check_follow(follower, followed)
|
|
end
|
|
|
|
test "it works for incoming accepts which were pre-accepted" do
|
|
follower = insert(:actor)
|
|
followed = insert(:group, manually_approves_followers: true)
|
|
|
|
refute Actors.check_follow(follower, followed)
|
|
|
|
{:ok, follow_activity, _} = Actions.Follow.follow(follower, followed)
|
|
assert Actors.check_follow(follower, followed)
|
|
|
|
follow_object_id = follow_activity.data["id"]
|
|
|
|
assert %Follower{} = Actors.get_follower_by_url(follow_object_id)
|
|
|
|
accept_data =
|
|
File.read!("test/fixtures/mastodon-accept-activity.json")
|
|
|> Jason.decode!()
|
|
|> Map.put("actor", followed.url)
|
|
|
|
object =
|
|
accept_data["object"]
|
|
|> Map.put("actor", follower.url)
|
|
|> Map.put("id", follow_object_id)
|
|
|
|
accept_data = Map.put(accept_data, "object", object)
|
|
|
|
{:ok, activity, _} = Transmogrifier.handle_incoming(accept_data)
|
|
refute activity.local
|
|
|
|
assert activity.data["object"]["id"] == follow_activity.data["id"]
|
|
|
|
{:ok, follower} = Actors.get_actor_by_url(follower.url)
|
|
|
|
assert Actors.check_follow(follower, followed)
|
|
end
|
|
|
|
test "it works for incoming accepts which are referenced by IRI only" do
|
|
follower = insert(:actor)
|
|
followed = insert(:group, manually_approves_followers: true)
|
|
|
|
{:ok, follow_activity, _} = Actions.Follow.follow(follower, followed)
|
|
|
|
accept_data =
|
|
File.read!("test/fixtures/mastodon-accept-activity.json")
|
|
|> Jason.decode!()
|
|
|> Map.put("actor", followed.url)
|
|
|> Map.put("object", follow_activity.data["id"])
|
|
|
|
{:ok, activity, _} = Transmogrifier.handle_incoming(accept_data)
|
|
assert activity.data["object"]["id"] == follow_activity.data["id"]
|
|
assert activity.data["object"]["id"] =~ "/follow/"
|
|
assert activity.data["id"] =~ "/accept/follow/"
|
|
|
|
{:ok, follower} = Actors.get_actor_by_url(follower.url)
|
|
|
|
assert Actors.check_follow(follower, followed)
|
|
end
|
|
|
|
test "it fails for incoming accepts which cannot be correlated" do
|
|
follower = insert(:actor)
|
|
followed = insert(:group)
|
|
|
|
accept_data =
|
|
File.read!("test/fixtures/mastodon-accept-activity.json")
|
|
|> Jason.decode!()
|
|
|> Map.put("actor", followed.url)
|
|
|
|
accept_data =
|
|
Map.put(accept_data, "object", Map.put(accept_data["object"], "actor", follower.url))
|
|
|
|
:error = Transmogrifier.handle_incoming(accept_data)
|
|
|
|
{:ok, follower} = Actors.get_actor_by_url(follower.url)
|
|
|
|
refute Actors.check_follow(follower, followed)
|
|
end
|
|
end
|
|
|
|
describe "handle incoming follow reject activities" do
|
|
test "it fails for incoming rejects which cannot be correlated" do
|
|
follower = insert(:actor)
|
|
followed = insert(:group)
|
|
|
|
accept_data =
|
|
File.read!("test/fixtures/mastodon-reject-activity.json")
|
|
|> Jason.decode!()
|
|
|> Map.put("actor", followed.url)
|
|
|
|
accept_data =
|
|
Map.put(accept_data, "object", Map.put(accept_data["object"], "actor", follower.url))
|
|
|
|
:error = Transmogrifier.handle_incoming(accept_data)
|
|
|
|
{:ok, follower} = Actors.get_actor_by_url(follower.url)
|
|
|
|
refute Actors.check_follow(follower, followed)
|
|
end
|
|
|
|
test "it works for incoming rejects which are referenced by IRI only" do
|
|
follower = insert(:actor)
|
|
followed = insert(:group)
|
|
|
|
{:ok, follow_activity, _} = Actions.Follow.follow(follower, followed)
|
|
|
|
assert Actors.check_follow(follower, followed)
|
|
|
|
reject_data =
|
|
File.read!("test/fixtures/mastodon-reject-activity.json")
|
|
|> Jason.decode!()
|
|
|> Map.put("actor", followed.url)
|
|
|> Map.put("object", follow_activity.data["id"])
|
|
|
|
{:ok, %Activity{data: _}, _} = Transmogrifier.handle_incoming(reject_data)
|
|
|
|
refute Actors.check_follow(follower, followed)
|
|
end
|
|
end
|
|
end
|