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}
117 actor: %User{} = actor,
118 action: "report_update",
119 subject: %Activity{data: %{"type" => "Flag"}} = subject
124 "actor" => user_to_map(actor),
125 "action" => "report_update",
126 "subject" => report_to_map(subject),
127 "subject_actor" => user_to_map(attrs[:subject_actor]),
131 |> insert_log_entry_with_message()
134 @spec insert_log(%{actor: User, subject: Activity, action: String.t(), text: String.t()}) ::
135 {:ok, ModerationLog} | {:error, any}
138 actor: %User{} = actor,
139 action: "report_note",
140 subject: %Activity{} = subject,
146 "actor" => user_to_map(actor),
147 "action" => "report_note",
148 "subject" => report_to_map(subject),
149 "subject_actor" => user_to_map(attrs[:subject_actor]),
153 |> insert_log_entry_with_message()
156 @spec insert_log(%{actor: User, subject: Activity, action: String.t(), text: String.t()}) ::
157 {:ok, ModerationLog} | {:error, any}
160 actor: %User{} = actor,
161 action: "report_note_delete",
162 subject: %Activity{} = subject,
168 "actor" => user_to_map(actor),
169 "action" => "report_note_delete",
170 "subject" => report_to_map(subject),
171 "subject_actor" => user_to_map(attrs[:subject_actor]),
175 |> insert_log_entry_with_message()
182 sensitive: String.t(),
183 visibility: String.t()
184 }) :: {:ok, ModerationLog} | {:error, any}
186 actor: %User{} = actor,
187 action: "status_update",
188 subject: %Activity{} = subject,
189 sensitive: sensitive,
190 visibility: visibility
194 "actor" => user_to_map(actor),
195 "action" => "status_update",
196 "subject" => status_to_map(subject),
197 "sensitive" => sensitive,
198 "visibility" => visibility,
202 |> insert_log_entry_with_message()
205 @spec insert_log(%{actor: User, action: String.t(), subject_id: String.t()}) ::
206 {:ok, ModerationLog} | {:error, any}
208 actor: %User{} = actor,
209 action: "status_delete",
210 subject_id: subject_id
214 "actor" => user_to_map(actor),
215 "action" => "status_delete",
216 "subject_id" => subject_id,
220 |> insert_log_entry_with_message()
223 @spec insert_log(%{actor: User, subject: User, action: String.t()}) ::
224 {:ok, ModerationLog} | {:error, any}
225 def insert_log(%{actor: %User{} = actor, subject: subject, action: action}) do
228 "actor" => user_to_map(actor),
230 "subject" => user_to_map(subject),
234 |> insert_log_entry_with_message()
237 @spec insert_log(%{actor: User, subjects: [User], action: String.t()}) ::
238 {:ok, ModerationLog} | {:error, any}
239 def insert_log(%{actor: %User{} = actor, subjects: subjects, action: action}) do
240 subjects = Enum.map(subjects, &user_to_map/1)
244 "actor" => user_to_map(actor),
246 "subjects" => subjects,
250 |> insert_log_entry_with_message()
253 @spec insert_log(%{actor: User, action: String.t(), followed: User, follower: User}) ::
254 {:ok, ModerationLog} | {:error, any}
256 actor: %User{} = actor,
257 followed: %User{} = followed,
258 follower: %User{} = follower,
263 "actor" => user_to_map(actor),
264 "action" => "follow",
265 "followed" => user_to_map(followed),
266 "follower" => user_to_map(follower),
270 |> insert_log_entry_with_message()
273 @spec insert_log(%{actor: User, action: String.t(), followed: User, follower: User}) ::
274 {:ok, ModerationLog} | {:error, any}
276 actor: %User{} = actor,
277 followed: %User{} = followed,
278 follower: %User{} = follower,
283 "actor" => user_to_map(actor),
284 "action" => "unfollow",
285 "followed" => user_to_map(followed),
286 "follower" => user_to_map(follower),
290 |> insert_log_entry_with_message()
296 nicknames: [String.t()],
298 }) :: {:ok, ModerationLog} | {:error, any}
300 actor: %User{} = actor,
301 nicknames: nicknames,
307 "actor" => user_to_map(actor),
308 "nicknames" => nicknames,
314 |> insert_log_entry_with_message()
317 @spec insert_log(%{actor: User, action: String.t(), target: String.t()}) ::
318 {:ok, ModerationLog} | {:error, any}
320 actor: %User{} = actor,
324 when action in ["relay_follow", "relay_unfollow"] do
327 "actor" => user_to_map(actor),
333 |> insert_log_entry_with_message()
336 @spec insert_log(%{actor: User, action: String.t(), subject_id: String.t()}) ::
337 {:ok, ModerationLog} | {:error, any}
338 def insert_log(%{actor: %User{} = actor, action: "chat_message_delete", subject_id: subject_id}) do
341 "actor" => %{"nickname" => actor.nickname},
342 "action" => "chat_message_delete",
343 "subject_id" => subject_id
346 |> insert_log_entry_with_message()
349 @spec insert_log_entry_with_message(ModerationLog) :: {:ok, ModerationLog} | {:error, any}
350 defp insert_log_entry_with_message(entry) do
351 entry.data["message"]
352 |> put_in(get_log_entry_message(entry))
356 defp user_to_map(users) when is_list(users) do
357 Enum.map(users, &user_to_map/1)
360 defp user_to_map(%User{} = user) do
362 |> Map.take([:id, :nickname])
363 |> Map.new(fn {k, v} -> {Atom.to_string(k), v} end)
364 |> Map.put("type", "user")
367 defp user_to_map(_), do: nil
369 defp report_to_map(%Activity{} = report) do
373 "state" => report.data["state"]
377 defp status_to_map(%Activity{} = status) do
384 def get_log_entry_message(%ModerationLog{
386 "actor" => %{"nickname" => actor_nickname},
388 "followed" => %{"nickname" => followed_nickname},
389 "follower" => %{"nickname" => follower_nickname}
392 "@#{actor_nickname} made @#{follower_nickname} #{action} @#{followed_nickname}"
395 @spec get_log_entry_message(ModerationLog) :: String.t()
396 def get_log_entry_message(%ModerationLog{
398 "actor" => %{"nickname" => actor_nickname},
399 "action" => "delete",
400 "subject" => subjects
403 "@#{actor_nickname} deleted users: #{users_to_nicknames_string(subjects)}"
406 @spec get_log_entry_message(ModerationLog) :: String.t()
407 def get_log_entry_message(%ModerationLog{
409 "actor" => %{"nickname" => actor_nickname},
410 "action" => "create",
411 "subjects" => subjects
414 "@#{actor_nickname} created users: #{users_to_nicknames_string(subjects)}"
417 @spec get_log_entry_message(ModerationLog) :: String.t()
418 def get_log_entry_message(%ModerationLog{
420 "actor" => %{"nickname" => actor_nickname},
421 "action" => "activate",
425 "@#{actor_nickname} activated users: #{users_to_nicknames_string(users)}"
428 @spec get_log_entry_message(ModerationLog) :: String.t()
429 def get_log_entry_message(%ModerationLog{
431 "actor" => %{"nickname" => actor_nickname},
432 "action" => "deactivate",
436 "@#{actor_nickname} deactivated users: #{users_to_nicknames_string(users)}"
439 @spec get_log_entry_message(ModerationLog) :: String.t()
440 def get_log_entry_message(%ModerationLog{
442 "actor" => %{"nickname" => actor_nickname},
443 "action" => "approve",
447 "@#{actor_nickname} approved users: #{users_to_nicknames_string(users)}"
450 @spec get_log_entry_message(ModerationLog) :: String.t()
451 def get_log_entry_message(%ModerationLog{
453 "actor" => %{"nickname" => actor_nickname},
454 "nicknames" => nicknames,
459 tags_string = tags |> Enum.join(", ")
461 "@#{actor_nickname} added tags: #{tags_string} to users: #{nicknames_to_string(nicknames)}"
464 @spec get_log_entry_message(ModerationLog) :: String.t()
465 def get_log_entry_message(%ModerationLog{
467 "actor" => %{"nickname" => actor_nickname},
468 "nicknames" => nicknames,
473 tags_string = tags |> Enum.join(", ")
475 "@#{actor_nickname} removed tags: #{tags_string} from users: #{nicknames_to_string(nicknames)}"
478 @spec get_log_entry_message(ModerationLog) :: String.t()
479 def get_log_entry_message(%ModerationLog{
481 "actor" => %{"nickname" => actor_nickname},
484 "permission" => permission
487 "@#{actor_nickname} made #{users_to_nicknames_string(users)} #{permission}"
490 @spec get_log_entry_message(ModerationLog) :: String.t()
491 def get_log_entry_message(%ModerationLog{
493 "actor" => %{"nickname" => actor_nickname},
494 "action" => "revoke",
496 "permission" => permission
499 "@#{actor_nickname} revoked #{permission} role from #{users_to_nicknames_string(users)}"
502 @spec get_log_entry_message(ModerationLog) :: String.t()
503 def get_log_entry_message(%ModerationLog{
505 "actor" => %{"nickname" => actor_nickname},
506 "action" => "relay_follow",
510 "@#{actor_nickname} followed relay: #{target}"
513 @spec get_log_entry_message(ModerationLog) :: String.t()
514 def get_log_entry_message(%ModerationLog{
516 "actor" => %{"nickname" => actor_nickname},
517 "action" => "relay_unfollow",
521 "@#{actor_nickname} unfollowed relay: #{target}"
524 @spec get_log_entry_message(ModerationLog) :: String.t()
525 def get_log_entry_message(
528 "actor" => %{"nickname" => actor_nickname},
529 "action" => "report_update",
530 "subject" => %{"id" => subject_id, "state" => state, "type" => "report"}
534 "@#{actor_nickname} updated report ##{subject_id}" <>
535 subject_actor_nickname(log, " (on user ", ")") <>
536 " with '#{state}' state"
539 @spec get_log_entry_message(ModerationLog) :: String.t()
540 def get_log_entry_message(
543 "actor" => %{"nickname" => actor_nickname},
544 "action" => "report_note",
545 "subject" => %{"id" => subject_id, "type" => "report"},
550 "@#{actor_nickname} added note '#{text}' to report ##{subject_id}" <>
551 subject_actor_nickname(log, " on user ")
554 @spec get_log_entry_message(ModerationLog) :: String.t()
555 def get_log_entry_message(
558 "actor" => %{"nickname" => actor_nickname},
559 "action" => "report_note_delete",
560 "subject" => %{"id" => subject_id, "type" => "report"},
565 "@#{actor_nickname} deleted note '#{text}' from report ##{subject_id}" <>
566 subject_actor_nickname(log, " on user ")
569 @spec get_log_entry_message(ModerationLog) :: String.t()
570 def get_log_entry_message(%ModerationLog{
572 "actor" => %{"nickname" => actor_nickname},
573 "action" => "status_update",
574 "subject" => %{"id" => subject_id, "type" => "status"},
576 "visibility" => visibility
579 "@#{actor_nickname} updated status ##{subject_id}, set visibility: '#{visibility}'"
582 @spec get_log_entry_message(ModerationLog) :: String.t()
583 def get_log_entry_message(%ModerationLog{
585 "actor" => %{"nickname" => actor_nickname},
586 "action" => "status_update",
587 "subject" => %{"id" => subject_id, "type" => "status"},
588 "sensitive" => sensitive,
592 "@#{actor_nickname} updated status ##{subject_id}, set sensitive: '#{sensitive}'"
595 @spec get_log_entry_message(ModerationLog) :: String.t()
596 def get_log_entry_message(%ModerationLog{
598 "actor" => %{"nickname" => actor_nickname},
599 "action" => "status_update",
600 "subject" => %{"id" => subject_id, "type" => "status"},
601 "sensitive" => sensitive,
602 "visibility" => visibility
605 "@#{actor_nickname} updated status ##{subject_id}, set sensitive: '#{sensitive}', visibility: '#{
610 @spec get_log_entry_message(ModerationLog) :: String.t()
611 def get_log_entry_message(%ModerationLog{
613 "actor" => %{"nickname" => actor_nickname},
614 "action" => "status_delete",
615 "subject_id" => subject_id
618 "@#{actor_nickname} deleted status ##{subject_id}"
621 @spec get_log_entry_message(ModerationLog) :: String.t()
622 def get_log_entry_message(%ModerationLog{
624 "actor" => %{"nickname" => actor_nickname},
625 "action" => "force_password_reset",
626 "subject" => subjects
629 "@#{actor_nickname} forced password reset for users: #{users_to_nicknames_string(subjects)}"
632 @spec get_log_entry_message(ModerationLog) :: String.t()
633 def get_log_entry_message(%ModerationLog{
635 "actor" => %{"nickname" => actor_nickname},
636 "action" => "confirm_email",
637 "subject" => subjects
640 "@#{actor_nickname} confirmed email for users: #{users_to_nicknames_string(subjects)}"
643 @spec get_log_entry_message(ModerationLog) :: String.t()
644 def get_log_entry_message(%ModerationLog{
646 "actor" => %{"nickname" => actor_nickname},
647 "action" => "resend_confirmation_email",
648 "subject" => subjects
651 "@#{actor_nickname} re-sent confirmation email for users: #{
652 users_to_nicknames_string(subjects)
656 @spec get_log_entry_message(ModerationLog) :: String.t()
657 def get_log_entry_message(%ModerationLog{
659 "actor" => %{"nickname" => actor_nickname},
660 "action" => "updated_users",
661 "subject" => subjects
664 "@#{actor_nickname} updated users: #{users_to_nicknames_string(subjects)}"
667 @spec get_log_entry_message(ModerationLog) :: String.t()
668 def get_log_entry_message(%ModerationLog{
670 "actor" => %{"nickname" => actor_nickname},
671 "action" => "chat_message_delete",
672 "subject_id" => subject_id
675 "@#{actor_nickname} deleted chat message ##{subject_id}"
678 def get_log_entry_message(%ModerationLog{
680 "actor" => %{"nickname" => actor_nickname},
681 "action" => "create_backup",
682 "subject" => %{"nickname" => user_nickname}
685 "@#{actor_nickname} requested account backup for @#{user_nickname}"
688 defp nicknames_to_string(nicknames) do
690 |> Enum.map(&"@#{&1}")
694 defp users_to_nicknames_string(users) do
696 |> Enum.map(&"@#{&1["nickname"]}")
700 defp subject_actor_nickname(%ModerationLog{data: data}, prefix_msg, postfix_msg \\ "") do
702 %{"subject_actor" => %{"nickname" => subject_actor}} ->
703 [prefix_msg, "@#{subject_actor}", postfix_msg]
704 |> Enum.reject(&(&1 == ""))