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
28 import Pleroma.DataCase
29 use Pleroma.Tests.Helpers
31 # Sets up OAuth access with specified scopes
32 defp oauth_access(scopes, opts \\ []) do
34 Keyword.get_lazy(opts, :user, fn ->
35 Pleroma.Factory.insert(:user)
39 Keyword.get_lazy(opts, :oauth_token, fn ->
40 Pleroma.Factory.insert(:oauth_token, user: user, scopes: scopes)
43 %{user: user, token: token}
50 |> Supervisor.which_children()
52 {name, _, _, [Cachex]} ->
55 |> String.trim_leading("cachex_")
56 |> Kernel.<>("_cache")
57 |> String.to_existing_atom()
66 :ok = Ecto.Adapters.SQL.Sandbox.checkout(Pleroma.Repo)
69 Mox.stub_with(Pleroma.CachexMock, Pleroma.NullCache)
72 Ecto.Adapters.SQL.Sandbox.mode(Pleroma.Repo, {:shared, self()})
73 Mox.stub_with(Pleroma.CachexMock, Pleroma.CachexProxy)
78 if tags[:needs_streamer] do
80 id: Pleroma.Web.Streamer.registry(),
82 {Registry, :start_link, [[keys: :duplicate, name: Pleroma.Web.Streamer.registry()]]}
92 Mox.stub_with(Pleroma.Web.ActivityPub.SideEffectsMock, Pleroma.Web.ActivityPub.SideEffects)
95 Pleroma.Web.ActivityPub.ObjectValidatorMock,
96 Pleroma.Web.ActivityPub.ObjectValidator
99 Mox.stub_with(Pleroma.Web.ActivityPub.MRFMock, Pleroma.Web.ActivityPub.MRF)
100 Mox.stub_with(Pleroma.Web.ActivityPub.ActivityPubMock, Pleroma.Web.ActivityPub.ActivityPub)
101 Mox.stub_with(Pleroma.Web.FederatorMock, Pleroma.Web.Federator)
102 Mox.stub_with(Pleroma.ConfigMock, Pleroma.Config)
105 def ensure_local_uploader(context) do
106 test_uploader = Map.get(context, :uploader, Pleroma.Uploaders.Local)
107 uploader = Pleroma.Config.get([Pleroma.Upload, :uploader])
108 filters = Pleroma.Config.get([Pleroma.Upload, :filters])
110 Pleroma.Config.put([Pleroma.Upload, :uploader], test_uploader)
111 Pleroma.Config.put([Pleroma.Upload, :filters], [])
114 Pleroma.Config.put([Pleroma.Upload, :uploader], uploader)
115 Pleroma.Config.put([Pleroma.Upload, :filters], filters)
122 A helper that transform changeset errors to a map of messages.
124 changeset = Accounts.create_user(%{password: "short"})
125 assert "password is too short" in errors_on(changeset).password
126 assert %{password: ["password is too short"]} = errors_on(changeset)
129 def errors_on(changeset) do
130 Ecto.Changeset.traverse_errors(changeset, fn {message, opts} ->
131 Enum.reduce(opts, message, fn {key, value}, acc ->
132 String.replace(acc, "%{#{key}}", to_string(value))