1 defmodule Pleroma.ModerationLog do
5 alias Pleroma.ModerationLog
11 schema "moderation_log" do
17 def get_all(params) do
20 |> maybe_filter_by_date(params)
21 |> maybe_filter_by_user(params)
22 |> maybe_filter_by_search(params)
24 query_with_pagination = base_query |> paginate_query(params)
27 items: Repo.all(query_with_pagination),
28 count: Repo.aggregate(base_query, :count, :id)
32 defp maybe_filter_by_date(query, %{start_date: nil, end_date: nil}), do: query
34 defp maybe_filter_by_date(query, %{start_date: start_date, end_date: nil}) do
36 where: q.inserted_at >= ^parse_datetime(start_date)
40 defp maybe_filter_by_date(query, %{start_date: nil, end_date: end_date}) do
42 where: q.inserted_at <= ^parse_datetime(end_date)
46 defp maybe_filter_by_date(query, %{start_date: start_date, end_date: end_date}) do
48 where: q.inserted_at >= ^parse_datetime(start_date),
49 where: q.inserted_at <= ^parse_datetime(end_date)
53 defp maybe_filter_by_user(query, %{user_id: nil}), do: query
55 defp maybe_filter_by_user(query, %{user_id: user_id}) do
57 where: fragment("(?)->'actor'->>'id' = ?", q.data, ^user_id)
61 defp maybe_filter_by_search(query, %{search: search}) when is_nil(search) or search == "",
64 defp maybe_filter_by_search(query, %{search: search}) do
66 where: fragment("(?)->>'message' ILIKE ?", q.data, ^"%#{search}%")
70 defp paginate_query(query, %{page: page, page_size: page_size}) do
73 offset: ^((page - 1) * page_size)
79 order_by: [desc: q.inserted_at]
83 defp parse_datetime(datetime) do
84 {:ok, parsed_datetime, _} = DateTime.from_iso8601(datetime)
89 @spec insert_log(%{actor: User, subject: [User], action: String.t(), permission: String.t()}) ::
90 {:ok, ModerationLog} | {:error, any}
92 actor: %User{} = actor,
95 permission: permission
99 "actor" => user_to_map(actor),
100 "subject" => user_to_map(subjects),
102 "permission" => permission,
106 |> insert_log_entry_with_message()
109 @spec insert_log(%{actor: User, subject: User, action: String.t()}) ::
110 {:ok, ModerationLog} | {:error, any}
112 actor: %User{} = actor,
113 action: "report_update",
114 subject: %Activity{data: %{"type" => "Flag"}} = subject
118 "actor" => user_to_map(actor),
119 "action" => "report_update",
120 "subject" => report_to_map(subject),
124 |> insert_log_entry_with_message()
127 @spec insert_log(%{actor: User, subject: Activity, action: String.t(), text: String.t()}) ::
128 {:ok, ModerationLog} | {:error, any}
130 actor: %User{} = actor,
131 action: "report_note",
132 subject: %Activity{} = subject,
137 "actor" => user_to_map(actor),
138 "action" => "report_note",
139 "subject" => report_to_map(subject),
143 |> insert_log_entry_with_message()
146 @spec insert_log(%{actor: User, subject: Activity, action: String.t(), text: String.t()}) ::
147 {:ok, ModerationLog} | {:error, any}
149 actor: %User{} = actor,
150 action: "report_note_delete",
151 subject: %Activity{} = subject,
156 "actor" => user_to_map(actor),
157 "action" => "report_note_delete",
158 "subject" => report_to_map(subject),
162 |> insert_log_entry_with_message()
169 sensitive: String.t(),
170 visibility: String.t()
171 }) :: {:ok, ModerationLog} | {:error, any}
173 actor: %User{} = actor,
174 action: "status_update",
175 subject: %Activity{} = subject,
176 sensitive: sensitive,
177 visibility: visibility
181 "actor" => user_to_map(actor),
182 "action" => "status_update",
183 "subject" => status_to_map(subject),
184 "sensitive" => sensitive,
185 "visibility" => visibility,
189 |> insert_log_entry_with_message()
192 @spec insert_log(%{actor: User, action: String.t(), subject_id: String.t()}) ::
193 {:ok, ModerationLog} | {:error, any}
195 actor: %User{} = actor,
196 action: "status_delete",
197 subject_id: subject_id
201 "actor" => user_to_map(actor),
202 "action" => "status_delete",
203 "subject_id" => subject_id,
207 |> insert_log_entry_with_message()
210 @spec insert_log(%{actor: User, subject: User, action: String.t()}) ::
211 {:ok, ModerationLog} | {:error, any}
212 def insert_log(%{actor: %User{} = actor, subject: subject, action: action}) do
215 "actor" => user_to_map(actor),
217 "subject" => user_to_map(subject),
221 |> insert_log_entry_with_message()
224 @spec insert_log(%{actor: User, subjects: [User], action: String.t()}) ::
225 {:ok, ModerationLog} | {:error, any}
226 def insert_log(%{actor: %User{} = actor, subjects: subjects, action: action}) do
227 subjects = Enum.map(subjects, &user_to_map/1)
231 "actor" => user_to_map(actor),
233 "subjects" => subjects,
237 |> insert_log_entry_with_message()
240 @spec insert_log(%{actor: User, action: String.t(), followed: User, follower: User}) ::
241 {:ok, ModerationLog} | {:error, any}
243 actor: %User{} = actor,
244 followed: %User{} = followed,
245 follower: %User{} = follower,
250 "actor" => user_to_map(actor),
251 "action" => "follow",
252 "followed" => user_to_map(followed),
253 "follower" => user_to_map(follower),
257 |> insert_log_entry_with_message()
260 @spec insert_log(%{actor: User, action: String.t(), followed: User, follower: User}) ::
261 {:ok, ModerationLog} | {:error, any}
263 actor: %User{} = actor,
264 followed: %User{} = followed,
265 follower: %User{} = follower,
270 "actor" => user_to_map(actor),
271 "action" => "unfollow",
272 "followed" => user_to_map(followed),
273 "follower" => user_to_map(follower),
277 |> insert_log_entry_with_message()
283 nicknames: [String.t()],
285 }) :: {:ok, ModerationLog} | {:error, any}
287 actor: %User{} = actor,
288 nicknames: nicknames,
294 "actor" => user_to_map(actor),
295 "nicknames" => nicknames,
301 |> insert_log_entry_with_message()
304 @spec insert_log(%{actor: User, action: String.t(), target: String.t()}) ::
305 {:ok, ModerationLog} | {:error, any}
307 actor: %User{} = actor,
311 when action in ["relay_follow", "relay_unfollow"] do
314 "actor" => user_to_map(actor),
320 |> insert_log_entry_with_message()
323 @spec insert_log(%{actor: User, action: String.t(), subject_id: String.t()}) ::
324 {:ok, ModerationLog} | {:error, any}
325 def insert_log(%{actor: %User{} = actor, action: "chat_message_delete", subject_id: subject_id}) do
328 "actor" => %{"nickname" => actor.nickname},
329 "action" => "chat_message_delete",
330 "subject_id" => subject_id
333 |> insert_log_entry_with_message()
336 @spec insert_log_entry_with_message(ModerationLog) :: {:ok, ModerationLog} | {:error, any}
337 defp insert_log_entry_with_message(entry) do
338 entry.data["message"]
339 |> put_in(get_log_entry_message(entry))
343 defp user_to_map(users) when is_list(users) do
344 users |> Enum.map(&user_to_map/1)
347 defp user_to_map(%User{} = user) do
350 |> Map.take([:id, :nickname])
351 |> Map.new(fn {k, v} -> {Atom.to_string(k), v} end)
352 |> Map.put("type", "user")
355 defp report_to_map(%Activity{} = report) do
359 "state" => report.data["state"]
363 defp status_to_map(%Activity{} = status) do
370 def get_log_entry_message(%ModerationLog{
372 "actor" => %{"nickname" => actor_nickname},
374 "followed" => %{"nickname" => followed_nickname},
375 "follower" => %{"nickname" => follower_nickname}
378 "@#{actor_nickname} made @#{follower_nickname} #{action} @#{followed_nickname}"
381 @spec get_log_entry_message(ModerationLog) :: String.t()
382 def get_log_entry_message(%ModerationLog{
384 "actor" => %{"nickname" => actor_nickname},
385 "action" => "delete",
386 "subject" => subjects
389 "@#{actor_nickname} deleted users: #{users_to_nicknames_string(subjects)}"
392 @spec get_log_entry_message(ModerationLog) :: String.t()
393 def get_log_entry_message(%ModerationLog{
395 "actor" => %{"nickname" => actor_nickname},
396 "action" => "create",
397 "subjects" => subjects
400 "@#{actor_nickname} created users: #{users_to_nicknames_string(subjects)}"
403 @spec get_log_entry_message(ModerationLog) :: String.t()
404 def get_log_entry_message(%ModerationLog{
406 "actor" => %{"nickname" => actor_nickname},
407 "action" => "activate",
411 "@#{actor_nickname} activated users: #{users_to_nicknames_string(users)}"
414 @spec get_log_entry_message(ModerationLog) :: String.t()
415 def get_log_entry_message(%ModerationLog{
417 "actor" => %{"nickname" => actor_nickname},
418 "action" => "deactivate",
422 "@#{actor_nickname} deactivated users: #{users_to_nicknames_string(users)}"
425 @spec get_log_entry_message(ModerationLog) :: String.t()
426 def get_log_entry_message(%ModerationLog{
428 "actor" => %{"nickname" => actor_nickname},
429 "action" => "approve",
433 "@#{actor_nickname} approved users: #{users_to_nicknames_string(users)}"
436 @spec get_log_entry_message(ModerationLog) :: String.t()
437 def get_log_entry_message(%ModerationLog{
439 "actor" => %{"nickname" => actor_nickname},
440 "nicknames" => nicknames,
445 tags_string = tags |> Enum.join(", ")
447 "@#{actor_nickname} added tags: #{tags_string} to users: #{nicknames_to_string(nicknames)}"
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} removed tags: #{tags_string} from 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},
470 "permission" => permission
473 "@#{actor_nickname} made #{users_to_nicknames_string(users)} #{permission}"
476 @spec get_log_entry_message(ModerationLog) :: String.t()
477 def get_log_entry_message(%ModerationLog{
479 "actor" => %{"nickname" => actor_nickname},
480 "action" => "revoke",
482 "permission" => permission
485 "@#{actor_nickname} revoked #{permission} role from #{users_to_nicknames_string(users)}"
488 @spec get_log_entry_message(ModerationLog) :: String.t()
489 def get_log_entry_message(%ModerationLog{
491 "actor" => %{"nickname" => actor_nickname},
492 "action" => "relay_follow",
496 "@#{actor_nickname} followed relay: #{target}"
499 @spec get_log_entry_message(ModerationLog) :: String.t()
500 def get_log_entry_message(%ModerationLog{
502 "actor" => %{"nickname" => actor_nickname},
503 "action" => "relay_unfollow",
507 "@#{actor_nickname} unfollowed relay: #{target}"
510 @spec get_log_entry_message(ModerationLog) :: String.t()
511 def get_log_entry_message(%ModerationLog{
513 "actor" => %{"nickname" => actor_nickname},
514 "action" => "report_update",
515 "subject" => %{"id" => subject_id, "state" => state, "type" => "report"}
518 "@#{actor_nickname} updated report ##{subject_id} with '#{state}' state"
521 @spec get_log_entry_message(ModerationLog) :: String.t()
522 def get_log_entry_message(%ModerationLog{
524 "actor" => %{"nickname" => actor_nickname},
525 "action" => "report_note",
526 "subject" => %{"id" => subject_id, "type" => "report"},
530 "@#{actor_nickname} added note '#{text}' to report ##{subject_id}"
533 @spec get_log_entry_message(ModerationLog) :: String.t()
534 def get_log_entry_message(%ModerationLog{
536 "actor" => %{"nickname" => actor_nickname},
537 "action" => "report_note_delete",
538 "subject" => %{"id" => subject_id, "type" => "report"},
542 "@#{actor_nickname} deleted note '#{text}' from report ##{subject_id}"
545 @spec get_log_entry_message(ModerationLog) :: String.t()
546 def get_log_entry_message(%ModerationLog{
548 "actor" => %{"nickname" => actor_nickname},
549 "action" => "status_update",
550 "subject" => %{"id" => subject_id, "type" => "status"},
552 "visibility" => visibility
555 "@#{actor_nickname} updated status ##{subject_id}, set visibility: '#{visibility}'"
558 @spec get_log_entry_message(ModerationLog) :: String.t()
559 def get_log_entry_message(%ModerationLog{
561 "actor" => %{"nickname" => actor_nickname},
562 "action" => "status_update",
563 "subject" => %{"id" => subject_id, "type" => "status"},
564 "sensitive" => sensitive,
568 "@#{actor_nickname} updated status ##{subject_id}, set sensitive: '#{sensitive}'"
571 @spec get_log_entry_message(ModerationLog) :: String.t()
572 def get_log_entry_message(%ModerationLog{
574 "actor" => %{"nickname" => actor_nickname},
575 "action" => "status_update",
576 "subject" => %{"id" => subject_id, "type" => "status"},
577 "sensitive" => sensitive,
578 "visibility" => visibility
581 "@#{actor_nickname} updated status ##{subject_id}, set sensitive: '#{sensitive}', visibility: '#{
586 @spec get_log_entry_message(ModerationLog) :: String.t()
587 def get_log_entry_message(%ModerationLog{
589 "actor" => %{"nickname" => actor_nickname},
590 "action" => "status_delete",
591 "subject_id" => subject_id
594 "@#{actor_nickname} deleted status ##{subject_id}"
597 @spec get_log_entry_message(ModerationLog) :: String.t()
598 def get_log_entry_message(%ModerationLog{
600 "actor" => %{"nickname" => actor_nickname},
601 "action" => "force_password_reset",
602 "subject" => subjects
605 "@#{actor_nickname} forced password reset for users: #{users_to_nicknames_string(subjects)}"
608 @spec get_log_entry_message(ModerationLog) :: String.t()
609 def get_log_entry_message(%ModerationLog{
611 "actor" => %{"nickname" => actor_nickname},
612 "action" => "confirm_email",
613 "subject" => subjects
616 "@#{actor_nickname} confirmed email for users: #{users_to_nicknames_string(subjects)}"
619 @spec get_log_entry_message(ModerationLog) :: String.t()
620 def get_log_entry_message(%ModerationLog{
622 "actor" => %{"nickname" => actor_nickname},
623 "action" => "resend_confirmation_email",
624 "subject" => subjects
627 "@#{actor_nickname} re-sent confirmation email for users: #{
628 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" => "updated_users",
637 "subject" => subjects
640 "@#{actor_nickname} updated 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" => "chat_message_delete",
648 "subject_id" => subject_id
651 "@#{actor_nickname} deleted chat message ##{subject_id}"
654 defp nicknames_to_string(nicknames) do
656 |> Enum.map(&"@#{&1}")
660 defp users_to_nicknames_string(users) do
662 |> Enum.map(&"@#{&1["nickname"]}")