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}")
181 test "With custom base_url" do
182 Pleroma.Config.put([Pleroma.Upload, :uploader], Pleroma.Uploaders.Local)
183 Pleroma.Config.put([Pleroma.Upload, :base_url], "https://sub.domain.tld/dir/")
186 content_type: "image/jpg",
187 path: Path.absname("test/fixtures/image.jpg"),
188 filename: "an_image.jpg"
193 {:ok, %Object{} = attachment} =
194 Pleroma.Web.ActivityPub.ActivityPub.upload(file, actor: user.ap_id)
196 %{data: %{"attachment" => [%{"url" => [%{"href" => href}]}]}} =
197 note = insert(:note, %{user: user, data: %{"attachment" => [attachment.data]}})
199 uploads_dir = Pleroma.Config.get!([Pleroma.Uploaders.Local, :uploads])
201 path = href |> Path.dirname() |> Path.basename()
203 assert {:ok, ["an_image.jpg"]} == File.ls("#{uploads_dir}/#{path}")
207 ObanHelpers.perform(all_enqueued(worker: Pleroma.Workers.AttachmentsCleanupWorker))
209 assert Object.get_by_id(attachment.id) == nil
211 assert {:ok, []} == File.ls("#{uploads_dir}/#{path}")
215 describe "normalizer" do
216 test "fetches unknown objects by default" do
218 object = Object.normalize("http://mastodon.example.org/@admin/99541947525187367")
220 assert object.data["url"] == "http://mastodon.example.org/@admin/99541947525187367"
223 test "fetches unknown objects when fetch_remote is explicitly true" do
225 object = Object.normalize("http://mastodon.example.org/@admin/99541947525187367", true)
227 assert object.data["url"] == "http://mastodon.example.org/@admin/99541947525187367"
230 test "does not fetch unknown objects when fetch_remote is false" do
232 Object.normalize("http://mastodon.example.org/@admin/99541947525187367", false)
237 describe "get_by_id_and_maybe_refetch" do
240 %{method: :get, url: "https://patch.cx/objects/9a172665-2bc5-452d-8428-2361d4c33b1d"} ->
241 %Tesla.Env{status: 200, body: File.read!("test/fixtures/tesla_mock/poll_original.json")}
244 apply(HttpRequestMock, :request, [env])
247 mock_modified = fn resp ->
249 %{method: :get, url: "https://patch.cx/objects/9a172665-2bc5-452d-8428-2361d4c33b1d"} ->
253 apply(HttpRequestMock, :request, [env])
257 on_exit(fn -> mock(fn env -> apply(HttpRequestMock, :request, [env]) end) end)
259 [mock_modified: mock_modified]
262 test "refetches if the time since the last refetch is greater than the interval", %{
263 mock_modified: mock_modified
266 object = Object.normalize("https://patch.cx/objects/9a172665-2bc5-452d-8428-2361d4c33b1d")
268 Object.set_cache(object)
270 assert Enum.at(object.data["oneOf"], 0)["replies"]["totalItems"] == 4
271 assert Enum.at(object.data["oneOf"], 1)["replies"]["totalItems"] == 0
273 mock_modified.(%Tesla.Env{
275 body: File.read!("test/fixtures/tesla_mock/poll_modified.json")
278 updated_object = Object.get_by_id_and_maybe_refetch(object.id, interval: -1)
279 object_in_cache = Object.get_cached_by_ap_id(object.data["id"])
280 assert updated_object == object_in_cache
281 assert Enum.at(updated_object.data["oneOf"], 0)["replies"]["totalItems"] == 8
282 assert Enum.at(updated_object.data["oneOf"], 1)["replies"]["totalItems"] == 3
285 test "returns the old object if refetch fails", %{mock_modified: mock_modified} do
287 object = Object.normalize("https://patch.cx/objects/9a172665-2bc5-452d-8428-2361d4c33b1d")
289 Object.set_cache(object)
291 assert Enum.at(object.data["oneOf"], 0)["replies"]["totalItems"] == 4
292 assert Enum.at(object.data["oneOf"], 1)["replies"]["totalItems"] == 0
294 assert capture_log(fn ->
295 mock_modified.(%Tesla.Env{status: 404, body: ""})
297 updated_object = Object.get_by_id_and_maybe_refetch(object.id, interval: -1)
298 object_in_cache = Object.get_cached_by_ap_id(object.data["id"])
299 assert updated_object == object_in_cache
300 assert Enum.at(updated_object.data["oneOf"], 0)["replies"]["totalItems"] == 4
301 assert Enum.at(updated_object.data["oneOf"], 1)["replies"]["totalItems"] == 0
303 "[error] Couldn't refresh https://patch.cx/objects/9a172665-2bc5-452d-8428-2361d4c33b1d"
306 test "does not refetch if the time since the last refetch is greater than the interval", %{
307 mock_modified: mock_modified
310 object = Object.normalize("https://patch.cx/objects/9a172665-2bc5-452d-8428-2361d4c33b1d")
312 Object.set_cache(object)
314 assert Enum.at(object.data["oneOf"], 0)["replies"]["totalItems"] == 4
315 assert Enum.at(object.data["oneOf"], 1)["replies"]["totalItems"] == 0
317 mock_modified.(%Tesla.Env{
319 body: File.read!("test/fixtures/tesla_mock/poll_modified.json")
322 updated_object = Object.get_by_id_and_maybe_refetch(object.id, interval: 100)
323 object_in_cache = Object.get_cached_by_ap_id(object.data["id"])
324 assert updated_object == object_in_cache
325 assert Enum.at(updated_object.data["oneOf"], 0)["replies"]["totalItems"] == 4
326 assert Enum.at(updated_object.data["oneOf"], 1)["replies"]["totalItems"] == 0
329 test "preserves internal fields on refetch", %{mock_modified: mock_modified} do
331 object = Object.normalize("https://patch.cx/objects/9a172665-2bc5-452d-8428-2361d4c33b1d")
333 Object.set_cache(object)
335 assert Enum.at(object.data["oneOf"], 0)["replies"]["totalItems"] == 4
336 assert Enum.at(object.data["oneOf"], 1)["replies"]["totalItems"] == 0
339 activity = Activity.get_create_by_object_ap_id(object.data["id"])
340 {:ok, _activity, object} = CommonAPI.favorite(activity.id, user)
342 assert object.data["like_count"] == 1
344 mock_modified.(%Tesla.Env{
346 body: File.read!("test/fixtures/tesla_mock/poll_modified.json")
349 updated_object = Object.get_by_id_and_maybe_refetch(object.id, interval: -1)
350 object_in_cache = Object.get_cached_by_ap_id(object.data["id"])
351 assert updated_object == object_in_cache
352 assert Enum.at(updated_object.data["oneOf"], 0)["replies"]["totalItems"] == 8
353 assert Enum.at(updated_object.data["oneOf"], 1)["replies"]["totalItems"] == 3
355 assert updated_object.data["like_count"] == 1