No OneTemporary
Actions

Size

867 B

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
	new file mode 100644
	index 000000000..c5784df69
	--- /dev/null
	+++ b/lib/mix/tasks/pleroma/search/indexer.ex
	@@ -0,0 +1,26 @@
	+# 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
	+
	+ def run(["index"]) do
	+ start_pleroma()
	+ Pleroma.HTML.compile_scrubbers()
	+
	+ q =
	+ from(a in Pleroma.Activity,
	+ limit: 100_000
	+ )
	+
	+ Pleroma.Repo.transaction(fn ->
	+ Pleroma.Repo.stream(q, timeout: :infinity)
	+ \|> Stream.each(fn activity ->
	+ Pleroma.Search.add_to_index(activity)
	+ end)
	+ \|> Stream.run()
	+ end)
	+ end
	+end