diff options
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/mix/tasks/pleroma/relay.ex | 2 | ||||
| -rw-r--r-- | lib/pleroma/activity.ex | 7 | ||||
| -rw-r--r-- | lib/pleroma/web/activity_pub/relay.ex | 19 | 
3 files changed, 24 insertions, 4 deletions
diff --git a/lib/mix/tasks/pleroma/relay.ex b/lib/mix/tasks/pleroma/relay.ex index 7ef5f9678..b0fadeae9 100644 --- a/lib/mix/tasks/pleroma/relay.ex +++ b/lib/mix/tasks/pleroma/relay.ex @@ -35,7 +35,7 @@ defmodule Mix.Tasks.Pleroma.Relay do    def run(["list"]) do      start_pleroma() -    with {:ok, list} <- Relay.list() do +    with {:ok, list} <- Relay.list(true) do        list |> Enum.each(&shell_info(&1))      else        {:error, e} -> shell_error("Error while fetching relay subscription list: #{inspect(e)}") diff --git a/lib/pleroma/activity.ex b/lib/pleroma/activity.ex index 397eb6e3f..6ca05f74e 100644 --- a/lib/pleroma/activity.ex +++ b/lib/pleroma/activity.ex @@ -308,6 +308,13 @@ defmodule Pleroma.Activity do      |> where([a], fragment("? ->> 'state' = 'pending'", a.data))    end +  def following_requests_for_actor(%Pleroma.User{ap_id: ap_id}) do +    Queries.by_type("Follow") +    |> where([a], fragment("?->>'state' = 'pending'", a.data)) +    |> where([a], a.actor == ^ap_id) +    |> Repo.all() +  end +    def restrict_deactivated_users(query) do      deactivated_users =        from(u in User.Query.build(%{deactivated: true}), select: u.ap_id) diff --git a/lib/pleroma/web/activity_pub/relay.ex b/lib/pleroma/web/activity_pub/relay.ex index bb5542c89..729c23af7 100644 --- a/lib/pleroma/web/activity_pub/relay.ex +++ b/lib/pleroma/web/activity_pub/relay.ex @@ -60,15 +60,28 @@ defmodule Pleroma.Web.ActivityPub.Relay do    def publish(_), do: {:error, "Not implemented"} -  @spec list() :: {:ok, [String.t()]} | {:error, any()} -  def list do +  @spec list(boolean()) :: {:ok, [String.t()]} | {:error, any()} +  def list(with_not_accepted \\ false) do      with %User{} = user <- get_actor() do -      list = +      accepted =          user          |> User.following()          |> Enum.map(fn entry -> URI.parse(entry).host end)          |> Enum.uniq() +      list = +        if with_not_accepted do +          without_accept = +            user +            |> Pleroma.Activity.following_requests_for_actor() +            |> Enum.map(fn a -> URI.parse(a.data["object"]).host <> " (no Accept received)" end) +            |> Enum.uniq() + +          accepted ++ without_accept +        else +          accepted +        end +        {:ok, list}      else        error -> format_error(error)  | 
