git.squeep.com Git - akkoma/blob - test/web/activity_pub/pipeline_test.exs

   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.PipelineTest do
   6   use Pleroma.DataCase
   7
   8   import Mock
   9   import Pleroma.Factory
  10
  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)
  14       meta = [local: true]
  15
  16       with_mocks([
  17         {Pleroma.Web.ActivityPub.ObjectValidator, [], [validate: fn o, m -> {:ok, o, m} end]},
  18         {
  19           Pleroma.Web.ActivityPub.MRF,
  20           [],
  21           [filter: fn o -> {:ok, o} end]
  22         },
  23         {
  24           Pleroma.Web.ActivityPub.ActivityPub,
  25           [],
  26           [persist: fn o, m -> {:ok, o, m} end]
  27         },
  28         {
  29           Pleroma.Web.ActivityPub.SideEffects,
  30           [],
  31           [handle: fn o, m -> {:ok, o, m} end]
  32         },
  33         {
  34           Pleroma.Web.Federator,
  35           [],
  36           [publish: fn _o -> :ok end]
  37         }
  38       ]) do
  39         assert {:ok, ^activity, ^meta} =
  40                  Pleroma.Web.ActivityPub.Pipeline.common_pipeline(activity, meta)
  41
  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))
  47       end
  48     end
  49
  50     test "it goes through validation, filtering, persisting, side effects without federation for remote activities" do
  51       activity = insert(:note_activity)
  52       meta = [local: false]
  53
  54       with_mocks([
  55         {Pleroma.Web.ActivityPub.ObjectValidator, [], [validate: fn o, m -> {:ok, o, m} end]},
  56         {
  57           Pleroma.Web.ActivityPub.MRF,
  58           [],
  59           [filter: fn o -> {:ok, o} end]
  60         },
  61         {
  62           Pleroma.Web.ActivityPub.ActivityPub,
  63           [],
  64           [persist: fn o, m -> {:ok, o, m} end]
  65         },
  66         {
  67           Pleroma.Web.ActivityPub.SideEffects,
  68           [],
  69           [handle: fn o, m -> {:ok, o, m} end]
  70         },
  71         {
  72           Pleroma.Web.Federator,
  73           [],
  74           []
  75         }
  76       ]) do
  77         assert {:ok, ^activity, ^meta} =
  78                  Pleroma.Web.ActivityPub.Pipeline.common_pipeline(activity, meta)
  79
  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))
  84       end
  85     end
  86   end
  87 end