end
def get(%User{} = follower, %User{} = following) do
- __MODULE__
- |> where(follower_id: ^follower.id, following_id: ^following.id)
- |> Repo.one()
+ following_relationship =
+ __MODULE__
+ |> where(follower_id: ^follower.id, following_id: ^following.id)
+ |> Repo.one()
+
+ case {following_relationship, following.local} do
+ {nil, false} ->
+ case Pleroma.Web.ActivityPub.Utils.fetch_latest_follow(follower, following) do
+ %{data: %{"state" => state}} when state in ["pending", "accept"] ->
+ %{state: state}
+
+ _ ->
+ nil
+ end
+
+ {following_relationship, _} ->
+ following_relationship
+ end
end
def update(follower, following, "reject"), do: unfollow(follower, following)
def unfollow(%User{} = follower, %User{} = following) do
case get(follower, following) do
- nil -> {:ok, nil}
%__MODULE__{} = following_relationship -> Repo.delete(following_relationship)
+ _ -> {:ok, nil}
end
end
refute User.subscribed_to?(follower, followed)
end
- test "cancels a pending follow" do
+ test "cancels a pending follow for a local user" do
follower = insert(:user)
followed = insert(:user, locked: true)
}
} = Pleroma.Web.ActivityPub.Utils.fetch_latest_undo(follower)
end
+
+ test "cancels a pending follow for a remote user" do
+ follower = insert(:user)
+ followed = insert(:user, locked: true, local: false, ap_enabled: true)
+
+ assert {:ok, follower, followed, %{id: activity_id, data: %{"state" => "pending"}}} =
+ CommonAPI.follow(follower, followed)
+
+ assert %{state: "pending"} = Pleroma.FollowingRelationship.get(follower, followed)
+
+ assert {:ok, follower} = CommonAPI.unfollow(follower, followed)
+
+ assert Pleroma.FollowingRelationship.get(follower, followed) == nil
+
+ assert %{id: ^activity_id, data: %{"state" => "cancelled"}} =
+ Pleroma.Web.ActivityPub.Utils.fetch_latest_follow(follower, followed)
+
+ assert %{
+ data: %{
+ "type" => "Undo",
+ "object" => %{"type" => "Follow", "state" => "cancelled"}
+ }
+ } = Pleroma.Web.ActivityPub.Utils.fetch_latest_undo(follower)
+ end
end
describe "accept_follow_request/2" do