# Pleroma: A lightweight social networking server # Copyright © 2017-2021 Pleroma Authors # SPDX-License-Identifier: AGPL-3.0-only defmodule Pleroma.Search.MeilisearchTest do require Pleroma.Constants use Pleroma.DataCase use Oban.Testing, repo: Pleroma.Repo import Pleroma.Factory import Tesla.Mock import Mock alias Pleroma.Search.Meilisearch alias Pleroma.Web.CommonAPI alias Pleroma.Workers.SearchIndexingWorker setup_all do Tesla.Mock.mock_global(fn env -> apply(HttpRequestMock, :request, [env]) end) :ok end describe "meilisearch" do setup do: clear_config([Pleroma.Search, :module], Meilisearch) setup_with_mocks( [ {Meilisearch, [:passthrough], [ add_to_index: fn a -> passthrough([a]) end, remove_from_index: fn a -> passthrough([a]) end, meili_put: fn u, a -> passthrough([u, a]) end ]} ], context, do: {:ok, context} ) test "indexes a local post on creation" do user = insert(:user) mock_global(fn %{method: :put, url: "http://127.0.0.1:7700/indexes/objects/documents", body: body} -> assert match?( [%{"content" => "guys i just don't wanna leave the swamp"}], Jason.decode!(body) ) json(%{updateId: 1}) end) {:ok, activity} = CommonAPI.post(user, %{ status: "guys i just don't wanna leave the swamp", visibility: "public" }) args = %{"op" => "add_to_index", "activity" => activity.id} assert_enqueued( worker: SearchIndexingWorker, args: args ) assert :ok = perform_job(SearchIndexingWorker, args) assert_called(Meilisearch.add_to_index(activity)) end test "doesn't index posts that are not public" do user = insert(:user) Enum.each(["unlisted", "private", "direct"], fn visiblity -> {:ok, activity} = CommonAPI.post(user, %{ status: "guys i just don't wanna leave the swamp", visibility: visiblity }) Meilisearch.add_to_index(activity) assert_not_called(Meilisearch.meili_put(:_)) end) history = call_history(Meilisearch) assert Enum.count(history) == 3 end test "deletes posts from index when deleted locally" do user = insert(:user) mock_global(fn %{method: :put, url: "http://127.0.0.1:7700/indexes/objects/documents", body: body} -> assert match?( [%{"content" => "guys i just don't wanna leave the swamp"}], Jason.decode!(body) ) json(%{updateId: 1}) %{method: :delete, url: "http://127.0.0.1:7700/indexes/objects/documents/" <> id} -> assert String.length(id) > 1 json(%{updateId: 2}) end) {:ok, activity} = CommonAPI.post(user, %{ status: "guys i just don't wanna leave the swamp", visibility: "public" }) args = %{"op" => "add_to_index", "activity" => activity.id} assert_enqueued(worker: SearchIndexingWorker, args: args) assert :ok = perform_job(SearchIndexingWorker, args) {:ok, _} = CommonAPI.delete(activity.id, user) delete_args = %{"op" => "remove_from_index", "object" => activity.object.id} assert_enqueued(worker: SearchIndexingWorker, args: delete_args) assert :ok = perform_job(SearchIndexingWorker, delete_args) assert_called(Meilisearch.remove_from_index(:_)) end end end