40 lines
1.4 KiB
Ruby
40 lines
1.4 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
module DossierSearchableConcern
|
|
extend ActiveSupport::Concern
|
|
|
|
included do
|
|
after_commit :index_search_terms_later, if: -> { previously_new_record? || user_previously_changed? || mandataire_first_name_previously_changed? || mandataire_last_name_previously_changed? }
|
|
|
|
SEARCH_TERMS_DEBOUNCE = 30.seconds
|
|
|
|
kredis_flag :debounce_index_search_terms_flag
|
|
|
|
def index_search_terms
|
|
DossierPreloader.load_one(self)
|
|
|
|
search_terms = [
|
|
user&.email,
|
|
*champs_public.flat_map(&:search_terms),
|
|
*etablissement&.search_terms,
|
|
individual&.nom,
|
|
individual&.prenom,
|
|
mandataire_first_name,
|
|
mandataire_last_name
|
|
].compact_blank.join(' ')
|
|
|
|
private_search_terms = champs_private.flat_map(&:search_terms).compact_blank.join(' ')
|
|
|
|
sql = "UPDATE dossiers SET search_terms = :search_terms, private_search_terms = :private_search_terms WHERE id = :id"
|
|
sanitized_sql = self.class.sanitize_sql_array([sql, search_terms:, private_search_terms:, id:])
|
|
self.class.connection.execute(sanitized_sql)
|
|
end
|
|
|
|
def index_search_terms_later
|
|
return if debounce_index_search_terms_flag.marked?
|
|
|
|
debounce_index_search_terms_flag.mark(expires_in: SEARCH_TERMS_DEBOUNCE)
|
|
DossierIndexSearchTermsJob.set(wait: SEARCH_TERMS_DEBOUNCE).perform_later(self)
|
|
end
|
|
end
|
|
end
|