1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2020 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()
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()})
75 Mox.stub_with(Pleroma.CachexMock, Pleroma.CachexProxy)
80 if tags[:needs_streamer] do
82 id: Pleroma.Web.Streamer.registry(),
84 {Registry, :start_link, [[keys: :duplicate, name: Pleroma.Web.Streamer.registry()]]}
96 Mox.stub_with(Pleroma.Web.ActivityPub.SideEffectsMock, Pleroma.Web.ActivityPub.SideEffects)
99 Pleroma.Web.ActivityPub.ObjectValidatorMock,
100 Pleroma.Web.ActivityPub.ObjectValidator
103 Mox.stub_with(Pleroma.Web.ActivityPub.MRFMock, Pleroma.Web.ActivityPub.MRF)
104 Mox.stub_with(Pleroma.Web.ActivityPub.ActivityPubMock, Pleroma.Web.ActivityPub.ActivityPub)
105 Mox.stub_with(Pleroma.Web.FederatorMock, Pleroma.Web.Federator)
106 Mox.stub_with(Pleroma.ConfigMock, Pleroma.Config)
109 def ensure_local_uploader(context) do
110 test_uploader = Map.get(context, :uploader) || Pleroma.Uploaders.Local
112 clear_config([Pleroma.Upload, :uploader], test_uploader)
113 clear_config([Pleroma.Upload, :filters], [])
119 A helper that transform changeset errors to a map of messages.
121 changeset = Accounts.create_user(%{password: "short"})
122 assert "password is too short" in errors_on(changeset).password
123 assert %{password: ["password is too short"]} = errors_on(changeset)
126 def errors_on(changeset) do
127 Ecto.Changeset.traverse_errors(changeset, fn {message, opts} ->
128 Enum.reduce(opts, message, fn {key, value}, acc ->
129 String.replace(acc, "%{#{key}}", to_string(value))