Contents

module Chake

  class Backend < Struct.new(:node)

    class CommandFailed < Exception
    end

    def scp
      ['scp']
    end

    def scp_dest
      ''
    end

    def rsync
      ['rsync']
    end

    def rsync_dest
      node.path + '/'
    end

    def run(cmd)
      printf "%#{Node.max_node_name_length}s: $ %s\n", node.hostname, cmd
      output = IO.popen(command_runner + [cmd])
      output.each_line do |line|
        printf "%#{Node.max_node_name_length}s: %s\n", node.hostname, line.strip
      end
      output.close
      if $?
        status = $?.exitstatus
        if status != 0
          raise CommandFailed.new([node.hostname, 'FAILED with exit status %d' % status].join(': '))
        end
      end
    end

    def run_as_root(cmd)
      if node.remote_username == 'root'
        run(cmd)
      else
        run('sudo sh -c "' + cmd + '"')
      end
    end

    def to_s
      self.class.backend_name
    end

    def skip?
      false
    end

    def self.backend_name
      name.split("::").last.downcase
    end

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

    def self.get(name)
      backend = @backends.find { |b| b.backend_name == name }
      backend || raise(ArgumentError.new("Invalid backend name: #{name}"))
    end

  end

end

require 'chake/backend/ssh'
require 'chake/backend/local'

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
chake-0.4.2	lib/chake/backend.rb
chake-0.4.1	lib/chake/backend.rb