Git of dcc - anni/blob - test/pleroma/web/activity_pub/transmogrifier/announce_handling_test.exs

   1 # Pleroma: A lightweight social networking server
   2 # Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
   3 # SPDX-License-Identifier: AGPL-3.0-only
   4
   5 defmodule Pleroma.Web.ActivityPub.Transmogrifier.AnnounceHandlingTest do
   6   use Pleroma.DataCase
   7
   8   alias Pleroma.Activity
   9   alias Pleroma.Object
  10   alias Pleroma.Web.ActivityPub.Transmogrifier
  11   alias Pleroma.Web.CommonAPI
  12
  13   import Pleroma.Factory
  14
  15   test "it works for incoming honk announces" do
  16     user = insert(:user, ap_id: "https://honktest/u/test", local: false)
  17     other_user = insert(:user)
  18     {:ok, post} = CommonAPI.post(other_user, %{status: "bonkeronk"})
  19
  20     announce = %{
  21       "@context" => "https://www.w3.org/ns/activitystreams",
  22       "actor" => "https://honktest/u/test",
  23       "id" => "https://honktest/u/test/bonk/1793M7B9MQ48847vdx",
  24       "object" => post.data["object"],
  25       "published" => "2019-06-25T19:33:58Z",
  26       "to" => "https://www.w3.org/ns/activitystreams#Public",
  27       "type" => "Announce"
  28     }
  29
  30     {:ok, %Activity{local: false}} = Transmogrifier.handle_incoming(announce)
  31
  32     object = Object.get_by_ap_id(post.data["object"])
  33
  34     assert length(object.data["announcements"]) == 1
  35     assert user.ap_id in object.data["announcements"]
  36   end
  37
  38   test "it works for incoming announces with actor being inlined (kroeg)" do
  39     data = File.read!("test/fixtures/kroeg-announce-with-inline-actor.json") |> Jason.decode!()
  40
  41     _user = insert(:user, local: false, ap_id: data["actor"]["id"])
  42     other_user = insert(:user)
  43
  44     {:ok, post} = CommonAPI.post(other_user, %{status: "kroegeroeg"})
  45
  46     data =
  47       data
  48       |> put_in(["object", "id"], post.data["object"])
  49
  50     {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)
  51
  52     assert data["actor"] == "https://puckipedia.com/"
  53   end
  54
  55   test "it works for incoming announces, fetching the announced object" do
  56     data =
  57       File.read!("test/fixtures/mastodon-announce.json")
  58       |> Jason.decode!()
  59       |> Map.put("object", "http://mastodon.example.org/users/admin/statuses/99541947525187367")
  60
  61     Tesla.Mock.mock(fn
  62       %{method: :get} ->
  63         %Tesla.Env{
  64           status: 200,
  65           body: File.read!("test/fixtures/mastodon-note-object.json"),
  66           headers: HttpRequestMock.activitypub_object_headers()
  67         }
  68     end)
  69
  70     _user = insert(:user, local: false, ap_id: data["actor"])
  71
  72     {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)
  73
  74     assert data["actor"] == "http://mastodon.example.org/users/admin"
  75     assert data["type"] == "Announce"
  76
  77     assert data["id"] ==
  78              "http://mastodon.example.org/users/admin/statuses/99542391527669785/activity"
  79
  80     assert data["object"] ==
  81              "http://mastodon.example.org/users/admin/statuses/99541947525187367"
  82
  83     assert(Activity.get_create_by_object_ap_id(data["object"]))
  84   end
  85
  86   @tag capture_log: true
  87   test "it works for incoming announces with an existing activity" do
  88     user = insert(:user)
  89     {:ok, activity} = CommonAPI.post(user, %{status: "hey"})
  90
  91     data =
  92       File.read!("test/fixtures/mastodon-announce.json")
  93       |> Jason.decode!()
  94       |> Map.put("object", activity.data["object"])
  95
  96     _user = insert(:user, local: false, ap_id: data["actor"])
  97
  98     {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)
  99
 100     assert data["actor"] == "http://mastodon.example.org/users/admin"
 101     assert data["type"] == "Announce"
 102
 103     assert data["id"] ==
 104              "http://mastodon.example.org/users/admin/statuses/99542391527669785/activity"
 105
 106     assert data["object"] == activity.data["object"]
 107
 108     assert Activity.get_create_by_object_ap_id(data["object"]).id == activity.id
 109   end
 110
 111   # Ignore inlined activities for now
 112   @tag skip: true
 113   test "it works for incoming announces with an inlined activity" do
 114     data =
 115       File.read!("test/fixtures/mastodon-announce-private.json")
 116       |> Jason.decode!()
 117
 118     _user =
 119       insert(:user,
 120         local: false,
 121         ap_id: data["actor"],
 122         follower_address: data["actor"] <> "/followers"
 123       )
 124
 125     {:ok, %Activity{data: data, local: false}} = Transmogrifier.handle_incoming(data)
 126
 127     assert data["actor"] == "http://mastodon.example.org/users/admin"
 128     assert data["type"] == "Announce"
 129
 130     assert data["id"] ==
 131              "http://mastodon.example.org/users/admin/statuses/99542391527669785/activity"
 132
 133     object = Object.normalize(data["object"], fetch: false)
 134
 135     assert object.data["id"] == "http://mastodon.example.org/@admin/99541947525187368"
 136     assert object.data["content"] == "this is a private toot"
 137   end
 138
 139   @tag capture_log: true
 140   test "it rejects incoming announces with an inlined activity from another origin" do
 141     Tesla.Mock.mock(fn
 142       %{method: :get} -> %Tesla.Env{status: 404, body: ""}
 143     end)
 144
 145     data =
 146       File.read!("test/fixtures/bogus-mastodon-announce.json")
 147       |> Jason.decode!()
 148
 149     _user = insert(:user, local: false, ap_id: data["actor"])
 150
 151     assert {:error, _e} = Transmogrifier.handle_incoming(data)
 152   end
 153 end