Contents

module Chake
  Connection = Struct.new(:node)
  class Connection
    class CommandFailed < RuntimeError
    end

    def scp
      ['scp']
    end

    def scp_dest
      ''
    end

    def rsync
      ['rsync']
    end

    def rsync_dest
      "#{node.path}/"
    end

    def run(cmd)
      node.log('$ %<command>s' % { command: cmd })
      io = IO.popen(command_runner + ['/bin/sh'], 'w+', err: %i[child out])
      io.write(cmd)
      io.close_write
      read_output(io)
    end

    def read_output(io)
      io.each_line do |line|
        node.log(line.gsub(/\s*$/, ''))
      end
      io.close
      if $CHILD_STATUS
        status = $CHILD_STATUS.exitstatus
        if status != 0
          raise CommandFailed, [node.hostname, 'FAILED with exit status %<status>d' % { status: status }].join(': ')
        end
      end
    end

    def run_shell
      system(*shell_command)
    end

    def run_as_root(cmd)
      if node.remote_username == 'root'
        run(cmd)
      else
        run("sudo #{cmd}")
      end
    end

    def to_s
      self.class.connection_name
    end

    def skip?
      false
    end

    def self.connection_name
      name.split('::').last.downcase
    end

    def self.inherited(subclass)
      super
      @connections ||= []
      @connections << subclass
    end

    def self.get(name)
      connection = @connections.find { |b| b.connection_name == name }
      raise ArgumentError, "Invalid connection name: #{name}" unless connection

      connection
    end
  end
end

require 'chake/connection/ssh'
require 'chake/connection/local'

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
chake-0.90.2	lib/chake/connection.rb