git.squeep.com Git - akkoma/blob - lib/pleroma/web/pleroma_api/pleroma_api_controller.ex

   1 # Pleroma: A lightweight social networking server
   2 # Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
   3 # SPDX-License-Identifier: AGPL-3.0-only
   4
   5 defmodule Pleroma.Web.PleromaAPI.PleromaAPIController do
   6   use Pleroma.Web, :controller
   7
   8   import Pleroma.Web.ControllerHelper, only: [add_link_headers: 2]
   9
  10   alias Pleroma.Conversation.Participation
  11   alias Pleroma.Notification
  12   alias Pleroma.SubscriptionNotification
  13   alias Pleroma.Web.ActivityPub.ActivityPub
  14   alias Pleroma.Web.MastodonAPI.ConversationView
  15   alias Pleroma.Web.MastodonAPI.NotificationView
  16   alias Pleroma.Web.MastodonAPI.StatusView
  17
  18   def conversation(%{assigns: %{user: user}} = conn, %{"id" => participation_id}) do
  19     with %Participation{} = participation <- Participation.get(participation_id),
  20          true <- user.id == participation.user_id do
  21       conn
  22       |> put_view(ConversationView)
  23       |> render("participation.json", %{participation: participation, for: user})
  24     end
  25   end
  26
  27   def conversation_statuses(
  28         %{assigns: %{user: user}} = conn,
  29         %{"id" => participation_id} = params
  30       ) do
  31     participation = Participation.get(participation_id, preload: [:conversation])
  32
  33     if user.id == participation.user_id do
  34       params =
  35         params
  36         |> Map.put("blocking_user", user)
  37         |> Map.put("muting_user", user)
  38         |> Map.put("user", user)
  39
  40       activities =
  41         participation.conversation.ap_id
  42         |> ActivityPub.fetch_activities_for_context(params)
  43         |> Enum.reverse()
  44
  45       conn
  46       |> add_link_headers(activities)
  47       |> put_view(StatusView)
  48       |> render("index.json", %{activities: activities, for: user, as: :activity})
  49     end
  50   end
  51
  52   def update_conversation(
  53         %{assigns: %{user: user}} = conn,
  54         %{"id" => participation_id, "recipients" => recipients}
  55       ) do
  56     participation =
  57       participation_id
  58       |> Participation.get()
  59
  60     with true <- user.id == participation.user_id,
  61          {:ok, participation} <- Participation.set_recipients(participation, recipients) do
  62       conn
  63       |> put_view(ConversationView)
  64       |> render("participation.json", %{participation: participation, for: user})
  65     end
  66   end
  67
  68   def read_notification(%{assigns: %{user: user}} = conn, %{"id" => notification_id}) do
  69     with {:ok, notification} <- Notification.read_one(user, notification_id) do
  70       conn
  71       |> put_view(NotificationView)
  72       |> render("show.json", %{notification: notification, for: user})
  73     else
  74       {:error, message} ->
  75         conn
  76         |> put_status(:bad_request)
  77         |> json(%{"error" => message})
  78     end
  79   end
  80
  81   def read_notification(%{assigns: %{user: user}} = conn, %{"max_id" => max_id}) do
  82     with notifications <- Notification.set_read_up_to(user, max_id) do
  83       notifications = Enum.take(notifications, 80)
  84
  85       conn
  86       |> put_view(NotificationView)
  87       |> render("index.json", %{notifications: notifications, for: user})
  88     end
  89   end
  90
  91   def delete_subscription_notification(%{assigns: %{user: user}} = conn, %{
  92         "id" => notification_id
  93       }) do
  94     with {:ok, notification} <- SubscriptionNotification.dismiss(user, notification_id) do
  95       conn
  96       |> put_view(NotificationView)
  97       |> render("show.json", %{notification: notification, for: user})
  98     else
  99       {:error, message} ->
 100         conn
 101         |> put_status(:bad_request)
 102         |> json(%{"error" => message})
 103     end
 104   end
 105
 106   def read_subscription_notification(%{assigns: %{user: user}} = conn, %{"max_id" => max_id}) do
 107     with notifications <- SubscriptionNotification.clear_up_to(user, max_id) do
 108       notifications = Enum.take(notifications, 80)
 109
 110       conn
 111       |> put_view(NotificationView)
 112       |> render("index.json", %{notifications: notifications, for: user})
 113     end
 114   end
 115 end