docuseal/lib/submissions.rb

# frozen_string_literal: true

module Submissions
  DEFAULT_SUBMITTERS_ORDER = 'random'

  module_function

  def maybe_update_completed_at(submission)
    viewer_uuids = submission.template_submitters.to_a.filter_map { |s| s['uuid'] if s['is_viewer'] }

    incomplete_submitter = Submitter.where(submission_id: submission.id, completed_at: nil).limit(1)
    incomplete_submitter = incomplete_submitter.where.not(uuid: viewer_uuids) if viewer_uuids.present?

    max_completed_at =
      Arel::Nodes::Grouping.new(
        Submitter.arel_table.project(Submitter.arel_table[:completed_at].maximum)
                 .where(Submitter.arel_table[:submission_id].eq(Submission.arel_table[:id]))
                 .ast
      )

    Submission.where(id: submission.id, completed_at: nil)
              .where.not(incomplete_submitter.select(1).arel.exists)
              .update_all(completed_at: max_completed_at)
              .positive?
  end

  def search(current_user, submissions, keyword, search_values: false, search_template: false)
    if Docuseal.fulltext_search?
      fulltext_search(current_user, submissions, keyword, search_template:)
    else
      plain_search(submissions, keyword, search_values:, search_template:)
    end
  end

  def plain_search(submissions, keyword, search_values: false, search_template: false)
    return submissions if keyword.blank?

    sanitized = ActiveRecord::Base.sanitize_sql_like(keyword.downcase)
    term = "%#{sanitized}%"

    arel_table = Submitter.arel_table

    submitter_arel = arel_table[:email].lower.matches(term)
                                       .or(arel_table[:phone].matches(term))
                                       .or(arel_table[:name].lower.matches(term))

    submitter_arel = submitter_arel.or(arel_table[:values].matches(term)) if search_values

    arel = Submitter.where(arel_table[:submission_id].eq(Submission.arel_table[:id]))
                    .where(submitter_arel).select(1).arel.exists

    if search_template
      submissions = submissions.left_joins(:template)

      arel = arel.or(Template.arel_table[:name].lower.matches(term))
    end

    submissions.where(arel)
  end

  def fulltext_search(current_user, submissions, keyword, search_template: false)
    return submissions if keyword.blank?

    arel = SearchEntry.where(record_type: 'Submission')
                      .where(account_id: current_user.account_id)
                      .where(*SearchEntries.build_tsquery(keyword))
                      .select(:record_id).arel

    if search_template
      arel = Arel::Nodes::Union.new(
        arel,
        Submission.where(
          template_id: SearchEntry.where(record_type: 'Template')
                                  .where(account_id: [current_user.account_id,
                                                      current_user.account.linked_account_account&.account_id].compact)
                                  .where(*SearchEntries.build_tsquery(keyword))
                                  .select(:record_id)
        ).select(:id).arel
      )
    end

    arel = Arel::Nodes::Union.new(
      arel, Submitter.joins(:search_entry)
                     .where(search_entry: { account_id: current_user.account_id })
                     .where(*SearchEntries.build_tsquery(keyword, with_or_vector: true))
                     .select(:submission_id).arel
    )

    submissions.where(Submission.arel_table[:id].in(arel))
  end

  def update_template_fields!(submission)
    submission.template_fields = submission.template.fields
    submission.variables_schema = submission.template.variables_schema
    submission.template_schema = submission.template.schema
    submission.template_submitters = submission.template.submitters if submission.template_submitters.blank?

    submission.save!
  end

  def preload_with_pages(submission)
    ActiveRecord::Associations::Preloader.new(
      records: submission.schema_documents,
      associations: [:blob, { preview_images_attachments: :blob }]
    ).call

    submission
  end

  def create_from_emails(template:, user:, emails:, source:, mark_as_sent: false, params: {})
    preferences = Submitters.normalize_preferences(user.account, user, params)

    expire_at = params[:expire_at].presence || Templates.build_default_expire_at(template)

    parse_emails(emails, user).uniq.map do |email|
      submission = template.submissions.new(created_by_user: user,
                                            account_id: user.account_id,
                                            source:,
                                            expire_at:,
                                            template_submitters: template.submitters)

      submission.submitters.new(email: normalize_email(email),
                                uuid: template.submitters.first['uuid'],
                                account_id: user.account_id,
                                preferences:,
                                sent_at: mark_as_sent ? Time.current : nil)

      Submissions::CreateFromSubmitters.maybe_set_dynamic_documents(submission)

      Submissions::CreateFromSubmitters.assign_submitters_is_viewer(submission)

      submission.save!

      if submission.expire_at?
        ProcessSubmissionExpiredJob.perform_at(submission.expire_at, 'submission_id' => submission.id,
                                                                     'expire_at' => submission.expire_at.to_i)
      end

      submission
    end
  end

  def parse_emails(emails, _user)
    emails = emails.to_s.scan(User::EMAIL_REGEXP) unless emails.is_a?(Array)

    emails
  end

  def create_from_submitters(template:, user:, submissions_attrs:, source:, with_template: true,
                             submitters_order: DEFAULT_SUBMITTERS_ORDER, params: {}, new_fields: nil)
    Submissions::CreateFromSubmitters.call(
      template:, user:, submissions_attrs:, source:, submitters_order:, params:, with_template:, new_fields:
    )
  end

  def send_signature_requests(submissions, delay: nil)
    submissions.each_with_index do |submission, index|
      delay_seconds = (delay + index).seconds if delay

      submitters_index = submission.submitters.reject(&:completed_at?).index_by(&:uuid)

      if submission.template_submitters.any? { |s| s['order'] }
        first_submitters = find_first_order_submitters(submission, submitters_index)

        Submitters.send_signature_requests(first_submitters, delay_seconds:)
      elsif submission.submitters_order_preserved?
        first_submitter = find_first_submitter(submission, submitters_index)

        if first_submitter
          first_viewers = find_first_viewers(first_submitter, submitters_index)

          Submitters.send_signature_requests([first_submitter, *first_viewers], delay_seconds:)
        elsif submission.submitters.all?(&:viewer?)
          Submitters.send_signature_requests(submitters_index.values, delay_seconds:)
        end
      else
        Submitters.send_signature_requests(submitters_index.values, delay_seconds:)
      end
    end
  end

  def find_first_order_submitters(submission, submitters_index)
    template_submitters = submission.template_submitters

    min_order = template_submitters.map.with_index { |s, i| s['order'] || i }.min

    template_submitters.filter_map { |s| submitters_index[s['uuid']] if s['order'] == min_order }
  end

  def find_first_submitter(submission, submitters_index)
    submission.template_submitters.filter_map { |s| submitters_index[s['uuid']] }.find { |s| !s.viewer? }
  end

  def find_first_viewers(first_submitter, submitters_index)
    first_submitter.submission.template_submitters.each_with_object([]) do |s, viewers|
      submitter = submitters_index[s['uuid']]

      break viewers if submitter && !submitter.viewer? && submitter != first_submitter

      viewers << submitter if submitter&.viewer?
    end
  end

  def normalize_email(email)
    return if email.blank?
    return if email.is_a?(Numeric)

    email = email.to_s.tr('/', ',')

    return email.downcase.sub(/@gmail?\z/i, '@gmail.com') if email.match?(/@gmail?\z/i)

    return email.downcase if email.include?(',') ||
                             email.match?(/\.(?:gob(?:\.\w+)?|om|mm|cm|et|mo|nz|za|ie|ed\.jp)\z/i) ||
                             email.exclude?('.')

    fixed_email = EmailTypo.call(email.delete_prefix('<'))

    return fixed_email if fixed_email == email

    domain = email.split('@').last.to_s.downcase
    fixed_domain = fixed_email.to_s.split('@').last

    return email.downcase if domain == fixed_domain
    return email.downcase if fixed_domain.match?(/\Agmail\.(?!com\z)/i)

    threshold = fixed_domain.start_with?('hotmail.') ? 2 : 3

    if DidYouMean::Levenshtein.distance(domain, fixed_domain) > threshold
      Rails.logger.info("Skipped email fix #{domain}")

      return email.downcase
    end

    Rails.logger.info("Fixed email #{domain}") if fixed_email != email.downcase.delete_prefix('<').strip

    fixed_email
  end

  def filtered_conditions_schema(submission, values: nil, include_submitter_uuid: nil)
    (submission.template_schema || submission.template.schema).filter_map do |item|
      if item['conditions'].present?
        values ||= submission.submitters.reduce({}) { |acc, sub| acc.merge(sub.values) }

        next unless check_item_conditions(item, values, submission.fields_uuid_index, include_submitter_uuid:)
      end

      item
    end
  end

  def filtered_conditions_fields(submitter, only_submitter_fields: true)
    submission = submitter.submission

    fields = submission.template_fields || submission.template.fields

    values = nil

    fields.filter_map do |field|
      next if field['submitter_uuid'] != submitter.uuid && only_submitter_fields

      if field['conditions'].present?
        values ||= submission.submitters.reduce({}) { |acc, sub| acc.merge(sub.values) }

        submitter_conditions = []

        next unless check_item_conditions(field, values, submission.fields_uuid_index,
                                          include_submitter_uuid: submitter.uuid,
                                          submitter_conditions_acc: submitter_conditions)

        field = field.merge('conditions' => submitter_conditions) if submitter_conditions != field['conditions']
      end

      field
    end
  end

  def check_item_conditions(item, values, fields_index, include_submitter_uuid: nil, submitter_conditions_acc: nil)
    return true if item['conditions'].blank?

    item['conditions'].each_with_object([]) do |condition, acc|
      result =
        if fields_index.dig(condition['field_uuid'], 'submitter_uuid') == include_submitter_uuid
          submitter_conditions_acc << condition if submitter_conditions_acc

          true
        else
          Submitters::SubmitValues.check_field_condition(condition, values, fields_index)
        end

      if condition['operation'] == 'or'
        acc.push(acc.pop || result)
      else
        acc.push(result)
      end
    end.exclude?(false)
  end

  def regenerate_documents(submission)
    submitters = submission.submitters.where.not(completed_at: nil).preload(:documents_attachments)

    submitters.each { |submitter| submitter.documents.each(&:destroy!) }

    submission.submitters.where.not(completed_at: nil).order(:completed_at).each do |submitter|
      GenerateResultAttachments.call(submitter)
    end

    return if submission.combined_document_attachment.blank?

    submission.combined_document_attachment.destroy!

    Submissions::GenerateCombinedAttachment.call(submission.submitters.completed.order(:completed_at).last)
  end
end