Git of dcc - anni/blob - lib/pleroma/web/admin_api/controllers/chat_controller.ex

   1 # Pleroma: A lightweight social networking server
   2 # Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
   3 # SPDX-License-Identifier: AGPL-3.0-only
   4
   5 defmodule Pleroma.Web.AdminAPI.ChatController do
   6   use Pleroma.Web, :controller
   7
   8   alias Pleroma.Activity
   9   alias Pleroma.Chat
  10   alias Pleroma.Chat.MessageReference
  11   alias Pleroma.Pagination
  12   alias Pleroma.Web.AdminAPI
  13   alias Pleroma.Web.CommonAPI
  14   alias Pleroma.Web.PleromaAPI.Chat.MessageReferenceView
  15   alias Pleroma.Web.Plugs.OAuthScopesPlug
  16
  17   require Logger
  18
  19   plug(Pleroma.Web.ApiSpec.CastAndValidate)
  20
  21   plug(
  22     OAuthScopesPlug,
  23     %{scopes: ["admin:read:chats"]} when action in [:show, :messages]
  24   )
  25
  26   plug(
  27     OAuthScopesPlug,
  28     %{scopes: ["admin:write:chats"]} when action in [:delete_message]
  29   )
  30
  31   action_fallback(Pleroma.Web.AdminAPI.FallbackController)
  32
  33   defdelegate open_api_operation(action), to: Pleroma.Web.ApiSpec.Admin.ChatOperation
  34
  35   def delete_message(%{assigns: %{user: user}} = conn, %{
  36         message_id: message_id,
  37         id: chat_id
  38       }) do
  39     with %MessageReference{object: %{data: %{"id" => object_ap_id}}} = cm_ref <-
  40            MessageReference.get_by_id(message_id),
  41          ^chat_id <- to_string(cm_ref.chat_id),
  42          %Activity{id: activity_id} <- Activity.get_create_by_object_ap_id(object_ap_id),
  43          {:ok, _} <- CommonAPI.delete(activity_id, user) do
  44       conn
  45       |> put_view(MessageReferenceView)
  46       |> render("show.json", chat_message_reference: cm_ref)
  47     else
  48       _e ->
  49         {:error, :could_not_delete}
  50     end
  51   end
  52
  53   def messages(conn, %{id: id} = params) do
  54     with %Chat{} = chat <- Chat.get_by_id(id) do
  55       cm_refs =
  56         chat
  57         |> MessageReference.for_chat_query()
  58         |> Pagination.fetch_paginated(params)
  59
  60       conn
  61       |> put_view(MessageReferenceView)
  62       |> render("index.json", chat_message_references: cm_refs)
  63     else
  64       _ ->
  65         conn
  66         |> put_status(:not_found)
  67         |> json(%{error: "not found"})
  68     end
  69   end
  70
  71   def show(conn, %{id: id}) do
  72     with %Chat{} = chat <- Chat.get_by_id(id) do
  73       conn
  74       |> put_view(AdminAPI.ChatView)
  75       |> render("show.json", chat: chat)
  76     end
  77   end
  78 end