1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2021 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Mix.Tasks.Pleroma.Search do
9 alias Pleroma.Elasticsearch
10 alias Pleroma.Activity
12 alias Pleroma.Pagination
14 @shortdoc "Manages elasticsearch"
16 def run(["import" | rest]) do
19 query = from(a in Activity, where: not ilike(a.actor, "%/relay"))
20 |> Activity.with_preloaded_object
21 |> Activity.with_preloaded_user_actor
25 defp get_all(query, max_id \\ nil) do
27 params = if max_id == nil do
30 Map.put(params, :max_id, max_id)
34 |> Pagination.fetch_paginated(params)
40 |> Pleroma.Elasticsearch.bulk_post(:activities)
42 get_all(query, List.last(res).id)