AkkomaGang/akkoma
AkkomaGang/akkoma
13
63
Fork 84
Code Issues 162 Pull requests 12 Packages Projects 2 Releases 14 Wiki Activity

Add a message with a count of posts to index

Browse source
This commit is contained in:
Ekaterina Vaartis 2021-08-23 20:02:34 +03:00 committed by FloatingGhost
parent dbf556cdcf
commit d5cc272a91
1 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
lib/mix/tasks/pleroma/search/meilisearch.ex
View file

@ -38,7 +38,7 @@ defmodule Mix.Tasks.Pleroma.Search.Meilisearch do
Pleroma.Repo.transaction( Pleroma.Repo.transaction(
fn -> fn ->
Pleroma.Repo.stream( query =
from(Pleroma.Object, from(Pleroma.Object,
# Only index public posts which are notes and have some text # Only index public posts which are notes and have some text
where: where:
@ -46,7 +46,13 @@ defmodule Mix.Tasks.Pleroma.Search.Meilisearch do
fragment("LENGTH(data->>'content') > 0") and fragment("LENGTH(data->>'content') > 0") and
fragment("data->'to' \\? ?", ^Pleroma.Constants.as_public()), fragment("data->'to' \\? ?", ^Pleroma.Constants.as_public()),
order_by: [desc: fragment("data->'published'")] 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 timeout: :infinity
) )
|> Stream.map(&Pleroma.Search.Meilisearch.object_to_search_data/1) |> Stream.map(&Pleroma.Search.Meilisearch.object_to_search_data/1)