Update pleroma.nginx
[akkoma] / test / web / activity_pub / activity_pub_controller_test.exs
index 957687c43143be04b17286ba28c741e76479a969..25b47ee31db4e3c32e9c91d698bded388de44542 100644 (file)
@@ -3,14 +3,16 @@ defmodule Pleroma.Web.ActivityPub.ActivityPubControllerTest do
   import Pleroma.Factory
   alias Pleroma.Web.ActivityPub.{UserView, ObjectView}
   alias Pleroma.{Repo, User}
+  alias Pleroma.Activity
 
   describe "/users/:nickname" do
     test "it returns a json representation of the user", %{conn: conn} do
       user = insert(:user)
 
-      conn = conn
-      |> put_req_header("accept", "application/activity+json")
-      |> get("/users/#{user.nickname}")
+      conn =
+        conn
+        |> put_req_header("accept", "application/activity+json")
+        |> get("/users/#{user.nickname}")
 
       user = Repo.get(User, user.id)
 
@@ -21,11 +23,12 @@ defmodule Pleroma.Web.ActivityPub.ActivityPubControllerTest do
   describe "/object/:uuid" do
     test "it returns a json representation of the object", %{conn: conn} do
       note = insert(:note)
-      uuid = String.split(note.data["id"], "/") |> List.last
+      uuid = String.split(note.data["id"], "/") |> List.last()
 
-      conn = conn
-      |> put_req_header("accept", "application/activity+json")
-      |> get("/objects/#{uuid}")
+      conn =
+        conn
+        |> put_req_header("accept", "application/activity+json")
+        |> get("/objects/#{uuid}")
 
       assert json_response(conn, 200) == ObjectView.render("object.json", %{object: note})
     end
@@ -33,14 +36,100 @@ defmodule Pleroma.Web.ActivityPub.ActivityPubControllerTest do
 
   describe "/users/:nickname/inbox" do
     test "it inserts an incoming activity into the database", %{conn: conn} do
-      data = File.read!("test/fixtures/mastodon-post-activity.json") |> Poison.decode!
+      data = File.read!("test/fixtures/mastodon-post-activity.json") |> Poison.decode!()
 
-      conn = conn
-      |> assign(:valid_signature, true)
-      |> put_req_header("content-type", "application/activity+json")
-      |> post("/users/doesntmatter/inbox", data)
+      conn =
+        conn
+        |> assign(:valid_signature, true)
+        |> put_req_header("content-type", "application/activity+json")
+        |> post("/inbox", data)
 
       assert "ok" == json_response(conn, 200)
+      :timer.sleep(500)
+      assert Activity.get_by_ap_id(data["id"])
+    end
+  end
+
+  describe "/users/:nickname/followers" do
+    test "it returns the followers in a collection", %{conn: conn} do
+      user = insert(:user)
+      user_two = insert(:user)
+      User.follow(user, user_two)
+
+      result =
+        conn
+        |> get("/users/#{user_two.nickname}/followers")
+        |> json_response(200)
+
+      assert result["first"]["orderedItems"] == [user.ap_id]
+    end
+
+    test "it works for more than 10 users", %{conn: conn} do
+      user = insert(:user)
+
+      Enum.each(1..15, fn _ ->
+        other_user = insert(:user)
+        User.follow(other_user, user)
+      end)
+
+      result =
+        conn
+        |> get("/users/#{user.nickname}/followers")
+        |> json_response(200)
+
+      assert length(result["first"]["orderedItems"]) == 10
+      assert result["first"]["totalItems"] == 15
+      assert result["totalItems"] == 15
+
+      result =
+        conn
+        |> get("/users/#{user.nickname}/followers?page=2")
+        |> json_response(200)
+
+      assert length(result["orderedItems"]) == 5
+      assert result["totalItems"] == 15
+    end
+  end
+
+  describe "/users/:nickname/following" do
+    test "it returns the following in a collection", %{conn: conn} do
+      user = insert(:user)
+      user_two = insert(:user)
+      User.follow(user, user_two)
+
+      result =
+        conn
+        |> get("/users/#{user.nickname}/following")
+        |> json_response(200)
+
+      assert result["first"]["orderedItems"] == [user_two.ap_id]
+    end
+
+    test "it works for more than 10 users", %{conn: conn} do
+      user = insert(:user)
+
+      Enum.each(1..15, fn _ ->
+        user = Repo.get(User, user.id)
+        other_user = insert(:user)
+        User.follow(user, other_user)
+      end)
+
+      result =
+        conn
+        |> get("/users/#{user.nickname}/following")
+        |> json_response(200)
+
+      assert length(result["first"]["orderedItems"]) == 10
+      assert result["first"]["totalItems"] == 15
+      assert result["totalItems"] == 15
+
+      result =
+        conn
+        |> get("/users/#{user.nickname}/following?page=2")
+        |> json_response(200)
+
+      assert length(result["orderedItems"]) == 5
+      assert result["totalItems"] == 15
     end
   end
 end