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

   1 defmodule Pleroma.Web.ActivityPub.ActivityPubControllerTest do
   2   use Pleroma.Web.ConnCase
   3   import Pleroma.Factory
   4   alias Pleroma.Web.ActivityPub.{UserView, ObjectView}
   5   alias Pleroma.{Repo, User}
   6   alias Pleroma.Activity
   7
   8   describe "/users/:nickname" do
   9     test "it returns a json representation of the user", %{conn: conn} do
  10       user = insert(:user)
  11
  12       conn =
  13         conn
  14         |> put_req_header("accept", "application/activity+json")
  15         |> get("/users/#{user.nickname}")
  16
  17       user = Repo.get(User, user.id)
  18
  19       assert json_response(conn, 200) == UserView.render("user.json", %{user: user})
  20     end
  21   end
  22
  23   describe "/object/:uuid" do
  24     test "it returns a json representation of the object", %{conn: conn} do
  25       note = insert(:note)
  26       uuid = String.split(note.data["id"], "/") |> List.last()
  27
  28       conn =
  29         conn
  30         |> put_req_header("accept", "application/activity+json")
  31         |> get("/objects/#{uuid}")
  32
  33       assert json_response(conn, 200) == ObjectView.render("object.json", %{object: note})
  34     end
  35
  36     test "it returns 404 for non-public messages", %{conn: conn} do
  37       note = insert(:direct_note)
  38       uuid = String.split(note.data["id"], "/") |> List.last()
  39
  40       conn =
  41         conn
  42         |> put_req_header("accept", "application/activity+json")
  43         |> get("/objects/#{uuid}")
  44
  45       assert json_response(conn, 404)
  46     end
  47   end
  48
  49   describe "/users/:nickname/inbox" do
  50     test "it inserts an incoming activity into the database", %{conn: conn} do
  51       data = File.read!("test/fixtures/mastodon-post-activity.json") |> Poison.decode!()
  52
  53       conn =
  54         conn
  55         |> assign(:valid_signature, true)
  56         |> put_req_header("content-type", "application/activity+json")
  57         |> post("/inbox", data)
  58
  59       assert "ok" == json_response(conn, 200)
  60       :timer.sleep(500)
  61       assert Activity.get_by_ap_id(data["id"])
  62     end
  63   end
  64
  65   describe "/users/:nickname/outbox" do
  66     test "it returns a note activity in a collection", %{conn: conn} do
  67       note_activity = insert(:note_activity)
  68       user = User.get_cached_by_ap_id(note_activity.data["actor"])
  69
  70       conn =
  71         conn
  72         |> put_req_header("accept", "application/activity+json")
  73         |> get("/users/#{user.nickname}/outbox")
  74
  75       assert response(conn, 200) =~ note_activity.data["object"]["content"]
  76     end
  77
  78     test "it returns an announce activity in a collection", %{conn: conn} do
  79       announce_activity = insert(:announce_activity)
  80       user = User.get_cached_by_ap_id(announce_activity.data["actor"])
  81
  82       conn =
  83         conn
  84         |> put_req_header("accept", "application/activity+json")
  85         |> get("/users/#{user.nickname}/outbox")
  86
  87       assert response(conn, 200) =~ announce_activity.data["object"]
  88     end
  89   end
  90
  91   describe "/users/:nickname/followers" do
  92     test "it returns the followers in a collection", %{conn: conn} do
  93       user = insert(:user)
  94       user_two = insert(:user)
  95       User.follow(user, user_two)
  96
  97       result =
  98         conn
  99         |> get("/users/#{user_two.nickname}/followers")
 100         |> json_response(200)
 101
 102       assert result["first"]["orderedItems"] == [user.ap_id]
 103     end
 104
 105     test "it works for more than 10 users", %{conn: conn} do
 106       user = insert(:user)
 107
 108       Enum.each(1..15, fn _ ->
 109         other_user = insert(:user)
 110         User.follow(other_user, user)
 111       end)
 112
 113       result =
 114         conn
 115         |> get("/users/#{user.nickname}/followers")
 116         |> json_response(200)
 117
 118       assert length(result["first"]["orderedItems"]) == 10
 119       assert result["first"]["totalItems"] == 15
 120       assert result["totalItems"] == 15
 121
 122       result =
 123         conn
 124         |> get("/users/#{user.nickname}/followers?page=2")
 125         |> json_response(200)
 126
 127       assert length(result["orderedItems"]) == 5
 128       assert result["totalItems"] == 15
 129     end
 130   end
 131
 132   describe "/users/:nickname/following" do
 133     test "it returns the following in a collection", %{conn: conn} do
 134       user = insert(:user)
 135       user_two = insert(:user)
 136       User.follow(user, user_two)
 137
 138       result =
 139         conn
 140         |> get("/users/#{user.nickname}/following")
 141         |> json_response(200)
 142
 143       assert result["first"]["orderedItems"] == [user_two.ap_id]
 144     end
 145
 146     test "it works for more than 10 users", %{conn: conn} do
 147       user = insert(:user)
 148
 149       Enum.each(1..15, fn _ ->
 150         user = Repo.get(User, user.id)
 151         other_user = insert(:user)
 152         User.follow(user, other_user)
 153       end)
 154
 155       result =
 156         conn
 157         |> get("/users/#{user.nickname}/following")
 158         |> json_response(200)
 159
 160       assert length(result["first"]["orderedItems"]) == 10
 161       assert result["first"]["totalItems"] == 15
 162       assert result["totalItems"] == 15
 163
 164       result =
 165         conn
 166         |> get("/users/#{user.nickname}/following?page=2")
 167         |> json_response(200)
 168
 169       assert length(result["orderedItems"]) == 5
 170       assert result["totalItems"] == 15
 171     end
 172   end
 173 end