class WorkerTools::CsvInput::CsvInputForeach
Public Class Methods
new(rows_enum:, input_columns:, mapping_order:, cleanup_method:, headers_present:)
click to toggle source
# File lib/worker_tools/csv_input.rb, line 162 def initialize(rows_enum:, input_columns:, mapping_order:, cleanup_method:, headers_present:) @rows_enum = rows_enum @input_columns = input_columns @mapping_order = mapping_order @cleanup_method = cleanup_method @headers_present = headers_present end
Public Instance Methods
each() { |values_to_row(values)| ... }
click to toggle source
# File lib/worker_tools/csv_input.rb, line 170 def each return enum_for(:each) unless block_given? @rows_enum.with_index.each do |values, index| next if index.zero? && @headers_present yield values_to_row(values) end end
values_to_row(values)
click to toggle source
# File lib/worker_tools/csv_input.rb, line 180 def values_to_row(values) return values_to_row_according_to_mapping(values) if @mapping_order values_to_row_according_to_position(values) end
values_to_row_according_to_mapping(values)
click to toggle source
# File lib/worker_tools/csv_input.rb, line 186 def values_to_row_according_to_mapping(values) @mapping_order.each_with_object(HashWithIndifferentAccess.new) do |(k, v), h| h[k] = @cleanup_method.call(values[v]) end end
values_to_row_according_to_position(values)
click to toggle source
# File lib/worker_tools/csv_input.rb, line 192 def values_to_row_according_to_position(values) @input_columns.map.with_index { |c, i| [c, @cleanup_method.call(values[i])] }.to_h.with_indifferent_access end