Class: Bolt::Transport::Local::Connection
- Inherits:
-
Object
- Object
- Bolt::Transport::Local::Connection
- Defined in:
- lib/bolt/transport/local/connection.rb
Instance Attribute Summary collapse
-
#logger ⇒ Object
Returns the value of attribute logger.
-
#target ⇒ Object
Returns the value of attribute target.
-
#user ⇒ Object
Returns the value of attribute user.
Instance Method Summary collapse
- #copy_file(source, dest) ⇒ Object
- #execute(command) ⇒ Object
-
#initialize(target) ⇒ Connection
constructor
A new instance of Connection.
- #max_command_length ⇒ Object
-
#reset_cwd? ⇒ Boolean
This is used by the Bash shell to decide whether to ‘cd` before executing commands as a run-as user.
- #shell ⇒ Object
Constructor Details
#initialize(target) ⇒ Connection
Returns a new instance of Connection.
15 16 17 18 19 20 |
# File 'lib/bolt/transport/local/connection.rb', line 15 def initialize(target) @target = target # The familiar problem: Etc.getlogin is broken on osx @user = ENV['USER'] || Etc.getlogin @logger = Logging.logger[self] end |
Instance Attribute Details
#logger ⇒ Object
Returns the value of attribute logger.
13 14 15 |
# File 'lib/bolt/transport/local/connection.rb', line 13 def logger @logger end |
#target ⇒ Object
Returns the value of attribute target.
13 14 15 |
# File 'lib/bolt/transport/local/connection.rb', line 13 def target @target end |
#user ⇒ Object
Returns the value of attribute user.
13 14 15 |
# File 'lib/bolt/transport/local/connection.rb', line 13 def user @user end |
Instance Method Details
#copy_file(source, dest) ⇒ Object
30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 |
# File 'lib/bolt/transport/local/connection.rb', line 30 def copy_file(source, dest) @logger.debug { "Uploading #{source}, to #{dest}" } if source.is_a?(StringIO) Tempfile.create(File.basename(dest)) do |f| f.write(source.read) f.close FileUtils.mv(f, dest) end else # Mimic the behavior of `cp --remove-destination` # since the flag isn't supported on MacOS FileUtils.cp_r(source, dest, remove_destination: true) end rescue StandardError => e = "Could not copy file to #{dest}: #{e}" raise Bolt::Node::FileError.new(, 'COPY_ERROR') end |
#execute(command) ⇒ Object
48 49 50 51 52 53 54 55 56 57 58 |
# File 'lib/bolt/transport/local/connection.rb', line 48 def execute(command) if Bolt::Util.windows? # If it's already a powershell command then invoke it normally. # Otherwise, wrap it in powershell.exe. unless command.start_with?('powershell.exe') command = ['powershell.exe', *Bolt::Shell::Powershell::PS_ARGS, '-Command', command] end end Open3.popen3(*command) end |
#max_command_length ⇒ Object
66 67 68 69 70 |
# File 'lib/bolt/transport/local/connection.rb', line 66 def max_command_length if Bolt::Util.windows? 32000 end end |
#reset_cwd? ⇒ Boolean
This is used by the Bash shell to decide whether to ‘cd` before executing commands as a run-as user
62 63 64 |
# File 'lib/bolt/transport/local/connection.rb', line 62 def reset_cwd? false end |