1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.ModerationLog do
9 alias Pleroma.ModerationLog
15 schema "moderation_log" do
21 def get_all(params) do
24 |> maybe_filter_by_date(params)
25 |> maybe_filter_by_user(params)
26 |> maybe_filter_by_search(params)
28 query_with_pagination = base_query |> paginate_query(params)
31 items: Repo.all(query_with_pagination),
32 count: Repo.aggregate(base_query, :count, :id)
36 defp maybe_filter_by_date(query, %{start_date: nil, end_date: nil}), do: query
38 defp maybe_filter_by_date(query, %{start_date: start_date, end_date: nil}) do
40 where: q.inserted_at >= ^parse_datetime(start_date)
44 defp maybe_filter_by_date(query, %{start_date: nil, end_date: end_date}) do
46 where: q.inserted_at <= ^parse_datetime(end_date)
50 defp maybe_filter_by_date(query, %{start_date: start_date, end_date: end_date}) do
52 where: q.inserted_at >= ^parse_datetime(start_date),
53 where: q.inserted_at <= ^parse_datetime(end_date)
57 defp maybe_filter_by_user(query, %{user_id: nil}), do: query
59 defp maybe_filter_by_user(query, %{user_id: user_id}) do
61 where: fragment("(?)->'actor'->>'id' = ?", q.data, ^user_id)
65 defp maybe_filter_by_search(query, %{search: search}) when is_nil(search) or search == "",
68 defp maybe_filter_by_search(query, %{search: search}) do
70 where: fragment("(?)->>'message' ILIKE ?", q.data, ^"%#{search}%")
74 defp paginate_query(query, %{page: page, page_size: page_size}) do
77 offset: ^((page - 1) * page_size)
83 order_by: [desc: q.inserted_at]
87 defp parse_datetime(datetime) do
88 {:ok, parsed_datetime, _} = DateTime.from_iso8601(datetime)
93 @spec insert_log(%{actor: User, subject: [User], action: String.t(), permission: String.t()}) ::
94 {:ok, ModerationLog} | {:error, any}
96 actor: %User{} = actor,
99 permission: permission
103 "actor" => user_to_map(actor),
104 "subject" => user_to_map(subjects),
106 "permission" => permission,
110 |> insert_log_entry_with_message()
113 @spec insert_log(%{actor: User, subject: User, action: String.t()}) ::
114 {:ok, ModerationLog} | {:error, any}
116 actor: %User{} = actor,
117 action: "report_update",
118 subject: %Activity{data: %{"type" => "Flag"}} = subject
122 "actor" => user_to_map(actor),
123 "action" => "report_update",
124 "subject" => report_to_map(subject),
128 |> insert_log_entry_with_message()
131 @spec insert_log(%{actor: User, subject: Activity, action: String.t(), text: String.t()}) ::
132 {:ok, ModerationLog} | {:error, any}
134 actor: %User{} = actor,
135 action: "report_note",
136 subject: %Activity{} = subject,
141 "actor" => user_to_map(actor),
142 "action" => "report_note",
143 "subject" => report_to_map(subject),
147 |> insert_log_entry_with_message()
150 @spec insert_log(%{actor: User, subject: Activity, action: String.t(), text: String.t()}) ::
151 {:ok, ModerationLog} | {:error, any}
153 actor: %User{} = actor,
154 action: "report_note_delete",
155 subject: %Activity{} = subject,
160 "actor" => user_to_map(actor),
161 "action" => "report_note_delete",
162 "subject" => report_to_map(subject),
166 |> insert_log_entry_with_message()
173 sensitive: String.t(),
174 visibility: String.t()
175 }) :: {:ok, ModerationLog} | {:error, any}
177 actor: %User{} = actor,
178 action: "status_update",
179 subject: %Activity{} = subject,
180 sensitive: sensitive,
181 visibility: visibility
185 "actor" => user_to_map(actor),
186 "action" => "status_update",
187 "subject" => status_to_map(subject),
188 "sensitive" => sensitive,
189 "visibility" => visibility,
193 |> insert_log_entry_with_message()
196 @spec insert_log(%{actor: User, action: String.t(), subject_id: String.t()}) ::
197 {:ok, ModerationLog} | {:error, any}
199 actor: %User{} = actor,
200 action: "status_delete",
201 subject_id: subject_id
205 "actor" => user_to_map(actor),
206 "action" => "status_delete",
207 "subject_id" => subject_id,
211 |> insert_log_entry_with_message()
214 @spec insert_log(%{actor: User, subject: User, action: String.t()}) ::
215 {:ok, ModerationLog} | {:error, any}
216 def insert_log(%{actor: %User{} = actor, subject: subject, action: action}) do
219 "actor" => user_to_map(actor),
221 "subject" => user_to_map(subject),
225 |> insert_log_entry_with_message()
228 @spec insert_log(%{actor: User, subjects: [User], action: String.t()}) ::
229 {:ok, ModerationLog} | {:error, any}
230 def insert_log(%{actor: %User{} = actor, subjects: subjects, action: action}) do
231 subjects = Enum.map(subjects, &user_to_map/1)
235 "actor" => user_to_map(actor),
237 "subjects" => subjects,
241 |> insert_log_entry_with_message()
244 @spec insert_log(%{actor: User, action: String.t(), followed: User, follower: User}) ::
245 {:ok, ModerationLog} | {:error, any}
247 actor: %User{} = actor,
248 followed: %User{} = followed,
249 follower: %User{} = follower,
254 "actor" => user_to_map(actor),
255 "action" => "follow",
256 "followed" => user_to_map(followed),
257 "follower" => user_to_map(follower),
261 |> insert_log_entry_with_message()
264 @spec insert_log(%{actor: User, action: String.t(), followed: User, follower: User}) ::
265 {:ok, ModerationLog} | {:error, any}
267 actor: %User{} = actor,
268 followed: %User{} = followed,
269 follower: %User{} = follower,
274 "actor" => user_to_map(actor),
275 "action" => "unfollow",
276 "followed" => user_to_map(followed),
277 "follower" => user_to_map(follower),
281 |> insert_log_entry_with_message()
287 nicknames: [String.t()],
289 }) :: {:ok, ModerationLog} | {:error, any}
291 actor: %User{} = actor,
292 nicknames: nicknames,
298 "actor" => user_to_map(actor),
299 "nicknames" => nicknames,
305 |> insert_log_entry_with_message()
308 @spec insert_log(%{actor: User, action: String.t(), target: String.t()}) ::
309 {:ok, ModerationLog} | {:error, any}
311 actor: %User{} = actor,
315 when action in ["relay_follow", "relay_unfollow"] do
318 "actor" => user_to_map(actor),
324 |> insert_log_entry_with_message()
327 @spec insert_log(%{actor: User, action: String.t(), subject_id: String.t()}) ::
328 {:ok, ModerationLog} | {:error, any}
329 def insert_log(%{actor: %User{} = actor, action: "chat_message_delete", subject_id: subject_id}) do
332 "actor" => %{"nickname" => actor.nickname},
333 "action" => "chat_message_delete",
334 "subject_id" => subject_id
337 |> insert_log_entry_with_message()
340 @spec insert_log_entry_with_message(ModerationLog) :: {:ok, ModerationLog} | {:error, any}
341 defp insert_log_entry_with_message(entry) do
342 entry.data["message"]
343 |> put_in(get_log_entry_message(entry))
347 defp user_to_map(users) when is_list(users) do
348 users |> Enum.map(&user_to_map/1)
351 defp user_to_map(%User{} = user) do
354 |> Map.take([:id, :nickname])
355 |> Map.new(fn {k, v} -> {Atom.to_string(k), v} end)
356 |> Map.put("type", "user")
359 defp report_to_map(%Activity{} = report) do
363 "state" => report.data["state"]
367 defp status_to_map(%Activity{} = status) do
374 def get_log_entry_message(%ModerationLog{
376 "actor" => %{"nickname" => actor_nickname},
378 "followed" => %{"nickname" => followed_nickname},
379 "follower" => %{"nickname" => follower_nickname}
382 "@#{actor_nickname} made @#{follower_nickname} #{action} @#{followed_nickname}"
385 @spec get_log_entry_message(ModerationLog) :: String.t()
386 def get_log_entry_message(%ModerationLog{
388 "actor" => %{"nickname" => actor_nickname},
389 "action" => "delete",
390 "subject" => subjects
393 "@#{actor_nickname} deleted users: #{users_to_nicknames_string(subjects)}"
396 @spec get_log_entry_message(ModerationLog) :: String.t()
397 def get_log_entry_message(%ModerationLog{
399 "actor" => %{"nickname" => actor_nickname},
400 "action" => "create",
401 "subjects" => subjects
404 "@#{actor_nickname} created users: #{users_to_nicknames_string(subjects)}"
407 @spec get_log_entry_message(ModerationLog) :: String.t()
408 def get_log_entry_message(%ModerationLog{
410 "actor" => %{"nickname" => actor_nickname},
411 "action" => "activate",
415 "@#{actor_nickname} activated users: #{users_to_nicknames_string(users)}"
418 @spec get_log_entry_message(ModerationLog) :: String.t()
419 def get_log_entry_message(%ModerationLog{
421 "actor" => %{"nickname" => actor_nickname},
422 "action" => "deactivate",
426 "@#{actor_nickname} deactivated users: #{users_to_nicknames_string(users)}"
429 @spec get_log_entry_message(ModerationLog) :: String.t()
430 def get_log_entry_message(%ModerationLog{
432 "actor" => %{"nickname" => actor_nickname},
433 "action" => "approve",
437 "@#{actor_nickname} approved users: #{users_to_nicknames_string(users)}"
440 @spec get_log_entry_message(ModerationLog) :: String.t()
441 def get_log_entry_message(%ModerationLog{
443 "actor" => %{"nickname" => actor_nickname},
444 "nicknames" => nicknames,
449 tags_string = tags |> Enum.join(", ")
451 "@#{actor_nickname} added tags: #{tags_string} to users: #{nicknames_to_string(nicknames)}"
454 @spec get_log_entry_message(ModerationLog) :: String.t()
455 def get_log_entry_message(%ModerationLog{
457 "actor" => %{"nickname" => actor_nickname},
458 "nicknames" => nicknames,
463 tags_string = tags |> Enum.join(", ")
465 "@#{actor_nickname} removed tags: #{tags_string} from users: #{nicknames_to_string(nicknames)}"
468 @spec get_log_entry_message(ModerationLog) :: String.t()
469 def get_log_entry_message(%ModerationLog{
471 "actor" => %{"nickname" => actor_nickname},
474 "permission" => permission
477 "@#{actor_nickname} made #{users_to_nicknames_string(users)} #{permission}"
480 @spec get_log_entry_message(ModerationLog) :: String.t()
481 def get_log_entry_message(%ModerationLog{
483 "actor" => %{"nickname" => actor_nickname},
484 "action" => "revoke",
486 "permission" => permission
489 "@#{actor_nickname} revoked #{permission} role from #{users_to_nicknames_string(users)}"
492 @spec get_log_entry_message(ModerationLog) :: String.t()
493 def get_log_entry_message(%ModerationLog{
495 "actor" => %{"nickname" => actor_nickname},
496 "action" => "relay_follow",
500 "@#{actor_nickname} followed relay: #{target}"
503 @spec get_log_entry_message(ModerationLog) :: String.t()
504 def get_log_entry_message(%ModerationLog{
506 "actor" => %{"nickname" => actor_nickname},
507 "action" => "relay_unfollow",
511 "@#{actor_nickname} unfollowed relay: #{target}"
514 @spec get_log_entry_message(ModerationLog) :: String.t()
515 def get_log_entry_message(%ModerationLog{
517 "actor" => %{"nickname" => actor_nickname},
518 "action" => "report_update",
519 "subject" => %{"id" => subject_id, "state" => state, "type" => "report"}
522 "@#{actor_nickname} updated report ##{subject_id} with '#{state}' state"
525 @spec get_log_entry_message(ModerationLog) :: String.t()
526 def get_log_entry_message(%ModerationLog{
528 "actor" => %{"nickname" => actor_nickname},
529 "action" => "report_note",
530 "subject" => %{"id" => subject_id, "type" => "report"},
534 "@#{actor_nickname} added note '#{text}' to report ##{subject_id}"
537 @spec get_log_entry_message(ModerationLog) :: String.t()
538 def get_log_entry_message(%ModerationLog{
540 "actor" => %{"nickname" => actor_nickname},
541 "action" => "report_note_delete",
542 "subject" => %{"id" => subject_id, "type" => "report"},
546 "@#{actor_nickname} deleted note '#{text}' from report ##{subject_id}"
549 @spec get_log_entry_message(ModerationLog) :: String.t()
550 def get_log_entry_message(%ModerationLog{
552 "actor" => %{"nickname" => actor_nickname},
553 "action" => "status_update",
554 "subject" => %{"id" => subject_id, "type" => "status"},
556 "visibility" => visibility
559 "@#{actor_nickname} updated status ##{subject_id}, set visibility: '#{visibility}'"
562 @spec get_log_entry_message(ModerationLog) :: String.t()
563 def get_log_entry_message(%ModerationLog{
565 "actor" => %{"nickname" => actor_nickname},
566 "action" => "status_update",
567 "subject" => %{"id" => subject_id, "type" => "status"},
568 "sensitive" => sensitive,
572 "@#{actor_nickname} updated status ##{subject_id}, set sensitive: '#{sensitive}'"
575 @spec get_log_entry_message(ModerationLog) :: String.t()
576 def get_log_entry_message(%ModerationLog{
578 "actor" => %{"nickname" => actor_nickname},
579 "action" => "status_update",
580 "subject" => %{"id" => subject_id, "type" => "status"},
581 "sensitive" => sensitive,
582 "visibility" => visibility
585 "@#{actor_nickname} updated status ##{subject_id}, set sensitive: '#{sensitive}', visibility: '#{
590 @spec get_log_entry_message(ModerationLog) :: String.t()
591 def get_log_entry_message(%ModerationLog{
593 "actor" => %{"nickname" => actor_nickname},
594 "action" => "status_delete",
595 "subject_id" => subject_id
598 "@#{actor_nickname} deleted status ##{subject_id}"
601 @spec get_log_entry_message(ModerationLog) :: String.t()
602 def get_log_entry_message(%ModerationLog{
604 "actor" => %{"nickname" => actor_nickname},
605 "action" => "force_password_reset",
606 "subject" => subjects
609 "@#{actor_nickname} forced password reset for users: #{users_to_nicknames_string(subjects)}"
612 @spec get_log_entry_message(ModerationLog) :: String.t()
613 def get_log_entry_message(%ModerationLog{
615 "actor" => %{"nickname" => actor_nickname},
616 "action" => "confirm_email",
617 "subject" => subjects
620 "@#{actor_nickname} confirmed email for users: #{users_to_nicknames_string(subjects)}"
623 @spec get_log_entry_message(ModerationLog) :: String.t()
624 def get_log_entry_message(%ModerationLog{
626 "actor" => %{"nickname" => actor_nickname},
627 "action" => "resend_confirmation_email",
628 "subject" => subjects
631 "@#{actor_nickname} re-sent confirmation email for users: #{
632 users_to_nicknames_string(subjects)
636 @spec get_log_entry_message(ModerationLog) :: String.t()
637 def get_log_entry_message(%ModerationLog{
639 "actor" => %{"nickname" => actor_nickname},
640 "action" => "updated_users",
641 "subject" => subjects
644 "@#{actor_nickname} updated users: #{users_to_nicknames_string(subjects)}"
647 @spec get_log_entry_message(ModerationLog) :: String.t()
648 def get_log_entry_message(%ModerationLog{
650 "actor" => %{"nickname" => actor_nickname},
651 "action" => "chat_message_delete",
652 "subject_id" => subject_id
655 "@#{actor_nickname} deleted chat message ##{subject_id}"
658 def get_log_entry_message(%ModerationLog{
660 "actor" => %{"nickname" => actor_nickname},
661 "action" => "create_backup",
662 "subject" => %{"nickname" => user_nickname}
665 "@#{actor_nickname} requested account backup for @#{user_nickname}"
668 defp nicknames_to_string(nicknames) do
670 |> Enum.map(&"@#{&1}")
674 defp users_to_nicknames_string(users) do
676 |> Enum.map(&"@#{&1["nickname"]}")