git.squeep.com Git - akkoma/blob - lib/pleroma/search.ex

   1 defmodule Pleroma.Search do
   2   def add_to_index(activity) do
   3     search_module = Pleroma.Config.get([Pleroma.Search, :module])
   4
   5     ConcurrentLimiter.limit(Pleroma.Search, fn ->
   6       Task.start(fn -> search_module.add_to_index(activity) end)
   7     end)
   8   end
   9
  10   def remove_from_index(object) do
  11     # Also delete from search index
  12     search_module = Pleroma.Config.get([Pleroma.Search, :module])
  13
  14     ConcurrentLimiter.limit(Pleroma.Search, fn ->
  15       Task.start(fn -> search_module.remove_from_index(object) end)
  16     end)
  17   end
  18
  19   def search(query, options) do
  20     search_module = Pleroma.Config.get([Pleroma.Search, :module], Pleroma.Activity)
  21
  22     search_module.search(options[:for_user], query, options)
  23   end
  24 end