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.PipelineTest do
11 describe "common_pipeline/2" do
12 test "it goes through validation, filtering, persisting, side effects and federation for local activities" do
13 activity = insert(:note_activity)
17 {Pleroma.Web.ActivityPub.ObjectValidator, [], [validate: fn o, m -> {:ok, o, m} end]},
19 Pleroma.Web.ActivityPub.MRF,
21 [filter: fn o -> {:ok, o} end]
24 Pleroma.Web.ActivityPub.ActivityPub,
26 [persist: fn o, m -> {:ok, o, m} end]
29 Pleroma.Web.ActivityPub.SideEffects,
31 [handle: fn o, m -> {:ok, o, m} end]
34 Pleroma.Web.Federator,
36 [publish: fn _o -> :ok end]
39 assert {:ok, ^activity, ^meta} =
40 Pleroma.Web.ActivityPub.Pipeline.common_pipeline(activity, meta)
42 assert_called(Pleroma.Web.ActivityPub.ObjectValidator.validate(activity, meta))
43 assert_called(Pleroma.Web.ActivityPub.MRF.filter(activity))
44 assert_called(Pleroma.Web.ActivityPub.ActivityPub.persist(activity, meta))
45 assert_called(Pleroma.Web.ActivityPub.SideEffects.handle(activity, meta))
46 assert_called(Pleroma.Web.Federator.publish(activity))
50 test "it goes through validation, filtering, persisting, side effects without federation for remote activities" do
51 activity = insert(:note_activity)
55 {Pleroma.Web.ActivityPub.ObjectValidator, [], [validate: fn o, m -> {:ok, o, m} end]},
57 Pleroma.Web.ActivityPub.MRF,
59 [filter: fn o -> {:ok, o} end]
62 Pleroma.Web.ActivityPub.ActivityPub,
64 [persist: fn o, m -> {:ok, o, m} end]
67 Pleroma.Web.ActivityPub.SideEffects,
69 [handle: fn o, m -> {:ok, o, m} end]
72 Pleroma.Web.Federator,
77 assert {:ok, ^activity, ^meta} =
78 Pleroma.Web.ActivityPub.Pipeline.common_pipeline(activity, meta)
80 assert_called(Pleroma.Web.ActivityPub.ObjectValidator.validate(activity, meta))
81 assert_called(Pleroma.Web.ActivityPub.MRF.filter(activity))
82 assert_called(Pleroma.Web.ActivityPub.ActivityPub.persist(activity, meta))
83 assert_called(Pleroma.Web.ActivityPub.SideEffects.handle(activity, meta))