Module: Eco::API::UseCases::GraphQL::Samples::Location::Command::TrackChangedIds

Includes:
Helpers::Base::CaseEnv
Included in:
DSL
Defined in:
lib/eco/api/usecases/graphql/samples/location/command/track_changed_ids.rb

Overview

Logic to: Create tags remap csv table batch design

Constant Summary collapse

REMAP_LOC_IDS_FOLDER = 
'cache'.freeze
REMAP_LOC_IDS_FILENAME = 
'remap_loc_ids.csv'.freeze

Instance Attribute Summary collapse

Attributes included from Helpers::Base::ErrorHandling

#exception, #exiting

Attributes included from Language::AuxiliarLogger

#logger

Instance Method Summary collapse

Methods included from Language::AuxiliarLogger

#log

Instance Attribute Details

#tags_remap_csv_file ⇒ Object

Returns the value of attribute tags_remap_csv_file.



6
7
8
 
# File 'lib/eco/api/usecases/graphql/samples/location/command/track_changed_ids.rb', line 6

def tags_remap_csv_file
  @tags_remap_csv_file
end

Instance Method Details

#close_handling_tags_remap_csv ⇒ Object

Note:

this method used to only work if we could run cummulative dry-runs to the back-end. However, after RS P3, as mappings are one-to-one (not many-to-many per row), we can just display the mappings in dry-run as well.

Generates the file



31
32
33
34
35
36
37
38
39
40
 
# File 'lib/eco/api/usecases/graphql/samples/location/command/track_changed_ids.rb', line 31

def close_handling_tags_remap_csv
  if tags_remap_table.any?
    puts "REMAP LOC IDs CSV (content):"
    puts tags_remap_table
    true
  else
    log(:info) { "Remap location ids NOT needed :)" }
    false
  end
end

#generate_tags_remap_csv(filename = tags_remap_csv_full_filename) ⇒ Object

Generates the final tags remap file



65
66
67
68
69
70
71
72
73
74
75
76
77
78
 
# File 'lib/eco/api/usecases/graphql/samples/location/command/track_changed_ids.rb', line 65

def generate_tags_remap_csv(filename = tags_remap_csv_full_filename)
  return if tags_remap_table.empty?

  timestamp_file(filename).tap do |file|
    CSV.open(file, 'w') do |csv|
      csv << %w[prev_node_ids new_node_ids]

      tags_remap_table.each do |tags_remap|
        csv << tags_remap.to_csv_row
      end
    end
    log(:info) { "Generated file '#{file}'" }
  end
end

#tags_remap_class ⇒ Object 



17
18
19
 
# File 'lib/eco/api/usecases/graphql/samples/location/command/track_changed_ids.rb', line 17

def tags_remap_class
  Eco::API::UseCases::GraphQL::Helpers::Location::TagsRemap
end

#tags_remap_csv_full_filename ⇒ Object 



11
12
13
14
15
 
# File 'lib/eco/api/usecases/graphql/samples/location/command/track_changed_ids.rb', line 11

def tags_remap_csv_full_filename
  folder   = self.class::REMAP_LOC_IDS_FOLDER
  filename = self.class::REMAP_LOC_IDS_FILENAME
  File.join(folder, filename)
end

#tags_remap_table ⇒ Array<Array>

The maps of tags to be used in batch remap tags

Returns:

  • (Array<Array>) —

    source/destination pairs of Array<String>



23
24
25
 
# File 'lib/eco/api/usecases/graphql/samples/location/command/track_changed_ids.rb', line 23

def tags_remap_table
  @tags_remap_table ||= tags_remap_class.new
end

#timestamp_file(filename, enviro_relative: true) ⇒ Object

Makes the file relative to the enviro



81
82
83
84
 
# File 'lib/eco/api/usecases/graphql/samples/location/command/track_changed_ids.rb', line 81

def timestamp_file(filename, enviro_relative: true)
  filename = session.file_manager.dir.file(filename) if enviro_relative
  Eco::Data::Files.timestamp_file(filename)
end

#update_tags_remap_table(results, stage, ref_tree = nil) ⇒ Boolean

Note:

The only update operation that generate tag remaps is :id (or :id_name).

Based on commands that succeded, and the batch stage, it tracks the tag remaps that should be batches against existing pages

Returns:

  • (Boolean) —

    whether new maps were inserted to the tracking table



47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
 
# File 'lib/eco/api/usecases/graphql/samples/location/command/track_changed_ids.rb', line 47

def update_tags_remap_table(results, stage, ref_tree = nil)
  return false unless %i[id id_name].include?(stage)

  msg = "Expecting CommandResults object. Given: #{results.class}"
  raise msg unless results.is_a?(request_results_class)

  target = simulate?? results.results : results.applied

  target.each do |result|
    prev_id, new_id = result.command_input_data.values_at(:nodeId, :newId)
    next if new_id.nil? # not an id change
    next if prev_id == new_id

    tags_remap_table << [[prev_id], [new_id]]
  end
end