CommonAPI: Standardize visibility error, use helper function if possible

This commit is contained in:
Phantasm 2025-12-12 18:05:58 +01:00
commit 49a5630c75
No known key found for this signature in database
GPG key ID: 2669E588BCC634C8
3 changed files with 18 additions and 17 deletions

View file

@ -269,7 +269,7 @@ defmodule Pleroma.Web.CommonAPI do
defp favorite_helper(user, id) do defp favorite_helper(user, id) do
with {_, %Activity{object: object}} <- {:find_object, Activity.get_by_id_with_object(id)}, with {_, %Activity{object: object}} <- {:find_object, Activity.get_by_id_with_object(id)},
{_, true} <- {:visible, Visibility.visible_for_user?(object, user)}, {_, true} <- {:visibility_error, activity_visible_to_actor(object, user)},
{_, {:ok, like_object, meta}} <- {:build_object, Builder.like(user, object)}, {_, {:ok, like_object, meta}} <- {:build_object, Builder.like(user, object)},
{_, {:ok, %Activity{} = activity, _meta}} <- {_, {:ok, %Activity{} = activity, _meta}} <-
{:common_pipeline, {:common_pipeline,
@ -279,7 +279,7 @@ defmodule Pleroma.Web.CommonAPI do
{:find_object, _} -> {:find_object, _} ->
{:error, :not_found} {:error, :not_found}
{:visible, _} -> {:visibility_error, _} ->
{:error, :not_found} {:error, :not_found}
{:common_pipeline, {:error, {:validate, {:error, changeset}}}} = e -> {:common_pipeline, {:error, {:validate, {:error, changeset}}}} = e ->
@ -300,7 +300,7 @@ defmodule Pleroma.Web.CommonAPI do
with {_, %Activity{data: %{"type" => "Create"}} = activity} <- with {_, %Activity{data: %{"type" => "Create"}} = activity} <-
{:find_activity, Activity.get_by_id(id)}, {:find_activity, Activity.get_by_id(id)},
%Object{} = note <- Object.normalize(activity, fetch: false), %Object{} = note <- Object.normalize(activity, fetch: false),
{_, true} <- {:visibility, activity_visible_to_actor(note, user)}, {_, true} <- {:visibility_error, activity_visible_to_actor(note, user)},
%Activity{} = like <- Utils.get_existing_like(user.ap_id, note), %Activity{} = like <- Utils.get_existing_like(user.ap_id, note),
{_, {:ok, _}} <- {:cancel_jobs, maybe_cancel_jobs(like)}, {_, {:ok, _}} <- {:cancel_jobs, maybe_cancel_jobs(like)},
{:ok, undo, _} <- Builder.undo(user, like), {:ok, undo, _} <- Builder.undo(user, like),
@ -308,7 +308,7 @@ defmodule Pleroma.Web.CommonAPI do
{:ok, activity} {:ok, activity}
else else
{:find_activity, _} -> {:error, :not_found} {:find_activity, _} -> {:error, :not_found}
{:visibility, _} -> {:error, :not_found} {:visibility_error, _} -> {:error, :not_found}
_ -> {:error, dgettext("errors", "Could not unfavorite")} _ -> {:error, dgettext("errors", "Could not unfavorite")}
end end
end end
@ -317,13 +317,13 @@ defmodule Pleroma.Web.CommonAPI do
{:ok, Activity.t()} | {:error, String.t()} {:ok, Activity.t()} | {:error, String.t()}
def react_with_emoji(id, user, emoji) do def react_with_emoji(id, user, emoji) do
with %Activity{} = activity <- Activity.get_by_id(id), with %Activity{} = activity <- Activity.get_by_id(id),
{_, true} <- {:visible, Visibility.visible_for_user?(activity, user)}, {_, true} <- {:visibility_error, activity_visible_to_actor(activity, user)},
object <- Object.normalize(activity, fetch: false), object <- Object.normalize(activity, fetch: false),
{:ok, emoji_react, _} <- Builder.emoji_react(user, object, emoji), {:ok, emoji_react, _} <- Builder.emoji_react(user, object, emoji),
{:ok, activity, _} <- Pipeline.common_pipeline(emoji_react, local: true) do {:ok, activity, _} <- Pipeline.common_pipeline(emoji_react, local: true) do
{:ok, activity} {:ok, activity}
else else
{:visible, _} -> {:visibility_error, _} ->
{:error, :not_found} {:error, :not_found}
_ -> _ ->
@ -586,7 +586,7 @@ defmodule Pleroma.Web.CommonAPI do
def add_mute(activity, user, params \\ %{}) do def add_mute(activity, user, params \\ %{}) do
expires_in = Map.get(params, :expires_in, 0) expires_in = Map.get(params, :expires_in, 0)
with true <- Visibility.visible_for_user?(activity, user), with true <- activity_visible_to_actor(activity, user),
{:ok, _} <- ThreadMute.add_mute(user.id, activity.data["context"]), {:ok, _} <- ThreadMute.add_mute(user.id, activity.data["context"]),
_ <- Pleroma.Notification.mark_context_as_read(user, activity.data["context"]) do _ <- Pleroma.Notification.mark_context_as_read(user, activity.data["context"]) do
if expires_in > 0 do if expires_in > 0 do
@ -599,18 +599,19 @@ defmodule Pleroma.Web.CommonAPI do
{:ok, activity} {:ok, activity}
else else
{:error, :visibility_error} -> {:error, :visibility_error}
{:error, _} -> {:error, dgettext("errors", "conversation is already muted")} {:error, _} -> {:error, dgettext("errors", "conversation is already muted")}
false -> {:error, :visibility_error}
end end
end end
@spec remove_mute(Activity.t(), User.t()) :: {:ok, Activity.t()} | {:error, any()} @spec remove_mute(Activity.t(), User.t()) :: {:ok, Activity.t()} | {:error, any()}
def remove_mute(%Activity{} = activity, %User{} = user) do def remove_mute(%Activity{} = activity, %User{} = user) do
if Visibility.visible_for_user?(activity, user) do case activity_visible_to_actor(activity, user) do
ThreadMute.remove_mute(user.id, activity.data["context"]) true ->
{:ok, activity} ThreadMute.remove_mute(user.id, activity.data["context"])
else {:ok, activity}
{:error, :visibility_error} error ->
error
end end
end end
@ -655,7 +656,7 @@ defmodule Pleroma.Web.CommonAPI do
}) })
else else
false -> false ->
{:error, :visibility} {:error, :visibility_error}
error -> error ->
error error

View file

@ -17,7 +17,7 @@ defmodule Pleroma.Web.MastodonAPI.ReportController do
with {:ok, activity} <- Pleroma.Web.CommonAPI.report(user, params) do with {:ok, activity} <- Pleroma.Web.CommonAPI.report(user, params) do
render(conn, "show.json", activity: activity) render(conn, "show.json", activity: activity)
else else
{:error, :visibility} -> {:error, :visibility_error} ->
{:error, :not_found, "Record not found"} {:error, :not_found, "Record not found"}
error -> error ->

View file

@ -1301,7 +1301,7 @@ defmodule Pleroma.Web.CommonAPITest do
status_ids: [post.id] status_ids: [post.id]
} }
assert {:error, :visibility} = CommonAPI.report(reporter, report_data) assert {:error, :visibility_error} = CommonAPI.report(reporter, report_data)
end end
test "doesn't create a report when some posts are not visible to user" do test "doesn't create a report when some posts are not visible to user" do
@ -1324,7 +1324,7 @@ defmodule Pleroma.Web.CommonAPITest do
status_ids: [visible_activity.id, invisibile_activity.id] status_ids: [visible_activity.id, invisibile_activity.id]
} }
assert {:error, :visibility} = CommonAPI.report(reporter, report_data_partial) assert {:error, :visibility_error} = CommonAPI.report(reporter, report_data_partial)
end end
test "updates report state" do test "updates report state" do