diff options
| author | Ekaterina Vaartis <vaartis@kotobank.ch> | 2021-08-23 20:02:34 +0300 |
|---|---|---|
| committer | Ekaterina Vaartis <vaartis@kotobank.ch> | 2022-10-10 20:19:09 +0300 |
| commit | a67f9da5cc46b4e184aa1afe3dd1bd1df31de15b (patch) | |
| tree | fe4dbd65ee6f4da34807c2224b22b7f792fec0e9 | |
| parent | 2c7d973af7797ae860829c1764ade521a17e7263 (diff) | |
| download | pleroma-a67f9da5cc46b4e184aa1afe3dd1bd1df31de15b.tar.gz pleroma-a67f9da5cc46b4e184aa1afe3dd1bd1df31de15b.zip | |
Add a message with a count of posts to index
| -rw-r--r-- | lib/mix/tasks/pleroma/search/meilisearch.ex | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/lib/mix/tasks/pleroma/search/meilisearch.ex b/lib/mix/tasks/pleroma/search/meilisearch.ex index 230be5aa1..557b06182 100644 --- a/lib/mix/tasks/pleroma/search/meilisearch.ex +++ b/lib/mix/tasks/pleroma/search/meilisearch.ex @@ -38,7 +38,7 @@ defmodule Mix.Tasks.Pleroma.Search.Meilisearch do Pleroma.Repo.transaction( fn -> - Pleroma.Repo.stream( + query = from(Pleroma.Object, # Only index public posts which are notes and have some text where: @@ -46,7 +46,13 @@ defmodule Mix.Tasks.Pleroma.Search.Meilisearch do fragment("LENGTH(data->>'content') > 0") and fragment("data->'to' \\? ?", ^Pleroma.Constants.as_public()), order_by: [desc: fragment("data->'published'")] - ), + ) + + count = query |> Pleroma.Repo.aggregate(:count, :data) + IO.puts("Entries to index: #{count}") + + Pleroma.Repo.stream( + query, timeout: :infinity ) |> Stream.map(&Pleroma.Search.Meilisearch.object_to_search_data/1) |