CLOSER-Cohorts/archivist

class Importers::TXT::Mapper::Mapping < Importers::TXT::Mapper::Instrument
  def initialize(thing, options)
    super(thing, options)
    @variables = @object.datasets.map(&:variables)
  end

  def import(options = {})
    Map.where(id: @object.maps.pluck(:id)).delete_all
    set_import_to_running
    @doc.each do |control_construct_scheme, q, dataset, v|
      log :input, "#{control_construct_scheme},#{q},#{dataset},#{v}"
      begin
        if control_construct_scheme.blank? || dataset.blank? || q.blank? || v.blank?
          raise StandardError.new(I18n.t('importers.txt.mapper.mapping.wrong_number_of_columns', actual_number_of_columns: {a: control_construct_scheme, b: q, c: v, d: dataset}.compact.count))
        elsif control_construct_scheme != @object.control_construct_scheme
          raise StandardError.new(I18n.t('importers.txt.mapper.mapping.record_invalid_control_construct_scheme', control_construct_scheme_from_line: control_construct_scheme, control_construct_scheme_from_object: @object.control_construct_scheme))
        end

        q_ident, q_coords = *q.split('$')
        qc = @object.cc_questions.find_by_label q_ident

        multidimensional_variable_finder = lambda do |name|
          return unless name
          @variables.each do |cp|
            found = cp.find_by('lower(name) = ?', name.downcase)
            return found unless found.nil?
          end
          return nil
        end

        var = multidimensional_variable_finder.call(v)
        log :matches, "matched to QuestionContruct(#{qc}) AND Variable (#{var})"
        if qc.nil? || var.nil?
          @errors = true
          log :outcome, "Record Invalid as QuestionContruct and Variable where not found"
        else
          fields = { variable: var }
          unless q_coords.nil?
            x, y = *q_coords.split(';')
            fields = fields.merge(x: x.to_i, y: y.to_i)
          end
          map = qc.maps.find_or_initialize_by variable: var, x: x.to_i, y: y.to_i
          if map.save
            log :outcome, "Record Saved"
          else
            @errors = true
            log :outcome, "Record Invalid : #{map.errors.full_messages.to_sentence}"
          end
        end
      rescue StandardError => e
        @errors = true
        log :outcome, (e.message =~ /Record Invalid/) ? e.message : "Record Invalid : #{e.message}"
      ensure
        write_to_log
      end
    end
    set_import_to_finished
  end
end