# Pleroma: A lightweight social networking server # Copyright © 2017-2018 Pleroma Authors <https://pleroma.social/> # SPDX-License-Identifier: AGPL-3.0-only defmodule Mix.Tasks.Pleroma.RelayTest do alias Pleroma.Activity alias Pleroma.User alias Pleroma.Web.ActivityPub.ActivityPub alias Pleroma.Web.ActivityPub.Relay alias Pleroma.Web.ActivityPub.Utils use Pleroma.DataCase setup_all do Tesla.Mock.mock_global(fn env -> apply(HttpRequestMock, :request, [env]) end) Mix.shell(Mix.Shell.Process) on_exit(fn -> Mix.shell(Mix.Shell.IO) end) :ok end describe "running follow" do test "relay is followed" do target_instance = "http://mastodon.example.org/users/admin" Mix.Tasks.Pleroma.Relay.run(["follow", target_instance]) local_user = Relay.get_actor() assert local_user.ap_id =~ "/relay" target_user = User.get_cached_by_ap_id(target_instance) refute target_user.local activity = Utils.fetch_latest_follow(local_user, target_user) assert activity.data["type"] == "Follow" assert activity.data["actor"] == local_user.ap_id assert activity.data["object"] == target_user.ap_id end end describe "running unfollow" do test "relay is unfollowed" do target_instance = "http://mastodon.example.org/users/admin" Mix.Tasks.Pleroma.Relay.run(["follow", target_instance]) %User{ap_id: follower_id} = local_user = Relay.get_actor() target_user = User.get_cached_by_ap_id(target_instance) follow_activity = Utils.fetch_latest_follow(local_user, target_user) User.follow(local_user, target_user) assert "#{target_instance}/followers" in refresh_record(local_user).following Mix.Tasks.Pleroma.Relay.run(["unfollow", target_instance]) cancelled_activity = Activity.get_by_ap_id(follow_activity.data["id"]) assert cancelled_activity.data["state"] == "cancelled" [undo_activity] = ActivityPub.fetch_activities([], %{ "type" => "Undo", "actor_id" => follower_id, "limit" => 1, "skip_preload" => true }) assert undo_activity.data["type"] == "Undo" assert undo_activity.data["actor"] == local_user.ap_id assert undo_activity.data["object"] == cancelled_activity.data refute "#{target_instance}/followers" in refresh_record(local_user).following end end describe "mix pleroma.relay list" do test "Prints relay subscription list" do :ok = Mix.Tasks.Pleroma.Relay.run(["list"]) refute_receive {:mix_shell, :info, _} Pleroma.Web.ActivityPub.Relay.get_actor() |> Ecto.Changeset.change( following: [ "http://test-app.com/user/test1", "http://test-app.com/user/test1", "http://test-app-42.com/user/test1" ] ) |> Pleroma.User.update_and_set_cache() :ok = Mix.Tasks.Pleroma.Relay.run(["list"]) assert_receive {:mix_shell, :info, ["test-app.com"]} assert_receive {:mix_shell, :info, ["test-app-42.com"]} end end end