No OneTemporary
Actions

Size

1 KB

Referenced Files

None

Subscribers

None

View Options

	diff --git a/lib/mix/tasks/pleroma/search/indexer.ex b/lib/mix/tasks/pleroma/search/indexer.ex
	index ae08f6410..2704ab9f1 100644
	--- a/lib/mix/tasks/pleroma/search/indexer.ex
	+++ b/lib/mix/tasks/pleroma/search/indexer.ex
	@@ -1,54 +1,57 @@
	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2021 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Mix.Tasks.Pleroma.Search.Indexer do
	import Mix.Pleroma
	import Ecto.Query

	alias Pleroma.Workers.SearchIndexingWorker

	def run(["index" \| options]) do
	{options, [], []} =
	OptionParser.parse(
	options,
	strict: [
	limit: :integer
	]
	)

	start_pleroma()

	limit = Keyword.get(options, :limit, 100_000)

	q =
	from(a in Pleroma.Activity,
	limit: ^limit,
	+ select: [:id],
	order_by: [desc: :id]
	)

	{:ok, ids} =
	Pleroma.Repo.transaction(fn ->
	Pleroma.Repo.stream(q, timeout: :infinity)
	- \|> Enum.map(fn a -> a.id end)
	+ \|> Enum.map(fn a ->
	+ a.id
	+ end)
	end)

	IO.puts("Got #{length(ids)} activities, adding to indexer")

	ids
	\|> Enum.chunk_every(100)
	\|> Enum.each(fn chunk ->
	IO.puts("Adding #{length(chunk)} activities to indexing queue")

	chunk
	\|> Enum.map(fn id ->
	SearchIndexingWorker.new(%{"op" => "add_to_index", "activity" => id})
	end)
	\|> Oban.insert_all()
	end)

	# \|> Stream.each(fn activity ->
	# Pleroma.Search.add_to_index(activity)
	# end)
	end
	end