class SSHKit::Backend::Local
Public Class Methods
new(_ = nil, &block)
click to toggle source
Calls superclass method
SSHKit::Backend::Abstract::new
# File lib/sshkit/backends/local.rb, line 9 def initialize(_ = nil, &block) super(Host.new(:local), &block) end
Public Instance Methods
download!(remote, local=nil, _options = {})
click to toggle source
# File lib/sshkit/backends/local.rb, line 28 def download!(remote, local=nil, _options = {}) remote = File.join(pwd_path, remote) unless remote.to_s.start_with?("/") || pwd_path.nil? if local.nil? FileUtils.cp(remote, File.basename(remote)) else File.open(remote, "rb") do |f| IO.copy_stream(f, local) end end end
upload!(local, remote, options = {})
click to toggle source
# File lib/sshkit/backends/local.rb, line 13 def upload!(local, remote, options = {}) remote = File.join(pwd_path, remote) unless remote.to_s.start_with?("/") || pwd_path.nil? if local.is_a?(String) if options[:recursive] FileUtils.cp_r(local, remote) else FileUtils.cp(local, remote) end else File.open(remote, "wb") do |f| IO.copy_stream(local, f) end end end
Private Instance Methods
execute_command(cmd)
click to toggle source
# File lib/sshkit/backends/local.rb, line 41 def execute_command(cmd) output.log_command_start(cmd.with_redaction) cmd.started = Time.now Open3.popen3(cmd.to_command) do |stdin, stdout, stderr, wait_thr| stdout_thread = Thread.new do while (line = stdout.gets) do cmd.on_stdout(stdin, line) output.log_command_data(cmd, :stdout, line) end end stderr_thread = Thread.new do while (line = stderr.gets) do cmd.on_stderr(stdin, line) output.log_command_data(cmd, :stderr, line) end end stdout_thread.join stderr_thread.join cmd.exit_status = wait_thr.value.to_i output.log_command_exit(cmd) end end