Sha256: 2e995d57bfbdc7993538ec5355ca4ae87b99f8152400f635fffe2842ae7d5745
Contents?: true
Size: 1.77 KB
Versions: 33
Compression:
Stored size: 1.77 KB
Contents
require 'escape'
require 'json'
module EY
module Serverside
class Adapter
class Command
def initialize(bin_path, *task)
@task = task
@arguments = []
@binary = bin_path.join('engineyard-serverside').to_s
end
def to_s
Escape.shell_command [@binary, "_#{ENGINEYARD_SERVERSIDE_VERSION}_"] + @task + @arguments.sort_by { |x| x.first }.flatten
end
def array_argument(switch, values)
compacted = values.compact.sort
if compacted.any?
@arguments << [switch, compacted]
end
end
def boolean_argument(switch, value)
if value
@arguments << [switch]
end
end
def hash_argument(switch, pairs)
if pairs.any? {|k,v| !v.nil?}
@arguments << [switch, pairs.reject { |k,v| v.nil? }.map { |pair| pair.join(':') }.sort]
end
end
def instances_argument(_, instances)
role_pairs = instances.inject({}) do |roles, instance|
roles.merge(instance[:hostname] => instance[:roles].join(','))
end
hash_argument('--instance-roles', role_pairs)
role_pairs = instances.inject({}) do |roles, instance|
roles.merge(instance[:hostname] => instance[:name])
end
hash_argument('--instance-names', role_pairs)
array_argument('--instances', instances.map{|i| i[:hostname]})
end
def json_argument(switch, value)
if value
string_argument(switch, value.to_json)
end
end
def string_argument(switch, value)
unless value.to_s.empty?
@arguments << [switch, value]
end
end
end
end
end
end
Version data entries
33 entries across 33 versions & 1 rubygems