109 lines
2.6 KiB
Ruby
109 lines
2.6 KiB
Ruby
module Kamal::Commands
|
|
class Base
|
|
delegate :sensitive, :argumentize, to: Kamal::Utils
|
|
|
|
DOCKER_HEALTH_STATUS_FORMAT = "'{{if .State.Health}}{{.State.Health.Status}}{{else}}{{.State.Status}}{{end}}'"
|
|
|
|
attr_accessor :config
|
|
|
|
def initialize(config)
|
|
@config = config
|
|
end
|
|
|
|
def run_over_ssh(*command, host:)
|
|
"ssh#{ssh_proxy_args}#{ssh_keys_args} -t #{config.ssh.user}@#{host} -p #{config.ssh.port} '#{command.join(" ").gsub("'", "'\\\\''")}'"
|
|
end
|
|
|
|
def container_id_for(container_name:, only_running: false)
|
|
docker :container, :ls, *("--all" unless only_running), "--filter", "name=^#{container_name}$", "--quiet"
|
|
end
|
|
|
|
def make_directory_for(remote_file)
|
|
make_directory Pathname.new(remote_file).dirname.to_s
|
|
end
|
|
|
|
def make_directory(path)
|
|
[ :mkdir, "-p", path ]
|
|
end
|
|
|
|
def remove_directory(path)
|
|
[ :rm, "-r", path ]
|
|
end
|
|
|
|
def remove_file(path)
|
|
[ :rm, path ]
|
|
end
|
|
|
|
private
|
|
def combine(*commands, by: "&&")
|
|
commands
|
|
.compact
|
|
.collect { |command| Array(command) + [ by ] }.flatten # Join commands
|
|
.tap { |commands| commands.pop } # Remove trailing combiner
|
|
end
|
|
|
|
def chain(*commands)
|
|
combine *commands, by: ";"
|
|
end
|
|
|
|
def pipe(*commands)
|
|
combine *commands, by: "|"
|
|
end
|
|
|
|
def append(*commands)
|
|
combine *commands, by: ">>"
|
|
end
|
|
|
|
def write(*commands)
|
|
combine *commands, by: ">"
|
|
end
|
|
|
|
def any(*commands)
|
|
combine *commands, by: "||"
|
|
end
|
|
|
|
def xargs(command)
|
|
[ :xargs, command ].flatten
|
|
end
|
|
|
|
def shell(command)
|
|
[ :sh, "-c", "'#{command.flatten.join(" ").gsub("'", "'\\\\''")}'" ]
|
|
end
|
|
|
|
def docker(*args)
|
|
args.compact.unshift :docker
|
|
end
|
|
|
|
def git(*args, path: nil)
|
|
[ :git, *([ "-C", path ] if path), *args.compact ]
|
|
end
|
|
|
|
def grep(*args)
|
|
args.compact.unshift :grep
|
|
end
|
|
|
|
def tags(**details)
|
|
Kamal::Tags.from_config(config, **details)
|
|
end
|
|
|
|
def ssh_proxy_args
|
|
case config.ssh.proxy
|
|
when Net::SSH::Proxy::Jump
|
|
" -J #{config.ssh.proxy.jump_proxies}"
|
|
when Net::SSH::Proxy::Command
|
|
" -o ProxyCommand='#{config.ssh.proxy.command_line_template}'"
|
|
end
|
|
end
|
|
|
|
def ssh_keys_args
|
|
"#{ ssh_keys.join("") if ssh_keys}" + "#{" -o IdentitiesOnly=yes" if config.ssh&.keys_only}"
|
|
end
|
|
|
|
def ssh_keys
|
|
config.ssh.keys&.map do |key|
|
|
" -i #{key}"
|
|
end
|
|
end
|
|
end
|
|
end
|