lib/chef/provisioning/machine/basic_machine.rb in chef-provisioning-2.0.0 vs lib/chef/provisioning/machine/basic_machine.rb in chef-provisioning-2.0.1
- old
+ new
@@ -1,84 +1,84 @@
-require 'chef/provisioning/machine'
-
-class Chef
-module Provisioning
- class Machine
- class BasicMachine < Machine
- def initialize(machine_spec, transport, convergence_strategy)
- super(machine_spec)
- @transport = transport
- @convergence_strategy = convergence_strategy
- end
-
- attr_reader :transport
- attr_reader :convergence_strategy
-
- def setup_convergence(action_handler)
- convergence_strategy.setup_convergence(action_handler, self)
- end
-
- def converge(action_handler)
- convergence_strategy.converge(action_handler, self)
- end
-
- def cleanup_convergence(action_handler)
- convergence_strategy.cleanup_convergence(action_handler, machine_spec)
- end
-
- def execute(action_handler, command, options = {})
- action_handler.perform_action "run '#{command}' on #{machine_spec.name}" do
- result = transport.execute(command, options)
- result.error!
- result
- end
- end
-
- def execute_always(command, options = {})
- transport.execute(command, options)
- end
-
- def read_file(path)
- transport.read_file(path)
- end
-
- def download_file(action_handler, path, local_path)
- if files_different?(path, local_path)
- action_handler.perform_action "download file #{path} on #{machine_spec.name} to #{local_path}" do
- transport.download_file(path, local_path)
- end
- end
- end
-
- def write_file(action_handler, path, content, options = {})
- if files_different?(path, nil, content)
- if options[:ensure_dir]
- create_dir(action_handler, dirname_on_machine(path))
- end
- action_handler.perform_action "write file #{path} on #{machine_spec.name}" do
- transport.write_file(path, content)
- end
- end
- end
-
- def upload_file(action_handler, local_path, path, options = {})
- if files_different?(path, local_path)
- if options[:ensure_dir]
- create_dir(action_handler, dirname_on_machine(path))
- end
- action_handler.perform_action "upload file #{local_path} to #{path} on #{machine_spec.name}" do
- transport.upload_file(local_path, path)
- end
- end
- end
-
- def make_url_available_to_remote(local_url)
- transport.make_url_available_to_remote(local_url)
- end
-
- def disconnect
- transport.disconnect
- end
- end
- end
-end
-end
+require 'chef/provisioning/machine'
+
+class Chef
+module Provisioning
+ class Machine
+ class BasicMachine < Machine
+ def initialize(machine_spec, transport, convergence_strategy)
+ super(machine_spec)
+ @transport = transport
+ @convergence_strategy = convergence_strategy
+ end
+
+ attr_reader :transport
+ attr_reader :convergence_strategy
+
+ def setup_convergence(action_handler)
+ convergence_strategy.setup_convergence(action_handler, self)
+ end
+
+ def converge(action_handler)
+ convergence_strategy.converge(action_handler, self)
+ end
+
+ def cleanup_convergence(action_handler)
+ convergence_strategy.cleanup_convergence(action_handler, machine_spec)
+ end
+
+ def execute(action_handler, command, options = {})
+ action_handler.perform_action "run '#{command}' on #{machine_spec.name}" do
+ result = transport.execute(command, options)
+ result.error!
+ result
+ end
+ end
+
+ def execute_always(command, options = {})
+ transport.execute(command, options)
+ end
+
+ def read_file(path)
+ transport.read_file(path)
+ end
+
+ def download_file(action_handler, path, local_path)
+ if files_different?(path, local_path)
+ action_handler.perform_action "download file #{path} on #{machine_spec.name} to #{local_path}" do
+ transport.download_file(path, local_path)
+ end
+ end
+ end
+
+ def write_file(action_handler, path, content, options = {})
+ if files_different?(path, nil, content)
+ if options[:ensure_dir]
+ create_dir(action_handler, dirname_on_machine(path))
+ end
+ action_handler.perform_action "write file #{path} on #{machine_spec.name}" do
+ transport.write_file(path, content)
+ end
+ end
+ end
+
+ def upload_file(action_handler, local_path, path, options = {})
+ if files_different?(path, local_path)
+ if options[:ensure_dir]
+ create_dir(action_handler, dirname_on_machine(path))
+ end
+ action_handler.perform_action "upload file #{local_path} to #{path} on #{machine_spec.name}" do
+ transport.upload_file(local_path, path)
+ end
+ end
+ end
+
+ def make_url_available_to_remote(local_url)
+ transport.make_url_available_to_remote(local_url)
+ end
+
+ def disconnect
+ transport.disconnect
+ end
+ end
+ end
+end
+end