[WIP] Using the new tag mapping for graph refresh

app/models/manageiq/providers/amazon/inventory/parser/cloud_manager.rb

@@ -199,12 +199,51 @@ def instances
         ),
       )
 
+      @tag_mapper = ContainerLabelTagMapping.mapper
+
+      labels = parse_labels(instance["tags"])
+      taggings = map_labels_to_tags("Vm", labels)
+      map_taggings(persister_instance, taggings)
+
       instance_hardware(persister_instance, instance, flavor)
       instance_operating_system(persister_instance, instance)
+
       vm_and_template_labels(persister_instance, instance["tags"] || [])
     end
   end
 
+  def parse_labels(entity)
+    parse_identifying_attributes(entity, 'labels')
+  end
+
+  def parse_identifying_attributes(attributes, section, source = "amazon")
+    result = []
+    return result if attributes.nil?
+      attributes.each do |tag|
+        custom_attr = {
+          :name    => tag["key"],
+          :value   => tag["value"],
+        }
+      result << custom_attr
+    end
+    result
+  end
+
+  def map_labels_to_tags(model_name, labels)
+    @tag_mapper.map_labels(model_name, labels)
+  end
+
+  # Conveniently, the tags map_labels emits are already in InventoryObject<Tag> form
+  def map_taggings(parent, tags_inventory_objects)
+    model_name = parent.inventory_collection.model_class.base_class.name
+    key = [:taggings_for, model_name]
+    collection = @inv_collections[key]
+    raise("can't save: missing @inv_collections[#{key}]") if collection.nil?
+    tags_inventory_objects.each do |tag|
+      collection.build(:taggable => parent, :tag => tag)
+    end
+  end
+
   def instance_hardware(persister_instance, instance, flavor)
     persister_hardware = persister.hardwares.find_or_build(persister_instance).assign_attributes(
       :bitness              => architecture_to_bitness(instance['architecture']),