class Procedure < ApplicationRecord include ProcedureStatsConcern include EncryptableConcern include InitiationProcedureConcern include ProcedureGroupeInstructeurAPIHackConcern include ProcedureSVASVRConcern include Discard::Model self.discard_column = :hidden_at self.ignored_columns += [ :direction, :durees_conservation_required, :cerfa_flag, :test_started_at, :lien_demarche ] default_scope -> { kept } OLD_MAX_DUREE_CONSERVATION = 36 NEW_MAX_DUREE_CONSERVATION = ENV.fetch('NEW_MAX_DUREE_CONSERVATION') { 12 }.to_i MIN_WEIGHT = 350000 DOSSIERS_COUNT_EXPIRING = 1.hour attr_encrypted :api_particulier_token has_many :revisions, -> { order(:id) }, class_name: 'ProcedureRevision', inverse_of: :procedure belongs_to :draft_revision, class_name: 'ProcedureRevision', optional: false belongs_to :published_revision, class_name: 'ProcedureRevision', optional: true has_many :deleted_dossiers, dependent: :destroy has_many :draft_types_de_champ_public, through: :draft_revision, source: :types_de_champ_public has_many :draft_types_de_champ_private, through: :draft_revision, source: :types_de_champ_private has_many :published_types_de_champ_public, through: :published_revision, source: :types_de_champ_public has_many :published_types_de_champ_private, through: :published_revision, source: :types_de_champ_private has_one :published_dossier_submitted_message, dependent: :destroy, through: :published_revision, source: :dossier_submitted_message has_one :draft_dossier_submitted_message, dependent: :destroy, through: :draft_revision, source: :dossier_submitted_message has_many :dossier_submitted_messages, through: :revisions, source: :dossier_submitted_message has_many :experts_procedures, dependent: :destroy has_many :experts, through: :experts_procedures has_many :replaced_procedures, -> { with_discarded }, inverse_of: :replaced_by_procedure, class_name: "Procedure", foreign_key: "replaced_by_procedure_id", dependent: :nullify has_one :module_api_carto, dependent: :destroy has_one :attestation_template, dependent: :destroy belongs_to :parent_procedure, class_name: 'Procedure', optional: true belongs_to :canonical_procedure, class_name: 'Procedure', optional: true belongs_to :replaced_by_procedure, -> { with_discarded }, inverse_of: :replaced_procedures, class_name: "Procedure", optional: true belongs_to :service, optional: true belongs_to :zone, optional: true has_and_belongs_to_many :zones def active_dossier_submitted_message published_dossier_submitted_message || draft_dossier_submitted_message end def active_revision brouillon? ? draft_revision : published_revision end def types_de_champ_for_procedure_presentation(parent = nil) if brouillon? if parent.nil? TypeDeChamp.fillable .joins(:revision_types_de_champ) .where(revision_types_de_champ: { revision_id: draft_revision_id, parent_id: nil }) .order(:private, :position) else draft_revision.children_of(parent) end else # all published revisions revision_ids = revisions.ids - [draft_revision_id] # fetch all parent types de champ parent_ids = if parent.present? ProcedureRevisionTypeDeChamp .where(revision_id: revision_ids) .joins(:type_de_champ) .where(type_de_champ: { stable_id: parent.stable_id }) .ids end # fetch all type_de_champ.stable_id for all the revisions expect draft # and for each stable_id take the bigger (more recent) type_de_champ.id recent_ids = TypeDeChamp .fillable .joins(:revision_types_de_champ) .where(revision_types_de_champ: { revision_id: revision_ids, parent_id: parent_ids }) .group(:stable_id).select('MAX(types_de_champ.id)') # fetch the more recent procedure_revision_types_de_champ # which includes recents_ids recents_prtdc = ProcedureRevisionTypeDeChamp .where(type_de_champ_id: recent_ids) .where.not(revision_id: draft_revision_id) .group(:type_de_champ_id) .select('MAX(id)') TypeDeChamp .joins(:revision_types_de_champ) .where(revision_types_de_champ: { id: recents_prtdc }) .order(:private, :position, 'revision_types_de_champ.revision_id': :desc) end end def types_de_champ_for_tags TypeDeChamp .fillable .joins(:revisions) .where(procedure_revisions: brouillon? ? { id: draft_revision_id } : { procedure_id: id }) .where(revision_types_de_champ: { parent_id: nil }) .order(:created_at) .distinct(:id) end def types_de_champ_public_for_tags types_de_champ_for_tags.public_only end def types_de_champ_private_for_tags types_de_champ_for_tags.private_only end def revisions_with_pending_dossiers @revisions_with_pending_dossiers ||= begin ids = dossiers .where.not(revision_id: [draft_revision_id, published_revision_id].compact) .state_en_construction_ou_instruction .distinct(:revision_id) .pluck(:revision_id) ProcedureRevision.includes(revision_types_de_champ: [:type_de_champ]).where(id: ids) end end has_many :administrateurs_procedures, dependent: :delete_all has_many :administrateurs, through: :administrateurs_procedures, after_remove: -> (procedure, _admin) { procedure.validate! } has_many :groupe_instructeurs, -> { order(:label) }, inverse_of: :procedure, dependent: :destroy has_many :instructeurs, through: :groupe_instructeurs has_many :active_groupe_instructeurs, -> { active }, class_name: 'GroupeInstructeur', inverse_of: false has_many :closed_groupe_instructeurs, -> { closed }, class_name: 'GroupeInstructeur', inverse_of: false # This relationship is used in following dossiers through. We can not use revisions relationship # as order scope introduces invalid sql in some combinations. has_many :unordered_revisions, class_name: 'ProcedureRevision', inverse_of: :procedure, dependent: :destroy has_many :dossiers, through: :unordered_revisions, dependent: :restrict_with_exception has_one :initiated_mail, class_name: "Mails::InitiatedMail", dependent: :destroy has_one :received_mail, class_name: "Mails::ReceivedMail", dependent: :destroy has_one :closed_mail, class_name: "Mails::ClosedMail", dependent: :destroy has_one :refused_mail, class_name: "Mails::RefusedMail", dependent: :destroy has_one :without_continuation_mail, class_name: "Mails::WithoutContinuationMail", dependent: :destroy belongs_to :defaut_groupe_instructeur, class_name: 'GroupeInstructeur', inverse_of: false, optional: true has_one_attached :logo has_one_attached :notice has_one_attached :deliberation scope :brouillons, -> { where(aasm_state: :brouillon) } scope :publiees, -> { where(aasm_state: :publiee) } scope :publiees_ou_brouillons, -> { where(aasm_state: [:publiee, :brouillon]) } scope :closes, -> { where(aasm_state: [:close, :depubliee]) } scope :opendata, -> { where(opendata: true) } scope :publiees_ou_closes, -> { where(aasm_state: [:publiee, :close, :depubliee]) } scope :with_external_urls, -> { where.not(lien_notice: [nil, '']).or(where.not(lien_dpo: [nil, ''])) } scope :publiques, -> do publiees_ou_closes .opendata .where('estimated_dossiers_count >= ?', 4) .where.not('lien_site_web LIKE ?', '%mail%') .where.not('lien_site_web LIKE ?', '%intra%') end scope :by_libelle, -> { order(libelle: :asc) } scope :created_during, -> (range) { where(created_at: range) } scope :cloned_from_library, -> { where(cloned_from_library: true) } scope :declarative, -> { where.not(declarative_with_state: nil) } scope :discarded_expired, -> do with_discarded .discarded .where('hidden_at < ?', 1.month.ago) end scope :for_api, -> { includes( :administrateurs, :module_api_carto, published_revision: [ :types_de_champ_private, :types_de_champ_public ], draft_revision: [ :types_de_champ_private, :types_de_champ_public ] ) } enum declarative_with_state: { en_instruction: 'en_instruction', accepte: 'accepte' } scope :for_api_v2, -> { includes(:draft_revision, :published_revision, administrateurs: :user) } scope :for_download, -> { includes( :groupe_instructeurs, dossiers: { champs_public: [ piece_justificative_file_attachments: :blob, champs: [ piece_justificative_file_attachments: :blob ] ] } ) } validates :libelle, presence: true, allow_blank: false, allow_nil: false validates :description, presence: true, allow_blank: false, allow_nil: false validates :administrateurs, presence: true validates :lien_site_web, presence: true, if: :publiee? validates :lien_notice, url: { no_local: true, allow_blank: true } validates :lien_dpo, url: { no_local: true, allow_blank: true, accept_email: true } validates :draft_types_de_champ_public, 'types_de_champ/no_empty_block': true, 'types_de_champ/no_empty_drop_down': true, on: :publication validates :draft_types_de_champ_private, 'types_de_champ/no_empty_block': true, 'types_de_champ/no_empty_drop_down': true, on: :publication validate :check_juridique, on: [:create, :publication] validates :path, presence: true, format: { with: /\A[a-z0-9_\-]{3,200}\z/ }, uniqueness: { scope: [:path, :closed_at, :hidden_at, :unpublished_at], case_sensitive: false } validates :duree_conservation_dossiers_dans_ds, allow_nil: false, numericality: { only_integer: true, greater_than_or_equal_to: 1, less_than_or_equal_to: :max_duree_conservation_dossiers_dans_ds } validates :max_duree_conservation_dossiers_dans_ds, allow_nil: false, numericality: { only_integer: true, greater_than_or_equal_to: 1, less_than_or_equal_to: 60 } validates_with MonAvisEmbedValidator validates_associated :draft_revision, on: :publication validates_associated :initiated_mail, on: :publication validates_associated :received_mail, on: :publication validates_associated :closed_mail, on: :publication validates_associated :refused_mail, on: :publication validates_associated :without_continuation_mail, on: :publication validates_associated :attestation_template, on: :publication, if: -> { attestation_template&.activated? } FILE_MAX_SIZE = 20.megabytes validates :notice, content_type: [ "application/msword", "application/pdf", "application/vnd.ms-powerpoint", "application/vnd.oasis.opendocument.presentation", "application/vnd.oasis.opendocument.text", "application/vnd.openxmlformats-officedocument.presentationml.presentation", "application/vnd.openxmlformats-officedocument.wordprocessingml.document", "image/jpeg", "image/jpg", "image/png", "text/plain" ], size: { less_than: FILE_MAX_SIZE }, if: -> { new_record? || created_at > Date.new(2020, 2, 28) } validates :deliberation, content_type: [ "application/msword", "application/pdf", "application/vnd.oasis.opendocument.text", "application/vnd.openxmlformats-officedocument.wordprocessingml.document", "image/jpeg", "image/jpg", "image/png", "text/plain" ], size: { less_than: FILE_MAX_SIZE }, if: -> { new_record? || created_at > Date.new(2020, 4, 29) } LOGO_MAX_SIZE = 5.megabytes validates :logo, content_type: ['image/png', 'image/jpg', 'image/jpeg'], size: { less_than: LOGO_MAX_SIZE }, if: -> { new_record? || created_at > Date.new(2020, 11, 13) } validates :api_entreprise_token, jwt_token: true, allow_blank: true validates :api_particulier_token, format: { with: /\A[A-Za-z0-9\-_=.]{15,}\z/ }, allow_blank: true validate :validate_auto_archive_on_in_the_future, if: :will_save_change_to_auto_archive_on? before_save :update_juridique_required after_initialize :ensure_path_exists before_save :ensure_path_exists after_create :ensure_defaut_groupe_instructeur include AASM aasm whiny_persistence: true do state :brouillon, initial: true state :publiee state :close state :depubliee event :publish, before: :before_publish do transitions from: :brouillon, to: :publiee, after: :after_publish transitions from: :close, to: :publiee, after: :after_republish transitions from: :depubliee, to: :publiee, after: :after_republish end event :close, after: :after_close do transitions from: :publiee, to: :close end event :unpublish, after: :after_unpublish do transitions from: :publiee, to: :depubliee end end def dossiers_close_to_expiration dossiers.close_to_expiration.count end def publish_or_reopen!(administrateur) Procedure.transaction do if brouillon? reset! end other_procedure = other_procedure_with_path(path) if other_procedure.present? && administrateur.owns?(other_procedure) other_procedure.unpublish! publish!(other_procedure.canonical_procedure || other_procedure) else publish! end end end def reset! if !locked? || draft_changed? dossier_ids_to_destroy = draft_revision.dossiers.ids if dossier_ids_to_destroy.present? Rails.logger.info("Resetting #{dossier_ids_to_destroy.size} dossiers on procedure #{id}: #{dossier_ids_to_destroy}") draft_revision.dossiers.destroy_all end end end def suggested_path(administrateur) if path_customized? return path end slug = libelle&.parameterize&.first(50) suggestion = slug counter = 1 while !path_available?(administrateur, suggestion) counter = counter + 1 suggestion = "#{slug}-#{counter}" end suggestion end def other_procedure_with_path(path) Procedure.publiees .where.not(id: self.id) .find_by(path: path) end def path_available?(administrateur, path) procedure = other_procedure_with_path(path) procedure.blank? || (administrateur.owns?(procedure) && canonical_procedure_child?(procedure)) end def canonical_procedure_child?(procedure) !canonical_procedure || canonical_procedure == procedure || canonical_procedure == procedure.canonical_procedure end def locked? publiee? || close? || depubliee? end def draft_changed? !brouillon? && published_revision.different_from?(draft_revision) && revision_changes.present? end def revision_changes published_revision.compare(draft_revision) end def accepts_new_dossiers? publiee? || brouillon? end def replaced_by_procedure? replaced_by_procedure_id.present? end def dossier_can_transition_to_en_construction? accepts_new_dossiers? || depubliee? end def expose_legacy_carto_api? module_api_carto&.use_api_carto? && module_api_carto&.migrated? end def declarative? declarative_with_state.present? end def declarative_accepte? declarative_with_state == Procedure.declarative_with_states.fetch(:accepte) end def declarative_en_instruction? declarative_with_state == Procedure.declarative_with_states.fetch(:en_instruction) end def self.declarative_attributes_for_select declarative_with_states.map do |state, _| [I18n.t("activerecord.attributes.#{model_name.i18n_key}.declarative_with_state/#{state}"), state] end end def feature_enabled?(feature) Flipper.enabled?(feature, self) end def path_customized? !path.match?(/[[:xdigit:]]{8}-[[:xdigit:]]{4}-[[:xdigit:]]{4}-[[:xdigit:]]{4}-[[:xdigit:]]{12}/) end def organisation_name service&.nom || organisation end def self.active(id) publiees.find(id) end def clone(admin, from_library) is_different_admin = !admin.owns?(self) populate_champ_stable_ids include_list = { attestation_template: [], draft_revision: { revision_types_de_champ: [:type_de_champ], dossier_submitted_message: [] } } include_list[:groupe_instructeurs] = :instructeurs if !is_different_admin procedure = self.deep_clone(include: include_list) do |original, kopy| PiecesJustificativesService.clone_attachments(original, kopy) end procedure.path = SecureRandom.uuid procedure.aasm_state = :brouillon procedure.closed_at = nil procedure.unpublished_at = nil procedure.published_at = nil procedure.auto_archive_on = nil procedure.lien_notice = nil procedure.duree_conservation_etendue_par_ds = false if procedure.duree_conservation_dossiers_dans_ds > NEW_MAX_DUREE_CONSERVATION procedure.duree_conservation_dossiers_dans_ds = NEW_MAX_DUREE_CONSERVATION procedure.max_duree_conservation_dossiers_dans_ds = NEW_MAX_DUREE_CONSERVATION end procedure.estimated_dossiers_count = 0 procedure.published_revision = nil procedure.draft_revision.procedure = procedure if is_different_admin procedure.administrateurs = [admin] procedure.api_entreprise_token = nil procedure.encrypted_api_particulier_token = nil procedure.opendata = true procedure.api_particulier_scopes = [] else procedure.administrateurs = administrateurs end procedure.initiated_mail = initiated_mail&.dup procedure.received_mail = received_mail&.dup procedure.closed_mail = closed_mail&.dup procedure.refused_mail = refused_mail&.dup procedure.without_continuation_mail = without_continuation_mail&.dup procedure.ask_birthday = false # see issue #4242 procedure.cloned_from_library = from_library procedure.parent_procedure = self procedure.canonical_procedure = nil procedure.replaced_by_procedure = nil procedure.service = nil if !procedure.valid? procedure.errors.attribute_names.each do |attribute| next if [:notice, :deliberation, :logo].exclude?(attribute) procedure.public_send("#{attribute}=", nil) end end transaction do procedure.save! move_new_children_to_new_parent_coordinate(procedure.draft_revision) end if is_different_admin || from_library procedure.draft_revision.types_de_champ_public.each { |tdc| tdc.options&.delete(:old_pj) } end new_defaut_groupe = procedure.groupe_instructeurs .find_by(label: defaut_groupe_instructeur.label) || procedure.groupe_instructeurs.first procedure.update!(defaut_groupe_instructeur: new_defaut_groupe) procedure end def whitelisted? whitelisted_at.present? end def total_dossier self.dossiers.state_not_brouillon.size end def procedure_overview(start_date, groups) ProcedureOverview.new(self, start_date, groups) end def initiated_mail_template initiated_mail || Mails::InitiatedMail.default_for_procedure(self) end def received_mail_template received_mail || Mails::ReceivedMail.default_for_procedure(self) end def closed_mail_template closed_mail || Mails::ClosedMail.default_for_procedure(self) end def refused_mail_template refused_mail || Mails::RefusedMail.default_for_procedure(self) end def without_continuation_mail_template without_continuation_mail || Mails::WithoutContinuationMail.default_for_procedure(self) end def mail_template_for(state) case state when Dossier.states.fetch(:en_construction) initiated_mail_template when Dossier.states.fetch(:en_instruction) received_mail_template when Dossier.states.fetch(:accepte) closed_mail_template when Dossier.states.fetch(:refuse) refused_mail_template when Dossier.states.fetch(:sans_suite) without_continuation_mail_template else raise "Unknown dossier state: #{state}" end end def self.default_sort { 'table' => 'self', 'column' => 'id', 'order' => 'desc' } end def whitelist! touch(:whitelisted_at) end def closed_mail_template_attestation_inconsistency_state # As an optimization, don’t check the predefined templates (they are presumed correct) if closed_mail.present? tag_present = closed_mail.body.to_s.include?("--lien attestation--") if attestation_template&.activated? && !tag_present :missing_tag elsif !attestation_template&.activated? && tag_present :extraneous_tag end end end def populate_champ_stable_ids TypeDeChamp .joins(:revisions) .where(procedure_revisions: { procedure_id: id }, stable_id: nil) .find_each do |type_de_champ| type_de_champ.update_column(:stable_id, type_de_champ.id) end end def missing_steps result = [] if service.nil? result << :service end if missing_instructeurs? result << :instructeurs end if missing_zones? result << :zones end result end def logo_url if logo.attached? Rails.application.routes.url_helpers.url_for(logo) else ActionController::Base.helpers.image_url(PROCEDURE_DEFAULT_LOGO_SRC) end end def missing_instructeurs? !AssignTo.exists?(groupe_instructeur: groupe_instructeurs) end def missing_zones? if Rails.application.config.ds_zonage_enabled zones.empty? else false end end def revised? revisions.size > 2 end def revisions_count # We start counting from the first revision after publication and we are not counting the draft (there is always one) revisions.size - 2 end def instructeurs_self_management? routing_enabled? || instructeurs_self_management_enabled? end def defaut_groupe_instructeur_for_new_dossier if !routing_enabled? || feature_enabled?(:procedure_routage_api) defaut_groupe_instructeur end end def groupe_instructeurs_but_defaut groupe_instructeurs - [defaut_groupe_instructeur] end def can_be_deleted_by_administrateur? brouillon? || dossiers.state_en_instruction.empty? end def can_be_deleted_by_manager? kept? && can_be_deleted_by_administrateur? end def discard_and_keep_track!(author) if brouillon? reset! elsif publiee? close! end dossiers.visible_by_administration.each do |dossier| dossier.hide_and_keep_track!(author, :procedure_removed) end discard! end def purge_discarded if dossiers.empty? destroy end end def self.purge_discarded discarded_expired.find_each(&:purge_discarded) end def restore(author) if discarded? && undiscard dossiers.hidden_by_administration.find_each do |dossier| dossier.restore(author) end end end def flipper_id "Procedure;#{id}" end def api_entreprise_role?(role) APIEntrepriseToken.new(api_entreprise_token).role?(role) end def api_entreprise_token self[:api_entreprise_token].presence || Rails.application.secrets.api_entreprise[:key] end def api_entreprise_token_expired? APIEntrepriseToken.new(api_entreprise_token).expired? end def create_new_revision(revision = nil) transaction do new_revision = (revision || draft_revision) .deep_clone(include: [:revision_types_de_champ]) .tap { |revision| revision.published_at = nil } .tap(&:save!) move_new_children_to_new_parent_coordinate(new_revision) # they are not aware of the new tdcs new_revision.types_de_champ_public.reset new_revision.types_de_champ_private.reset new_revision end end def average_dossier_weight if dossiers.termine.any? dossiers_sample = dossiers.termine.limit(100) total_size = Champ .includes(piece_justificative_file_attachments: :blob) .where(type: Champs::PieceJustificativeChamp.to_s, dossier: dossiers_sample) .sum('active_storage_blobs.byte_size') MIN_WEIGHT + total_size / dossiers_sample.length else nil end end def publish_revision! reset! transaction do self.published_revision = draft_revision self.draft_revision = create_new_revision save!(context: :publication) published_revision.touch(:published_at) end dossiers .state_not_termine .find_each(&:rebase_later) end def reset_draft_revision! if published_revision.present? && draft_changed? reset! transaction do draft_revision.types_de_champ.filter(&:only_present_on_draft?).each(&:destroy) draft_revision.update(dossier_submitted_message: nil) draft_revision.destroy update!(draft_revision: create_new_revision(published_revision)) end end end def cnaf_enabled? api_particulier_sources['cnaf'].present? end def dgfip_enabled? api_particulier_sources['dgfip'].present? end def pole_emploi_enabled? api_particulier_sources['pole_emploi'].present? end def mesri_enabled? api_particulier_sources['mesri'].present? end def published_or_created_at published_at || created_at end def publiee_or_close? publiee? || close? end def self.tags unnest = Arel::Nodes::NamedFunction.new('UNNEST', [self.arel_table[:tags]]) query = self.select(unnest.as('tags')).publiees.distinct.order('tags') self.connection.query(query.to_sql).flatten end def compute_dossiers_count now = Time.zone.now if now > (self.dossiers_count_computed_at || self.created_at) + DOSSIERS_COUNT_EXPIRING self.update(estimated_dossiers_count: self.dossiers.visible_by_administration.count, dossiers_count_computed_at: now) end end def move_new_children_to_new_parent_coordinate(new_draft) children = new_draft.revision_types_de_champ .includes(parent: :type_de_champ) .where.not(parent_id: nil) coordinates_by_stable_id = new_draft.revision_types_de_champ .includes(:type_de_champ) .index_by(&:stable_id) children.each do |child| child.update!(parent: coordinates_by_stable_id.fetch(child.parent.stable_id)) end new_draft.reload end def before_publish assign_attributes(closed_at: nil, unpublished_at: nil) end def after_publish(canonical_procedure = nil) self.canonical_procedure = canonical_procedure self.published_revision = draft_revision self.draft_revision = create_new_revision save!(context: :publication) touch(:published_at) published_revision.touch(:published_at) end def after_republish(canonical_procedure = nil) touch(:published_at) end def after_close touch(:closed_at) end def after_unpublish touch(:unpublished_at) end def update_juridique_required self.juridique_required ||= (cadre_juridique.present? || deliberation.attached?) true end def check_juridique if juridique_required? && (cadre_juridique.blank? && !deliberation.attached?) errors.add(:cadre_juridique, " : veuillez remplir le texte de loi ou la délibération") end end def ensure_path_exists if self.path.blank? self.path = SecureRandom.uuid end end def ensure_defaut_groupe_instructeur if self.groupe_instructeurs.empty? gi = groupe_instructeurs.create(label: GroupeInstructeur::DEFAUT_LABEL) self.update(defaut_groupe_instructeur_id: gi.id) end end def stable_ids_used_by_routing_rules @stable_ids_used_by_routing_rules ||= groupe_instructeurs.flat_map { _1.routing_rule&.sources }.compact end # We need this to unfuck administrate + aasm def self.human_attribute_name(attribute, options = {}) if attribute == :aasm_state 'Statut' else super end end def pieces_jointes_list? pieces_jointes_list_without_conditionnal.present? || pieces_jointes_list_with_conditionnal.present? end def pieces_jointes_list_without_conditionnal active_revision.types_de_champ_public.not_condition.filter(&:piece_justificative?) end def pieces_jointes_list_with_conditionnal active_revision.types_de_champ_public.where.not(condition: nil).filter(&:piece_justificative?) end def toggle_routing update!(routing_enabled: self.groupe_instructeurs.active.many?) end def lien_dpo_email? lien_dpo.present? && lien_dpo.match?(/@/) end private def validate_auto_archive_on_in_the_future return if auto_archive_on.nil? return if auto_archive_on.future? errors.add(:auto_archive_on, 'doit être dans le futur') end end