44 lines
1.3 KiB
Ruby
44 lines
1.3 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class AccountFullTextSearchService < BaseService
|
|
def call(query, account, limit, options = {})
|
|
@query = query&.strip
|
|
@account = account
|
|
@options = options
|
|
@limit = limit.to_i
|
|
@offset = options[:offset].to_i
|
|
|
|
return if @query.blank? || @limit.zero?
|
|
|
|
perform_account_text_search!
|
|
end
|
|
|
|
private
|
|
|
|
def perform_account_text_search!
|
|
definition = parsed_query.apply(AccountsIndex.filter(term: { discoverable: true }))
|
|
|
|
results = definition.limit(@limit).offset(@offset).objects.compact
|
|
account_ids = results.map(&:id)
|
|
preloaded_relations = relations_map_for_account(@account, account_ids)
|
|
|
|
results.reject { |target_account| AccountSearchFilter.new(target_account, @account, preloaded_relations).filtered? }
|
|
rescue Faraday::ConnectionFailed, Parslet::ParseFailed
|
|
[]
|
|
end
|
|
|
|
def relations_map_for_account(account, account_ids)
|
|
presenter = AccountRelationshipsPresenter.new(account_ids, account)
|
|
{
|
|
blocking: presenter.blocking,
|
|
blocked_by: presenter.blocked_by,
|
|
muting: presenter.muting,
|
|
following: presenter.following,
|
|
domain_blocking_by_domain: presenter.domain_blocking,
|
|
}
|
|
end
|
|
|
|
def parsed_query
|
|
SearchQueryTransformer.new.apply(SearchQueryParser.new.parse(@query))
|
|
end
|
|
end
|