Change recieving options in Itamae::Resource::Base at initialize time

lib/itamae/recipe.rb

@@ -25,40 +25,41 @@ def find_recipe_in_gem(recipe)
       end
     end
 
-    def initialize(runner, path)
+    def initialize(runner, path, options = {})
       @runner = runner
       @path = path
       @delayed_notifications = []
       @children = RecipeChildren.new
+      @options = options
     end
 
     def dir
       ::File.dirname(@path)
     end
 
     def load(vars = {})
-      context = EvalContext.new(self, vars)
+      context = EvalContext.new(self, vars, @options)
       context.instance_eval(File.read(path), path, 1)
     end
 
     def run(options = {})
       show_banner
 
       Logger.formatter.with_indent do
-        @children.run(options)
-        run_delayed_notifications(options)
+        @children.run(@options)
+        run_delayed_notifications
       end
     end
 
     private
 
-    def run_delayed_notifications(options)
+    def run_delayed_notifications
       @delayed_notifications.uniq! do |notification|
         [notification.action, notification.action_resource]
       end
 
       while notification = @delayed_notifications.shift
-        notification.run(options)
+        notification.run(@options)
       end
     end
 
@@ -67,8 +68,9 @@ def show_banner
     end
 
     class EvalContext
-      def initialize(recipe, vars)
+      def initialize(recipe, vars, options = {})
         @recipe = recipe
+        @options = options
 
         vars.each do |k, v|
           define_singleton_method(k) { v }
@@ -92,7 +94,7 @@ def method_missing(*args, &block)
           super
         end
 
-        resource = klass.new(@recipe, name, &block)
+        resource = klass.new(@recipe, name, @options, &block)
         @recipe.children << resource
       end
 
@@ -116,7 +118,7 @@ def include_recipe(target)
           return
         end
 
-        recipe = Recipe.new(runner, path)
+        recipe = Recipe.new(runner, path, @options)
         @recipe.children << recipe
         recipe.load
       end
@@ -138,7 +140,7 @@ class RecipeFromDefinition < Recipe
       attr_accessor :definition
 
       def load(vars = {})
-        context = EvalContext.new(self, vars)
+        context = EvalContext.new(self, vars, @options)
         context.instance_eval(&@definition.class.definition_block)
       end
 

lib/itamae/recipe_children.rb

@@ -57,7 +57,7 @@ def run(options)
       self.each do |resource|
         case resource
         when Resource::Base
-          resource.run(nil, dry_run: options[:dry_run])
+          resource.run
         when Recipe
           resource.run(options)
         end

lib/itamae/resource/base.rb

@@ -100,10 +100,11 @@ def define_attribute(name, options)
       attr_reader :notifications
       attr_reader :updated
 
-      def initialize(recipe, resource_name, &block)
+      def initialize(recipe, resource_name, options = {}, &block)
         clear_current_attributes
         @recipe = recipe
         @resource_name = resource_name
+        @options = options
         @updated = false
 
         EvalContext.new(self).tap do |context|
@@ -132,11 +133,11 @@ def run(specific_action = nil, options = {})
           end
 
           [specific_action || attributes.action].flatten.each do |action|
-            run_action(action, options)
+            run_action(action)
           end
 
-          verify unless options[:dry_run]
-          notify(options) if updated?
+          verify unless @options[:dry_run]
+          notify if updated?
         end
 
         @updated = false
@@ -165,7 +166,7 @@ def resource_type
 
       alias_method :current, :current_attributes
 
-      def run_action(action, options)
+      def run_action(action, options = {})
         @current_action = action
 
         clear_current_attributes
@@ -185,12 +186,12 @@ def run_action(action, options)
           show_differences
 
           method_name = "action_#{action}"
-          if options[:dry_run]
+          if @options[:dry_run]
             unless respond_to?(method_name)
               Logger.error "action #{action.inspect} is unavailable"
             end
           else
-            public_send(method_name, options)
+            public_send(method_name, @options)
           end
 
           updated! if different?
@@ -323,7 +324,7 @@ def updated?
         @updated
       end
 
-      def notify(options)
+      def notify(options = {})
         (notifications + recipe.children.subscribing(self)).each do |notification|
           message = "Notifying #{notification.action} to #{notification.action_resource.resource_type} resource '#{notification.action_resource.resource_name}'"
 
@@ -342,7 +343,7 @@ def notify(options)
           if notification.delayed?
             @recipe.delayed_notifications << notification
           elsif notification.immediately?
-            notification.run(options)
+            notification.run(@options)
           end
         end
       end
@@ -360,4 +361,3 @@ def verify
     end
   end
 end
-

lib/itamae/resource/file.rb

@@ -20,9 +20,11 @@ def pre_action
         when :edit
           attributes.exist = true
 
-          content = backend.receive_file(attributes.path)
-          attributes.block.call(content)
-          attributes.content = content
+          unless @options[:dry_run]
+            content = backend.receive_file(attributes.path)
+            attributes.block.call(content)
+            attributes.content = content
+          end
         end
 
         send_tempfile
@@ -145,4 +147,3 @@ def send_tempfile
     end
   end
 end
-

lib/itamae/runner.rb

@@ -43,7 +43,7 @@ def initialize(backend, options)
 
     def load_recipes(paths)
       paths.each do |path|
-        recipe = Recipe.new(self, File.expand_path(path))
+        recipe = Recipe.new(self, File.expand_path(path), @options)
         children << recipe
         recipe.load
       end
@@ -85,4 +85,3 @@ def create_node
     end
   end
 end
-

spec/unit/lib/itamae/resource/base_spec.rb

@@ -122,10 +122,12 @@ class TestResource < Itamae::Resource::Base
     end
 
     context 'with dry_run' do
+      subject(:dry_run_resource) { described_class.new(recipe, "name", dry_run: true) }
+
       context 'when specified action is unavailable' do
         it 'logs error' do
           expect(Itamae::Logger).to receive(:error).with(/action :name is unavailable/)
-          subject.run(nil, dry_run: true)
+          subject.run
         end
       end
     end