class Rbfs::Command
Attributes
config[RW]
Public Class Methods
new(config = nil)
click to toggle source
# File lib/rbfs/command.rb, line 12 def initialize(config = nil) if config @config = config else @config = parse_config unless config end @config[:logger] = Logger.new(@config) logger.critical "No hosts file specified" unless @config[:hosts] logger.critical "Root path not specified" unless @config[:root] end
Public Instance Methods
logger()
click to toggle source
# File lib/rbfs/command.rb, line 38 def logger @config[:logger] end
parse_config()
click to toggle source
# File lib/rbfs/command.rb, line 23 def parse_config config = {} cmdline_args = Rbfs::Args.new.parse if cmdline_args[:config] config_args = Rbfs::Config.new(cmdline_args[:config]).parse config = config_args.merge(cmdline_args) else config = cmdline_args end unless config[:remote_root] config[:remote_root] = config[:root] end config end
sync()
click to toggle source
# File lib/rbfs/command.rb, line 50 def sync success = true sync_hosts.each do |host, result| logger.info "#{host.name}: #{result.error}" result.changes.each do |change| if config[:verbose] logger.puts " | #{change.filename} (#{change.summary})" end end success = false unless result.success? end success end
sync_host(host)
click to toggle source
# File lib/rbfs/command.rb, line 74 def sync_host(host) if config[:threaded] Future.new do Rsync.new(config, host).sync end else Rsync.new(config, host).sync end end
sync_hosts()
click to toggle source
# File lib/rbfs/command.rb, line 66 def sync_hosts logger.info "Syncing #{sync_path}..." hosts = HostsFile.load(config[:hosts]) hosts.collect do |host| [host, sync_host(host)] end end
sync_path()
click to toggle source
# File lib/rbfs/command.rb, line 42 def sync_path if config[:subpath] File.join(config[:root], config[:subpath]) else config[:root] end end