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: 7]
   9
  10   alias Pleroma.Activity
  11   alias Pleroma.Object
  12   alias Pleroma.User
  13   alias Pleroma.Conversation.Participation
  14   alias Pleroma.Web.ActivityPub.ActivityPub
  15   alias Pleroma.Web.CommonAPI
  16   alias Pleroma.Web.MastodonAPI.AccountView
  17   alias Pleroma.Web.MastodonAPI.ConversationView
  18   alias Pleroma.Web.MastodonAPI.StatusView
  19
  20   def emoji_reactions_by(%{assigns: %{user: user}} = conn, %{"id" => activity_id}) do
  21     with %Activity{} = activity <- Activity.get_by_id_with_object(activity_id),
  22          %Object{data: %{"reactions" => emoji_reactions}} <- Object.normalize(activity) do
  23       reactions =
  24         Enum.reduce(emoji_reactions, %{}, fn {emoji, users}, res ->
  25           users =
  26             users
  27             |> Enum.map(&User.get_cached_by_ap_id/1)
  28
  29           res
  30           |> Map.put(
  31             emoji,
  32             AccountView.render("accounts.json", %{users: users, for: user, as: :user})
  33           )
  34         end)
  35
  36       conn
  37       |> json(reactions)
  38     else
  39       _e ->
  40         conn
  41         |> json(%{})
  42     end
  43   end
  44
  45   def react_with_emoji(%{assigns: %{user: user}} = conn, %{"id" => activity_id, "emoji" => emoji}) do
  46     with {:ok, _activity, _object} <- CommonAPI.react_with_emoji(activity_id, user, emoji),
  47          activity = Activity.get_by_id(activity_id) do
  48       conn
  49       |> put_view(StatusView)
  50       |> render("status.json", %{activity: activity, for: user, as: :activity})
  51     end
  52   end
  53
  54   def conversation(%{assigns: %{user: user}} = conn, %{"id" => participation_id}) do
  55     with %Participation{} = participation <- Participation.get(participation_id),
  56          true <- user.id == participation.user_id do
  57       conn
  58       |> put_view(ConversationView)
  59       |> render("participation.json", %{participation: participation, for: user})
  60     end
  61   end
  62
  63   def conversation_statuses(
  64         %{assigns: %{user: user}} = conn,
  65         %{"id" => participation_id} = params
  66       ) do
  67     params =
  68       params
  69       |> Map.put("blocking_user", user)
  70       |> Map.put("muting_user", user)
  71       |> Map.put("user", user)
  72
  73     participation =
  74       participation_id
  75       |> Participation.get(preload: [:conversation])
  76
  77     if user.id == participation.user_id do
  78       activities =
  79         participation.conversation.ap_id
  80         |> ActivityPub.fetch_activities_for_context(params)
  81         |> Enum.reverse()
  82
  83       conn
  84       |> add_link_headers(
  85         :conversation_statuses,
  86         activities,
  87         participation_id,
  88         params,
  89         nil,
  90         &pleroma_api_url/4
  91       )
  92       |> put_view(StatusView)
  93       |> render("index.json", %{activities: activities, for: user, as: :activity})
  94     end
  95   end
  96
  97   def update_conversation(
  98         %{assigns: %{user: user}} = conn,
  99         %{"id" => participation_id, "recipients" => recipients}
 100       ) do
 101     participation =
 102       participation_id
 103       |> Participation.get()
 104
 105     with true <- user.id == participation.user_id,
 106          {:ok, participation} <- Participation.set_recipients(participation, recipients) do
 107       conn
 108       |> put_view(ConversationView)
 109       |> render("participation.json", %{participation: participation, for: user})
 110     end
 111   end
 112 end