1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.ObjectTest do
7 use Oban.Testing, repo: Pleroma.Repo
8 import ExUnit.CaptureLog
11 alias Pleroma.Activity
14 alias Pleroma.Tests.ObanHelpers
15 alias Pleroma.Web.CommonAPI
18 mock(fn env -> apply(HttpRequestMock, :request, [env]) end)
22 test "returns an object by it's AP id" do
23 object = insert(:note)
24 found_object = Object.get_by_ap_id(object.data["id"])
26 assert object == found_object
29 describe "generic changeset" do
30 test "it ensures uniqueness of the id" do
31 object = insert(:note)
32 cs = Object.change(%Object{}, %{data: %{id: object.data["id"]}})
35 {:error, _result} = Repo.insert(cs)
39 describe "deletion function" do
40 test "deletes an object" do
41 object = insert(:note)
42 found_object = Object.get_by_ap_id(object.data["id"])
44 assert object == found_object
46 Object.delete(found_object)
48 found_object = Object.get_by_ap_id(object.data["id"])
50 refute object == found_object
52 assert found_object.data["type"] == "Tombstone"
55 test "ensures cache is cleared for the object" do
56 object = insert(:note)
57 cached_object = Object.get_cached_by_ap_id(object.data["id"])
59 assert object == cached_object
61 Cachex.put(:web_resp_cache, URI.parse(object.data["id"]).path, "cofe")
63 Object.delete(cached_object)
65 {:ok, nil} = Cachex.get(:object_cache, "object:#{object.data["id"]}")
66 {:ok, nil} = Cachex.get(:web_resp_cache, URI.parse(object.data["id"]).path)
68 cached_object = Object.get_cached_by_ap_id(object.data["id"])
70 refute object == cached_object
72 assert cached_object.data["type"] == "Tombstone"
76 describe "delete attachments" do
77 clear_config([Pleroma.Upload])
79 test "in subdirectories" do
80 Pleroma.Config.put([Pleroma.Upload, :uploader], Pleroma.Uploaders.Local)
83 content_type: "image/jpg",
84 path: Path.absname("test/fixtures/image.jpg"),
85 filename: "an_image.jpg"
90 {:ok, %Object{} = attachment} =
91 Pleroma.Web.ActivityPub.ActivityPub.upload(file, actor: user.ap_id)
93 %{data: %{"attachment" => [%{"url" => [%{"href" => href}]}]}} =
94 note = insert(:note, %{user: user, data: %{"attachment" => [attachment.data]}})
96 uploads_dir = Pleroma.Config.get!([Pleroma.Uploaders.Local, :uploads])
98 path = href |> Path.dirname() |> Path.basename()
100 assert {:ok, ["an_image.jpg"]} == File.ls("#{uploads_dir}/#{path}")
104 ObanHelpers.perform(all_enqueued(worker: Pleroma.Workers.AttachmentsCleanupWorker))
106 assert Object.get_by_id(attachment.id) == nil
108 assert {:ok, []} == File.ls("#{uploads_dir}/#{path}")
111 test "with dedupe enabled" do
112 Pleroma.Config.put([Pleroma.Upload, :uploader], Pleroma.Uploaders.Local)
113 Pleroma.Config.put([Pleroma.Upload, :filters], [Pleroma.Upload.Filter.Dedupe])
115 uploads_dir = Pleroma.Config.get!([Pleroma.Uploaders.Local, :uploads])
117 File.mkdir_p!(uploads_dir)
120 content_type: "image/jpg",
121 path: Path.absname("test/fixtures/image.jpg"),
122 filename: "an_image.jpg"
127 {:ok, %Object{} = attachment} =
128 Pleroma.Web.ActivityPub.ActivityPub.upload(file, actor: user.ap_id)
130 %{data: %{"attachment" => [%{"url" => [%{"href" => href}]}]}} =
131 note = insert(:note, %{user: user, data: %{"attachment" => [attachment.data]}})
133 filename = Path.basename(href)
135 assert {:ok, files} = File.ls(uploads_dir)
136 assert filename in files
140 ObanHelpers.perform(all_enqueued(worker: Pleroma.Workers.AttachmentsCleanupWorker))
142 assert Object.get_by_id(attachment.id) == nil
143 assert {:ok, files} = File.ls(uploads_dir)
144 refute filename in files
147 test "with objects that have legacy data.url attribute" do
148 Pleroma.Config.put([Pleroma.Upload, :uploader], Pleroma.Uploaders.Local)
151 content_type: "image/jpg",
152 path: Path.absname("test/fixtures/image.jpg"),
153 filename: "an_image.jpg"
158 {:ok, %Object{} = attachment} =
159 Pleroma.Web.ActivityPub.ActivityPub.upload(file, actor: user.ap_id)
161 {:ok, %Object{}} = Object.create(%{url: "https://google.com", actor: user.ap_id})
163 %{data: %{"attachment" => [%{"url" => [%{"href" => href}]}]}} =
164 note = insert(:note, %{user: user, data: %{"attachment" => [attachment.data]}})
166 uploads_dir = Pleroma.Config.get!([Pleroma.Uploaders.Local, :uploads])
168 path = href |> Path.dirname() |> Path.basename()
170 assert {:ok, ["an_image.jpg"]} == File.ls("#{uploads_dir}/#{path}")
174 ObanHelpers.perform(all_enqueued(worker: Pleroma.Workers.AttachmentsCleanupWorker))
176 assert Object.get_by_id(attachment.id) == nil
178 assert {:ok, []} == File.ls("#{uploads_dir}/#{path}")
182 describe "normalizer" do
183 test "fetches unknown objects by default" do
185 object = Object.normalize("http://mastodon.example.org/@admin/99541947525187367")
187 assert object.data["url"] == "http://mastodon.example.org/@admin/99541947525187367"
190 test "fetches unknown objects when fetch_remote is explicitly true" do
192 object = Object.normalize("http://mastodon.example.org/@admin/99541947525187367", true)
194 assert object.data["url"] == "http://mastodon.example.org/@admin/99541947525187367"
197 test "does not fetch unknown objects when fetch_remote is false" do
199 Object.normalize("http://mastodon.example.org/@admin/99541947525187367", false)
204 describe "get_by_id_and_maybe_refetch" do
207 %{method: :get, url: "https://patch.cx/objects/9a172665-2bc5-452d-8428-2361d4c33b1d"} ->
208 %Tesla.Env{status: 200, body: File.read!("test/fixtures/tesla_mock/poll_original.json")}
211 apply(HttpRequestMock, :request, [env])
214 mock_modified = fn resp ->
216 %{method: :get, url: "https://patch.cx/objects/9a172665-2bc5-452d-8428-2361d4c33b1d"} ->
220 apply(HttpRequestMock, :request, [env])
224 on_exit(fn -> mock(fn env -> apply(HttpRequestMock, :request, [env]) end) end)
226 [mock_modified: mock_modified]
229 test "refetches if the time since the last refetch is greater than the interval", %{
230 mock_modified: mock_modified
233 object = Object.normalize("https://patch.cx/objects/9a172665-2bc5-452d-8428-2361d4c33b1d")
235 Object.set_cache(object)
237 assert Enum.at(object.data["oneOf"], 0)["replies"]["totalItems"] == 4
238 assert Enum.at(object.data["oneOf"], 1)["replies"]["totalItems"] == 0
240 mock_modified.(%Tesla.Env{
242 body: File.read!("test/fixtures/tesla_mock/poll_modified.json")
245 updated_object = Object.get_by_id_and_maybe_refetch(object.id, interval: -1)
246 object_in_cache = Object.get_cached_by_ap_id(object.data["id"])
247 assert updated_object == object_in_cache
248 assert Enum.at(updated_object.data["oneOf"], 0)["replies"]["totalItems"] == 8
249 assert Enum.at(updated_object.data["oneOf"], 1)["replies"]["totalItems"] == 3
252 test "returns the old object if refetch fails", %{mock_modified: mock_modified} do
254 object = Object.normalize("https://patch.cx/objects/9a172665-2bc5-452d-8428-2361d4c33b1d")
256 Object.set_cache(object)
258 assert Enum.at(object.data["oneOf"], 0)["replies"]["totalItems"] == 4
259 assert Enum.at(object.data["oneOf"], 1)["replies"]["totalItems"] == 0
261 assert capture_log(fn ->
262 mock_modified.(%Tesla.Env{status: 404, body: ""})
264 updated_object = Object.get_by_id_and_maybe_refetch(object.id, interval: -1)
265 object_in_cache = Object.get_cached_by_ap_id(object.data["id"])
266 assert updated_object == object_in_cache
267 assert Enum.at(updated_object.data["oneOf"], 0)["replies"]["totalItems"] == 4
268 assert Enum.at(updated_object.data["oneOf"], 1)["replies"]["totalItems"] == 0
270 "[error] Couldn't refresh https://patch.cx/objects/9a172665-2bc5-452d-8428-2361d4c33b1d"
273 test "does not refetch if the time since the last refetch is greater than the interval", %{
274 mock_modified: mock_modified
277 object = Object.normalize("https://patch.cx/objects/9a172665-2bc5-452d-8428-2361d4c33b1d")
279 Object.set_cache(object)
281 assert Enum.at(object.data["oneOf"], 0)["replies"]["totalItems"] == 4
282 assert Enum.at(object.data["oneOf"], 1)["replies"]["totalItems"] == 0
284 mock_modified.(%Tesla.Env{
286 body: File.read!("test/fixtures/tesla_mock/poll_modified.json")
289 updated_object = Object.get_by_id_and_maybe_refetch(object.id, interval: 100)
290 object_in_cache = Object.get_cached_by_ap_id(object.data["id"])
291 assert updated_object == object_in_cache
292 assert Enum.at(updated_object.data["oneOf"], 0)["replies"]["totalItems"] == 4
293 assert Enum.at(updated_object.data["oneOf"], 1)["replies"]["totalItems"] == 0
296 test "preserves internal fields on refetch", %{mock_modified: mock_modified} do
298 object = Object.normalize("https://patch.cx/objects/9a172665-2bc5-452d-8428-2361d4c33b1d")
300 Object.set_cache(object)
302 assert Enum.at(object.data["oneOf"], 0)["replies"]["totalItems"] == 4
303 assert Enum.at(object.data["oneOf"], 1)["replies"]["totalItems"] == 0
306 activity = Activity.get_create_by_object_ap_id(object.data["id"])
307 {:ok, _activity, object} = CommonAPI.favorite(activity.id, user)
309 assert object.data["like_count"] == 1
311 mock_modified.(%Tesla.Env{
313 body: File.read!("test/fixtures/tesla_mock/poll_modified.json")
316 updated_object = Object.get_by_id_and_maybe_refetch(object.id, interval: -1)
317 object_in_cache = Object.get_cached_by_ap_id(object.data["id"])
318 assert updated_object == object_in_cache
319 assert Enum.at(updated_object.data["oneOf"], 0)["replies"]["totalItems"] == 8
320 assert Enum.at(updated_object.data["oneOf"], 1)["replies"]["totalItems"] == 3
322 assert updated_object.data["like_count"] == 1