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 "/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/inbox" do
  66     test "it inserts an incoming activity into the database", %{conn: conn} do
  67       user = insert(:user)
  68
  69       data =
  70         File.read!("test/fixtures/mastodon-post-activity.json")
  71         |> Poison.decode!()
  72         |> Map.put("bcc", [user.ap_id])
  73
  74       conn =
  75         conn
  76         |> assign(:valid_signature, true)
  77         |> put_req_header("content-type", "application/activity+json")
  78         |> post("/users/#{user.nickname}/inbox", data)
  79
  80       assert "ok" == json_response(conn, 200)
  81       :timer.sleep(500)
  82       assert Activity.get_by_ap_id(data["id"])
  83     end
  84   end
  85
  86   describe "/users/:nickname/outbox" do
  87     test "it returns a note activity in a collection", %{conn: conn} do
  88       note_activity = insert(:note_activity)
  89       user = User.get_cached_by_ap_id(note_activity.data["actor"])
  90
  91       conn =
  92         conn
  93         |> put_req_header("accept", "application/activity+json")
  94         |> get("/users/#{user.nickname}/outbox")
  95
  96       assert response(conn, 200) =~ note_activity.data["object"]["content"]
  97     end
  98
  99     test "it returns an announce activity in a collection", %{conn: conn} do
 100       announce_activity = insert(:announce_activity)
 101       user = User.get_cached_by_ap_id(announce_activity.data["actor"])
 102
 103       conn =
 104         conn
 105         |> put_req_header("accept", "application/activity+json")
 106         |> get("/users/#{user.nickname}/outbox")
 107
 108       assert response(conn, 200) =~ announce_activity.data["object"]
 109     end
 110   end
 111
 112   describe "/users/:nickname/followers" do
 113     test "it returns the followers in a collection", %{conn: conn} do
 114       user = insert(:user)
 115       user_two = insert(:user)
 116       User.follow(user, user_two)
 117
 118       result =
 119         conn
 120         |> get("/users/#{user_two.nickname}/followers")
 121         |> json_response(200)
 122
 123       assert result["first"]["orderedItems"] == [user.ap_id]
 124     end
 125
 126     test "it works for more than 10 users", %{conn: conn} do
 127       user = insert(:user)
 128
 129       Enum.each(1..15, fn _ ->
 130         other_user = insert(:user)
 131         User.follow(other_user, user)
 132       end)
 133
 134       result =
 135         conn
 136         |> get("/users/#{user.nickname}/followers")
 137         |> json_response(200)
 138
 139       assert length(result["first"]["orderedItems"]) == 10
 140       assert result["first"]["totalItems"] == 15
 141       assert result["totalItems"] == 15
 142
 143       result =
 144         conn
 145         |> get("/users/#{user.nickname}/followers?page=2")
 146         |> json_response(200)
 147
 148       assert length(result["orderedItems"]) == 5
 149       assert result["totalItems"] == 15
 150     end
 151   end
 152
 153   describe "/users/:nickname/following" do
 154     test "it returns the following in a collection", %{conn: conn} do
 155       user = insert(:user)
 156       user_two = insert(:user)
 157       User.follow(user, user_two)
 158
 159       result =
 160         conn
 161         |> get("/users/#{user.nickname}/following")
 162         |> json_response(200)
 163
 164       assert result["first"]["orderedItems"] == [user_two.ap_id]
 165     end
 166
 167     test "it works for more than 10 users", %{conn: conn} do
 168       user = insert(:user)
 169
 170       Enum.each(1..15, fn _ ->
 171         user = Repo.get(User, user.id)
 172         other_user = insert(:user)
 173         User.follow(user, other_user)
 174       end)
 175
 176       result =
 177         conn
 178         |> get("/users/#{user.nickname}/following")
 179         |> json_response(200)
 180
 181       assert length(result["first"]["orderedItems"]) == 10
 182       assert result["first"]["totalItems"] == 15
 183       assert result["totalItems"] == 15
 184
 185       result =
 186         conn
 187         |> get("/users/#{user.nickname}/following?page=2")
 188         |> json_response(200)
 189
 190       assert length(result["orderedItems"]) == 5
 191       assert result["totalItems"] == 15
 192     end
 193   end
 194 end