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
13 clear_config([:instance, :federating], true)
17 test "it goes through validation, filtering, persisting, side effects and federation for local activities" do
18 activity = insert(:note_activity)
22 {Pleroma.Web.ActivityPub.ObjectValidator, [], [validate: fn o, m -> {:ok, o, m} end]},
24 Pleroma.Web.ActivityPub.MRF,
26 [filter: fn o -> {:ok, o} end]
29 Pleroma.Web.ActivityPub.ActivityPub,
31 [persist: fn o, m -> {:ok, o, m} end]
34 Pleroma.Web.ActivityPub.SideEffects,
37 handle: fn o, m -> {:ok, o, m} end,
38 handle_after_transaction: fn m -> m end
42 Pleroma.Web.Federator,
44 [publish: fn _o -> :ok end]
47 assert {:ok, ^activity, ^meta} =
48 Pleroma.Web.ActivityPub.Pipeline.common_pipeline(activity, meta)
50 assert_called(Pleroma.Web.ActivityPub.ObjectValidator.validate(activity, meta))
51 assert_called(Pleroma.Web.ActivityPub.MRF.filter(activity))
52 assert_called(Pleroma.Web.ActivityPub.ActivityPub.persist(activity, meta))
53 assert_called(Pleroma.Web.ActivityPub.SideEffects.handle(activity, meta))
54 assert_called(Pleroma.Web.Federator.publish(activity))
58 test "it goes through validation, filtering, persisting, side effects without federation for remote activities" do
59 activity = insert(:note_activity)
63 {Pleroma.Web.ActivityPub.ObjectValidator, [], [validate: fn o, m -> {:ok, o, m} end]},
65 Pleroma.Web.ActivityPub.MRF,
67 [filter: fn o -> {:ok, o} end]
70 Pleroma.Web.ActivityPub.ActivityPub,
72 [persist: fn o, m -> {:ok, o, m} end]
75 Pleroma.Web.ActivityPub.SideEffects,
77 [handle: fn o, m -> {:ok, o, m} end, handle_after_transaction: fn m -> m end]
80 Pleroma.Web.Federator,
85 assert {:ok, ^activity, ^meta} =
86 Pleroma.Web.ActivityPub.Pipeline.common_pipeline(activity, meta)
88 assert_called(Pleroma.Web.ActivityPub.ObjectValidator.validate(activity, meta))
89 assert_called(Pleroma.Web.ActivityPub.MRF.filter(activity))
90 assert_called(Pleroma.Web.ActivityPub.ActivityPub.persist(activity, meta))
91 assert_called(Pleroma.Web.ActivityPub.SideEffects.handle(activity, meta))
95 test "it goes through validation, filtering, persisting, side effects without federation for local activities if federation is deactivated" do
96 clear_config([:instance, :federating], false)
98 activity = insert(:note_activity)
102 {Pleroma.Web.ActivityPub.ObjectValidator, [], [validate: fn o, m -> {:ok, o, m} end]},
104 Pleroma.Web.ActivityPub.MRF,
106 [filter: fn o -> {:ok, o} end]
109 Pleroma.Web.ActivityPub.ActivityPub,
111 [persist: fn o, m -> {:ok, o, m} end]
114 Pleroma.Web.ActivityPub.SideEffects,
116 [handle: fn o, m -> {:ok, o, m} end, handle_after_transaction: fn m -> m end]
119 Pleroma.Web.Federator,
124 assert {:ok, ^activity, ^meta} =
125 Pleroma.Web.ActivityPub.Pipeline.common_pipeline(activity, meta)
127 assert_called(Pleroma.Web.ActivityPub.ObjectValidator.validate(activity, meta))
128 assert_called(Pleroma.Web.ActivityPub.MRF.filter(activity))
129 assert_called(Pleroma.Web.ActivityPub.ActivityPub.persist(activity, meta))
130 assert_called(Pleroma.Web.ActivityPub.SideEffects.handle(activity, meta))