Add an option to store record changes

lib/inventory_refresh/inventory_collection.rb

@@ -94,7 +94,7 @@ class InventoryCollection
 
     attr_accessor :attributes_blacklist, :attributes_whitelist
 
-    attr_reader :model_class, :strategy, :custom_save_block, :parent, :internal_attributes, :delete_method, :dependency_attributes, :manager_ref, :create_only, :association, :complete, :update_only, :transitive_dependency_attributes, :check_changed, :arel, :inventory_object_attributes, :name, :saver_strategy, :targeted_scope, :default_values, :targeted_arel, :targeted, :manager_ref_allowed_nil, :use_ar_object, :created_records, :updated_records, :deleted_records, :retention_strategy, :custom_reconnect_block, :batch_extra_attributes, :references_storage, :unconnected_edges, :assert_graph_integrity
+    attr_reader :model_class, :strategy, :custom_save_block, :parent, :internal_attributes, :delete_method, :dependency_attributes, :manager_ref, :create_only, :association, :complete, :update_only, :transitive_dependency_attributes, :check_changed, :arel, :inventory_object_attributes, :name, :saver_strategy, :targeted_scope, :default_values, :targeted_arel, :targeted, :manager_ref_allowed_nil, :use_ar_object, :created_records, :updated_records, :deleted_records, :retention_strategy, :custom_reconnect_block, :batch_extra_attributes, :references_storage, :unconnected_edges, :assert_graph_integrity, :store_record_changes, :record_changes
 
     delegate :<<,
              :build,
@@ -149,7 +149,8 @@ def initialize(properties = {})
                  properties[:update_only],
                  properties[:use_ar_object],
                  properties[:targeted],
-                 properties[:assert_graph_integrity])
+                 properties[:assert_graph_integrity],
+                 properties[:store_record_changes])
 
       init_strategies(properties[:strategy],
                       properties[:saver_strategy],
@@ -214,6 +215,11 @@ def store_deleted_records(records)
       @deleted_records.concat(records_identities(records))
     end
 
+    def store_record_changes(records)
+      records = [records] unless records.respond_to?(:map)
+      @record_changes.concat(records.map { |r| {record_identity(r)[:id] => record.changes} })
+    end
+
     # @return [Array<Symbol>] all columns that are part of the best fit unique index
     def unique_index_columns
       return @unique_index_columns if @unique_index_columns

lib/inventory_refresh/inventory_collection/helpers/initialize_helper.rb

@@ -177,9 +177,11 @@ def init_ic_relations(dependency_attributes, parent_inventory_collections = nil)
         #        for the batch saver strategy.
         # @param targeted [Boolean] True if the collection is targeted, in that case it will be leveraging :manager_uuids
         #        :parent_inventory_collections and :targeted_arel to save a subgraph of a data.
+        # @param store_record_changes [Boolean] By default false.  If true changes to the InventoryObject will be stored for use
+        #        by other inventory collections
         def init_flags(complete, create_only, check_changed,
                        update_only, use_ar_object, targeted,
-                       assert_graph_integrity)
+                       assert_graph_integrity, store_record_changes)
           @complete               = complete.nil? ? true : complete
           @create_only            = create_only.nil? ? false : create_only
           @check_changed          = check_changed.nil? ? true : check_changed
@@ -188,6 +190,7 @@ def init_flags(complete, create_only, check_changed,
           @use_ar_object          = use_ar_object || false
           @targeted               = !!targeted
           @assert_graph_integrity = assert_graph_integrity.nil? ? true : assert_graph_integrity
+          @store_record_changes   = store_record_changes.nil? ? false : store_record_changes
         end
 
         # @param attributes_blacklist [Array] Attributes we do not want to include into saving. We cannot blacklist an
@@ -390,6 +393,7 @@ def init_changed_records_stats
           @created_records = []
           @updated_records = []
           @deleted_records = []
+          @record_changes  = []
         end
 
         # Processes passed saver strategy

lib/inventory_refresh/inventory_collection/helpers/questions_helper.rb

@@ -87,6 +87,11 @@ def targeted?
           targeted
         end
 
+        # @return [Boolean] if true will store changes to the InventoryObject
+        def store_record_changes?
+          store_record_changes
+        end
+
         # True if processing of this InventoryCollection object would lead to no operations. Then we use this marker to
         # stop processing of the InventoryCollector object very soon, to avoid a lot of unnecessary Db queries, etc.
         #

lib/inventory_refresh/save_collection/saver/default.rb

@@ -13,7 +13,9 @@ class Default < InventoryRefresh::SaveCollection::Saver::Base
       #        key value
       def update_record!(record, hash, inventory_object)
         record.assign_attributes(hash.except(:id))
+
         if !inventory_collection.check_changed? || record.changed?
+          inventory_collection.store_record_changes(record) if inventory_collection.store_record_changes?
           record.save
           inventory_collection.store_updated_records(record)
         end