1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.Web.ActivityPub.ObjectValidator do
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
12 alias Pleroma.Activity
13 alias Pleroma.EctoType.ActivityPub.ObjectValidators
16 alias Pleroma.Web.ActivityPub.ObjectValidators.AcceptRejectValidator
17 alias Pleroma.Web.ActivityPub.ObjectValidators.AnnounceValidator
18 alias Pleroma.Web.ActivityPub.ObjectValidators.AnswerValidator
19 alias Pleroma.Web.ActivityPub.ObjectValidators.BlockValidator
20 alias Pleroma.Web.ActivityPub.ObjectValidators.ChatMessageValidator
21 alias Pleroma.Web.ActivityPub.ObjectValidators.CreateChatMessageValidator
22 alias Pleroma.Web.ActivityPub.ObjectValidators.CreateGenericValidator
23 alias Pleroma.Web.ActivityPub.ObjectValidators.DeleteValidator
24 alias Pleroma.Web.ActivityPub.ObjectValidators.EmojiReactValidator
25 alias Pleroma.Web.ActivityPub.ObjectValidators.FollowValidator
26 alias Pleroma.Web.ActivityPub.ObjectValidators.LikeValidator
27 alias Pleroma.Web.ActivityPub.ObjectValidators.QuestionValidator
28 alias Pleroma.Web.ActivityPub.ObjectValidators.UndoValidator
29 alias Pleroma.Web.ActivityPub.ObjectValidators.UpdateValidator
31 @spec validate(map(), keyword()) :: {:ok, map(), keyword()} | {:error, any()}
32 def validate(object, meta)
34 def validate(%{"type" => type} = object, meta)
35 when type in ~w[Accept Reject] do
38 |> AcceptRejectValidator.cast_and_validate()
39 |> Ecto.Changeset.apply_action(:insert) do
40 object = stringify_keys(object)
45 def validate(%{"type" => "Follow"} = object, meta) do
48 |> FollowValidator.cast_and_validate()
49 |> Ecto.Changeset.apply_action(:insert) do
50 object = stringify_keys(object)
55 def validate(%{"type" => "Block"} = block_activity, meta) do
56 with {:ok, block_activity} <-
58 |> BlockValidator.cast_and_validate()
59 |> Ecto.Changeset.apply_action(:insert) do
60 block_activity = stringify_keys(block_activity)
61 outgoing_blocks = Pleroma.Config.get([:activitypub, :outgoing_blocks])
64 if !outgoing_blocks do
65 Keyword.put(meta, :do_not_federate, true)
70 {:ok, block_activity, meta}
74 def validate(%{"type" => "Update"} = update_activity, meta) do
75 with {:ok, update_activity} <-
77 |> UpdateValidator.cast_and_validate()
78 |> Ecto.Changeset.apply_action(:insert) do
79 update_activity = stringify_keys(update_activity)
80 {:ok, update_activity, meta}
84 def validate(%{"type" => "Undo"} = object, meta) do
87 |> UndoValidator.cast_and_validate()
88 |> Ecto.Changeset.apply_action(:insert) do
89 object = stringify_keys(object)
90 undone_object = Activity.get_by_ap_id(object["object"])
94 |> Keyword.put(:object_data, undone_object.data)
100 def validate(%{"type" => "Delete"} = object, meta) do
101 with cng <- DeleteValidator.cast_and_validate(object),
102 do_not_federate <- DeleteValidator.do_not_federate?(cng),
103 {:ok, object} <- Ecto.Changeset.apply_action(cng, :insert) do
104 object = stringify_keys(object)
105 meta = Keyword.put(meta, :do_not_federate, do_not_federate)
110 def validate(%{"type" => "Like"} = object, meta) do
111 with {:ok, object} <-
113 |> LikeValidator.cast_and_validate()
114 |> Ecto.Changeset.apply_action(:insert) do
115 object = stringify_keys(object)
120 def validate(%{"type" => "ChatMessage"} = object, meta) do
121 with {:ok, object} <-
123 |> ChatMessageValidator.cast_and_validate()
124 |> Ecto.Changeset.apply_action(:insert) do
125 object = stringify_keys(object)
130 def validate(%{"type" => "Question"} = object, meta) do
131 with {:ok, object} <-
133 |> QuestionValidator.cast_and_validate()
134 |> Ecto.Changeset.apply_action(:insert) do
135 object = stringify_keys(object)
140 def validate(%{"type" => "Answer"} = object, meta) do
141 with {:ok, object} <-
143 |> AnswerValidator.cast_and_validate()
144 |> Ecto.Changeset.apply_action(:insert) do
145 object = stringify_keys(object)
150 def validate(%{"type" => "EmojiReact"} = object, meta) do
151 with {:ok, object} <-
153 |> EmojiReactValidator.cast_and_validate()
154 |> Ecto.Changeset.apply_action(:insert) do
155 object = stringify_keys(object)
161 %{"type" => "Create", "object" => %{"type" => "ChatMessage"} = object} = create_activity,
164 with {:ok, object_data} <- cast_and_apply(object),
165 meta = Keyword.put(meta, :object_data, object_data |> stringify_keys),
166 {:ok, create_activity} <-
168 |> CreateChatMessageValidator.cast_and_validate(meta)
169 |> Ecto.Changeset.apply_action(:insert) do
170 create_activity = stringify_keys(create_activity)
171 {:ok, create_activity, meta}
176 %{"type" => "Create", "object" => %{"type" => objtype} = object} = create_activity,
179 when objtype in ["Question", "Answer"] do
180 with {:ok, object_data} <- cast_and_apply(object),
181 meta = Keyword.put(meta, :object_data, object_data |> stringify_keys),
182 {:ok, create_activity} <-
184 |> CreateGenericValidator.cast_and_validate(meta)
185 |> Ecto.Changeset.apply_action(:insert) do
186 create_activity = stringify_keys(create_activity)
187 {:ok, create_activity, meta}
191 def validate(%{"type" => "Announce"} = object, meta) do
192 with {:ok, object} <-
194 |> AnnounceValidator.cast_and_validate()
195 |> Ecto.Changeset.apply_action(:insert) do
196 object = stringify_keys(object)
201 def cast_and_apply(%{"type" => "ChatMessage"} = object) do
202 ChatMessageValidator.cast_and_apply(object)
205 def cast_and_apply(%{"type" => "Question"} = object) do
206 QuestionValidator.cast_and_apply(object)
209 def cast_and_apply(%{"type" => "Answer"} = object) do
210 AnswerValidator.cast_and_apply(object)
213 def cast_and_apply(o), do: {:error, {:validator_not_set, o}}
215 # is_struct/1 isn't present in Elixir 1.8.x
216 def stringify_keys(%{__struct__: _} = object) do
222 def stringify_keys(object) when is_map(object) do
224 |> Map.new(fn {key, val} -> {to_string(key), stringify_keys(val)} end)
227 def stringify_keys(object) when is_list(object) do
229 |> Enum.map(&stringify_keys/1)
232 def stringify_keys(object), do: object
234 def fetch_actor(object) do
235 with {:ok, actor} <- ObjectValidators.ObjectID.cast(object["actor"]) do
236 User.get_or_fetch_by_ap_id(actor)
240 def fetch_actor_and_object(object) do
242 Object.normalize(object["object"], true)