git.squeep.com Git - akkoma/blob - lib/pleroma/web/activity_pub/object_validator.ex

   1 # Pleroma: A lightweight social networking server
   2 # Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
   3 # SPDX-License-Identifier: AGPL-3.0-only
   4
   5 defmodule Pleroma.Web.ActivityPub.ObjectValidator do
   6   @moduledoc """
   7   This module is responsible for validating an object (which can be an activity)
   8   and checking if it is both well formed and also compatible with our view of
   9   the system.
  10   """
  11
  12   alias Pleroma.Activity
  13   alias Pleroma.EctoType.ActivityPub.ObjectValidators
  14   alias Pleroma.Object
  15   alias Pleroma.User
  16   alias Pleroma.Web.ActivityPub.ObjectValidators.AnnounceValidator
  17   alias Pleroma.Web.ActivityPub.ObjectValidators.BlockValidator
  18   alias Pleroma.Web.ActivityPub.ObjectValidators.ChatMessageValidator
  19   alias Pleroma.Web.ActivityPub.ObjectValidators.CreateChatMessageValidator
  20   alias Pleroma.Web.ActivityPub.ObjectValidators.DeleteValidator
  21   alias Pleroma.Web.ActivityPub.ObjectValidators.EmojiReactValidator
  22   alias Pleroma.Web.ActivityPub.ObjectValidators.FollowValidator
  23   alias Pleroma.Web.ActivityPub.ObjectValidators.LikeValidator
  24   alias Pleroma.Web.ActivityPub.ObjectValidators.UndoValidator
  25   alias Pleroma.Web.ActivityPub.ObjectValidators.UpdateValidator
  26
  27   @spec validate(map(), keyword()) :: {:ok, map(), keyword()} | {:error, any()}
  28   def validate(object, meta)
  29
  30   def validate(%{"type" => "Follow"} = object, meta) do
  31     with {:ok, object} <-
  32            object
  33            |> FollowValidator.cast_and_validate()
  34            |> Ecto.Changeset.apply_action(:insert) do
  35       object = stringify_keys(object)
  36       {:ok, object, meta}
  37     end
  38   end
  39
  40   def validate(%{"type" => "Block"} = block_activity, meta) do
  41     with {:ok, block_activity} <-
  42            block_activity
  43            |> BlockValidator.cast_and_validate()
  44            |> Ecto.Changeset.apply_action(:insert) do
  45       block_activity = stringify_keys(block_activity)
  46       outgoing_blocks = Pleroma.Config.get([:activitypub, :outgoing_blocks])
  47
  48       meta =
  49         if !outgoing_blocks do
  50           Keyword.put(meta, :do_not_federate, true)
  51         else
  52           meta
  53         end
  54
  55       {:ok, block_activity, meta}
  56     end
  57   end
  58
  59   def validate(%{"type" => "Update"} = update_activity, meta) do
  60     with {:ok, update_activity} <-
  61            update_activity
  62            |> UpdateValidator.cast_and_validate()
  63            |> Ecto.Changeset.apply_action(:insert) do
  64       update_activity = stringify_keys(update_activity)
  65       {:ok, update_activity, meta}
  66     end
  67   end
  68
  69   def validate(%{"type" => "Undo"} = object, meta) do
  70     with {:ok, object} <-
  71            object
  72            |> UndoValidator.cast_and_validate()
  73            |> Ecto.Changeset.apply_action(:insert) do
  74       object = stringify_keys(object)
  75       undone_object = Activity.get_by_ap_id(object["object"])
  76
  77       meta =
  78         meta
  79         |> Keyword.put(:object_data, undone_object.data)
  80
  81       {:ok, object, meta}
  82     end
  83   end
  84
  85   def validate(%{"type" => "Delete"} = object, meta) do
  86     with cng <- DeleteValidator.cast_and_validate(object),
  87          do_not_federate <- DeleteValidator.do_not_federate?(cng),
  88          {:ok, object} <- Ecto.Changeset.apply_action(cng, :insert) do
  89       object = stringify_keys(object)
  90       meta = Keyword.put(meta, :do_not_federate, do_not_federate)
  91       {:ok, object, meta}
  92     end
  93   end
  94
  95   def validate(%{"type" => "Like"} = object, meta) do
  96     with {:ok, object} <-
  97            object
  98            |> LikeValidator.cast_and_validate()
  99            |> Ecto.Changeset.apply_action(:insert) do
 100       object = stringify_keys(object)
 101       {:ok, object, meta}
 102     end
 103   end
 104
 105   def validate(%{"type" => "ChatMessage"} = object, meta) do
 106     with {:ok, object} <-
 107            object
 108            |> ChatMessageValidator.cast_and_validate()
 109            |> Ecto.Changeset.apply_action(:insert) do
 110       object = stringify_keys(object)
 111       {:ok, object, meta}
 112     end
 113   end
 114
 115   def validate(%{"type" => "EmojiReact"} = object, meta) do
 116     with {:ok, object} <-
 117            object
 118            |> EmojiReactValidator.cast_and_validate()
 119            |> Ecto.Changeset.apply_action(:insert) do
 120       object = stringify_keys(object |> Map.from_struct())
 121       {:ok, object, meta}
 122     end
 123   end
 124
 125   def validate(%{"type" => "Create", "object" => object} = create_activity, meta) do
 126     with {:ok, object_data} <- cast_and_apply(object),
 127          meta = Keyword.put(meta, :object_data, object_data |> stringify_keys),
 128          {:ok, create_activity} <-
 129            create_activity
 130            |> CreateChatMessageValidator.cast_and_validate(meta)
 131            |> Ecto.Changeset.apply_action(:insert) do
 132       create_activity = stringify_keys(create_activity)
 133       {:ok, create_activity, meta}
 134     end
 135   end
 136
 137   def validate(%{"type" => "Announce"} = object, meta) do
 138     with {:ok, object} <-
 139            object
 140            |> AnnounceValidator.cast_and_validate()
 141            |> Ecto.Changeset.apply_action(:insert) do
 142       object = stringify_keys(object |> Map.from_struct())
 143       {:ok, object, meta}
 144     end
 145   end
 146
 147   def cast_and_apply(%{"type" => "ChatMessage"} = object) do
 148     ChatMessageValidator.cast_and_apply(object)
 149   end
 150
 151   def cast_and_apply(o), do: {:error, {:validator_not_set, o}}
 152
 153   def stringify_keys(%{__struct__: _} = object) do
 154     object
 155     |> Map.from_struct()
 156     |> stringify_keys
 157   end
 158
 159   def stringify_keys(object) when is_map(object) do
 160     object
 161     |> Map.new(fn {key, val} -> {to_string(key), stringify_keys(val)} end)
 162   end
 163
 164   def stringify_keys(object) when is_list(object) do
 165     object
 166     |> Enum.map(&stringify_keys/1)
 167   end
 168
 169   def stringify_keys(object), do: object
 170
 171   def fetch_actor(object) do
 172     with {:ok, actor} <- ObjectValidators.ObjectID.cast(object["actor"]) do
 173       User.get_or_fetch_by_ap_id(actor)
 174     end
 175   end
 176
 177   def fetch_actor_and_object(object) do
 178     fetch_actor(object)
 179     Object.normalize(object["object"], true)
 180     :ok
 181   end
 182 end