forked from AkkomaGang/akkoma
removing grouped reports admin api endpoint
This commit is contained in:
parent
e999c67cee
commit
b607ae1a1c
5 changed files with 1 additions and 335 deletions
|
@ -795,102 +795,6 @@ def get_reports(params, page, page_size) do
|
||||||
ActivityPub.fetch_activities([], params, :offset)
|
ActivityPub.fetch_activities([], params, :offset)
|
||||||
end
|
end
|
||||||
|
|
||||||
def parse_report_group(activity) do
|
|
||||||
reports = get_reports_by_status_id(activity["id"])
|
|
||||||
max_date = Enum.max_by(reports, &NaiveDateTime.from_iso8601!(&1.data["published"]))
|
|
||||||
actors = Enum.map(reports, & &1.user_actor)
|
|
||||||
[%{data: %{"object" => [account_id | _]}} | _] = reports
|
|
||||||
|
|
||||||
account =
|
|
||||||
AccountView.render("show.json", %{
|
|
||||||
user: User.get_by_ap_id(account_id)
|
|
||||||
})
|
|
||||||
|
|
||||||
status = get_status_data(activity)
|
|
||||||
|
|
||||||
%{
|
|
||||||
date: max_date.data["published"],
|
|
||||||
account: account,
|
|
||||||
status: status,
|
|
||||||
actors: Enum.uniq(actors),
|
|
||||||
reports: reports
|
|
||||||
}
|
|
||||||
end
|
|
||||||
|
|
||||||
defp get_status_data(status) do
|
|
||||||
case status["deleted"] do
|
|
||||||
true ->
|
|
||||||
%{
|
|
||||||
"id" => status["id"],
|
|
||||||
"deleted" => true
|
|
||||||
}
|
|
||||||
|
|
||||||
_ ->
|
|
||||||
Activity.get_by_ap_id(status["id"])
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
def get_reports_by_status_id(ap_id) do
|
|
||||||
from(a in Activity,
|
|
||||||
where: fragment("(?)->>'type' = 'Flag'", a.data),
|
|
||||||
where: fragment("(?)->'object' @> ?", a.data, ^[%{id: ap_id}]),
|
|
||||||
or_where: fragment("(?)->'object' @> ?", a.data, ^[ap_id])
|
|
||||||
)
|
|
||||||
|> Activity.with_preloaded_user_actor()
|
|
||||||
|> Repo.all()
|
|
||||||
end
|
|
||||||
|
|
||||||
@spec get_reports_grouped_by_status([String.t()]) :: %{
|
|
||||||
required(:groups) => [
|
|
||||||
%{
|
|
||||||
required(:date) => String.t(),
|
|
||||||
required(:account) => %{},
|
|
||||||
required(:status) => %{},
|
|
||||||
required(:actors) => [%User{}],
|
|
||||||
required(:reports) => [%Activity{}]
|
|
||||||
}
|
|
||||||
]
|
|
||||||
}
|
|
||||||
def get_reports_grouped_by_status(activity_ids) do
|
|
||||||
parsed_groups =
|
|
||||||
activity_ids
|
|
||||||
|> Enum.map(fn id ->
|
|
||||||
id
|
|
||||||
|> build_flag_object()
|
|
||||||
|> parse_report_group()
|
|
||||||
end)
|
|
||||||
|
|
||||||
%{
|
|
||||||
groups: parsed_groups
|
|
||||||
}
|
|
||||||
end
|
|
||||||
|
|
||||||
@spec get_reported_activities() :: [
|
|
||||||
%{
|
|
||||||
required(:activity) => String.t(),
|
|
||||||
required(:date) => String.t()
|
|
||||||
}
|
|
||||||
]
|
|
||||||
def get_reported_activities do
|
|
||||||
reported_activities_query =
|
|
||||||
from(a in Activity,
|
|
||||||
where: fragment("(?)->>'type' = 'Flag'", a.data),
|
|
||||||
select: %{
|
|
||||||
activity: fragment("jsonb_array_elements((? #- '{object,0}')->'object')", a.data)
|
|
||||||
},
|
|
||||||
group_by: fragment("activity")
|
|
||||||
)
|
|
||||||
|
|
||||||
from(a in subquery(reported_activities_query),
|
|
||||||
distinct: true,
|
|
||||||
select: %{
|
|
||||||
id: fragment("COALESCE(?->>'id'::text, ? #>> '{}')", a.activity, a.activity)
|
|
||||||
}
|
|
||||||
)
|
|
||||||
|> Repo.all()
|
|
||||||
|> Enum.map(& &1.id)
|
|
||||||
end
|
|
||||||
|
|
||||||
def update_report_state(%Activity{} = activity, state)
|
def update_report_state(%Activity{} = activity, state)
|
||||||
when state in @strip_status_report_states do
|
when state in @strip_status_report_states do
|
||||||
{:ok, stripped_activity} = strip_report_status_data(activity)
|
{:ok, stripped_activity} = strip_report_status_data(activity)
|
||||||
|
|
|
@ -715,14 +715,6 @@ def list_reports(conn, params) do
|
||||||
|> render("index.json", %{reports: reports})
|
|> render("index.json", %{reports: reports})
|
||||||
end
|
end
|
||||||
|
|
||||||
def list_grouped_reports(conn, _params) do
|
|
||||||
statuses = Utils.get_reported_activities()
|
|
||||||
|
|
||||||
conn
|
|
||||||
|> put_view(ReportView)
|
|
||||||
|> render("index_grouped.json", Utils.get_reports_grouped_by_status(statuses))
|
|
||||||
end
|
|
||||||
|
|
||||||
def report_show(conn, %{"id" => id}) do
|
def report_show(conn, %{"id" => id}) do
|
||||||
with %Activity{} = report <- Activity.get_by_id(id) do
|
with %Activity{} = report <- Activity.get_by_id(id) do
|
||||||
conn
|
conn
|
||||||
|
|
|
@ -4,7 +4,7 @@
|
||||||
|
|
||||||
defmodule Pleroma.Web.AdminAPI.ReportView do
|
defmodule Pleroma.Web.AdminAPI.ReportView do
|
||||||
use Pleroma.Web, :view
|
use Pleroma.Web, :view
|
||||||
alias Pleroma.Activity
|
|
||||||
alias Pleroma.HTML
|
alias Pleroma.HTML
|
||||||
alias Pleroma.User
|
alias Pleroma.User
|
||||||
alias Pleroma.Web.AdminAPI.Report
|
alias Pleroma.Web.AdminAPI.Report
|
||||||
|
@ -44,32 +44,6 @@ def render("show.json", %{report: report, user: user, account: account, statuses
|
||||||
}
|
}
|
||||||
end
|
end
|
||||||
|
|
||||||
def render("index_grouped.json", %{groups: groups}) do
|
|
||||||
reports =
|
|
||||||
Enum.map(groups, fn group ->
|
|
||||||
status =
|
|
||||||
case group.status do
|
|
||||||
%Activity{} = activity -> StatusView.render("show.json", %{activity: activity})
|
|
||||||
_ -> group.status
|
|
||||||
end
|
|
||||||
|
|
||||||
%{
|
|
||||||
date: group[:date],
|
|
||||||
account: group[:account],
|
|
||||||
status: Map.put_new(status, "deleted", false),
|
|
||||||
actors: Enum.map(group[:actors], &merge_account_views/1),
|
|
||||||
reports:
|
|
||||||
group[:reports]
|
|
||||||
|> Enum.map(&Report.extract_report_info(&1))
|
|
||||||
|> Enum.map(&render(__MODULE__, "show.json", &1))
|
|
||||||
}
|
|
||||||
end)
|
|
||||||
|
|
||||||
%{
|
|
||||||
reports: reports
|
|
||||||
}
|
|
||||||
end
|
|
||||||
|
|
||||||
def render("index_notes.json", %{notes: notes}) when is_list(notes) do
|
def render("index_notes.json", %{notes: notes}) when is_list(notes) do
|
||||||
Enum.map(notes, &render(__MODULE__, "show_note.json", &1))
|
Enum.map(notes, &render(__MODULE__, "show_note.json", &1))
|
||||||
end
|
end
|
||||||
|
|
|
@ -186,7 +186,6 @@ defmodule Pleroma.Web.Router do
|
||||||
patch("/users/resend_confirmation_email", AdminAPIController, :resend_confirmation_email)
|
patch("/users/resend_confirmation_email", AdminAPIController, :resend_confirmation_email)
|
||||||
|
|
||||||
get("/reports", AdminAPIController, :list_reports)
|
get("/reports", AdminAPIController, :list_reports)
|
||||||
get("/grouped_reports", AdminAPIController, :list_grouped_reports)
|
|
||||||
get("/reports/:id", AdminAPIController, :report_show)
|
get("/reports/:id", AdminAPIController, :report_show)
|
||||||
patch("/reports", AdminAPIController, :reports_update)
|
patch("/reports", AdminAPIController, :reports_update)
|
||||||
post("/reports/:id/notes", AdminAPIController, :report_notes_create)
|
post("/reports/:id/notes", AdminAPIController, :report_notes_create)
|
||||||
|
|
|
@ -21,7 +21,6 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do
|
||||||
alias Pleroma.UserInviteToken
|
alias Pleroma.UserInviteToken
|
||||||
alias Pleroma.Web.ActivityPub.Relay
|
alias Pleroma.Web.ActivityPub.Relay
|
||||||
alias Pleroma.Web.CommonAPI
|
alias Pleroma.Web.CommonAPI
|
||||||
alias Pleroma.Web.MastodonAPI.StatusView
|
|
||||||
alias Pleroma.Web.MediaProxy
|
alias Pleroma.Web.MediaProxy
|
||||||
|
|
||||||
setup_all do
|
setup_all do
|
||||||
|
@ -1586,208 +1585,6 @@ test "returns 403 when requested by anonymous" do
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
describe "GET /api/pleroma/admin/grouped_reports" do
|
|
||||||
setup do
|
|
||||||
[reporter, target_user] = insert_pair(:user)
|
|
||||||
|
|
||||||
date1 = (DateTime.to_unix(DateTime.utc_now()) + 1000) |> DateTime.from_unix!()
|
|
||||||
date2 = (DateTime.to_unix(DateTime.utc_now()) + 2000) |> DateTime.from_unix!()
|
|
||||||
date3 = (DateTime.to_unix(DateTime.utc_now()) + 3000) |> DateTime.from_unix!()
|
|
||||||
|
|
||||||
first_status =
|
|
||||||
insert(:note_activity, user: target_user, data_attrs: %{"published" => date1})
|
|
||||||
|
|
||||||
second_status =
|
|
||||||
insert(:note_activity, user: target_user, data_attrs: %{"published" => date2})
|
|
||||||
|
|
||||||
third_status =
|
|
||||||
insert(:note_activity, user: target_user, data_attrs: %{"published" => date3})
|
|
||||||
|
|
||||||
{:ok, first_report} =
|
|
||||||
CommonAPI.report(reporter, %{
|
|
||||||
"account_id" => target_user.id,
|
|
||||||
"status_ids" => [first_status.id, second_status.id, third_status.id]
|
|
||||||
})
|
|
||||||
|
|
||||||
{:ok, second_report} =
|
|
||||||
CommonAPI.report(reporter, %{
|
|
||||||
"account_id" => target_user.id,
|
|
||||||
"status_ids" => [first_status.id, second_status.id]
|
|
||||||
})
|
|
||||||
|
|
||||||
{:ok, third_report} =
|
|
||||||
CommonAPI.report(reporter, %{
|
|
||||||
"account_id" => target_user.id,
|
|
||||||
"status_ids" => [first_status.id]
|
|
||||||
})
|
|
||||||
|
|
||||||
%{
|
|
||||||
first_status: Activity.get_by_ap_id_with_object(first_status.data["id"]),
|
|
||||||
second_status: Activity.get_by_ap_id_with_object(second_status.data["id"]),
|
|
||||||
third_status: Activity.get_by_ap_id_with_object(third_status.data["id"]),
|
|
||||||
first_report: first_report,
|
|
||||||
first_status_reports: [first_report, second_report, third_report],
|
|
||||||
second_status_reports: [first_report, second_report],
|
|
||||||
third_status_reports: [first_report],
|
|
||||||
target_user: target_user,
|
|
||||||
reporter: reporter
|
|
||||||
}
|
|
||||||
end
|
|
||||||
|
|
||||||
test "returns reports grouped by status", %{
|
|
||||||
conn: conn,
|
|
||||||
first_status: first_status,
|
|
||||||
second_status: second_status,
|
|
||||||
third_status: third_status,
|
|
||||||
first_status_reports: first_status_reports,
|
|
||||||
second_status_reports: second_status_reports,
|
|
||||||
third_status_reports: third_status_reports,
|
|
||||||
target_user: target_user,
|
|
||||||
reporter: reporter
|
|
||||||
} do
|
|
||||||
response =
|
|
||||||
conn
|
|
||||||
|> get("/api/pleroma/admin/grouped_reports")
|
|
||||||
|> json_response(:ok)
|
|
||||||
|
|
||||||
assert length(response["reports"]) == 3
|
|
||||||
|
|
||||||
first_group = Enum.find(response["reports"], &(&1["status"]["id"] == first_status.id))
|
|
||||||
|
|
||||||
second_group = Enum.find(response["reports"], &(&1["status"]["id"] == second_status.id))
|
|
||||||
|
|
||||||
third_group = Enum.find(response["reports"], &(&1["status"]["id"] == third_status.id))
|
|
||||||
|
|
||||||
assert length(first_group["reports"]) == 3
|
|
||||||
assert length(second_group["reports"]) == 2
|
|
||||||
assert length(third_group["reports"]) == 1
|
|
||||||
|
|
||||||
assert first_group["date"] ==
|
|
||||||
Enum.max_by(first_status_reports, fn act ->
|
|
||||||
NaiveDateTime.from_iso8601!(act.data["published"])
|
|
||||||
end).data["published"]
|
|
||||||
|
|
||||||
assert first_group["status"] ==
|
|
||||||
Map.put(
|
|
||||||
stringify_keys(StatusView.render("show.json", %{activity: first_status})),
|
|
||||||
"deleted",
|
|
||||||
false
|
|
||||||
)
|
|
||||||
|
|
||||||
assert(first_group["account"]["id"] == target_user.id)
|
|
||||||
|
|
||||||
assert length(first_group["actors"]) == 1
|
|
||||||
assert hd(first_group["actors"])["id"] == reporter.id
|
|
||||||
|
|
||||||
assert Enum.map(first_group["reports"], & &1["id"]) --
|
|
||||||
Enum.map(first_status_reports, & &1.id) == []
|
|
||||||
|
|
||||||
assert second_group["date"] ==
|
|
||||||
Enum.max_by(second_status_reports, fn act ->
|
|
||||||
NaiveDateTime.from_iso8601!(act.data["published"])
|
|
||||||
end).data["published"]
|
|
||||||
|
|
||||||
assert second_group["status"] ==
|
|
||||||
Map.put(
|
|
||||||
stringify_keys(StatusView.render("show.json", %{activity: second_status})),
|
|
||||||
"deleted",
|
|
||||||
false
|
|
||||||
)
|
|
||||||
|
|
||||||
assert second_group["account"]["id"] == target_user.id
|
|
||||||
|
|
||||||
assert length(second_group["actors"]) == 1
|
|
||||||
assert hd(second_group["actors"])["id"] == reporter.id
|
|
||||||
|
|
||||||
assert Enum.map(second_group["reports"], & &1["id"]) --
|
|
||||||
Enum.map(second_status_reports, & &1.id) == []
|
|
||||||
|
|
||||||
assert third_group["date"] ==
|
|
||||||
Enum.max_by(third_status_reports, fn act ->
|
|
||||||
NaiveDateTime.from_iso8601!(act.data["published"])
|
|
||||||
end).data["published"]
|
|
||||||
|
|
||||||
assert third_group["status"] ==
|
|
||||||
Map.put(
|
|
||||||
stringify_keys(StatusView.render("show.json", %{activity: third_status})),
|
|
||||||
"deleted",
|
|
||||||
false
|
|
||||||
)
|
|
||||||
|
|
||||||
assert third_group["account"]["id"] == target_user.id
|
|
||||||
|
|
||||||
assert length(third_group["actors"]) == 1
|
|
||||||
assert hd(third_group["actors"])["id"] == reporter.id
|
|
||||||
|
|
||||||
assert Enum.map(third_group["reports"], & &1["id"]) --
|
|
||||||
Enum.map(third_status_reports, & &1.id) == []
|
|
||||||
end
|
|
||||||
|
|
||||||
test "reopened report renders status data", %{
|
|
||||||
conn: conn,
|
|
||||||
first_report: first_report,
|
|
||||||
first_status: first_status
|
|
||||||
} do
|
|
||||||
{:ok, _} = CommonAPI.update_report_state(first_report.id, "resolved")
|
|
||||||
|
|
||||||
response =
|
|
||||||
conn
|
|
||||||
|> get("/api/pleroma/admin/grouped_reports")
|
|
||||||
|> json_response(:ok)
|
|
||||||
|
|
||||||
first_group = Enum.find(response["reports"], &(&1["status"]["id"] == first_status.id))
|
|
||||||
|
|
||||||
assert first_group["status"] ==
|
|
||||||
Map.put(
|
|
||||||
stringify_keys(StatusView.render("show.json", %{activity: first_status})),
|
|
||||||
"deleted",
|
|
||||||
false
|
|
||||||
)
|
|
||||||
end
|
|
||||||
|
|
||||||
test "reopened report does not render status data if status has been deleted", %{
|
|
||||||
conn: conn,
|
|
||||||
first_report: first_report,
|
|
||||||
first_status: first_status,
|
|
||||||
target_user: target_user
|
|
||||||
} do
|
|
||||||
{:ok, _} = CommonAPI.update_report_state(first_report.id, "resolved")
|
|
||||||
{:ok, _} = CommonAPI.delete(first_status.id, target_user)
|
|
||||||
|
|
||||||
refute Activity.get_by_ap_id(first_status.id)
|
|
||||||
|
|
||||||
response =
|
|
||||||
conn
|
|
||||||
|> get("/api/pleroma/admin/grouped_reports")
|
|
||||||
|> json_response(:ok)
|
|
||||||
|
|
||||||
assert Enum.find(response["reports"], &(&1["status"]["deleted"] == true))["status"][
|
|
||||||
"deleted"
|
|
||||||
] == true
|
|
||||||
|
|
||||||
assert length(Enum.filter(response["reports"], &(&1["status"]["deleted"] == false))) == 2
|
|
||||||
end
|
|
||||||
|
|
||||||
test "account not empty if status was deleted", %{
|
|
||||||
conn: conn,
|
|
||||||
first_report: first_report,
|
|
||||||
first_status: first_status,
|
|
||||||
target_user: target_user
|
|
||||||
} do
|
|
||||||
{:ok, _} = CommonAPI.update_report_state(first_report.id, "resolved")
|
|
||||||
{:ok, _} = CommonAPI.delete(first_status.id, target_user)
|
|
||||||
|
|
||||||
refute Activity.get_by_ap_id(first_status.id)
|
|
||||||
|
|
||||||
response =
|
|
||||||
conn
|
|
||||||
|> get("/api/pleroma/admin/grouped_reports")
|
|
||||||
|> json_response(:ok)
|
|
||||||
|
|
||||||
assert Enum.find(response["reports"], &(&1["status"]["deleted"] == true))["account"]
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
describe "PUT /api/pleroma/admin/statuses/:id" do
|
describe "PUT /api/pleroma/admin/statuses/:id" do
|
||||||
setup do
|
setup do
|
||||||
activity = insert(:note_activity)
|
activity = insert(:note_activity)
|
||||||
|
|
Loading…
Reference in a new issue