Contents

require 'uri'
require 'etc'
require 'forwardable'

require 'chake/connection'
require 'chake/config_manager'

module Chake
  class Node
    extend Forwardable

    attr_reader :hostname, :port, :username, :remote_username, :data

    attr_accessor :silent

    def self.max_node_name_length
      @max_node_name_length ||= 0
    end

    class << self
      attr_writer :max_node_name_length
    end

    def initialize(hostname, data = {})
      uri = parse_uri(hostname)
      @connection_name = uri.scheme
      @hostname = uri.host
      @port = uri.port
      @username = uri.user || Etc.getpwuid.name
      @remote_username = uri.user
      @path = uri.path
      @data = data
      set_max_node_length
    end

    def connection
      @connection ||= Chake::Connection.get(@connection_name).new(self)
    end

    def_delegators :connection, :run, :run_as_root, :run_shell, :rsync, :rsync_dest, :scp, :scp_dest, :skip?

    def config_manager
      @config_manager ||= Chake::ConfigManager.get(self)
    end

    def_delegators :config_manager, :converge, :apply, :path, :bootstrap_steps, :needs_upload?

    def path
      @path ||= config_manager.path
    end

    def log(msg)
      return if silent

      puts("%#{Node.max_node_name_length}<host>s: %<msg>s\n" % { host: hostname, msg: msg })
    end

    private

    def parse_uri(hostname)
      uri = URI.parse(hostname)
      if incomplete_uri(uri)
        uri = URI.parse("ssh://#{hostname}")
      end
      uri.path = nil if uri.path.empty?
      uri
    end

    def incomplete_uri(uri)
      !uri.host && ((!uri.scheme && uri.path) || (uri.scheme && uri.opaque))
    end

    def set_max_node_length
      return if @hostname.length <= self.class.max_node_name_length

      self.class.max_node_name_length = @hostname.length
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
chake-0.91	lib/chake/node.rb
chake-0.90.3	lib/chake/node.rb
chake-0.90.2	lib/chake/node.rb
chake-0.90.1	lib/chake/node.rb
chake-0.90	lib/chake/node.rb
chake-0.82	lib/chake/node.rb
chake-0.81.1	lib/chake/node.rb
chake-0.81	lib/chake/node.rb