1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.DataCase do
7 This module defines the setup for tests requiring
8 access to the application's data layer.
10 You may define functions here to be used as helpers in
13 Finally, if the test case interacts with the database,
14 it cannot be async. For this reason, every test runs
15 inside a transaction which is reset at the beginning
16 of the test unless the test case is marked as async.
19 use ExUnit.CaseTemplate
21 import Pleroma.Tests.Helpers, only: [clear_config: 2]
30 import Pleroma.DataCase
31 use Pleroma.Tests.Helpers
33 # Sets up OAuth access with specified scopes
34 defp oauth_access(scopes, opts \\ []) do
36 Keyword.get_lazy(opts, :user, fn ->
37 Pleroma.Factory.insert(:user)
41 Keyword.get_lazy(opts, :oauth_token, fn ->
42 Pleroma.Factory.insert(:oauth_token, user: user, scopes: scopes)
45 %{user: user, token: token}
52 |> Supervisor.which_children()
54 {name, _, _, [Cachex]} ->
57 |> String.trim_leading("cachex_")
58 |> Kernel.<>("_cache")
59 |> String.to_existing_atom()
67 def setup_multi_process_mode(tags) do
68 :ok = Ecto.Adapters.SQL.Sandbox.checkout(Pleroma.Repo)
71 Mox.stub_with(Pleroma.CachexMock, Pleroma.NullCache)
74 Ecto.Adapters.SQL.Sandbox.mode(Pleroma.Repo, {:shared, self()})
77 Mox.stub_with(Pleroma.CachexMock, Pleroma.CachexProxy)
84 def setup_streamer(tags) do
85 if tags[:needs_streamer] do
87 id: Pleroma.Web.Streamer.registry(),
89 {Registry, :start_link, [[keys: :duplicate, name: Pleroma.Web.Streamer.registry()]]}
97 setup_multi_process_mode(tags)
101 Mox.verify_on_exit!()
107 Mox.stub_with(Pleroma.Web.ActivityPub.SideEffectsMock, Pleroma.Web.ActivityPub.SideEffects)
110 Pleroma.Web.ActivityPub.ObjectValidatorMock,
111 Pleroma.Web.ActivityPub.ObjectValidator
114 Mox.stub_with(Pleroma.Web.ActivityPub.MRFMock, Pleroma.Web.ActivityPub.MRF)
115 Mox.stub_with(Pleroma.Web.ActivityPub.ActivityPubMock, Pleroma.Web.ActivityPub.ActivityPub)
116 Mox.stub_with(Pleroma.Web.FederatorMock, Pleroma.Web.Federator)
117 Mox.stub_with(Pleroma.ConfigMock, Pleroma.Config)
118 Mox.stub_with(Pleroma.StaticStubbedConfigMock, Pleroma.Test.StaticConfig)
121 def ensure_local_uploader(context) do
122 test_uploader = Map.get(context, :uploader) || Pleroma.Uploaders.Local
124 clear_config([Pleroma.Upload, :uploader], test_uploader)
125 clear_config([Pleroma.Upload, :filters], [])
131 A helper that transform changeset errors to a map of messages.
133 changeset = Accounts.create_user(%{password: "short"})
134 assert "password is too short" in errors_on(changeset).password
135 assert %{password: ["password is too short"]} = errors_on(changeset)
138 def errors_on(changeset) do
139 Ecto.Changeset.traverse_errors(changeset, fn {message, opts} ->
140 Enum.reduce(opts, message, fn {key, value}, acc ->
141 String.replace(acc, "%{#{key}}", to_string(value))