# frozen_string_literal: true

module DossierSearchableConcern
  extend ActiveSupport::Concern

  included do
    after_commit :update_search_terms_later

    SEARCH_TERMS_DEBOUNCE = 30.seconds

    kredis_flag :debounce_update_search_terms_flag

    def update_search_terms
      search_terms = [
        user&.email,
        *champs_public.flat_map(&:search_terms),
        *etablissement&.search_terms,
        individual&.nom,
        individual&.prenom
      ].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 update_search_terms_later
      return if debounce_update_search_terms_flag.marked?

      debounce_update_search_terms_flag.mark(expires_in: SEARCH_TERMS_DEBOUNCE)
      DossierUpdateSearchTermsJob.set(wait: SEARCH_TERMS_DEBOUNCE).perform_later(self)
    end
  end
end