Ensure all provider get() data is cached

Ensure that remaining data fetched with the provider get() method
is cached.

Author: seanmil

lib/puppet/resource_api.rb

@@ -244,19 +244,36 @@ def to_resource_shim(resource)
         type_definition.create_attribute_in(self, name, param_or_property, parent, options)
       end
 
+      def self.rsapi_provider_get(names = [])
+        # If the cache has been marked as having all instances, then just return the
+        # full contents:
+        return rsapi_provider_get_cache.all if rsapi_provider_get_cache.cached_all? && names.empty?
+
+        fetched = if type_definition.feature?('simple_get_filter')
+                    my_provider.get(context, names)
+                  else
+                    my_provider.get(context)
+                  end
+
+        fetched.each do |resource_hash|
+          type_definition.check_schema(resource_hash)
+          rsapi_provider_get_cache.add(build_title(type_definition, resource_hash), resource_hash)
+        end
+
+        if !type_definition.feature?('simple_get_filter') || names.empty?
+          # Mark the cache as having all possible instances:
+          rsapi_provider_get_cache.cached_all
+        end
+
+        fetched
+      end
+
       def self.instances
         # puts 'instances'
         # force autoloading of the provider
         provider(type_definition.name)
 
-        initial_fetch = if type_definition.feature?('simple_get_filter')
-                          my_provider.get(context, [])
-                        else
-                          my_provider.get(context)
-                        end
-
-        initial_fetch.map do |resource_hash|
-          type_definition.check_schema(resource_hash)
+        rsapi_provider_get.map do |resource_hash|
           # allow a :title from the provider to override the default
           result = if resource_hash.key? :title
                      new(title: resource_hash[:title])
@@ -271,14 +288,9 @@ def self.instances
       end
 
       def refresh_current_state
-        current_state = if type_definition.feature?('simple_get_filter')
-                          my_provider.get(context, [rsapi_title]).find { |h| namevar_match?(h) }
-                        else
-                          my_provider.get(context).find { |h| namevar_match?(h) }
-                        end
+        current_state = self.class.rsapi_provider_get([rsapi_title]).find { |h| namevar_match?(h) }
 
         if current_state
-          type_definition.check_schema(current_state)
           strict_check(current_state)
         else
           current_state = if rsapi_title.is_a? Hash

spec/acceptance/get_calls_spec.rb

@@ -20,8 +20,7 @@
       # rubocop:disable Metrics/LineLength
       stdout_str, _status = Open3.capture2e("puppet apply #{common_args} -e \"test_get_calls_basic { foo: }\ntest_get_calls_basic { bar: }\"")
       expect(stdout_str).to match %r{Notice: test_get_calls_basic: Provider get called 1 times}
-      expect(stdout_str).to match %r{Notice: test_get_calls_basic: Provider get called 2 times}
-      expect(stdout_str).not_to match %r{Notice: test_get_calls_basic: Provider get called 3 times}
+      expect(stdout_str).not_to match %r{Notice: test_get_calls_basic: Provider get called 2 times}
       expect(stdout_str).not_to match %r{Creating}
       # rubocop:enable Metrics/LineLength
     end

spec/puppet/resource_api_spec.rb

@@ -2142,6 +2142,10 @@ def set(_context, changes) end
     it { expect { described_class.register_type(definition) }.not_to raise_error }
 
     context 'with the type registered' do
+      before(:each) do
+        type.rsapi_provider_get_cache.clear
+      end
+
       it 'is seen as a supported feature' do
         expect(Puppet).not_to receive(:warning).with(%r{Unknown feature detected:.*simple_test_filter_2})
         expect { described_class.register_type(definition) }.not_to raise_error