Class: Kiba::Extend::Transforms::Replace::GlobalReverse

Inherits:
Object
  • Object
show all
Defined in:
lib/kiba/extend/transforms/replace/global_reverse.rb

Overview

Note:

Runs on all fields in the job where it is used.

Note:

Has no effect if ProjectConfig.global_reversible_replacements is not populated

Replaces all ProjectConfig.global_reversible_replacements value[:replace] matches with the corresponding value[:reversed] value

Examples:

# Used in pipeline as:
# transform Replace::GlobalReverse
Kiba::Extend::ProjectConfig
  .config.global_reversible_replacements = {
    /(?:\n|\r)/ => {replace: "%CR%", reversed: "\n"},
    /\t/ => {replace: "%TAB%", reversed: " "},
    /  +/ => {replace: " ", reversed: " "}
  }
xform = Replace::GlobalReverse.new
input = [{
  ant: "a%CR%b",
  bat: nil,
  cow: nil,
  dog: "c%CR%d",
  eel: "e%TAB%f",
  fawn: "g o"
}]
result = Kiba::StreamingRunner.transform_stream(input, xform)
  .map{ |row| row }
expected = [{
  ant: "a\nb",
  bat: nil,
  cow: nil,
  dog: "c\nd",
  eel: "e f",
  fawn: "g o"
}]
expect(result).to eq(expected)
Kiba::Extend::ProjectConfig.reset_config

See Also:

Instance Method Summary collapse

Constructor Details

#initialize(omit_from_all_fields: []) ⇒ GlobalReverse

Returns a new instance of GlobalReverse.

Parameters:

  • omit_from_all_fields (Array<Symbol>) (defaults to: []) —

    fields to omit from inclusion in “all” fields



49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
 
# File 'lib/kiba/extend/transforms/replace/global_reverse.rb', line 49

def initialize(omit_from_all_fields: [])
  @omit_from_all_fields = omit_from_all_fields
  @replacers =
    Kiba::Extend::ProjectConfig.global_reversible_replacements
      .values
      .reject { |config| config[:replace] == config[:reversed] }
      .map do |config|
        Clean::RegexpFindReplaceFieldVals.new(
          fields: :all,
          omit_from_all_fields: omit_from_all_fields,
          find: Regexp.new(config[:replace]),
          replace: config[:reversed]
        )
      end
end

Instance Method Details

#process(row) ⇒ Object 



65
66
67
68
 
# File 'lib/kiba/extend/transforms/replace/global_reverse.rb', line 65

def process(row)
  replacers.each { |replacer| replacer.process(row) }
  row
end